mongodb - 将 $lookup 结果合并到现有数组

Question

我是 mongo 新手，我需要你的帮助。

我有收藏studijneProgramy。这是示例文档:

{
    "_id" : "dGFY",
    "garranti" : [
        {
            "typ" : {
                "sk" : "garant",
                "en" : "Chairman of study board"
            },
            "id" : "1025769"
        },
        {
            "typ" : {
                "sk" : "predseda odborovej komisie",
                "en" : "Chairman of study board"
            },
            "id" : "1025769"
        }
    ]
}

接下来我有收藏osoby。
示例文档:

{
    "_id" : "1025769",
    "plneMeno" : "prof. RNDr. Peter Moczo, DrSc.",
    "priezvisko" : "Moczo",
    "meno" : "Peter",
    "jeGarantProgramu" : "dGFY/x"
}

我需要的是将osoby中的文档添加到数组garranti中的相应文档(其中studijneProgramy.garanti.id == osoby._id)。这就是我想要的结果:

{
    "_id" : "dGFY",
    "garranti" : [
        {
            "typ" : {
                "sk" : "garant",
                "en" : "Chairman of study board"
            },
            "id" : "1025769"
            "garant":{
                "_id" : "1025769",
                "plneMeno" : "prof. RNDr. Peter Moczo, DrSc.",
                "priezvisko" : "Moczo",
                "meno" : "Peter",
                "jeGarantProgramu" : "dGFY/x"
            }
        },
        {
            "typ" : {
                "sk" : "predseda odborovej komisie",
                "en" : "Chairman of study board"
            },
            "id" : "1025769"
            "garant":{
                "_id" : "1025769",
                "plneMeno" : "prof. RNDr. Peter Moczo, DrSc.",
                "priezvisko" : "Moczo",
                "meno" : "Peter",
                "jeGarantProgramu" : "dGFY/x"
            }
        }
    ]
}

我尝试了此聚合，但它替换了 garranti 的内容。

db.studijneProgramy.aggregate([
{
    $lookup:
    {
        from:"osoby", 
        localField:"garranti.id",
        foreignField:"_id", 
        as:"garranti.garant"
    }
 }
]
).pretty()

任何帮助将不胜感激!

Answer 1

MongoDB $lookup不会使用“查找”集合中的匹配项“更新”现有数组中的元素。它将仅输出与给定条件匹配的“数组”，即与您拥有的值的“现有数组”或奇异值相匹配的“数组”。

为了将条目与“服务器”“结婚”$lookup您必须继续执行以下选项之一才能以您想要的形式返回操作。

$首先展开数组

最简单的形式是简单地更改文档的结构，以便在您实际尝试“合并”相关信息之前，源中的每个数组成员首先是它自己的文档:

db.studijneProgramy.aggregate([
  { "$unwind": "$garranti" },
  { "$lookup": {
    "from": "osoby",
    "as": "garranti.garrant",
    "localField": "garranti.id",
    "foreignField": "_id"
  }},
  { "$unwind": "$garranti.garrant" },
  { "$group": {
    "_id": "$_id",
    "garranti": { "$push": "$garranti" }
  }}
])

由于原始数组 Material 现在是单个文档，因此每个文档仅接收来自连接集合的匹配“数组”。这将 $unwind再次最后使用$group为了$push到带有“连接”条目的最终数组形式。

关联“数组”

在支持它的版本中更花哨的是使用 $indexOfArray 的功能和 $arrayElemAt为了“匹配” $lookup 的输出数组到文档中现有的数组条目:

db.studijneProgramy.aggregate([
  { "$lookup": {
    "from": "osoby",
    "as": "related",
    "localField": "garranti.id",
    "foreignField": "_id"
  }},
  { "$project": {
    "garranti": {
      "$map": {
        "input": "$garranti",
        "in": {
          "typ": "$$this.typ",
          "id": "$$this.id",
          "garrant": {
            "$arrayElemAt": [
              "$related",
              { "$indexOfArray": [ "$related._id", "$$this.id" ] }
            ]
          }
        }
      }
    }
  }}
])

因此，查找返回“匹配数组”(相关)，然后您“查找”这些匹配条目，并通过$map将它们转置到原始文档数组中。 。当然这需要额外的$project stage 或类似的以便 reshape 文档结果，因为您无法“定位” $lookup 中现有数组的每个元素输出如前所述。

这实际上是“服务器”上与某些库(例如“mongoose”)为“客户端上的连接模拟”所做的直接关联。实际上，“外部”条目被“映射”到现有数组上。

子管道处理

使用 Uncorrelated subquery 的“子管道”处理的另一种选择有点花哨和冗长。从 MongoDB 3.6 及以上版本可用。这里我们基本上是在$lookup的“子管道”中进行操作。而不是在后续聚合阶段进行处理:

db.studijneProgramy.aggregate([
  { "$lookup": {
    "from": "osoby",
    "as": "garranti",
    "let": { "garranti": "$garranti" },
    "pipeline": [
      { "$match": {
        "$expr": { "$in": [ "$_id", "$$garranti.id" ] } 
      }},
      { "$addFields": {
        "docs": {
          "$filter": {
            "input": "$$garranti",
            "cond": {
              "$eq": [ "$$this.id", "$_id" ]
            }
          }
        }
      }},
      { "$unwind": "$docs" },
      { "$replaceRoot": {
        "newRoot": {
          "$mergeObjects": [
            "$docs",
            { "garrant": {
              "$arrayToObject": {
                "$filter": { 
                  "input": { "$objectToArray": "$$ROOT" },
                  "cond": { "$ne": [ "$$this.k", "docs"] }
                }
              }
            }}
          ]
        }
      }}
    ]
  }}
])

这种操作“彻底”转变，并有效地将“源文档”中的“匹配数组元素”作为数组放入每个匹配的外部元素中。

处理然后有效地使用 $unwind在过滤的源列表上，然后合并外部集合中的内容，因此现在看来 $lookup “输出数组”实际上是“本地数组”中的数据，现在与“外部内容”“合并”。

实际上，这只是对相同 $map 的更奇特的调用。过程如上，但在结果与原始父文档合并并覆盖原始数组属性之前，对条目进行“关联”。

<小时/>

我认为某个地方有一个 JIRA 可以解决这个问题，但我有点感觉所有此类报告上都标记了“按设计工作”，因此它不太可能改变目前确实如此。

因此，您的误解是“加入”会“自动”与数组条目“合并”。事实并非如此。

如果您想真正“合并数组输出”，那么上面的方法就是“服务器”方法。