Spring Boot下MongoDB聚合管道使用$merge不生效问题排查求助

问题核心原因 #

你遇到的问题90%以上是因为没有触发聚合管道的实际执行：

• MongoDB Java 驱动中MongoCollection.aggregate()方法返回的是懒加载的AggregateIterable实例，只有主动消费游标时才会真正向服务端发送请求执行完整管道
• 你测试$out时大概率是不小心触发了游标消费（比如后续逻辑遍历了返回结果），所以能正常执行，而$merge的测试代码没有触发消费，所以看起来没有生效

解决方案 #

只需要在aggregate()方法后追加任意游标消费方法即可，哪怕你不需要返回结果：

final ArrayList<Document> pipeline = new ArrayList<>();

pipeline.add(Document.parse("{$match: {type: 'ABC'}}"));
pipeline.add(Document.parse("{$merge: {into: 'OUTPUT_COLLECTION', whenMatched: 'replace'}}"));

mongoTemplate.getDb()
    .getCollection("SOURCE_COLLECTION", Document.class) // 注意你示例代码里的源集合名多写了一个T，注意修正拼写
    .aggregate(pipeline)
    .first(); // 追加这行即可，执行完管道后会直接返回null，几乎没有额外开销

其他可选排查点 #

如果上述修改后依然不生效，可以检查这两个点：

• 确认服务端MongoDB版本 >=4.2，$merge是4.2版本才新增的聚合阶段
• 确认当前MongoDB账号对目标集合有写入、修改权限

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