MongoDB聚合pipeline中如何对lookup返回数组内userId执行关联查询

你只需要在原有关联评价的子聚合流水线中，新增关联用户的逻辑即可，修改后的完整聚合代码如下：

Property.aggregate([
  { $match: { _id: ObjectId(propertyId) } },
  {
    $lookup: {
      from: 'propertytestimonials',
      let: { propPropertyId: '$_id' },
      pipeline: [
        {
          $match: {
            $expr: {
              $eq: ['$propertyId', '$$propPropertyId']
            },
          },
        },
        // 关联对应用户信息
        {
          $lookup: {
            from: 'users', // 替换为你的用户集合实际名称
            localField: 'userId',
            foreignField: '_id',
            as: 'user'
          }
        },
        // 将user数组转为单个对象（每个评价仅对应一个用户）
        {
          $unwind: '$user'
        }
      ],
      as: 'testimonials',
    },
  },
]) 

逻辑说明 #

修改的核心是在查询评价的子流水线中嵌套了用户关联逻辑：

• 先通过$lookup用评价的userId匹配用户集合的_id，查询结果默认以数组形式存在user字段
• 再通过$unwind把只有单元素的user数组转为对象格式，正好匹配你需要的返回结构

补充说明 #

• 如果你的用户集合自定义过名称，需要把$lookup的from参数改成你实际的集合名，Mongoose默认会将模型名转为小写复数作为集合名，比如User模型对应users集合
• 你之前示例返回的评价内容字段是message，但Testimonial Schema中定义的字段是testimonial，请根据你的实际业务字段调整对应取值
• 如果需要保留没有匹配到用户的评价，可以将$unwind阶段修改为以下配置，匹配不到用户时user字段会返回null：

  {
    $unwind: {
      path: '$user',
      preserveNullAndEmptyArrays: true
    }
  }
  

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