使用Elasticsearch查询大量数据时基本的分页查询就会报错,这种情况下可以使用scroll(滚动)查询
直接上代码:
// 创建查询条件对象
BoolQueryBuilder queryBuilder = QueryBuilders.boolQuery();
// 拼接查询条件
queryBuilder.must(QueryBuilders.termQuery("status", 1)); 假设查询状态为1的
// 创建查询对象
SearchQuery searchQuery = new NativeSearchQueryBuilder()
.withIndices("test_index")//索引名
.withTypes("test")//类型名
.withQuery(queryBuilder)// 查询条件对象
.withPageable(PageRequest.of(0, 1000))//从0页开始查,每页1000个结果
.build();
// 滚动查询
ScrolledPage scroll = (ScrolledPage) elasticsearchTemplate.startScroll(3000, searchQuery, TestEntity.class);
// 判断是否有内容
while (scroll.hasContent()) {
List content = scroll.getContent();
// 业务逻辑省略
//取下一页,scrollId在es服务器上可能会发生变化,需要用最新的。发起continueScroll请求会重新刷新快照保留时间
scroll = (ScrolledPage) elasticsearchTemplate.continueScroll(scroll.getScrollId(), 3000, EstateInfoEntity.class);
}
// 最后释放查询
elasticsearchTemplate.clearScroll(scroll.getScrollId());