Mongoose Aggregate聚合管道返回空数组问题求助

问题场景 #

定义了如下Mongoose Schema：

const membershipsSchema = new Schema({
  spaceId: {
    type: Schema.Types.ObjectId,
    ref: 'Space',
  },
  member: {
    type: Schema.Types.ObjectId,
    ref: 'User',
  },
  // 其他字段
});

mongoose.model('Membership', membershipsSchema);

需要实现类似以下SQL的关联查询逻辑：

Select * from membershipPlans as plans join User as users on plans.member=users._id
where plans.spaceId=id and users.status <> 'archived'; -- id为函数传入参数

尝试用Aggregate聚合管道实现，但返回空数组：

const memberships = await Memberships.aggregate([
  {
    $match: {
      spaceId: id
    }
  },
  {
    $lookup: {
      from: 'User',
      localField: 'member',
      foreignField: '_id',
      as: 'users',
    },
  },
  {
    $match: {
      'users.status': {$ne: 'archived'}
    }
  },
]);

甚至仅保留$match阶段的聚合管道也返回空数组，但Memberships.find({ spaceId: id })能正常返回目标数据。

问题原因 #

1. 集合名称错误：Mongoose默认会将模型名转为复数小写作为集合名，比如User模型对应的集合是users，而非User，$lookup中指定的集合名不匹配会导致关联失败。
2. ObjectId类型不兼容：find方法会自动将字符串类型的id转为ObjectId，但聚合管道的$match不会自动转换，若传入的id是字符串，会导致匹配不到数据。
3. 数组匹配逻辑问题：$lookup返回的users是数组，直接用'users.status'进行匹配的逻辑不严谨，需要针对数组结构调整匹配规则。

解决方案 #

1. 修正集合名称 #

将$lookup中的from改为复数小写的正确集合名：

{
  $lookup: {
    from: 'users', // 修正为实际集合名
    localField: 'member',
    foreignField: '_id',
    as: 'users',
  },
}

2. 统一ObjectId类型 #

手动将传入的字符串id转为ObjectId类型：

const mongoose = require('mongoose');
const targetSpaceId = mongoose.Types.ObjectId(id);

3. 修正数组匹配逻辑 #

使用$elemMatch针对数组内元素进行匹配，同时排除无关联用户的记录：

{
  $match: {
    users: {
      $elemMatch: {
        status: { $ne: 'archived' }
      }
    }
  }
}

完整修正代码 #

const mongoose = require('mongoose');
const targetSpaceId = mongoose.Types.ObjectId(id);

const memberships = await Memberships.aggregate([
  {
    $match: {
      spaceId: targetSpaceId
    }
  },
  {
    $lookup: {
      from: 'users',
      localField: 'member',
      foreignField: '_id',
      as: 'users',
    },
  },
  {
    $match: {
      users: {
        $elemMatch: {
          status: { $ne: 'archived' }
        }
      }
    }
  },
]);

替代方案：使用populate简化实现 #

如果不需要复杂聚合逻辑，可直接用Mongoose的populate结合条件筛选，代码更简洁：

const memberships = await Memberships.find({ spaceId: id })
  .populate({
    path: 'member',
    match: { status: { $ne: 'archived' } },
    model: 'User'
  })
  .where('member').ne(null); // 过滤掉无匹配用户的记录

内容的提问来源于stack exchange，提问作者Junaid S.