NestJS与MongoDB中如何用$cond结合集合首文档实现自定义Keyset分页

错误原因 #

你在find()的查询条件中使用了MongoDB聚合操作符$cond和$first，这是完全错误的用法：

• $cond、$first属于聚合管道专属操作符，只能在aggregate()的管道阶段中使用，无法直接作为find()的查询过滤器。
• 由于MongoDB无法解析无效的查询条件，会直接忽略该过滤规则，因此无论传入什么startId都会返回所有文档。

正确实现方案 #

要实现你的需求，需要先判断传入的startId是否为集合首文档的_id，再根据判断结果构建对应的查询条件，具体步骤如下：

1. 新增获取集合首文档ID的辅助方法

async getFirstUserId(): Promise<string | null> {
  const firstUser = await this.userModel.findOne().sort({ _id: 1 });
  return firstUser?._id.toString() || null;
}

2. 修改分页查询方法

async findAll(
  page?: number,
  documentsToSkip = 0,
  limitOfDocuments?: number,
  startId?: string,
): Promise<UserDocument[]> {
  let queryFilter = {};

  if (startId) {
    const firstUserId = await this.getFirstUserId();
    // 转换为MongoDB ObjectId类型（避免字符串与ObjectId类型不匹配）
    const startObjectId = new this.userModel.schema.Types.ObjectId(startId);
    
    if (startId === firstUserId) {
      queryFilter = { _id: { $gte: startObjectId } };
    } else {
      queryFilter = { _id: { $gt: startObjectId } };
    }
  }

  return this.userModel
    .find(queryFilter)
    .sort({ _id: 1 }) // 键集分页必须依赖稳定排序，这里与获取首文档的排序规则保持一致
    .skip(documentsToSkip)
    .limit(limitOfDocuments);
}

关键注意事项 #

• 稳定排序的必要性：键集分页必须依赖不会产生歧义的排序规则，使用_id排序是最优选择——MongoDB的ObjectId包含时间戳，天然有序且唯一，不会出现排序冲突。
• 类型匹配：如果你的_id是ObjectId类型，必须将传入的字符串startId转换为ObjectId，否则会出现类型不匹配导致的查询失效。
• 扩展场景：如果需要基于其他字段（如createdAt）分页，需同步修改getFirstUserId和查询条件的排序规则，确保首文档判断与分页逻辑的排序一致。

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