MongoDB聚合时使用$group合并嵌套数组的实现方法

核心思路是以objectData._id为分组键，用$push收集quoteData到数组，同时用$first保留完整的objectData对象。以下是具体实现步骤和注意事项：

假设你的数据结构（$unwind+$lookup后） #

经过$unwind和$lookup后，你的文档应该类似这样（每个文档对应一条关联的quote数据）：

{
  "objectData": { "_id": "obj_001", "name": "商品A", "category": "电子产品" },
  "quoteData": { "_id": "quote_001", "price": 299, "vendor": "商家X" }
},
{
  "objectData": { "_id": "obj_001", "name": "商品A", "category": "电子产品" },
  "quoteData": { "_id": "quote_002", "price": 319, "vendor": "商家Y" }
}

期望输出结构 #

{
  "objectData": { "_id": "obj_001", "name": "商品A", "category": "电子产品" },
  "quotes": [
    { "_id": "quote_001", "price": 299, "vendor": "商家X" },
    { "_id": "quote_002", "price": 319, "vendor": "商家Y" }
  ]
}

聚合管道实现 #

db.your_collection.aggregate([
  // 这里是你已有的$unwind和$lookup阶段，例如：
  // { $unwind: "$quoteIds" }, // 假设你是先unwind了存储quote ID的数组
  // {
  //   $lookup: {
  //     from: "quotes",
  //     localField: "quoteIds",
  //     foreignField: "_id",
  //     as: "quoteData"
  //   }
  // },
  // 注意：如果$lookup返回的quoteData是数组（即使只有一条数据），必须先unquoteData：
  // { $unwind: "$quoteData" },

  // 关键的$group阶段
  {
    $group: {
      _id: "$objectData._id", // 按objectData的唯一ID分组
      objectData: { $first: "$objectData" }, // 保留完整的objectData（同一组内的objectData完全一致）
      quotes: { $push: "$quoteData" } // 将每组内的所有quoteData收集为数组
    }
  },
  // 可选：移除自动生成的_id字段，让输出更符合期望结构
  {
    $project: {
      _id: 0,
      objectData: 1,
      quotes: 1
    }
  }
])

常见误区排查 #

• $lookup返回的是数组，未做unwind：如果你的quoteData是数组类型（即使只有一条数据），$push会把数组直接加入quotes，导致嵌套数组。解决方法是在$group前增加{ $unwind: "$quoteData" }。
• 分组键选择错误：必须用$objectData._id作为分组键，而不是整个objectData对象（虽然也能工作，但效率更低）。
• 多余使用$map：不需要用$map转换quoteData，$push可以直接收集完整的quoteData对象。如果需要筛选quoteData的字段，直接在$push里指定即可，例如：

  quotes: { $push: { _id: "$quoteData._id", price: "$quoteData.price" } }
  

• 未正确保留objectData：同一分组内的objectData是完全相同的，用$first取第一个文档的objectData即可完整保留所有字段，不需要逐个字段指定。

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