如何复制MongoDB集合主键到同库另一集合并使用$lookup关联查询

整个操作分两步完成，先批量给目标集合写入关联用的_id2字段，再执行$lookup关联查询。

1. 批量写入_id2字段 #

首先你需要确认两个集合之间的一一匹配规则：MongoDB 没有固定的文档存储顺序，不能靠插入顺序对应文档，必须通过两个集合共有的唯一业务字段（比如订单号、用户ID这类唯一标识）做匹配，避免主键写入错位。
执行以下批量更新命令，注意替换命令里的集合名、匹配字段名为你实际业务的字段：

// 替换target_collection为你的目标集合名（要写入_id2的集合）
db.target_collection.updateMany(
  // 过滤条件：只处理还没写入_id2的文档，重复执行不会覆盖已有数据
  { _id2: { $exists: false } },
  [
    {
      $lookup: {
        from: "source_collection", // 替换为你的源集合名（主键所在的第一个集合）
        localField: "your_match_field", // 替换为目标集合里用来和源集合匹配的唯一业务字段
        foreignField: "your_match_field", // 替换为源集合里对应的同名字段
        as: "temp_source_doc"
      }
    },
    {
      $set: {
        // 提取匹配到的源文档主键，写入_id2字段
        _id2: { $first: "$temp_source_doc._id" }
      }
    },
    // 删除临时关联生成的冗余字段
    { $unset: "temp_source_doc" }
  ]
)

参考截图：

• 待复制主键的源集合：
  
• 待写入_id2字段的目标集合：
  

2. 执行$lookup关联查询 #

等批量更新完成、所有目标集合文档都写入正确的_id2字段后，就可以直接执行关联查询，合并两个集合的数据，示例聚合语句如下：

db.target_collection.aggregate([
  {
    $lookup: {
      from: "source_collection",
      localField: "_id2", // 目标集合上一步写入的关联字段
      foreignField: "_id", // 源集合的主键字段
      as: "source_join_data" // 关联出来的源集合数据存在这个字段下
    }
  }
  // 后续可以按需追加$match、$project、$unwind等其他聚合阶段处理结果
])

注意事项 #

• 批量更新前建议先在测试环境验证匹配逻辑，确认_id2取值正确后再操作生产数据
• 如果后续有新增的目标集合文档，需要补跑上述更新逻辑写入_id2，否则新增文档无法关联到源集合数据

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