ElasticsearchTemplate springboot2.7 如何聚合分组

在Spring Boot 2.7中使用ElasticsearchTemplate进行聚合分组的步骤如下：

1. 创建一个SearchQuery对象，可以使用QueryBuilder构建查询条件。

2. 创建一个AggregationBuilder对象，使用它来构建聚合分组的条件。

3. 将AggregationBuilder对象添加到SearchQuery对象中。

4. 使用ElasticsearchTemplate对象执行查询，通过调用queryForPage方法获取结果。

下面是一个简单的示例代码，可以实现按照某一个字段进行分组统计：

// 创建查询条件
QueryBuilder queryBuilder = QueryBuilders.matchAllQuery();
SearchQuery searchQuery = new NativeSearchQueryBuilder()
        .withQuery(queryBuilder)
        .build();

// 创建聚合分组条件
AggregationBuilder aggregationBuilder = AggregationBuilders
        .terms("group_by_field")
        .field("field_to_group_by")
        .subAggregation(AggregationBuilders.sum("sum_of_field").field("field_to_sum"));

// 将聚合分组条件添加到查询条件中
searchQuery.addAggregation(aggregationBuilder);

// 执行查询并获取结果
AggregatedPage<MyEntity> result = elasticsearchTemplate.queryForPage(searchQuery, MyEntity.class);

// 获取分组统计结果
StringTerms groupByResult = result.getAggregation("group_by_field");
List<StringTerms.Bucket> buckets = groupByResult.getBuckets();
for (StringTerms.Bucket bucket : buckets) {
    String key = (String) bucket.getKey();
    Long count = bucket.getDocCount();
    Sum sum = bucket.getAggregations().get("sum_of_field");
    Double sumValue = sum.getValue();
    System.out.println(key + ": " + count + ", " + sumValue);
}

上面的示例代码中，假设我们需要对一个名为MyEntity的实体按照field_to_group_by字段进行分组统计，同时还需要对field_to_sum字段进行求和操作。执行完查询之后，我们可以通过遍历聚合分组的结果，获取每个分组的key、docCount和sum_of_field的值。