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(); // 执行查询 AggregatedPagetestEntities = 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(); // 执行查询 AggregatedPagetestEntities = 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(); // 执行查询 AggregatedPagetestEntities = 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实现聚合查询
本文路径:http://pwwzsj.com/article/gscpep.html