MongoDB $lookup关联数组对象：如何将数据嵌入对应子对象？

问题场景回顾 #

源集合（比如命名为playerInventories）的文档结构示例：

{
  "_id": ObjectId("xxx"),
  "playerId": "player123",
  "gameItemsWithQty": [
    { "gameItem": { "_id": ObjectId("item001") }, "qty": 5 },
    { "gameItem": { "_id": ObjectId("item002") }, "qty": 2 }
  ]
}

游戏物品集合（比如命名为gameItems）的文档结构示例：

{
  "_id": ObjectId("item001"),
  "name": "回复药水",
  "type": "consumable",
  "effect": "恢复100HP"
}

你之前的$lookup写法会把所有匹配的物品整合成数组直接塞进gameItemsWithQty.gameItem，而非对应到原数组的每个子对象中——这是因为直接用数组字段作为localField时，MongoDB会收集数组内所有_id批量关联，再将结果数组直接赋值给as指定路径，不会自动匹配原数组的单个元素。

正确方案1：使用$lookup子管道（推荐，MongoDB 3.6+支持） #

无需拆分数组，直接通过子管道精准匹配每个数组元素，性能更优：

db.playerInventories.aggregate([
  {
    $lookup: {
      from: "gameItems",
      let: { itemsArr: "$gameItemsWithQty" },
      pipeline: [
        {
          $match: {
            $expr: {
              $in: ["$_id", "$itemsArr.gameItem._id"]
            }
          }
        },
        {
          $project: {
            itemDetails: "$$ROOT",
            itemId: "$_id"
          }
        }
      ],
      as: "matchedItems"
    }
  },
  {
    $addFields: {
      gameItemsWithQty: {
        $map: {
          input: "$gameItemsWithQty",
          as: "itemWithQty",
          in: {
            qty: "$$itemWithQty.qty",
            gameItem: {
              $first: {
                $filter: {
                  input: "$matchedItems",
                  cond: { $eq: ["$$this.itemId", "$$itemWithQty.gameItem._id"] }
                }
              }
            }
          }
        }
      },
      matchedItems: "$$REMOVE" // 清理临时字段
    }
  }
])

步骤说明： #

1. $lookup通过let定义变量引用原数组，子管道先匹配所有关联的物品，同时投影出物品详情和_id用于后续匹配。
2. $addFields用$map遍历原数组，对每个元素通过$filter从匹配结果中找到对应_id的物品详情，替换原gameItem字段，最后移除临时的matchedItems。

正确方案2：$unwind + $lookup + $group（兼容旧版本MongoDB） #

如果你的MongoDB版本低于3.6，可采用拆分数组再聚合的方式：

db.playerInventories.aggregate([
  // 拆分数组为单个文档
  { $unwind: "$gameItemsWithQty" },
  // 关联游戏物品集合
  {
    $lookup: {
      from: "gameItems",
      localField: "gameItemsWithQty.gameItem._id",
      foreignField: "_id",
      as: "gameItemsWithQty.gameItem"
    }
  },
  // 将lookup返回的数组转为单个对象（每个元素仅匹配一个物品）
  {
    $addFields: {
      "gameItemsWithQty.gameItem": { $first: "$gameItemsWithQty.gameItem" }
    }
  },
  // 按原文档_id重新聚合，重组数组
  {
    $group: {
      _id: "$_id",
      playerId: { $first: "$playerId" }, // 按需保留原文档其他字段
      gameItemsWithQty: { $push: "$gameItemsWithQty" }
    }
  }
])

步骤说明： #

1. $unwind将数组拆分为多个独立文档，每个文档对应原数组的一个元素。
2. 此时localField指向单个元素的gameItem._id，$lookup可正确关联对应物品（返回结果为数组）。
3. 用$first将数组转为单个对象，因为每个元素只会匹配到一个物品。
4. $group按原文档_id聚合，将拆分后的元素重新组合为gameItemsWithQty数组，同时保留原文档的其他字段。

注意事项 #

• 方案1性能更优，尤其当数组元素较多时，可避免$unwind和$group带来的额外开销。
• 确保gameItems集合的_id字段有索引（默认主键已自带索引），可大幅提升关联速度。

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