如何将Mongo带$mergeObjects的聚合脚本转换为Spring Mongo Java代码

针对你已经验证可运行的Mongo Shell聚合脚本，提供两种可直接落地的实现方案，覆盖不同版本兼容场景，规避常见的参数映射报错问题。

推荐生产环境实现：内置Aggregation API 管道构建 #

这种方式通过Spring Data Mongo封装的原生API构建管道，字段引用规则由框架自动处理，可维护性更强，兼容Spring Data MongoDB 3.0及以上版本。

完整可运行代码如下：

import org.springframework.data.mongodb.core.MongoTemplate;
import org.springframework.data.mongodb.core.aggregation.Aggregation;
import org.springframework.data.mongodb.core.aggregation.AggregationResults;
import java.util.Map;

// 业务方法内执行逻辑
String queryAppId = "2021010706001";

// 1. 对应shell中的$match阶段
var matchStage = Aggregation.match(
    org.springframework.data.mongodb.core.query.Criteria.where("applicationId").is(queryAppId)
);

// 2. 对应shell中的$group阶段，按applicationId分组并合并mapData
var groupStage = Aggregation.group("applicationId")
    .merge("mapData")
    .as("mapData");

// 3. 对应shell中的$replaceRoot阶段，将mapData设为根节点
var replaceRootStage = Aggregation.replaceRoot(
    Aggregation.Replacement.newRoot().from("mapData")
);

// 执行聚合查询
AggregationResults<Map> queryResult = mongoTemplate.aggregate(
    Aggregation.newAggregation(matchStage, groupStage, replaceRootStage),
    "Application", // 与数据库实际集合名完全一致，不要依赖实体类自动映射
    Map.class
);

// 最终取合并后的mapData结果
Map mergedMapData = queryResult.getUniqueMappedResult();

低版本兼容/零误差对齐实现 #

如果项目使用Spring Data MongoDB 2.x及以下低版本，框架未内置$mergeObjects的group操作方法，或者需要100%和shell逻辑对齐、减少API适配误差，可以直接通过原生文档结构构建管道执行。

完整代码如下：

import org.bson.Document;
import org.springframework.data.mongodb.core.MongoTemplate;
import org.springframework.data.mongodb.core.aggregation.Aggregation;
import org.springframework.data.mongodb.core.aggregation.AggregationResults;
import org.springframework.data.mongodb.core.aggregation.AggregationOperation;
import java.util.List;
import java.util.Map;

// 直接将shell中的管道阶段逐行转换为Mongo原生Document结构
List<Document> pipelineStages = List.of(
    new Document("$match", new Document("applicationId", "2021010706001")),
    new Document("$group", new Document("_id", "$applicationId")
        .append("mapData", new Document("$mergeObjects", "$mapData"))
    ),
    new Document("$replaceRoot", new Document("newRoot", "$mapData"))
);

// 转换为Spring可识别的聚合操作并执行
List<AggregationOperation> operations = pipelineStages.stream()
    .map(doc -> (AggregationOperation) aggregationContext -> doc)
    .toList();

AggregationResults<Map> queryResult = mongoTemplate.aggregate(
    Aggregation.newAggregation(operations),
    "Application",
    Map.class
);

Map mergedResult = queryResult.getUniqueMappedResult();

常见踩坑提醒 #

• 字段引用规则差异：Spring内置API在写分组、替换的字段路径时，不需要手动加$前缀，框架会自动补全字段引用标识；手动构建原生Document时，引用集合字段必须带$前缀，否则会出现字段取不到值的问题
• 结果接收类型：由于最后通过$replaceRoot将根节点替换成了mapData的内容，不要直接用原Application实体类接收结果，会出现字段全为null的映射异常，优先用通用Map结构接收
• 集合名校验：代码中传入的集合名要和数据库中实际存在的集合名完全匹配，不要依赖实体类上@Document注解的自动映射值，避免注解配置和实际库表不一致导致的查空问题

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