MongoDB跨集合数据比对：提取相同数据的code键值求助

方法一：聚合管道（高效适配大数据集） #

利用$lookup关联两个集合，匹配相同code的文档，过滤后写入新集合。若需全字段匹配，可添加额外校验条件。

基础版（仅匹配code同时存在于两个集合）

db.Collection1.aggregate([
  {
    $lookup: {
      from: "Collection2",
      localField: "code",
      foreignField: "code",
      as: "matched_docs"
    }
  },
  {
    $match: {
      matched_docs: { $ne: [] }
    }
  },
  // 按需保留需要的字段，_id设为0避免重复写入
  {
    $project: {
      _id: 0,
      code: 1,
      // 添加你需要提取的其他字段，例如：
      name: 1,
      value: 1
    }
  },
  // 写入新集合，这里命名为MatchedCodes
  {
    $out: "MatchedCodes"
  }
])

进阶版（匹配code及其他所有字段完全相同）

如果需要确保两个集合中对应code的所有字段（除_id外）完全一致，修改$match阶段：

db.Collection1.aggregate([
  {
    $lookup: {
      from: "Collection2",
      localField: "code",
      foreignField: "code",
      as: "matched_docs"
    }
  },
  {
    $match: {
      $expr: {
        $and: [
          { $ne: ["$matched_docs", []] },
          // 排除_id后对比整个文档内容
          { $eq: [
              { $mergeObjects: [{ _id: "$$REMOVE" }, "$$ROOT"] },
              { $mergeObjects: [{ _id: "$$REMOVE" }, { $arrayElemAt: ["$matched_docs", 0] }] }
            ]
          }
        ]
      }
    }
  },
  {
    $project: {
      _id: 0,
      code: 1,
      name: 1,
      value: 1
    }
  },
  {
    $out: "MatchedCodes"
  }
])

方法二：遍历查询（适合小数据集） #

如果数据集规模较小，可通过遍历Collection1的文档，在Collection2中查找匹配项后插入新集合：

// 可选：清空目标集合避免重复数据
db.MatchedCodes.deleteMany({})

db.Collection1.find().forEach(doc1 => {
  // 查找Collection2中code相同且字段匹配的文档，按需添加字段条件
  const matchedDoc = db.Collection2.findOne({
    code: doc1.code,
    name: doc1.name,
    value: doc1.value
  })
  
  if (matchedDoc) {
    // 插入需要的字段到新集合
    db.MatchedCodes.insertOne({
      code: doc1.code,
      name: doc1.name,
      value: doc1.value
    })
  }
})

优化建议 #

• 给两个集合的code字段创建索引，大幅提升匹配效率：

  db.Collection1.createIndex({ code: 1 })
  db.Collection2.createIndex({ code: 1 })
  

• 若新集合已存在，$out会直接替换集合数据；若需追加数据，改用$merge阶段替代$out。

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