MongoDB能否通过聚合操作一次性更新多个关联集合？

MongoDB 单个聚合管道无法直接完成多集合的同步修改操作，原因是聚合管道的写入阶段（$out/$merge）仅支持将结果输出到单个集合，无法同时写入多个不同集合。但你可以通过「单次聚合查询批量获取待更新文档ID + 多集合批量更新」的方案在数据库层完成操作，性能远高于应用层循环更新。

具体实现方案 #

假设你需要更新的目标 CollectionOne 记录_id为ObjectId("目标CollectionOneID")，需要修改为的新_masterCollectionId为ObjectId("新的MasterID")，实现步骤如下：

步骤1：单次聚合查询获取所有待更新的文档ID #

直接在 CollectionOne 上执行聚合，一次性关联查询出所有关联的 CollectionTwo、CollectionThree 文档ID，避免多次IO请求：

const updateInfo = await db.CollectionOne.aggregate([
  // 匹配目标CollectionOne记录
  { $match: { _id: ObjectId("目标CollectionOneID") } },
  // 关联查询所有对应的CollectionTwo记录
  {
    $lookup: {
      from: "CollectionTwo",
      localField: "_id",
      foreignField: "_parentId",
      as: "c2List"
    }
  },
  // 关联查询所有对应的CollectionThree记录
  {
    $lookup: {
      from: "CollectionThree",
      localField: "c2List._id",
      foreignField: "_parentId",
      as: "c3List"
    }
  },
  // 仅返回需要的ID列表
  {
    $project: {
      c1Id: "$_id",
      c2Ids: "$c2List._id",
      c3Ids: "$c3List._id",
      _id: 0
    }
  }
]).next()

步骤2：执行多集合批量更新 #

用updateMany直接在数据库层完成批量更新，全程不需要在应用层循环遍历数据：

const newMasterId = ObjectId("新的MasterID")
// 1. 更新目标CollectionOne记录
await db.CollectionOne.updateOne(
  { _id: updateInfo.c1Id },
  { $set: { _masterCollectionId: newMasterId } }
)
// 2. 批量更新关联的CollectionTwo记录
await db.CollectionTwo.updateMany(
  { _id: { $in: updateInfo.c2Ids } },
  { $set: { _masterCollectionId: newMasterId } }
)
// 3. 批量更新关联的CollectionThree记录
await db.CollectionThree.updateMany(
  { _id: { $in: updateInfo.c3Ids } },
  { $set: { _masterCollectionId: newMasterId } }
)

可选原子性保证 #

如果需要三个集合的更新操作满足原子性（要么全部成功，要么全部回滚），可以将上述更新操作放在MongoDB事务中执行，要求MongoDB版本≥4.0，且部署为副本集或分片集群。

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