使用Mongoose Find和Populate跨模型按性别筛选返回空数组问题排查

你的代码返回空数组的核心原因是：Update集合中的trainee字段是指向trainee集合的ObjectId引用，并非嵌套的完整trainee文档，所以直接在Update的查询条件中使用trainee.personalDetails.gender是无效的——MongoDB在Update文档里找不到这个路径的字段。

解决方法 #

方法1：使用聚合管道（推荐，保证分页准确性） #

通过聚合管道先关联trainee集合，再筛选符合gender条件的文档，同时处理分页和排序：

const getUpdates = async (request: any, reply: FastifyReply) => {
  const { coachId }: { coachId: string } = request.user;
  const {
    page,
    limit,
    status,
    escortId,
    gender,
    sort,
  }: {
    page: number;
    limit: number;
    status: string | null;
    escortId: string | null;
    gender: string | null;
    sort?: 'asc' | 'desc';
  } = request.query;

  let coach: CoachType | null;
  try {
    coach = await Coach.findById(coachId);
  } catch (err: Error | any) {
    logger.error(`can't get coach by his id: ${err.message} - ${coachId}`);
    return await replyErr(
      reply,
      500,
      'Getting updates failed, please try again.',
    );
  }

  if (!coach) {
    logger.error(`didn't find coach by his id - ${coachId}`);
    return await replyErr(reply, 404, 'Could not find coach for provided id.');
  }

  const sortDirection = sort === 'asc' ? 1 : -1;
  const aggregatePipeline = [
    // 基础条件匹配
    {
      $match: {
        coach: coachId,
        status: { $regex: status ?? '', $options: 'i' },
        ...(escortId && { escort: escortId })
      }
    },
    // 关联trainee集合
    {
      $lookup: {
        from: 'trainees', // 注意这里要写trainee集合的实际名称（通常是复数形式）
        localField: 'trainee',
        foreignField: '_id',
        as: 'trainee'
      }
    },
    // 过滤gender符合条件的文档
    ...(gender ? [{
      $match: {
        'trainee.personalDetails.gender': { $regex: gender, $options: 'i' }
      }
    }] : []),
    // 将关联的数组转为单个对象（一个Update对应一个trainee）
    { $unwind: '$trainee' },
    // 选择需要返回的字段
    {
      $project: {
        // 保留Update文档的必要字段，根据实际需求调整
        status: 1,
        createdAt: 1,
        escort: 1,
        trainee: {
          name: 1,
          'personalDetails.gender': 1
        }
      }
    },
    // 排序
    { $sort: { createdAt: sortDirection } },
    // 分页
    { $skip: (page - 1) * limit },
    { $limit: limit }
  ];

  let updates: any = [];
  try {
    updates = await Update.aggregate(aggregatePipeline);
  } catch (err: Error | any) {
    logger.error(`can't get updates - ${coachId}`, err);
    return await replyErr(
      reply,
      500,
      'Getting updates failed, please try again.',
    );
  }

  // 后续返回逻辑...
};

方法2：在Populate中添加Match（注意分页准确性问题） #

这种方法先查询符合基础条件的Update文档，再过滤填充的trainee，但会导致分页不准确（因为先取了limit条Update，过滤后可能返回结果少于limit）：

// 修改原代码中的populate部分
updatesQueryPromise = Update.find(query).populate({
  path: 'trainee',
  select: 'name personalDetails.gender',
  // 添加match条件过滤trainee
  match: gender ? { 'personalDetails.gender': { $regex: gender, $options: 'i' } } : {}
});

const sortDirection = sort === 'asc' ? 1 : -1;
// 过滤掉trainee为null的文档（不符合gender条件的会被置为null）
updates = (await updatesQueryPromise
  .skip((page - 1) * limit)
  .limit(limit)
  .sort({ createdAt: sortDirection })).filter(item => item.trainee);

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