MongoDB多集合聚合查询：获取关联用户数据的最佳方案咨询

针对你提供的四个集合结构，以下是使用aggregate管道实现预期结果的最优方案，能解决之前find/findOne偶尔返回空结果的问题：

核心聚合管道代码 #

db.user.aggregate([
  // 匹配目标用户（如需批量查询可调整或移除该阶段）
  { $match: { id: '123' } },
  // 关联cities集合，将city_id转换为城市名称数组
  {
    $lookup: {
      from: 'cities',
      localField: 'cities',
      foreignField: 'city_id',
      as: 'city_details'
    }
  },
  // 提取city_name并替换原cities字段
  {
    $project: {
      _id: 0,
      user_id: '$id',
      name: 1,
      cities: '$city_details.city_name',
      services: 1,
      email: 1
    }
  },
  // 关联prices集合，获取当前用户的所有价格记录
  {
    $lookup: {
      from: 'prices',
      localField: 'user_id',
      foreignField: 'user_id',
      as: 'prices'
    }
  },
  // 关联services集合，为每条价格记录补充服务名称
  {
    $lookup: {
      from: 'services',
      localField: 'prices.service_id',
      foreignField: 'service_id',
      as: 'service_details'
    }
  },
  // 合并价格与服务信息，匹配对应关系
  {
    $project: {
      user_id: 1,
      name: 1,
      cities: 1,
      email: 1,
      prices: {
        $map: {
          input: '$prices',
          as: 'price',
          in: {
            $mergeObjects: [
              '$$price',
              {
                $arrayElemAt: [
                  '$service_details',
                  { $indexOfArray: ['$service_details.service_id', '$$price.service_id'] }
                ]
              }
            ]
          }
        }
      }
    }
  },
  // 过滤冗余字段，保留预期输出结构
  {
    $project: {
      user_id: 1,
      name: 1,
      cities: 1,
      email: 1,
      prices: {
        $map: {
          input: '$prices',
          as: 'p',
          in: {
            service_name: '$$p.service_name',
            price: '$$p.price'
          }
        }
      }
    }
  }
])

方案优势 #

1. 原子性保障：所有关联逻辑在数据库端一次性完成，避免客户端多次查询引发的异步数据不一致问题（这也是你之前偶尔得到空结果的核心原因）。
2. 分步清晰：按「用户筛选→城市名称转换→价格关联→服务名称补充→结构整理」的顺序处理，逻辑直观易维护。
3. 扩展性强：若需批量查询用户，只需修改或移除$match阶段，其余管道逻辑无需大幅调整。

内容的提问来源于stack exchange，提问作者Hakan Akkaş