如何使用ElasticsearchTemplate執行滾動查詢

這篇文章主要講解了“如何使用ElasticsearchTemplate執行滾動查詢”，文中的講解內容簡單清晰，易于學習與理解，下面請大家跟著小編的思路慢慢深入，一起來研究和學習“如何使用ElasticsearchTemplate執行滾動查詢”吧！

使用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());

感謝各位的閱讀，以上就是“如何使用ElasticsearchTemplate執行滾動查詢”的內容了，經過本文的學習后，相信大家對如何使用ElasticsearchTemplate執行滾動查詢這一問題有了更深刻的體會，具體使用情況還需要大家實踐驗證。這里是億速云，小編將為大家推送更多相關知識點的文章，歡迎關注！