MongoDB中如何将accountants集合ID追加到匹配的users集合数组字段

要完成将匹配的accountants文档ID追加到users集合对应文档的数组字段中，可以使用MongoDB 4.2及以上版本支持的聚合管道式更新（高效批量处理）；如果是低版本MongoDB，也可以用遍历查询的方式实现。

方法一：聚合管道批量更新（推荐） #

通过updateMany结合聚合管道，一次性完成关联查询与数组更新，支持去重逻辑：

db.users.updateMany(
  {}, // 若需限定更新范围，可添加匹配条件，例如 { name: { $exists: true } }
  [
    // 关联accountants集合，匹配name和family字段，仅返回对应文档的_id
    {
      $lookup: {
        from: "accountants",
        let: { userName: "$name", userFamily: "$family" },
        pipeline: [
          {
            $match: {
              $expr: {
                $and: [
                  { $eq: ["$name", "$$userName"] },
                  { $eq: ["$family", "$$userFamily"] }
                ]
              }
            }
          },
          { $project: { _id: 1 } }
        ],
        as: "matchedAccountants"
      }
    },
    // 将匹配到的accountant ID追加到目标数组，自动去重
    {
      $set: {
        accountantIds: {
          $setUnion: [
            { $ifNull: ["$accountantIds", []] }, // 若原字段不存在，用空数组兜底
            { $map: { input: "$matchedAccountants", as: "acc", in: "$$acc._id" } }
          ]
        }
      }
    },
    // 清理临时生成的关联字段
    { $unset: "matchedAccountants" }
  ]
)

关键逻辑说明 #

• $lookup的pipeline参数实现精准匹配：通过let定义当前users文档的name和family变量，再用$expr关联accountants集合的对应字段，仅返回需要的_id，减少数据传输。
• $setUnion用于合并数组并自动去重，避免重复添加同一accountant ID；如果不需要去重，可改用$concatArrays直接拼接。
• $ifNull处理目标数组字段不存在的情况，确保更新不会报错。

方法二：遍历查询更新（低版本兼容） #

如果你的MongoDB版本低于4.2，不支持聚合管道式更新，可以通过遍历accountants文档，逐个更新对应的users文档：

db.accountants.find().forEach(function(accDoc) {
  db.users.updateMany(
    { name: accDoc.name, family: accDoc.family },
    { $addToSet: { accountantIds: accDoc._id } } // $addToSet自动避免重复
  )
})

优缺点 #

• 优点：逻辑简单，无需复杂聚合语法。
• 缺点：属于循环单条更新，数据量较大时效率较低，不建议用于百万级以上数据。

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