MongoDB聚合中如何条件应用$match实现多字段搜索并统计总数

问题背景 #

我有一个展示产品的服务，需要按productName、barcode或sku字段搜索产品，之前用find方法实现的代码如下：

const query: FilterQuery<TProductSchema> = {};

if (search) {
  query.$or = [
    {
      productName: {
        $regex: String(search).split(' ').join('|'),
        $options: 'i',
      },
    },
    {
      barcode: {
        $regex: String(search),
        $options: 'i',
      },
    },
    { sku: { $regex: String(search).split(' ').join('|'), $options: 'i' } },
  ];
}

if (folderId && folderId !== 'all') {
  query.folder = { _id: folderId };
}

const products = await ProductModel.find<HydratedDocument<TProductSchema>>(query)
  .limit(Number(limit) === -1 ? 0 : Number(limit))
  .skip(Number(page) * Number(limit));

现在需要在返回结果中包含符合条件的文档总数（总数会随选中的folderId变化），尝试用聚合框架实现时，想在search参数存在时才条件性应用$match，但写的代码报错：

const products = await ProductModel.aggregate([
  { $match: {/* match folder */ },
  { /* count matched documents */ },
  // next search documents IF `search` is present
  {
    $match: {
      $cond: [search, /* here goes `query` object, '']
    }
  },
]);

报错信息：unknown top level operator "$cond"

解决方案 #

1. 核心问题说明 #

MongoDB的$match阶段不支持将$cond作为顶级操作符，$match只能接收标准的查询条件对象。条件性添加匹配逻辑，应该在代码层面动态构建聚合管道，而不是在聚合阶段内部用条件表达式。

2. 同时获取总数和分页数据的完整实现 #

要同时拿到符合条件的总文档数和分页后的产品列表，推荐用$facet阶段——它允许在一个聚合中并行执行多个子管道，分别返回总数统计和分页结果，效率更高。

完整代码如下：

// 初始化聚合管道数组
const pipeline: any[] = [];

// 第一步：先添加folder匹配条件（如果有）
if (folderId && folderId !== 'all') {
  pipeline.push({
    $match: {
      'folder._id': folderId
    }
  });
}

// 第二步：用$facet分两个子管道，分别处理总数统计和搜索分页
pipeline.push({
  $facet: {
    totalCount: [{ $count: 'count' }],
    products: [
      // 条件性添加搜索匹配阶段：只有search存在时才加入
      ...(search ? [{
        $match: {
          $or: [
            {
              productName: {
                $regex: String(search).split(' ').join('|'),
                $options: 'i'
              }
            },
            {
              barcode: {
                $regex: String(search),
                $options: 'i'
              }
            },
            {
              sku: {
                $regex: String(search).split(' ').join('|'),
                $options: 'i'
              }
            }
          ]
        }
      }] : []),
      // 执行分页逻辑
      { $skip: Number(page) * Number(limit) },
      { $limit: Number(limit) === -1 ? 0 : Number(limit) }
    ]
  }
});

// 执行聚合查询
const result = await ProductModel.aggregate(pipeline);

// 解析结果：处理空数据的边界情况
const total = result[0].totalCount[0]?.count || 0;
const products = result[0].products;

// 最终返回结构示例
// return { total, products };

关键细节 #

• 动态管道构建：通过数组展开语法...(search ? [...] : [])，在search参数存在时才将搜索匹配的$match阶段加入到products子管道中，实现条件性匹配。
• $facet的优势：totalCount子管道负责统计当前筛选条件下的总文档数，products子管道负责处理搜索和分页，两个子管道并行执行，避免了多次查询数据库。
• 边界处理：当没有匹配到文档时，totalCount会返回空数组，所以用|| 0兜底保证总数为0。

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