MongoDB聚合查询报错：unknown top-level operator: $match 求助

需求说明 #

• 前端传入keyword时，需在MongoDB的title或street字段做正则匹配，结果存入keywordFilterQuery
• 前端传入keyword_features时，需在special_features、facilities或fixtures_fittings字段做正则匹配，结果存入filterQuery
• 最终将filterQuery传入aggregate方法执行聚合查询

问题现象 #

执行时触发错误：

MongoError: unknown top-level operator: $match. If you have a field name that starts with a '$' symbol, consider using $getField or $setField.

但直接将keywordFilterQuery传入聚合查询时能正常返回匹配结果。

原始代码片段 #

if(keyword){
  keywordFilterQuery =   {"$match":{$or: [{title : { $regex: keyword, $options: "i" }},{street : { $regex: keyword, $options: "i" }}],...search}}
} else if(keyword === "" || keyword === undefined || keyword === null) {
  keywordFilterQuery= {search}
}
if(keyword_features){
  filterQuery = {"$match":{$or: [{special_features : {$regex: keyword_features, $options: "i"}}, {facilities : {$regex: keyword_features, $options: "i"}}, {fixtures_fittings : {$regex: keyword_features, $options: "i"}}],...keywordFilterQuery}}   
} 
else if(keyword_features === "" || keyword_features === undefined || keyword_features === null) {
  filterQuery = keywordFilterQuery
}

const results = await model.aggregate([      
  filterQuery
])

问题分析 #

错误根源是嵌套了$match操作符：

1. 当同时传入keyword和keyword_features时，keywordFilterQuery本身是一个包含$match的聚合阶段对象
2. 代码将keywordFilterQuery展开到新的$match条件中，导致最终的filterQuery里，$match的查询条件中出现了另一个$match键
3. MongoDB会把这个嵌套的$match当成字段名，而非聚合操作符，因此抛出错误

修复方案 #

将keywordFilterQuery和filterQuery改为只存储查询条件（不带$match），最后统一包裹成$match阶段传入聚合数组：

1. 去掉所有直接给变量赋值$match的逻辑，只保留查询条件部分
2. 当同时存在keyword和keyword_features时，用$and合并两组查询条件
3. 最终聚合数组中传入完整的$match阶段对象

修复后的代码 #

// 初始化查询条件
let query = {};

// 处理keyword条件
if (keyword) {
  query.$or = [
    { title: { $regex: keyword, $options: "i" } },
    { street: { $regex: keyword, $options: "i" } }
  ];
  // 合并search条件
  Object.assign(query, search);
} else if (keyword === "" || keyword == null) {
  query = { ...search };
}

// 处理keyword_features条件
if (keyword_features) {
  const featureQuery = {
    $or: [
      { special_features: { $regex: keyword_features, $options: "i" } },
      { facilities: { $regex: keyword_features, $options: "i" } },
      { fixtures_fittings: { $regex: keyword_features, $options: "i" } }
    ]
  };
  // 合并已有查询条件，用$and连接
  if (Object.keys(query).length > 0) {
    query = { $and: [query, featureQuery] };
  } else {
    query = featureQuery;
  }
}

// 执行聚合查询，统一包裹$match阶段
const results = await model.aggregate([
  { $match: query }
]);

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