MongoDB聚合查询问题：商品搜索与分类筛选失效排查

核心问题分析 #

1. $match逻辑错误：原代码用$or将分类筛选条件和搜索+未删除条件并列，导致只要满足其中一个就会返回，而非同时满足「分类+（搜索/无搜索）+未删除」的预期逻辑。
2. 数组字段匹配错误：$lookup返回的category是数组类型，直接用"category.name": categoryQry无法正确匹配数组内对象的name字段。
3. 全局条件缺失：isDeleted: false应该作为所有查询的基础条件，而非仅和搜索条件绑定。
4. 异步代码冗余：同时使用await和then/catch，导致代码嵌套且冗余。

修正后的代码 #

export const getTestProduct = async (req, res) => {
  try {
    const { search, category } = req.query;
    // 构建基础查询条件：仅返回未删除商品
    let matchConditions = { isDeleted: false };

    // 处理搜索条件
    if (search) {
      matchConditions.$or = [
        { name: { $regex: search, $options: "i" } },
        { description: { $regex: search, $options: "i" } }
      ];
    }

    // 处理分类筛选条件
    if (category) {
      // 匹配category数组中存在name等于目标值的项
      matchConditions["category.name"] = { $eq: category };
      // 若需更严谨的数组匹配，可改用：matchConditions.category = { $elemMatch: { name: category } }
    }

    const products = await productModel.aggregate([
      {
        $lookup: {
          from: "categories",
          localField: "category",
          foreignField: "_id",
          as: "category"
        }
      },
      { $match: matchConditions }
    ]);

    res.status(200).json({
      products,
      message: "product fetched",
      Total: products.length,
      status: true
    });
  } catch (error) {
    res.status(error.status || 500).json({
      message: error.message,
      status: false
    });
  }
};

关键改动说明 #

• 统一查询条件构建：先初始化基础条件isDeleted: false，再根据参数逐步添加搜索、分类条件，MongoDB对象内的多个条件默认是「与」关系，符合预期逻辑。
• 正确匹配数组字段：针对$lookup返回的数组，直接通过"category.name": { $eq: category }匹配数组内对象的name属性，MongoDB会自动遍历数组查找匹配项。
• 简化异步逻辑：移除冗余的then/catch，统一使用try/catch处理异步错误，代码更简洁易维护。
• 性能优化建议：如果商品数据量较大，建议先通过categories集合查询到对应分类的_id，再在products集合的$match阶段先过滤category字段等于该_id，再执行$lookup，减少关联的数据量：

  // 性能优化版：先查分类ID再过滤商品
  if (category) {
    const targetCategory = await categoryModel.findOne({ name: category });
    if (targetCategory) {
      matchConditions.category = targetCategory._id;
    } else {
      return res.status(200).json({ products: [], message: "category not found", Total: 0, status: true });
    }
  }
  // 聚合管道调整为先$match再$lookup
  const products = await productModel.aggregate([
    { $match: matchConditions },
    { $lookup: { /* 原lookup配置 */ } }
  ]);
  

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