MongoDB聚合查询：关联集合并合并子文档字段

嘿，刚从MySQL转MongoDB确实得适应一下文档型数据库的思路～你遇到的这个问题，核心是要把Students集合里subjects数组的额外字段（比如passed）和Subjects集合的课程详情合并到一起，只用$lookup确实完不成字段合并，还需要配合几个聚合阶段来实现，我给你一步步拆解：

先明确示例数据（方便理解操作逻辑） #

假设你的集合数据结构是这样的：

Students集合示例 #

{
  "_id": ObjectId("60d21b4667d0d8992e610c85"),
  "name": "Alice",
  "subjects": [
    { "_id": ObjectId("60d21b8967d0d8992e610c86"), "passed": true },
    { "_id": ObjectId("60d21b9f67d0d8992e610c87"), "passed": false }
  ]
}

Subjects集合示例 #

{
  "_id": ObjectId("60d21b8967d0d8992e610c86"),
  "name": "Mathematics",
  "credit": 3
},
{
  "_id": ObjectId("60d21b9f67d0d8992e610c87"),
  "name": "English",
  "credit": 2
}

方法一：通用版（适配所有MongoDB版本） #

通过拆分-关联-合并-重组的流程实现字段合并：

db.students.aggregate([
  // 1. 拆分students的subjects数组，把每个学科项拆成独立文档
  { $unwind: "$subjects" },
  // 2. 关联subjects集合，根据学科_id获取课程详情
  {
    $lookup: {
      from: "subjects",
      localField: "subjects._id",
      foreignField: "_id",
      as: "subjectDetails"
    }
  },
  // 3. 把关联得到的数组转成单个对象（每个学科只会匹配到一条课程数据）
  { $unwind: "$subjectDetails" },
  // 4. 合并学科额外字段（passed）和课程详情
  {
    $addFields: {
      "mergedSubject": {
        $mergeObjects: ["$subjectDetails", "$subjects"]
      }
    }
  },
  // 5. 按学生_id分组，重新组装成带合并后学科的数组结构
  {
    $group: {
      _id: "$_id",
      name: { $first: "$name" }, // 保留学生的其他字段
      subjects: { $push: "$mergedSubject" }
    }
  }
])

执行后得到的目标数据 #

{
  "_id": ObjectId("60d21b4667d0d8992e610c85"),
  "name": "Alice",
  "subjects": [
    {
      "_id": ObjectId("60d21b8967d0d8992e610c86"),
      "name": "Mathematics",
      "credit": 3,
      "passed": true
    },
    {
      "_id": ObjectId("60d21b9f67d0d8992e610c87"),
      "name": "English",
      "credit": 2,
      "passed": false
    }
  ]
}

方法二：高效版（MongoDB 5.0+可用） #

利用$lookup的pipeline选项，不用拆分重组，直接在关联阶段完成字段合并，性能更优：

db.students.aggregate([
  {
    $lookup: {
      from: "subjects",
      // 把当前学生的subjects数组传递到关联管道中
      let: { studentSubjects: "$subjects" },
      pipeline: [
        // 匹配当前学生选的学科
        {
          $match: {
            $expr: { $in: ["$_id", "$$studentSubjects._id"] }
          }
        },
        // 合并课程详情和对应学科的额外字段
        {
          $replaceRoot: {
            newRoot: {
              $mergeObjects: [
                "$$ROOT", // 课程详情
                {
                  // 从学生的subjects数组中过滤出当前学科的额外字段
                  $arrayElemAt: [
                    {
                      $filter: {
                        input: "$$studentSubjects",
                        cond: { $eq: ["$$this._id", "$_id"] }
                      }
                    },
                    0
                  ]
                }
              ]
            }
          }
        }
      ],
      as: "subjects"
    }
  }
])

小提示 #

MongoDB的聚合管道思路和MySQL的JOIN完全不同，要习惯文档拆分、字段转换、重组文档这类操作，多试试不同聚合阶段的组合，慢慢就能熟练掌握啦～

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