MongoDB中以Policy集合为起点关联Person集合的实现求助

本人熟悉SQL，现需进行MongoDB转换工作。拥有Policy与Person两个集合，其中Policy集合的Persons字段以Person集合的_id作为键存储。尝试过$locate、$let、$convert等操作，仍无法实现以Policy为起点的两集合关联，恳请技术协助。

Policy集合示例 #

[{
    "_id": {
        "$oid": "61169375e2145bbfd73dedbe"
    },
    
    "PolicyNumber": {
        "Identifier": "A56B096A",
        "Sequence": 1
    },
    
    "Persons": {
        "61169362982ac4e8ae2ad768": null,
        "60de07a8dc031e91ac5f35c0": null
    }
}]

Person集合示例 #

[{
  "_id": {
    "$oid": "5f0c6d087937e0000145e5c3"
  },
  "UniqueCode": "PER0004",
  "PassportExpiryDate": null,
  "Age": 35,
  "Gender": "M",
  "Nationality": null,
  "LanguageCode": null,
  "Name": "NAME",
  "Surname": "SURNAME",
  "Initials": null,
  "ContactDetails": {
    "Addresses": {
      "physicalAddress": {
        "AddressType": null,
        "UnitNumber": null,
        "UnitName": null,
        "PoBox": null,
        "StreetNumber": null,
        "StreetName": null,
        "Suburb": null,
        "Town": null,
        "PostalCode": "7100",
        "Country": null,
        "Coordinates": null,
        "InitialCenter": null
      }
    },
    "EmailAddresses": {
      "emailAddress": "EMAIL@EMAIL.COM"
    },
    "TelephoneNumbers": {
      "cellphone": "0000000000"
    },
    "PreferredCommunicationMethod": "SMS"
  },
  "BankingDetails": [],
  "Statistics": null,
  "Imported": false,
  "ImportReference": null
}]

Policy集合的Persons字段是动态键值对（键为Person的_id字符串），常规$lookup无法直接匹配，需先将对象转成数组再关联，具体聚合步骤如下：

1. Persons对象转数组：用$objectToArray把Persons的键值对转成包含k（Person的_id字符串）和v（值）的数组。
2. 关联Person集合：通过$lookup子管道，将字符串id转为ObjectId类型后匹配Person集合的_id。
3. 整理输出结果：按需保留或清理字段，也可将关联数据映射回原键结构。

基础关联查询代码 #

db.Policy.aggregate([
  // 把Persons对象转为数组，提取id列表
  {
    $addFields: {
      personIds: { $objectToArray: "$Persons" }
    }
  },
  // 关联Person集合，匹配id
  {
    $lookup: {
      from: "Person",
      let: { ids: "$personIds.k" },
      pipeline: [
        {
          $match: {
            $expr: {
              $in: [ { $toString: "$_id" }, "$$ids" ]
            }
          }
        }
      ],
      as: "relatedPersons"
    }
  },
  // 清理临时字段，保留核心数据
  {
    $project: {
      _id: 1,
      PolicyNumber: 1,
      relatedPersons: 1
      // 需保留原Persons字段可添加Persons:1
    }
  }
])

代码说明 #

• $objectToArray：将Persons对象转换为[{k: "xxx", v: null}, ...]格式的数组，方便提取id列表。
• $lookup子管道：用$toString把Person的ObjectId类型_id转为字符串，再通过$in判断是否在Policy的id列表中，实现精准匹配。

进阶：保留原键结构的关联结果 #

如果需要将关联后的Person数据与原Persons的键对应，可在$project前添加以下阶段：

{
  $addFields: {
    personsWithDetails: {
      $arrayToObject: {
        $map: {
          input: "$personIds",
          as: "item",
          in: {
            k: "$$item.k",
            v: {
              $first: {
                $filter: {
                  input: "$relatedPersons",
                  cond: { $eq: [ { $toString: "$$this._id" }, "$$item.k" ] }
                }
              }
            }
          }
        }
      }
    }
  }
}

此步骤会生成personsWithDetails字段，键为原Person id，值为对应的完整Person文档。

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