如何使用ElasticsearchTemplate執(zhí)行滾動查詢

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

使用Elasticsearch查詢大量數(shù)據(jù)時基本的分頁查詢就會報錯，這種情況下可以使用scroll（滾動）查詢

直接上代碼：

// 創(chuàng)建查詢條件對象
BoolQueryBuilder queryBuilder = QueryBuilders.boolQuery();

// 拼接查詢條件
queryBuilder.must(QueryBuilders.termQuery("status", 1)); 假設(shè)查詢狀態(tài)為1的

// 創(chuàng)建查詢對象
SearchQuery searchQuery = new NativeSearchQueryBuilder()
                .withIndices("test_index")//索引名
                .withTypes("test")//類型名
                .withQuery(queryBuilder)// 查詢條件對象
                .withPageable(PageRequest.of(0, 1000))//從0頁開始查，每頁1000個結(jié)果
                .build();

// 滾動查詢
ScrolledPage<TestEntity> scroll = (ScrolledPage<TestEntity>) elasticsearchTemplate.startScroll(3000, searchQuery, TestEntity.class);

// 判斷是否有內(nèi)容
while (scroll.hasContent()) {
	List<TestEntity> content = scroll.getContent();
	// 業(yè)務(wù)邏輯省略
	//取下一頁，scrollId在es服務(wù)器上可能會發(fā)生變化，需要用最新的。發(fā)起continueScroll請求會重新刷新快照保留時間
	scroll = (ScrolledPage<TestEntity>) elasticsearchTemplate.continueScroll(scroll.getScrollId(), 3000, EstateInfoEntity.class);
}

// 最后釋放查詢
elasticsearchTemplate.clearScroll(scroll.getScrollId());

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