码迷,mamicode.com
首页 > 编程语言 > 详细

springBoot集成es查询,使用ElasticsearchTemplate执行滚动查询

时间:2020-07-24 09:52:43      阅读:104      评论:0      收藏:0      [点我收藏+]

标签:com   page   服务   拼接   java   大量   termquery   http   star   

使用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<TestEntity> scroll = (ScrolledPage<TestEntity>) elasticsearchTemplate.startScroll(3000, searchQuery, TestEntity.class);

// 判断是否有内容
while (scroll.hasContent()) {
	List<TestEntity> content = scroll.getContent();
	// 业务逻辑省略
	//取下一页,scrollId在es服务器上可能会发生变化,需要用最新的。发起continueScroll请求会重新刷新快照保留时间
	scroll = (ScrolledPage<TestEntity>) elasticsearchTemplate.continueScroll(scroll.getScrollId(), 3000, EstateInfoEntity.class);
}

// 最后释放查询
elasticsearchTemplate.clearScroll(scroll.getScrollId());

springBoot集成es查询,使用ElasticsearchTemplate执行滚动查询

标签:com   page   服务   拼接   java   大量   termquery   http   star   

原文地址:https://www.cnblogs.com/1994jinnan/p/13369551.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!