MongoDB多集合左关联问题：实现zone与tax文档一一对应

问题根源 #

你的聚合查询仅通过user_id关联两个集合，这会导致每个est_zone文档匹配所有同user_id的est_tax文档，形成笛卡尔积，自然无法实现tempo1对应fam1、tempo2对应fam2的一一配对。

核心思路 #

要实现这种配对，必须给每一组对应的est_zone和est_tax文档添加一个共同的关联标识（比如sequence序号字段），用来明确指定哪条est_zone对应哪条est_tax。

步骤1：修改数据插入逻辑，添加关联标识 #

更新插入语句，为每组配对的文档添加相同的sequence值：

插入用户文档 #

db.user.insertOne({ user_id: "id_user_1" })

插入第一组配对文档 #

db.est_zone.insertOne({
  zone: { temp: "tempo1" },
  user_id: "id_user_1",
  sequence: 1 // 第一组标识
})

db.est_tax.insertOne({
  tax: { fam: "fam1" },
  user_id: "id_user_1",
  sequence: 1 // 与对应est_zone同标识
})

插入第二组配对文档 #

db.est_zone.insertOne({
  zone: { temp: "tempo2" },
  user_id: "id_user_1",
  sequence: 2 // 第二组标识
})

db.est_tax.insertOne({
  tax: { fam: "fam2" },
  user_id: "id_user_1",
  sequence: 2 // 与对应est_zone同标识
})

步骤2：修改聚合查询，实现精准配对 #

调整聚合流程，先关联est_zone，再用est_zone中的sequence字段关联对应的est_tax文档：

db.user.aggregate([
  { $match: { user_id: "id_user_1" } },
  // 关联est_zone并展开
  {
    $lookup: {
      from: "est_zone",
      localField: "user_id",
      foreignField: "user_id",
      as: "est_zone"
    }
  },
  { $unwind: "$est_zone" },
  // 基于user_id+sequence关联对应的est_tax
  {
    $lookup: {
      from: "est_tax",
      let: {
        userId: "$user_id",
        seq: "$est_zone.sequence"
      },
      pipeline: [
        {
          $match: {
            $expr: {
              $and: [
                { $eq: ["$user_id", "$$userId"] },
                { $eq: ["$sequence", "$$seq"] }
              ]
            }
          }
        }
      ],
      as: "est_tax"
    }
  },
  // 展开est_tax数组（因为匹配的是单个文档，展开后为对象）
  { $unwind: "$est_tax" },
  // 可选：整理输出字段，去掉冗余
  {
    $project: {
      _id: 0,
      user_id: 1,
      zone_temp: "$est_zone.zone.temp",
      tax_fam: "$est_tax.tax.fam"
    }
  }
])

替代方案（不修改现有数据） #

如果无法修改已插入的数据，可尝试依赖文档插入顺序（通过_id的时间戳排序）来配对，但这种方式不推荐，因为插入顺序可能因集群部署、写入并发等因素出现偏差：

db.user.aggregate([
  { $match: { user_id: "id_user_1" } },
  {
    $lookup: {
      from: "est_zone",
      localField: "user_id",
      foreignField: "user_id",
      as: "est_zone"
    }
  },
  { $unwind: "$est_zone" },
  // 先获取当前user_id下的所有est_tax并按_id排序
  {
    $lookup: {
      from: "est_tax",
      localField: "user_id",
      foreignField: "user_id",
      as: "all_tax"
    }
  },
  // 给est_zone按_id排序并添加索引，通过索引匹配对应位置的est_tax
  {
    $set: {
      est_zones_sorted: {
        $sortArray: { input: "$est_zone", sortBy: { _id: 1 } }
      },
      est_taxes_sorted: {
        $sortArray: { input: "$all_tax", sortBy: { _id: 1 } }
      }
    }
  },
  { $unwind: { path: "$est_zones_sorted", includeArrayIndex: "index" } },
  {
    $set: {
      est_tax: { $arrayElemAt: ["$est_taxes_sorted", "$index"] }
    }
  },
  {
    $project: {
      _id: 0,
      user_id: 1,
      zone_temp: "$est_zones_sorted.zone.temp",
      tax_fam: "$est_tax.tax.fam"
    }
  }
])

最终效果 #

执行推荐的聚合查询后，会得到符合预期的结果：

[
  { "user_id": "id_user_1", "zone_temp": "tempo1", "tax_fam": "fam1" },
  { "user_id": "id_user_1", "zone_temp": "tempo2", "tax_fam": "fam2" }
]

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