MongoDB关联查询无结果：ObjectId与非ObjectId字段匹配问题

我有两个MongoDB集合expertKstag和nomenclatureKstag，结构如下：

expertKstag集合文档 #

{
    _id: ObjectId('6244213ec4c8aa000104d5ba'),
    userID: '60a65e6142e3320001cc8178',
    uid: 'klavidal',
    firstName: 'Kevin',
    name: 'Lavidal',
    email: 'kevin.lavidal@xxx.fr',
    expertProfileInProgressList: {},
    expertProfileList: [
        {
            _id: ObjectId('6453abc94e5cd20001596e1c'),
            version: 0,
            language: 'fr',
            isReference: true,
            state: 'PUBLISHED',
            personalDetails: {
                firstName: 'Kevin',
                name: 'Lavidal',
                email: 'kevin.lavidal@xxx.fr',
                isAbesIDFromLdap: false,
                requiredFieldsLeft: false
            },
            professionalStatus: {
                corpsID: '62442223b8fb982305a5bd67',
                lastUpdateDate: ISODate('2023-05-05T08:36:51.327Z')
            }
        }
    ],
    _class: 'fr.ubordeaux.thehub.expertprofilesservice.model.dao.indexed.ExpertIndexed'
}

nomenclatureKstag集合文档 #

{
    _id: ObjectId('62442223b8fb982305a5bd67'),
    type: 'STATUT_CORPS',
    level: 1,
    hasCNU: true,
    labels: [
        {
            language: 'fr',
            text: 'Enseignant-chercheur'
        },
        {
            language: 'en',
            text: 'Teacher-Researcher'
        }
    ],
    isValid: true
}

尝试用以下聚合语句关联expertProfileList.professionalStatus.corpsID和nomenclatureKstag._id，但无结果返回：

db.expertKstag.aggregate([
   {
      $lookup:
         {
           from: "nomenclatureKstag",
           localField: "expertKstag.expertProfileList.professionalStatus.corpsID",
           foreignField: "_id",
           as: "joinresultat"
         }
   },
   {
      $unwind: "$join_resultat"
   },
   {
      $project: {
         "_id": 1,
         "userID": 1,
         "uid": 1,
         "firstName": 1,
         "name": 1,
         "email": 1,
         "join_resultat.isValid": 1
      }
   }
])

问题原因分析 #

你的猜测是正确的，同时还有其他几个关键错误：

• 类型不匹配：corpsID是字符串类型，而nomenclatureKstag._id是ObjectId类型，两者无法直接匹配。
• localField路径错误：localField不需要加上集合名expertKstag.，应该直接写当前集合内的字段路径expertProfileList.professionalStatus.corpsID。
• 字段名不匹配：$lookup的as参数是joinresultat，但后续$unwind使用的是$join_resultat（下划线差异），导致unwind后没有数据。
• 数组字段未处理：expertProfileList是数组，直接用$lookup关联数组内的字段，默认会用整个数组去匹配，无法正确关联到数组中的单个元素。

修正后的聚合语句 #

先处理数组，转换类型后再关联：

db.expertKstag.aggregate([
  // 先展开expertProfileList数组，确保每个元素单独处理
  { $unwind: "$expertProfileList" },
  {
    $lookup: {
      from: "nomenclatureKstag",
      // 将字符串类型的corpsID转换为ObjectId
      let: { corpsIdObj: { $toObjectId: "$expertProfileList.professionalStatus.corpsID" } },
      // 子管道中完成类型匹配
      pipeline: [
        { $match: { $expr: { $eq: ["$_id", "$$corpsIdObj"] } } }
      ],
      as: "joinresultat"
    }
  },
  // 展开关联结果数组
  { $unwind: "$joinresultat" },
  {
    $project: {
      "_id": 1,
      "userID": 1,
      "uid": 1,
      "firstName": 1,
      "name": 1,
      "email": 1,
      "joinresultat.isValid": 1
    }
  }
])

关键修正点说明 #

1. 使用$unwind展开expertProfileList数组，确保数组内每个professionalStatus都能单独参与关联。
2. 通过$toObjectId将字符串类型的corpsID转换为ObjectId，与nomenclatureKstag._id类型统一。
3. 采用$lookup的pipeline模式，在子管道中完成类型转换后的精准匹配，避免直接字段匹配的类型冲突。
4. 统一字段命名：as和后续$unwind使用相同的joinresultat，避免名称不一致导致的数据丢失。

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