MongoDB 4.4聚合：如何为数组对象内的ObjectId关联添加字段？

问题分析 #

你当前的聚合语句之所以会让每个checkouts对象的title变成所有关联书籍的数组，核心原因是：

1. $lookup通过localField: "checkouts.bookId"提取了所有借阅记录中的bookId组成数组，返回所有匹配的书籍到临时字段；
2. {$addFields: { "checkouts.title": "$book_tmp_field.title" }}是将所有书籍的title数组直接赋值给每个checkouts对象的title字段，而非匹配单个bookId对应的书名。

解决方案 #

针对MongoDB 4.4版本，提供两种可行的实现方式：

方式一：使用$unwind拆分重组（易理解，适合小数据量） #

通过拆分数组逐个关联书籍，再重组回原文档结构：

db.getCollection('subscribers').aggregate([
  // 匹配目标用户
  {$match: {_id: ObjectId("63208c2e0d97eff0cfbefb46") } },
  // 将checkouts数组拆分为单个文档
  {$unwind: "$checkouts"},
  // 为每个拆分后的checkout关联对应的书籍
  {$lookup: {
      from: "books",
      localField: "checkouts.bookId",
      foreignField: "_id",
      as: "book_info"
  }},
  // 将书籍title合并到checkout对象中
  {$addFields: {
      "checkouts.title": {$arrayElemAt: ["$book_info.title", 0]}
  }},
  // 移除临时字段
  {$project: { book_info: 0 }},
  // 按用户ID重组checkouts数组，恢复原文档结构
  {$group: {
      _id: "$_id",
      name: {$first: "$name"},
      address: {$first: "$address"},
      checkouts: {$push: "$checkouts"}
  }}
])

方式二：使用带Pipeline的$lookup+数组映射（高效，适合大数据量） #

通过lookup的自定义Pipeline匹配书籍，再通过$map+$filter将书名精准匹配到对应借阅记录：

db.getCollection('subscribers').aggregate([
  // 匹配目标用户
  {$match: {_id: ObjectId("63208c2e0d97eff0cfbefb46") } },
  // 自定义lookup管道，仅查询当前用户借阅的书籍
  {$lookup: {
      from: "books",
      let: { user_checkouts: "$checkouts" },
      pipeline: [
        {$match: {
            $expr: {$in: ["$_id", "$$user_checkouts.bookId"]}
        }},
        {$project: { title: 1, _id: 1 }} // 仅保留需要的字段
      ],
      as: "matched_books"
  }},
  // 将匹配到的书名映射到对应的checkouts对象中
  {$addFields: {
      checkouts: {
          $map: {
              input: "$checkouts",
              as: "checkout",
              in: {
                  $mergeObjects: [
                      "$$checkout",
                      // 筛选当前checkout对应的书籍，取出title
                      {$arrayElemAt: [
                          {$filter: {
                              input: "$matched_books",
                              cond: {$eq: ["$$this._id", "$$checkout.bookId"]}
                          }},
                          0
                      ]}
                  ]
              }
          }
      }
  }},
  // 移除临时字段
  {$project: { matched_books: 0 }}
])

验证结果 #

两种方式执行后，均可得到符合预期的输出：每个checkouts对象的title字段对应其bookId关联的书籍名称，而非所有书名的数组。

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