elasticsearchTemplate實現聚合查詢

本篇內容主要講解“elasticsearchTemplate實現聚合查詢”，感興趣的朋友不妨來看看。本文介紹的方法操作簡單快捷，實用性強。下面就讓小編來帶大家學習“elasticsearchTemplate實現聚合查詢”吧!

直接上代碼：

// 創建一個查詢條件對象
BoolQueryBuilder queryBuilder = QueryBuilders.boolQuery();
// 拼接查詢條件
queryBuilder.should(QueryBuilders.termQuery("字段", "值"))；
// 創建聚合查詢條件
TermsAggregationBuilder agg = AggregationBuilders.terms("聚合名稱，自定義，取出時會用到").field("聚合字段").size(100)；// size是查詢聚合出來的條數
// 創建查詢對象
SearchQuery build = new NativeSearchQueryBuilder()
                .withQuery(queryBuilder) //添加查詢條件
                .addAggregation(agg) // 添加聚合條件
                .withPageable(PageRequest.of(0, 1)) //符合查詢條件的文檔分頁（不是聚合的分頁）
                .build();

// 執行查詢
AggregatedPage<TestEntity> testEntities = elasticsearchTemplate.queryForPage(build, TestEntity.class);

// 取出聚合結果
Aggregations entitiesAggregations = testEntities.getAggregations();
        Terms terms = (Terms)propertyInfoEntities.getAggregation("聚合名稱，之前自定義的");

// 遍歷取出聚合字段列的值，與對應的數量
for (Terms.Bucket bucket : terms.getBuckets()) {
            String keyAsString = bucket.getKeyAsString(); // 聚合字段列的值
            long docCount = bucket.getDocCount();// 聚合字段對應的數量
        }

多字段聚合：

// 創建一個查詢條件對象
BoolQueryBuilder queryBuilder = QueryBuilders.boolQuery();
// 拼接查詢條件
queryBuilder.should(QueryBuilders.termQuery("字段", "值"))；
// 創建聚合查詢條件

TermsAggregationBuilder agg1 = AggregationBuilders.terms("聚合名稱2").field(聚合字段2).size(100)

TermsAggregationBuilder agg = AggregationBuilders.terms("聚合名稱1").field("聚合字段1").size(100).subAggregation(agg1)//拼接上上一個聚合條件
// 創建查詢對象
SearchQuery build = new NativeSearchQueryBuilder()
                .withQuery(queryBuilder) //添加查詢條件
                .addAggregation(agg) // 添加聚合條件
                .withPageable(PageRequest.of(0, 1)) //符合查詢條件的文檔分頁（不是聚合的分頁）
                .build();

// 執行查詢
AggregatedPage<TestEntity> testEntities = elasticsearchTemplate.queryForPage(build, TestEntity.class);

// 取出聚合結果
Aggregations entitiesAggregations = testEntities.getAggregations();
        Terms terms = (Terms)propertyInfoEntities.getAggregation("聚合名稱");

// 遍歷最外層的聚合結果
for (Terms.Bucket bucket : terms.getBuckets()) {
            String keyAsString = bucket.getKeyAsString(); // 聚合字段列的名稱
            long docCount = bucket.getDocCount();// 聚合字段對應的數量
	    // 獲取內部的聚合字段信息
            Aggregations aggregations = bucket.getAggregations();
            Terms terms2 = aggregations.get("聚合名稱2");
	// 遍歷獲取agg1的聚合信息
	for (Terms.Bucket bucket1 : terms2.getBuckets()) {
                String keyAsString2 = bucket.getKeyAsString(); // 聚合字段列的名稱
                long docCount2 = bucket.getDocCount();// 聚合字段對應的數量
            }
        }

多個字段一次性聚合：

// 創建一個查詢條件對象
BoolQueryBuilder queryBuilder = QueryBuilders.boolQuery();
// 拼接查詢條件
queryBuilder.should(QueryBuilders.termQuery("字段", "值"))；
// 創建聚合查詢條件

String script = "doc['" + 字段1 + "'].values +'/'+ doc['" + 字段2 + "'].values +'/'+ doc['" + 字段3 + "'].values"; // 編寫script語句

Script script1 = new Script(script); // 新建一個script對象

TermsAggregationBuilder agg = AggregationBuilders.terms("聚合名稱").script(script1).size(99999); // 創建一個聚合查詢對象

SearchQuery build = new NativeSearchQueryBuilder()
                .withQuery(queryBuilder) //添加查詢條件
                .addAggregation(agg) // 添加聚合條件
                .withPageable(PageRequest.of(0, 1)) //符合查詢條件的文檔分頁（不是聚合的分頁）
                .build();

// 執行查詢
AggregatedPage<TestEntity> testEntities = elasticsearchTemplate.queryForPage(build, TestEntity.class);

Terms terms = (Terms) shopDbEntities.getAggregation("聚合名稱");

for (Terms.Bucket bucket : terms.getBuckets()) { // 循環取出聚合的值
            String keyAsString = bucket.getKeyAsString();
            String[] split = keyAsString.split("/"); // 切割取出每個字段
            System.out.println("字段1"+split[0]);
            System.out.println("字段2"+split[1]);
            System.out.println("字段3"+split[2]);
        }

更多字段聚合按照以上類推，如果實在對于結構不理解可以將查詢語句打印出來，將打印語句拿到Kibana之類的查詢工具中查詢看下結構，或者直接Debug看下數據結構，就比較好理解了

到此，相信大家對“elasticsearchTemplate實現聚合查詢”有了更深的了解，不妨來實際操作一番吧！這里是億速云網站，更多相關內容可以進入相關頻道進行查詢，關注我們，繼續學習！