Mongoose如何通过用户ID查找文档数组中的对应Organization

我有一个包含文档数组的Organization文档，想在不知道主文档_id的情况下，通过Member文档关联的User的ID找到对应的Organization。

相关Schema定义如下：

Organization Schema #

const organizationSchema = new Schema({
  name: { type: String, required: true, unique: true },
  members: {
   type: [{ type: Schema.Types.ObjectId, ref: "Member" }],
   default: [],
  }
 });

Member Schema #

const memberSchema = new Schema({
 user: {
   type: Schema.Types.ObjectId,
   ref: "User",
   required: true,
 },
 status: { type: String, enum: Status, required: true },
});

我尝试用aggregate查询，但返回空数组，代码如下：

const existingOrganization = await Organization.aggregate([
  {
    $match: { "members.user._id": objectId },
  },
  {
    $unwind: "$members",
  },
]);

数据库返回的文档示例（已populate members）：

[
{
    "_id": "63376128758f036eafa9277f",
    "name": "test",
    "email": "test@test.com",
    "members": [
        {
            "_id": "63376128758f036eafa9277e",
            "user": {
                "_id": "63067438faa89240f4371f6e",
                "email": "test2@test.com",
            },
            "status": "Accepted",
            "__v": 0
        }
    ],
    "__v": 0
}
]

你的查询失败有两个核心原因：

1. 查询顺序错误：先执行$match时，members还是未展开的ObjectId数组，根本不存在members.user._id字段，自然匹配不到结果。
2. 未关联Member集合：Organization的members字段存的是Member的ObjectId引用，不是内嵌的完整Member文档（你提供的示例是populate后的结果，不是数据库原始存储内容），所以直接查询members.user._id在原始数据里无效。

针对需求，有两种可行实现方式：

方式一：用Aggregate关联Member集合 #

通过$lookup关联Member集合，再匹配User的ID，代码如下：

const existingOrganization = await Organization.aggregate([
  // 先展开members数组
  { $unwind: "$members" },
  // 关联Member集合，获取完整Member文档
  {
    $lookup: {
      from: "members", // Member集合名称（mongoose会自动转小写加复数）
      localField: "members",
      foreignField: "_id",
      as: "memberDetail"
    }
  },
  // 展开关联后的memberDetail数组
  { $unwind: "$memberDetail" },
  // 匹配目标User的ID
  { $match: { "memberDetail.user": objectId } },
  // 可选：清理结果，保留需要的字段
  {
    $project: {
      name: 1,
      email: 1,
      members: 1,
      _id: 1
    }
  }
]);

方式二：用Mongoose的populate + 匹配（更简洁） #

借助Mongoose链式调用，先populate members再过滤：

const existingOrganization = await Organization.find()
  .populate({
    path: "members",
    match: { user: objectId },
    select: "status user" // 可选：指定返回的Member字段
  })
  // 过滤掉没有匹配到目标User的组织
  .where("members").ne([]);

补充说明 #

如果你的数据库原始存储就是直接内嵌完整Member文档（和Schema定义不符，但和你提供的示例一致），那只需调整查询顺序即可：

const existingOrganization = await Organization.aggregate([
  { $unwind: "$members" },
  { $match: { "members.user._id": objectId } }
]);

但按照Schema设计，更推荐前两种方式。

内容的提问来源于stack exchange，提问作者Luis Daniel Cova