如何修正MongoDB Aggregation Pipeline：标记未在售商品是否存在于productDetail集合

需求明确 #

• 通过_id关联products和productDetail集合
• 筛选出不存在onSale字段的未在售商品
• 为每个商品添加inProductDetailCollection标记：存在于productDetail则为true，否则为false

问题根源 #

现有管道标记始终为true，是因为$lookup执行后，即使没有匹配到数据，也会返回空数组[]，而原有逻辑未判断数组是否为空，直接将标记设为true。

修正后的聚合代码 #

db.products.aggregate([
  // 筛选无onSale字段的商品
  {
    $match: {
      onSale: { $exists: false }
    }
  },
  // 关联productDetail集合，按_id匹配
  {
    $lookup: {
      from: "productDetail",
      localField: "_id",
      foreignField: "_id",
      as: "detailMatch"
    }
  },
  // 根据关联结果设置标记：数组非空则存在
  {
    $addFields: {
      inProductDetailCollection: {
        $ne: ["$detailMatch", []]
      }
    }
  },
  // 可选：移除临时的detailMatch数组（不需要保留关联数据时用）
  {
    $project: {
      detailMatch: 0
    }
  }
])

示例数据验证 #

示例products数据 #

[
  { _id: ObjectId("60d21b4667d0d8992e610c85"), name: "商品A", price: 99 },
  { _id: ObjectId("60d21b5067d0d8992e610c86"), name: "商品B", price: 199, onSale: true },
  { _id: ObjectId("60d21b5967d0d8992e610c87"), name: "商品C", price: 299 }
]

示例productDetail数据 #

[
  { _id: ObjectId("60d21b4667d0d8992e610c85"), desc: "商品A的详细描述" }
]

执行结果 #

[
  {
    "_id": ObjectId("60d21b4667d0d8992e610c85"),
    "name": "商品A",
    "price": 99,
    "inProductDetailCollection": true
  },
  {
    "_id": ObjectId("60d21b5967d0d8992e610c87"),
    "name": "商品C",
    "price": 299,
    "inProductDetailCollection": false
  }
]

核心逻辑说明 #

• $match阶段精准过滤掉带有onSale字段的在售商品
• $lookup返回的detailMatch是数组，无匹配时为空数组[]
• 用$ne判断数组是否为空，以此生成正确的存在标记
• 可选的$project用于清理临时数据，让输出更整洁

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