MongoDB如何通过ObjectID外键跨集合查询关联字段值

使用MongoDB原生聚合管道的$lookup阶段即可完成两个集合的关联查询，无需在应用层遍历集合B逐次查询集合A，单条语句即可输出符合后续统计要求的结构化JSON结果。

核心实现逻辑 #

• 以集合B为左表，通过自身存储的collectionA_id字段，关联集合A的_id主键字段
• 关联完成后裁剪冗余字段，仅保留两个集合中需要的经纬度字段，降低后续统计运算的数据量
• 输出结果为标准JSON结构，可直接对接后续统计逻辑，也可在聚合管道中追加统计阶段直接完成运算

可直接运行的查询语句 #

注意将语句中的collectionA、collectionB替换为你实际业务中的集合名称：

db.collectionB.aggregate([
  // 若collectionA_id存储为字符串、集合A的_id为ObjectId类型，先放开下方阶段做类型转换
  // {
  //   $addFields: {
  //     collectionA_id: { $toObjectId: "$collectionA_id" }
  //   }
  // },
  // 关联集合A
  {
    $lookup: {
      from: "collectionA",
      localField: "collectionA_id",
      foreignField: "_id",
      as: "relatedADoc"
    }
  },
  // 裁剪字段，结构化输出需要的内容
  {
    $project: {
      _id: 1,
      b_lat: "$lat",
      b_lon: "$lon",
      a_lat: { $arrayElemAt: ["$relatedADoc.lat", 0] },
      a_lon: { $arrayElemAt: ["$relatedADoc.lon", 0] }
    }
  }
  // 若需要直接在库内完成统计，可在此处追加$group、$addFields（距离计算）等聚合阶段
])

返回结果格式 #

单条返回结果为标准JSON对象，结构示例如下：

{
  "_id": ObjectId("集合B文档的主键值"),
  "b_lat": 39.9042,
  "b_lon": 116.4074,
  "a_lat": 31.2304,
  "a_lon": 121.4737
}

注意事项 #

• 上述写法适配集合B和集合A为1对1关联的场景（即一个collectionA_id仅对应集合A中一条文档），如果是1对多场景可调整字段拆解逻辑
• 关联前务必确认两个关联字段的类型一致，若类型不统一（比如一个是字符串一个是ObjectId）会出现关联为空的问题，放开语句中注释的类型转换阶段即可解决
• 数据量较大时，建议给集合B的collectionA_id字段、集合A的_id字段建索引，可大幅提升关联查询性能

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