如何使用$lookup聚合查询处理嵌套数组ID？（Mongoose多模型场景）

看起来你已经搞定了Label和Conversations的关联，现在要进一步把Conversations里嵌套的Messages也关联出来对吧？这在MongoDB的聚合里完全可以通过嵌套$lookup来实现，而且有两种比较常用的方式，我给你详细讲讲：

方法一：在Conversations的$lookup中嵌套子管道推荐 #

这种方法最高效，因为它把两次关联合并在一个聚合阶段里，不用额外的展开和分组操作。假设你的Conversations模型里存储Messages ID的字段叫messages（如果不是这个名字，记得替换成实际字段名），代码可以这么写：

const labeledConversationsWithMessages = await Label.aggregate([
  // 第一步：匹配目标Label
  { $match: { _id: mongoose.Types.ObjectId("5abcb74bb59afe4310c60266") } },
  // 第二步：关联Conversations，同时在子管道里关联Messages
  {
    $lookup: {
      from: 'conversations',
      localField: 'conversations',
      foreignField: '_id',
      as: "conversations",
      // 子管道：给每个关联到的Conversation填充对应的Messages
      pipeline: [
        {
          $lookup: {
            from: 'messages',
            localField: 'messages', // 替换成Conversations中存Messages ID的字段名
            foreignField: '_id',
            as: 'messages' // 关联后的Messages会存在这个字段里
          }
        }
      ]
    }
  }
]);

效果说明 #

执行后，你得到的Label文档里，conversations数组中的每个元素都会多出一个messages字段，里面是对应的Message完整文档，结构大概是这样：

[
  {
    _id: "5abcb74bb59afe4310c60266",
    name: 'Archive',
    value: 'archive',
    user: "5abc93a85d3914318cc8d3d7",
    conversations: [
      {
        _id: "xxx",
        // Conversation的其他字段
        messages: [
          { _id: "yyy", content: "xxx", ... }, // 完整的Message文档
          // 更多Message
        ]
      },
      // 更多Conversation
    ]
  }
]

方法二：先展开再关联可选，适合复杂场景 #

如果你的业务逻辑需要对Conversations做更多中间处理，也可以先把conversations数组展开，关联Messages后再重新分组：

const labeledConversationsWithMessages = await Label.aggregate([
  { $match: { _id: mongoose.Types.ObjectId("5abcb74bb59afe4310c60266") } },
  // 展开conversations数组，每个元素单独成文档
  { $unwind: "$conversations" },
  // 关联Conversations文档
  {
    $lookup: {
      from: 'conversations',
      localField: 'conversations',
      foreignField: '_id',
      as: "conversation"
    }
  },
  { $unwind: "$conversation" },
  // 关联Messages到对应的Conversation
  {
    $lookup: {
      from: 'messages',
      localField: 'conversation.messages',
      foreignField: '_id',
      as: "conversation.messages"
    }
  },
  // 重新分组回原来的Label结构
  {
    $group: {
      _id: "$_id",
      name: { $first: "$name" },
      value: { $first: "$value" },
      user: { $first: "$user" },
      conversations: { $push: "$conversation" }
    }
  }
]);

这种方法步骤更多，但灵活性更高，适合需要在中间阶段对单个Conversation做过滤、排序等操作的场景。

需要注意的是，两种方法都要求你的MongoDB版本在3.6及以上（因为用到了$lookup的pipeline参数或者更灵活的聚合操作），如果是旧版本可能需要调整，但现在大部分项目都用的是新版本啦。

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