使用ElasticsearchRepository实现Java聚合查询时聚合结果始终为空

• Java = 8
• ElasticSearchServer = 7.16.3

你的代码无法返回聚合值，主要存在以下问题及对应修正方案：

1. @Query注解的JSON语法错误 #

原始Query字符串中，bool逻辑块后多了一个闭合的}，导致aggs定义被排除在根查询对象之外，ES无法识别聚合配置。

修正后的@Query代码：

@Query("{\"size\":0, \"bool\": {\"must\": [{\"match\": {\"status\": \"Completed\"}}]}, \"aggs\": {\"percentAggs\": {\"percentile_ranks\": {\"field\": \"Total_Time\", \"values\": [5000]}}}}")
SearchHits<ScPayHkIndex> getPercentileRank();

• 添加"size":0可避免返回匹配文档，仅返回聚合结果，减少数据传输
• 移除多余的}，让aggs与bool同属根查询对象的属性
• 在percentile_ranks中添加values: [5000]，指定需要计算百分位的目标数值，ES会返回该数值对应的百分位排名

2. 聚合字段类型验证 #

确保ES中Total_Time字段的映射类型为数值型（如double、long），如果是字符串类型，聚合计算会直接失败。

你可以在实体类ScPayHkIndex中给该字段添加正确注解：

@Field(type = FieldType.Double) // 或FieldType.Long，根据实际数据类型选择
private Double Total_Time;

3. 空指针安全处理 #

在获取聚合结果时添加空指针判断，避免因聚合结果为空导致异常：

default double getMyPercentileValue() {
    SearchHits<ScPayHkIndex> response = getPercentileRank();
    Aggregations aggregation = response.getAggregations();
    
    if (aggregation == null) {
        return 0.0; // 或根据业务需求抛出异常
    }
    
    PercentileRanks percentileRanks = aggregation.get("percentAggs");
    if (percentileRanks == null) {
        return 0.0;
    }
    
    Double percentileValue = percentileRanks.percent(5000);
    return percentileValue != null ? percentileValue : 0.0;
}

内容的提问来源于stack exchange，提问作者Mahaveer Jangir