Mongoose同一集合双查询合并：如何实现类SQL JOIN单查询？

完全不用分两次查询——在Mongoose里，你可以借助**聚合管道（Aggregation Pipeline）**的$lookup阶段，实现类似SQL JOIN的单查询关联逻辑，不管是关联同一集合还是不同集合的文档都适用。

下面给你举几个贴合需求的实际例子：

场景1：同一集合内按字段关联其他文档 #

假设你的集合是users，每个文档结构如下：

{
  _id: ObjectId("60d21b4667d0d8992e610c85"),
  username: "Ozan",
  teamId: "team_001",
  createdAt: ISODate("2021-06-23T12:00:00Z")
}

需求是：先找到用户Ozan的文档，再获取同一teamId下的所有其他用户。

对应的Mongoose聚合查询写法：

const teamMembers = await User.aggregate([
  // 第一步：定位到目标用户Ozan
  { $match: { username: "Ozan" } },
  // 第二步：关联同一集合中同teamId的所有用户
  {
    $lookup: {
      from: "users", // 因为是同一集合，填自己的集合名
      localField: "teamId", // 当前文档用来匹配的字段
      foreignField: "teamId", // 关联文档中对应的匹配字段
      as: "sameTeamUsers" // 结果会存在这个数组字段里
    }
  },
  // 可选：过滤掉用户自己，只保留同组的其他成员
  {
    $project: {
      username: 1,
      teamId: 1,
      sameTeamUsers: {
        $filter: {
          input: "$sameTeamUsers",
          cond: { $ne: ["$$this._id", "$_id"] } // 排除自己的文档
        }
      }
    }
  }
]);

场景2：更复杂的自定义关联条件 #

如果需要基于目标用户的多个字段做匹配（比如找同组且注册时间晚于Ozan的用户），可以用$lookup的let和pipeline参数自定义子查询逻辑：

const lateTeamMembers = await User.aggregate([
  { $match: { username: "Ozan" } },
  {
    $lookup: {
      from: "users",
      // 把当前文档的字段传递给子查询
      let: { targetTeamId: "$teamId", targetCreateTime: "$createdAt" },
      // 子查询管道，自定义匹配规则
      pipeline: [
        {
          $match: {
            $expr: {
              $and: [
                { $eq: ["$teamId", "$$targetTeamId"] }, // 同teamId
                { $gt: ["$createdAt", "$$targetCreateTime"] }, // 注册时间更晚
                { $ne: ["$_id", "$_id"] } // 排除自己
              ]
            }
          }
        },
        // 还可以在子查询里加排序、投影等操作
        { $sort: { createdAt: 1 } }
      ],
      as: "latecomersInTeam"
    }
  }
]);

关键说明 #

• $lookup相当于SQL的左外连接，会把匹配到的文档以数组形式返回
• 整个逻辑都在一个聚合查询里完成，避免了两次查询的网络开销和异步等待
• Mongoose的模型直接支持aggregate()方法，和普通查询一样可以用async/await处理结果

内容的提问来源于stack exchange，提问作者Ozan Ertürk