MongoDB v3.6.3：NodeJS驱动下关联User与Business嵌套Products数组

嘿，我懂你现在的困扰——之前产品是单独集合时用$lookup+$unwind就能轻松关联，但现在产品嵌套在Business集合的Products数组里，常规方法就不适用了。不过别担心，我们可以用MongoDB 3.6支持的带内部管道的$lookup来实现这个需求，下面是具体的解决方案：

核心思路 #

我们需要先从User集合出发，通过$lookup关联Business集合，在关联的内部管道里完成：展开商家的Products数组、匹配用户保存的产品ID、给产品添加商家信息，最后再把结果整理成你想要的结构。

完整聚合查询代码 #

db.User.aggregate([
  // 1. 关联Business集合，筛选出用户保存的产品并附加商家信息
  {
    $lookup: {
      from: "Business",
      let: { savedProductIds: "$saved_products" },
      pipeline: [
        // 先展开商家的Products数组，把每个产品变成独立文档
        { $unwind: "$Products" },
        // 匹配Products的_id在用户saved_products数组中的项
        { $match: { $expr: { $in: ["$Products._id", "$$savedProductIds"] } } },
        // 给匹配到的产品添加商家相关字段
        {
          $addFields: {
            "Products._business_id": "$_id",
            "Products.business_name": "$name",
            "Products.location": "$location"
          }
        },
        // 只保留处理后的Products字段，减少冗余
        { $project: { Products: 1, _id: 0 } }
      ],
      as: "matchedProducts"
    }
  },
  // 2. 展开matchedProducts数组，方便后续合并字段
  { $unwind: "$matchedProducts" },
  // 3. 将嵌套的Products字段合并到根文档，简化结构
  { $replaceRoot: { newRoot: { $mergeObjects: ["$$ROOT", "$matchedProducts.Products"] } } },
  // 4. 按用户ID分组，把所有匹配的产品整理成数组，同时保留用户基础信息
  {
    $group: {
      _id: "$_id",
      username: { $first: "$username" },
      mobile_number: { $first: "$mobile_number" },
      profile_url: { $first: "$profile_url" },
      saved_products: { $push: "$$ROOT" }
    }
  },
  // 5. 清理输出字段，确保和预期结构完全一致
  {
    $project: {
      _id: 1,
      username: 1,
      mobile_number: 1,
      profile_url: 1,
      saved_products: {
        _id: 1,
        name: 1,
        tags: 1,
        description: 1,
        lower_price: 1,
        higher_price: 1,
        min_order: 1,
        units: 1,
        media_urls: 1,
        _business_id: 1,
        business_name: 1,
        location: 1
      }
    }
  }
])

各阶段详细说明 #

• $lookup阶段：这是核心，内部管道先处理Business集合的数据——展开Products数组后，用$expr和$in匹配用户的saved_products，然后给产品添加上商家的ID、名称和位置，最后只保留处理后的Products。
• $unwind阶段：把$lookup得到的matchedProducts数组展开，因为每个元素是一个包含单个产品的对象。
• $replaceRoot阶段：将Products的字段合并到根文档，这样后续分组时能直接获取产品的所有信息。
• $group阶段：按用户ID分组，把所有匹配的产品用$push整理成saved_products数组，同时用$first保留用户的基础信息（因为同一用户的这些信息是相同的）。
• $project阶段：最后筛选出需要的字段，确保输出结构和你预期的完全一致，去掉多余的中间字段。

注意事项 #

因为你使用的是MongoDB 3.6，刚好支持$lookup的内部管道功能，所以这个方案完全适用。另外建议确保产品的_id是全局唯一的，避免不同商家出现相同ID的产品导致结果混乱。

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