MongoDB从集合读取数据更新后写入新集合失败问题求助

核心错误及修复方案 #

• 聚合源集合配置错误
  你定义的两个聚合pipeline都是从目标集合mergeCollection（也就是你要写入的UpdatedCollection）执行查询，这个集合初始是空的，自然没有数据可以处理写入。要读取源集合数据，应该把聚合执行主体换成你用来存原始数据的collectionDB对象：

// 错误写法
AggregateIterable<Document> resultsPipeline = mergeCollection.aggregate(pipeline).allowDiskUse(false);
// 修正写法
AggregateIterable<Document> resultsPipeline = collectionDB.aggregate(pipeline).allowDiskUse(false);
// pipeline2同理也要换成从collectionDB执行
AggregateIterable<Document> resultsPipeline2 = collectionDB.aggregate(pipeline2).allowDiskUse(false);

• $out/$merge参数格式错误
  MongoDB的$out、$merge聚合阶段只接收集合名字符串，或者指定库名和集合名的文档对象，不能直接传入Java的MongoCollection实例，把对应阶段的参数改成集合名字符串即可：

// $out阶段修正
new Document().append("$out", "UpdatedCollection")
// $merge阶段修正
new Document().append("$merge", new Document().append("into", "UpdatedCollection"))

• $match阶段重复键覆盖问题
  你的pipeline2的$match里三次append了key字段，同一个Document的同名键会被后写入的值覆盖，最终只会保留key: sourceSystem的匹配条件，导致你要匹配的SS、EXO条件完全失效。要匹配同一个字段的多个值，要用$in操作符：

.append("$match", new Document()
        .append("key", new Document("$in", Arrays.asList("SS", "EXO", sourceSystem)))
        .append("Period", financialPeriod)
)

• 聚合操作未触发执行
  MongoDB Java驱动的AggregateIterable是懒加载对象，只声明不调用终端操作（比如forEach、into、first）的话，整个聚合pipeline根本不会运行，自然没有数据写入。你需要给两个聚合都加上终端触发逻辑，不需要处理结果的话可以调用first()触发执行：

resultsPipeline.first(); // 触发第一个聚合执行，完成$out写入
resultsPipeline2.first(); // 触发第二个聚合执行，完成$merge写入

• 更新过滤器匹配不到数据
  你前面的$project阶段已经把_id字段设置为0（也就是不输出），写入UpdatedCollection的文档根本不会有_id = 1的记录，updateMany自然不会匹配到任何数据。如果要更新所有写入的文档，直接把过滤器设为空即可：

Bson filter = new Document(); // 匹配集合中所有文档
mergeCollection.updateMany(filter, updateTempQuery);

• $merge目标集合名错误
  最后一个聚合pipeline3的$merge写的是"collectionDB"，这是你代码里的变量名，不是MongoDB里实际的集合名，换成你要写入的真实集合名即可。

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