如何将MongoDB聚合结果通过updateMany写入数据库？

你可以通过以下两种常用方式，把聚合生成的pricingOptionId、quantity字段写回tickets集合：

方法一：使用聚合的$merge阶段（推荐） #

$merge能直接将聚合结果合并回原集合，支持匹配更新且不会替换整个集合，适合大多数场景。在你现有聚合查询末尾添加$merge阶段即可：

db.tickets.aggregate([
  {
    $lookup: {
      from: "payments",
      localField: "paymentId",
      foreignField: "_id",
      as: "payment"
    }
  },
  {
    $unwind: {
      path: "$payment",
      preserveNullAndEmptyArrays: true
    }
  },
  {
    $addFields: {
      pricingOptionId: "$payment.pricingOptionId",
      quantity: "$payment.quantity"
    }
  },
  {
    $project: {
      payment: 0 // 不需要payment字段则排除
    }
  },
  // 新增$merge阶段，将结果合并回tickets集合
  {
    $merge: {
      into: "tickets",
      on: "_id", // 用唯一主键_id匹配原文档
      whenMatched: "merge", // 匹配到原文档时，保留原字段并合并聚合生成的字段
      whenNotMatched: "discard" // 无匹配原文档的聚合结果直接丢弃，不新增文档
    }
  }
])

参数说明： #

• into：指定目标集合，这里即为tickets
• whenMatched：若用"replace"会直接替换整个文档，容易丢失原文档其他字段，因此优先用"merge"
• whenNotMatched：因为我们仅需更新原集合已有文档，所以设置为"discard"

方法二：游标循环更新（适合小数据集） #

如果tickets数据量较小，可先通过聚合获取结果，再循环逐个更新文档：

db.tickets.aggregate([
  {
    $lookup: {
      from: "payments",
      localField: "paymentId",
      foreignField: "_id",
      as: "payment"
    }
  },
  {
    $unwind: {
      path: "$payment",
      preserveNullAndEmptyArrays: true
    }
  },
  {
    $addFields: {
      pricingOptionId: "$payment.pricingOptionId",
      quantity: "$payment.quantity"
    }
  },
  {
    $project: {
      payment: 0,
      pricingOptionId: 1,
      quantity: 1
    }
  }
]).forEach(doc => {
  db.tickets.updateOne(
    { _id: doc._id },
    { $set: {
      pricingOptionId: doc.pricingOptionId,
      quantity: doc.quantity
    }}
  )
})

注意事项： #

• 该方法会发送多次更新请求，数据量大时性能远不如$merge
• 可考虑优化为批量更新，但会提升实现复杂度

额外提醒 #

• 操作前建议在测试环境验证，或提前备份数据
• 若paymentId对应多条payments文档，$unwind会生成多条结果，$merge会用最后一条匹配结果更新原文档，需确认业务逻辑是否允许
• 为payments._id和tickets.paymentId建立索引，可大幅提升$lookup的执行效率

内容的提问来源于stack exchange，提问作者János