能否通过MongoDB聚合操作实现文档创建与更新的联动？

需求描述 #

现有MongoDB集合数据结构如下：

[
  {
    "_id": { "$oid": "664baf560b9539e48fbc6ed1" },
    "name": "first assignment",
    "next": { "$oid": "664baf620b9539e48fbc6ed2" },
    "preview": null,
    "date": { "$date": "2024-04-20T10:00:00.000Z" }
  },
  {
    "_id": { "$oid": "664baf620b9539e48fbc6ed2" },
    "name": "second assignment",
    "next": { "$oid": "664baf6d0b9539e48fbc6ed3" },
    "preview": { "$oid": "664baf560b9539e48fbc6ed1" },
    "date": { "$date": "2024-04-21T10:00:00.000Z" }
  },
  {
    "_id": { "$oid": "664baf6d0b9539e48fbc6ed3" },
    "name": "third assignment",
    "next": { "$oid": "664baf8d0b9539e48fbc6ed4" },
    "preview": { "$oid": "664baf620b9539e48fbc6ed2" },
    "date": { "$date": "2024-04-22T10:00:00.000Z" }
  },
  {
    "_id": { "$oid": "664baf8d0b9539e48fbc6ed4" },
    "name": "fourth assignment",
    "next": null,
    "preview": { "$oid": "664baf6d0b9539e48fbc6ed3" },
    "date": { "$date": "2024-04-23T10:00:00.000Z" }
  }
]

其中next和preview字段引用同集合内其他文档的ID。需求为：
当收到第四个任务的ID（664baf8d0b9539e48fbc6ed4）时，执行两个关联操作：

1. 创建一个结构相同的新文档，其preview字段设为该ID；
2. 更新第四个任务文档，将其next字段设为新创建文档的ID。

解决方案说明 #

• 无法通过MongoDB聚合操作实现：MongoDB聚合管道本质是用于数据查询、转换和分析的只读型操作（仅$out、$merge能写入集合，但这类操作无法同时完成「插入新文档+更新已有文档」的关联逻辑——新文档的_id需要生成后才能回填到旧文档的next字段，聚合管道无法处理这种依赖生成结果的后续更新）。
• 推荐实现方式：
  1. 使用MongoDB事务：在一个事务中依次执行「插入新文档」和「更新第四个任务的next字段」操作，保证两个操作的原子性，避免数据不一致。示例代码（以Node.js驱动为例）：

     const session = await client.startSession();
     try {
       await session.withTransaction(async () => {
         // 插入新文档，获取自动生成的_id
         const newDocResult = await db.collection('assignments').insertOne({
           name: 'new assignment', // 替换为实际任务名称
           next: null,
           preview: ObjectId('664baf8d0b9539e48fbc6ed4'),
           date: new Date() // 替换为实际任务日期
         }, { session });
     
         // 更新第四个任务的next字段为新文档ID
         await db.collection('assignments').updateOne(
           { _id: ObjectId('664baf8d0b9539e48fbc6ed4') },
           { $set: { next: newDocResult.insertedId } },
           { session }
         );
       });
     } finally {
       await session.endSession();
     }
     

  2. 分两步执行传统操作：如果业务场景允许短暂的数据不一致，可以先插入新文档，再用返回的insertedId更新第四个任务的next字段。但这种方式在高并发场景下可能出现数据异常，建议优先使用事务。

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