[数据库]es~通过ElasticsearchTemplate进行聚合操作

0

2020-08-24 17:00:38

聚合操作，我们可以对数据进行分组的求和，求数，最大值，最小值，或者其它的自定义的统计功能，es对聚合有着不错的支持，需要注意的是，在对某字段进行聚合之后，需要开启这个字段的fielddata我，或者会出现如下错误：Fielddata is disabled on text fields by default.

通过postman等工作像es api发送请求，可以将字段的这个特性打开.PUT /esdto/esdto/_mapping{ "properties": { "sex": { "type": "text", "fielddata": true } }}

使用ElasticsearchTemplate对sex字段进行聚合// 创建一个查询条件对象 BoolQueryBuilder queryBuilder = QueryBuilders.boolQuery(); // 拼接查询条件 queryBuilder.should(QueryBuilders.termQuery("creator", "1")); // 创建聚合查询条件 TermsAggregationBuilder agg = AggregationBuilders.terms("sex").field("sex.keyword");//keyword表示不使用分词进行聚合 // 创建查询对象 SearchQuery build = new NativeSearchQueryBuilder() .withQuery(queryBuilder) //添加查询条件 .addAggregation(agg) // 添加聚合条件 .withPageable(PageRequest.of(0, 10)) //符合查询条件的文档分页(不是聚合的分页) .build(); // 执行查询 AggregatedPage testEntities = elasticsearchTemplate.queryForPage(build, TestEsDto.class); // 取出聚合结果 Aggregations entitiesAggregations = testEntities.getAggregations(); Terms terms = (Terms) entitiesAggregations.asMap().get("sex"); // 遍历取出聚合字段列的值，与对应的数量 for (Terms.Bucket bucket : terms.getBuckets()) { String keyAsString = bucket.getKeyAsString(); // 聚合字段列的值 long docCount = bucket.getDocCount();// 聚合字段对应的数量 log.info("keyAsString={},value={}", keyAsString, docCount); }

本文网址：http://www.shaoqun.com/a/466734.html

*特别声明：以上内容来自于网络收集，著作权属原作者所有，如有侵权，请联系我们：admin@shaoqun.com。

0