springBoot集成es查詢,使用ElasticsearchTemplate執行滾動查詢

使用Elasticsearch查詢大量數據時基本的分頁查詢就會報錯,這種狀況下可使用scroll(滾動)查詢java

直接上代碼:服務器

// 建立查詢條件對象
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<EstateInfoEntity>) elasticsearchTemplate.continueScroll(scroll.getScrollId(), 3000, EstateInfoEntity.class);
}

// 最後釋放查詢
elasticsearchTemplate.clearScroll(scroll.getScrollId());
相關文章
相關標籤/搜索