MongoDB聚合$lookup关联返回空数组及ObjectId转换报错问题

问题分析 #

你遇到的三个核心问题原因如下：

1. $eq: ["$$reserveData", "$_id"]返回空数组：$$reserveData是字符串类型，而reserves集合的_id是ObjectId类型，类型不匹配导致无法匹配到数据。
2. new mongoose.Types.ObjectId("$$reserveData")报错：new mongoose.Types.ObjectId()是Node.js端执行的代码，此时$$reserveData只是字面量字符串，不是聚合管道中的变量，直接传入会因不符合ObjectId格式报错。
3. $toObjectId/$toString报错：大概率是$$reserveData的值不是有效的24位十六进制ObjectId字符串，或者在聚合管道中的语法使用错误。

解决方案 #

根据reserve字段的存储类型，选择以下对应写法：

情况1：reserve字段存储的是字符串类型的ObjectId #

在聚合管道内使用MongoDB原生的$toObjectId操作符，将字符串转换为ObjectId后再对比：

aggregate([
   {
     $unwind: {
        path: "$reserve",
        preserveNullAndEmptyArrays: true
    }
   },
   {
     $lookup: {
       from: "reserves",
       let: { reserveData: "$reserve" },
       pipeline: [
         {
           $match: {
             $expr: {
               $eq: [ { $toObjectId: "$$reserveData" }, "$_id" ]
             }
           }
         }
       ],
       as: "reserve"
     }
   }
])

情况2：reserve字段存储的是ObjectId类型 #

直接对比即可，但需确保原集合中reserve数组的元素确实是ObjectId而非字符串：

aggregate([
   {
     $unwind: {
        path: "$reserve",
        preserveNullAndEmptyArrays: true
    }
   },
   {
     $lookup: {
       from: "reserves",
       let: { reserveData: "$reserve" },
       pipeline: [
         {
           $match: {
             $expr: {
               $eq: [ "$$reserveData", "$_id" ]
             }
           }
         }
       ],
       as: "reserve"
     }
   }
])

额外检查点 #

• 确认原文档的reserve数组中存在有效的值，且格式符合ObjectId要求（24位十六进制字符串）。
• 若使用$toObjectId仍报错，先通过$project阶段输出$$reserveData的值，验证其是否为有效的ObjectId字符串。

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