如何基于条件动态增减MongoDB聚合中的$skip和$limit？

一、Express/代码构建层面（推荐，符合DRY原则） #

核心思路是先定义基础聚合管道数组，再根据options.limit的取值动态追加分页阶段，无需重复编写完整管道。

示例代码：

// 1. 定义基础聚合阶段（不含分页）
const basePipeline = [
  { $match: { status: "active" } }, // 你的匹配条件
  { $sort: { createdAt: -1 } }, // 你的排序规则
  { $lookup: { from: "users", localField: "userId", foreignField: "_id", as: "user" } }, // 关联配置
  { $unwind: "$user" } // 展开配置
];

// 2. 复制基础管道，动态添加分页阶段
const pipeline = [...basePipeline];

// 仅当limit为有效正整数时，追加$skip和$limit
if (options.limit && Number.isInteger(+options.limit) && +options.limit > 0) {
  const skipCount = options.skip ? Math.max(+options.skip, 0) : 0;
  pipeline.push(
    { $skip: skipCount },
    { $limit: +options.limit }
  );
}

// 执行聚合
const result = await db.collection("yourCollection").aggregate(pipeline).toArray();

这种方式完全避免了重复的if/else分支，所有基础逻辑只写一次，分页逻辑按需追加，代码简洁易维护。

二、MongoDB原生聚合层面（适合特殊场景） #

如果需要完全在MongoDB聚合管道内实现动态判断，可以利用MongoDB 5.0+支持的$cond结合$facet功能，将分页与全量结果分开处理后再选择输出：

示例代码：

const pipeline = [
  { $match: { status: "active" } },
  { $sort: { createdAt: -1 } },
  { $lookup: { from: "users", localField: "userId", foreignField: "_id", as: "user" } },
  { $unwind: "$user" },
  // 用$facet拆分分页/全量两个分支
  {
    $facet: {
      paginated: [
        { $skip: options.skip || 0 },
        { $limit: options.limit || 0 }
      ],
      full: [{}] // 空阶段保留全部结果
    }
  },
  // 根据limit值选择输出分支
  {
    $project: {
      data: {
        $cond: {
          if: { $gt: [+options.limit, 0] },
          then: "$paginated",
          else: "$full"
        }
      }
    }
  },
  // 还原结果结构
  { $unwind: "$data" },
  { $replaceRoot: { newRoot: "$data" } }
];

const result = await db.collection("yourCollection").aggregate(pipeline).toArray();

注意：这种方式会先处理全量数据再分支，数据量较大时性能不如代码层面的动态构建，仅推荐在必须完全通过聚合管道实现逻辑的场景使用。

额外注意事项 #

• 务必对options.limit和options.skip做参数校验，确保为非负整数，避免无效参数导致聚合错误；
• 如果业务中存在单独传递skip但无limit的场景，建议统一处理为不启用分页，避免出现无限制跳过数据的情况。

内容的提问来源于stack exchange，提问作者Mr. Kenneth