MongoDB同集合$aggregation与$lookup关联子分类失败问题排查

问题描述 #

我定义了包含category、material等字段的Product_options Mongoose Schema，其中category数组元素带有parent_id字段。尝试通过MongoDB的aggregate与lookup操作，为每个category添加isChildExist字段，展示所有parent_id等于当前category._id的子分类，但isChildExist始终为空数组，本该有子分类的Gemstones分类也未正确返回结果。

Product_options Schema定义 #

const productOptionsSchema = new mongoose.Schema({
    category: [{
        value: { type: String },
        display: { type: Number },
        display_order: { type: String },
        categoryImage: { type: String },
        parent_id: { type: mongoose.Schema.Types.ObjectId },
        parent_name: { type: String }
    }],
    material: [{
        value: { type: String },
        display: { type: Number },
        display_order: { type: String },
        price: { type: String }
    }],
    addon_type: [{
        type: mongoose.Schema.Types.ObjectId,
        ref: 'AddOnDetails'
    }],
    design: [{
        type: mongoose.Schema.Types.ObjectId,
        ref: 'DesignDetails'
    }]
  }, {
    timestamps: true
})

const Product_options = mongoose.model('Product_options', productOptionsSchema)

错误的Node.js代码 #

const cat = await Product_options.aggregate( [
    {
        $unwind: {
            path: "$category",
            preserveNullAndEmptyArrays: true
        }
    },
    {
        $lookup: {
            from: 'Product_options.category',
            localField: '_id',
            foreignField: 'parent_id',
            as: 'category.isChildExist'
        }
    },
    {
        "$project": {
            "_id": 0,
            "category": 1,
        }
    }
] );

res.json({
    msg: 'Success!',
    cat
})

当前响应（isChildExist为空数组） #

{
       "msg": "Success!",
        "cat": [
         {
            "category": {
                "value": "Rudraksha",
                "display": 1,
                "display_order": "",
                "categoryImage": "",
                "parent_id": null,
                "parent_name": null,
                "_id": "63aeac69f969cf78856b7db9",
                "isChildExist": []
            }
        },
        {
            "category": {
                "value": "Gemstones",
                "display": 1,
                "display_order": "1",
                "categoryImage": "",
                "parent_id": null,
                "parent_name": null,
                "_id": "63aeb968f969cf78856b8cd9",
                "isChildExist": []
            }
        },
        // 其他分类条目略
        ]
}

预期响应（Gemstones的isChildExist包含子分类） #

{
    "category": {
        "value": "Gemstones",
        "display": 1,
        "display_order": "1",
        "categoryImage": "",
        "parent_id": null,
        "parent_name": null,
        "_id": "63aeb968f969cf78856b8cd9",
        "isChildExist": [
    {
        "value": "Natural Yellow Sapphire - Pukhraj ",
        "display": 1,
        "display_order": "1",
        "categoryImage": "",
        "parent_id": "63aeb968f969cf78856b8cd9",
        "parent_name": "Gemstones",
        "_id": "63aec39bf969cf78856bb9c3",
        "child": []
    },
    // 其他子分类条目略
    ]
    }
}

解决方法 #

错误原因分析 #

1. $lookup的from参数错误：MongoDB的lookup只能关联整个集合，不能直接指定集合内的子数组字段（如Product_options.category），必须使用集合名称。
2. 关联字段匹配错误：原代码用文档的_id作为关联字段，但实际需要匹配的是当前category的_id与子分类的parent_id。
3. 未处理子数组的展开与过滤：关联集合内的category是数组，需要先展开再匹配父ID，才能正确提取子分类。

修正后的代码 #

const cat = await Product_options.aggregate([
  {
    $unwind: {
      path: "$category",
      preserveNullAndEmptyArrays: true
    }
  },
  {
    $lookup: {
      from: "product_options", // Mongoose默认集合名为小写复数，若自定义集合名请替换
      let: { parentCatId: "$category._id" },
      pipeline: [
        { $unwind: "$category" },
        { $match: { $expr: { $eq: ["$category.parent_id", "$$parentCatId"] } } },
        { $replaceRoot: { newRoot: "$category" } }
      ],
      as: "category.isChildExist"
    }
  },
  {
    $project: {
      "_id": 0,
      "category": 1
    }
  }
]);

res.json({
  msg: 'Success!',
  cat
});

代码说明 #

1. $unwind：将每个Product_options文档的category数组拆分为独立文档，每个文档对应一个分类项。
2. 带Pipeline的$lookup：
   • 定义变量parentCatId存储当前分类的_id
   • 在关联集合的pipeline中：先展开category数组，再匹配parent_id等于parentCatId的子分类，最后将匹配到的分类对象作为结果根节点
3. $project：仅保留category字段，移除原文档的_id

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