MongoDB 如何实现同一集合不同文档间内嵌数组元素的移动

以下方案均基于Mongo Shell环境编写，可根据你使用的编程语言驱动调整对应API语法。

前提说明 #

• 操作集合：orders
• 待移动条目：orderNumber为"100"的文档中，itemId为"I000007"的子文档
• 目标位置：orderNumber为"102"的文档的items数组
• 你给出的预期结果中，源文档I000005的region字段发生了变更，属于额外修改需求，方案末尾会补充对应的实现逻辑。

方案1：事务原子操作（生产环境推荐） #

该方案基于MongoDB事务实现，可保证操作原子性，避免出现「源条目已删除但目标未添加」的半成功数据不一致问题，支持MongoDB 4.0+副本集、4.2+分片集群。

// 开启会话
const session = db.getMongo().startSession();
session.startTransaction({
  readConcern: { level: "snapshot" },
  writeConcern: { w: "majority" }
});

try {
  const ordersCollection = session.getDatabase(db.getName()).orders;

  // 查询待移动的目标条目
  const sourceOrder = ordersCollection.findOne(
    { orderNumber: "100" },
    { items: { $elemMatch: { itemId: "I000007" } }, _id: 0 }
  );
  if (!sourceOrder?.items?.length) throw new Error("未找到待移动的I000007条目");
  const movedItem = sourceOrder.items[0];

  // 从源文档移除目标条目
  ordersCollection.updateOne(
    { orderNumber: "100" },
    { $pull: { items: { itemId: "I000007" } } }
  );

  // 将条目推入目标文档数组
  ordersCollection.updateOne(
    { orderNumber: "102" },
    { $push: { items: movedItem } }
  );

  // 提交事务
  session.commitTransaction();
  print("条目移动成功");
} catch (e) {
  // 出错回滚事务
  session.abortTransaction();
  print("操作失败已回滚，错误信息：" + e.message);
} finally {
  // 关闭会话
  session.endSession();
}

方案2：非事务批量操作（测试环境使用） #

该方案不保证原子性，仅适合本地测试环境使用，操作中途出错可能产生脏数据。

// 查询待移动的条目
const movedItem = db.orders.findOne(
  { orderNumber: "100" },
  { items: { $elemMatch: { itemId: "I000007" } } }
)?.items?.[0];

if (movedItem) {
  // 批量执行两个更新
  db.orders.bulkWrite([
    {
      updateOne: {
        filter: { orderNumber: "100" },
        update: { $pull: { items: { itemId: "I000007" } } }
      }
    },
    {
      updateOne: {
        filter: { orderNumber: "102" },
        update: { $push: { items: movedItem } }
      }
    }
  ]);
  print("操作完成");
} else {
  print("未找到待移动的条目");
}

额外需求补充 #

如果需要同步修改源文档中I000005的region字段为["AMRS", "APAC"]，只需要将源文档的更新语句调整为如下即可：

ordersCollection.updateOne(
  { orderNumber: "100" },
  { 
    $pull: { items: { itemId: "I000007" } },
    $set: { "items.$[item].region": ["AMRS", "APAC"] }
  },
  { arrayFilters: [{ "item.itemId": "I000005" }] }
);

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