MongoDB低版本中$lookup结合pipeline与关联字段报错的解决方法

问题原因 #

低版本MongoDB（4.2及之前）的$lookup不允许同时指定localField/foreignField和pipeline参数，必须将关联逻辑完全移到pipeline内部实现。

修改后的查询语句 #

db.Products.aggregate([
  {
    $lookup: {
      from: "Products_History",
      as: "joins",
      pipeline: [
        {
          $match: {
            $expr: { $eq: ["$_fid", "$$ROOT._fid"] }
          }
        },
        {
          $sort: { "date": -1 }
        },
        {
          $limit: 1 // 直接只取最新的一条，优化性能
        }
      ]
    }
  },
  {
    $project: {
      "_fid": 1,
      "field1": 1,
      "field2": 1,
      "field3": 1,
      "last_version": { $arrayElemAt: ["$joins.version", 0] }
    }
  },
  {
    $match: {
      "last_version": { $exists: true, $ne: null }
    }
  }
])

关键修改点 #

• 移除$lookup中的localField和foreignField，改用$match + $expr在子管道内关联主集合的_fid（通过$$ROOT._fid引用主文档字段）
• 在子管道中添加$limit:1，直接只保留最新的历史记录，避免后续处理整个数组，提升查询效率
• 使用$arrayElemAt替代$first，更直观地获取数组中第一个元素的version字段
• 优化$match条件，同时判断last_version存在且不为空，过滤无匹配历史记录的文档

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