MongoDB populate匹配后移除关联数据为空的文档

问题场景 #

使用Mongoose的populate对关联的attachments字段按type: 2过滤后，不符合条件的主文档仍被保留，仅attachments字段为空数组，需要直接移除这些无有效关联数据的文档。

当前populate配置：

"populate": [
    {
        "path": "attachments",
        "select": "_id type",
        "match": {
            "type": {
                "$in": [2]
            }
        }
    }
]

原始数据、当前结果及期望结果如下：

原始未过滤数据 #

[
  {
   _id : "6e43454gvbnbvb7888",
   name: "T1",
   attachments :{
         _id : "6errtfhg6757876898",
         type : 2
   }
  },
  {
   _id : "6e43454gvbnbvb7888",
   name: "T1",
   attachments :{
         _id : "6errtfhg6757876898",
         type : 1
   }
  }
]

当前执行结果 #

[
  {
   _id : "6e43454gvbnbvb7888",
   name: "T1",
   attachments :[{
         _id : "6errtfhg6757876898",
         type : 2
   }]
  },
  {
   _id : "6e43454gvbnbvb7888",
   name: "T1",
   attachments :[]
  }
]

期望结果 #

[
  {
   _id : "6e43454gvbnbvb7888",
   name: "T1",
   attachments :{
         _id : "6errtfhg6757876898",
         type : 2
   }
  }
]

当前查询通过以下代码执行：

return new Promise((resolve, reject) => {
      model.paginate(query, options, (err, data) => {
          if (err) reject(err);
          else resolve(data);
      });
});

解决方案 #

方案1：使用聚合管道（推荐，数据库层面过滤） #

用$lookup替代populate，在聚合阶段同时完成关联过滤和主文档过滤，性能更优：

model.aggregate([
  // 关联并过滤attachments
  {
    $lookup: {
      from: "attachments", // 替换为你的attachments集合名称
      localField: "attachments",
      foreignField: "_id",
      as: "attachments",
      pipeline: [
        { $match: { type: { $in: [2] } } },
        { $project: { _id: 1, type: 1 } }
      ]
    }
  },
  // 过滤掉attachments为空的文档
  { $match: { attachments: { $ne: [] } } },
  // 分页处理（根据实际page和limit参数调整）
  { $skip: (page - 1) * limit },
  { $limit: limit }
])
.then(data => resolve(data))
.catch(err => reject(err));

方案2：查询后内存过滤（简单直接） #

如果不想修改查询方式，可在paginate返回结果后手动过滤空文档：

return new Promise((resolve, reject) => {
  model.paginate(query, options, (err, data) => {
    if (err) reject(err);
    else {
      // 过滤掉attachments为空的文档
      data.docs = data.docs.filter(doc => doc.attachments.length > 0);
      // 可选：更新分页的total计数
      data.total = data.docs.length;
      resolve(data);
    }
  });
});

说明 #

• 方案1在数据库层面完成所有过滤，适合数据量较大的场景，避免内存中处理大量数据。
• 方案2实现简单，适合数据量较小的场景，无需修改原有查询结构。

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