MongoDB聚合$lookup未返回预期结果，请求技术协助

嘿，我来帮你排查一下聚合查询里的问题，其实主要是$lookup的关联字段用错了，还有后续的字段处理逻辑没跟上，导致没得到想要的结果。

你的代码核心错误点 #

• 关联字段匹配错误：你设置的localField: "_id"是把business文档自身的_id和boxes集合的_id做关联，这完全不匹配——你实际需要关联的是business文档中boxes数组里的每个_id，应该用localField: "boxes._id"。
• 未正确处理查询结果：你把$lookup的结果存到了box字段，但后续根本没用到这个字段，反而对原始的boxes数组做了$unwind，这只会把原始的带_id的对象拆分成单独文档，完全没实现替换逻辑。
• $unwind的使用不符合需求：你的目标是保留原business文档结构，替换boxes数组内的内容，而$unwind会把数组拆成多条文档，这和你的期望相悖。

正确的聚合查询写法 #

下面是调整后的代码，能实现你想要的“把business的boxes数组里的_id替换为对应完整boxes文档”的需求：

db.db('database').collection("business").aggregate([
  // 第一步：关联boxes集合，获取所有匹配的完整文档
  {
    $lookup: {
      from: "boxes",
      localField: "boxes._id", // 用business里boxes数组的_id去关联
      foreignField: "_id",     // 关联boxes集合的_id
      as: "matchedBoxes"       // 临时存储匹配到的完整boxes文档
    }
  },
  // 第二步：替换原始的boxes数组
  {
    $addFields: {
      boxes: {
        $map: {
          input: "$boxes", // 遍历原始的boxes数组
          as: "boxRef",
          in: {
            // 从matchedBoxes中筛选出和当前boxRef._id匹配的文档
            $first: {
              $filter: {
                input: "$matchedBoxes",
                cond: { $eq: ["$$this._id", "$$boxRef._id"] }
              }
            }
          }
        }
      }
    }
  },
  // 第三步：移除临时字段，保持结果整洁
  {
    $project: {
      matchedBoxes: 0
    }
  }
]).toArray(function(err, result) {
  if (err) throw err;
  res.send(result);
  db.close();
  res.end();
});

代码逻辑解释 #

1. $lookup阶段：根据business文档中boxes数组里的所有_id，从boxes集合中查询对应的完整文档，把结果存到matchedBoxes临时字段里。
2. $addFields阶段：用$map遍历原始的boxes数组，对每个仅含_id的对象，通过$filter在matchedBoxes中找到匹配的完整文档，再用$first取出唯一的匹配项，替换掉原始数组中的元素。
3. $project阶段：删除临时的matchedBoxes字段，让最终结果只保留你需要的结构。

如果你使用的是MongoDB 3.6及以上版本，还可以用更高效的$lookup嵌套管道写法，避免后续的筛选操作：

db.db('database').collection("business").aggregate([
  {
    $lookup: {
      from: "boxes",
      let: { boxIds: "$boxes._id" }, // 定义变量存储business的boxes_id数组
      pipeline: [
        // 在boxes集合中筛选出_id在boxIds数组里的文档
        { $match: { $expr: { $in: ["$_id", "$$boxIds"] } } }
      ],
      as: "matchedBoxes"
    }
  },
  // 后续的$addFields和$project和上面一致
])

这样调整后，你就能得到期望的结果啦～

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