本篇內容主要講解“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實現聚合查詢”有了更深的了解,不妨來實際操作一番吧!這里是創新互聯網站,更多相關內容可以進入相關頻道進行查詢,關注我們,繼續學習!
當前文章:elasticsearchTemplate實現聚合查詢
URL鏈接:http://m.newbst.com/article48/gscpep.html
成都網站建設公司_創新互聯,為您提供Google、網站改版、微信小程序、、營銷型網站建設、商城網站
聲明:本網站發布的內容(圖片、視頻和文字)以用戶投稿、用戶轉載內容為主,如果涉及侵權請盡快告知,我們將會在第一時間刪除。文章觀點不代表本網站立場,如需處理請聯系客服。電話:028-86922220;郵箱:631063699@qq.com。內容未經允許不得轉載,或轉載時需注明來源: 創新互聯