如何使用MongoDB将`$ lookup`聚合为`findOne()`

Fiz*_*zix 33 mongodb mongodb-query aggregation-framework

众所周知,find()返回一个结果数组,findOne()只返回一个简单的对象.

使用Angular,这会产生巨大的差异.{{myresult[0].name}}我可以简单地写一下,而不是去{{myresult.name}}.

我发现$lookup聚合管道中的方法返回结果数组而不是单个对象.

例如,我有两个收藏:

users 采集:

[{
  "firstName": "John",
  "lastName": "Smith",
  "country": 123
}, {
  "firstName": "Luke",
  "lastName": "Jones",
  "country": 321
}]
Run Code Online (Sandbox Code Playgroud)

countries 采集:

[{
  "name": "Australia",
  "code": "AU",
  "_id": 123
}, {
  "name": "New Zealand",
  "code": "NZ",
  "_id": 321
}]
Run Code Online (Sandbox Code Playgroud)

我的总计$lookup:

db.users.aggregate([{
  $project: {
    "fullName": {
      $concat: ["$firstName", " ", "$lastName"]
    },
    "country": "$country"
  }
}, {
  $lookup: {
    from: "countries",
    localField: "country",
    foreignField: "_id",
    as: "country"
  }
}])
Run Code Online (Sandbox Code Playgroud)

查询结果:

[{
  "fullName": "John Smith",
  "country": [{
    "name": "Australia",
    "code": "AU",
    "_id": 123
  }]
}, {
 "fullName": "Luke Jones",
 "country": [{
   "name": "New Zealand",
   "code": "NZ",
   "_id": 321
 }]
}]
Run Code Online (Sandbox Code Playgroud)

正如您在上面的结果中所看到的,每个country都是一个数组,而不是像一个对象"country": {....}.

如何让我$lookup返回单个对象而不是数组,因为它只能匹配单个文档?

sty*_*ane 49

你几乎就在那里,你需要$project在管道中添加另一个阶段并使用它$arrayElemAt来返回数组中的单个元素.

db.users.aggregate(
    [
        {   "$project": {     
            "fullName": {       
                "$concat": [ "$firstName", " ", "$lastName"]     
            },
            "country": "$country"   
        }}, 
        { "$lookup": {     
                "from": "countries",     
                "localField": "country",     
                "foreignField": "_id",     
                "as": "countryInfo"   
        }}, 
        { "$project": { 
            "fullName": 1, 
            "country": 1, 
            "countryInfo": { "$arrayElemAt": [ "$countryInfo", 0 ] } 
        }} 
    ]
)
Run Code Online (Sandbox Code Playgroud)

  • 现在你也可以使用`$ unwind` https://docs.mongodb.com/manual/reference/operator/aggregation/unwind/ (8认同)
  • 作为游戏后期的 2 美分附加组件,我喜欢将“$lookup”与“$unwind”配对。我的一部分大脑喜欢认为这种组合可以在服务器端进行优化,类似于“$limit”和“$sort”组合(其中“sort”操作仅跟踪“limit”记录)。 (2认同)
  • 如果您想控制使用“$arrayElemAt”选择的元素中包含哪些字段——而不需要执行另一个“$project”阶段——您可以使用“$let”,如下所述:https://stackoverflow.com/a/ 39650846/483520 (2认同)
  • 除了 `$arrayElemAt` 之外,您还可以使用 [`$first` 数组运算符](https://docs.mongodb.com/manual/reference/operator/aggregation/first-array-element)(在版本 4.4 中引入) ): `{ "$arrayElemAt": [ "$countryInfo", 0 ] } ` 变为 `{ "$first": "$countryInfo" }` (2认同)

小智 15

db.users.aggregate([
    {
        $lookup: {
            from: 'countries',
            localField: 'country',
            foreignField: '_id',
            as: 'country'
        }
    },
    {
        $unwind: '$country'
    }
]).pretty()
Run Code Online (Sandbox Code Playgroud)

您可以使用此 mongo 查询来获取国家/地区对象


小智 9

您也可以使用 "preserveNullAndEmptyArrays"

像这样:

 db.users.aggregate(
        [
            {   "$project": {     
                "fullName": {       
                    "$concat": [ "$firstName", " ", "$lastName"]     
                },
                "country": "$country"   
            }}, 
            { "$lookup": {     
                    "from": "countries",     
                    "localField": "country",     
                    "foreignField": "_id",     
                    "as": "countryInfo"   
            }}, 
            {"$unwind": {
                    "path": "$countryInfo",
                    "preserveNullAndEmptyArrays": true
                }
            },
        ]
    )
Run Code Online (Sandbox Code Playgroud)

  • @CervEd 感谢您提出这个可能的问题。我测试过,确实这似乎是一个问题——在这种情况下 $unwind 实际上是一个完全连接,如果数组为空,它将删除整个条目。因此,`"preserveNullAndEmptyArrays": true` 是必要的。 (4认同)
  • {$ unwind:{path:'$ countryInfo'}}就足够了。 (3认同)
  • {$ unwind:'$ countryInfo'}也足够 (3认同)
  • 为了便于使用,为什么不创建视图并像普通集合一样引用它(有一些限制)https://docs.mongodb.com/manual/core/views/ (2认同)
  • @benipsen,如果您没有 1-1 关系,省略 `preserveNullAndEmptyArrays` 是否会过滤掉没有 `countryInfo` 的身份,或者 `countryInfo` 是否未定义? (2认同)

小智 8

当您不想重复项目中的所有字段时,只需使用 $addFields 覆盖有问题的字段:

db.users.aggregate([
    {   "$project": {     
        "fullName": {       
            "$concat": [ "$firstName", " ", "$lastName"]     
        },
        "country": "$country"   
    }}, 
    { "$lookup": {     
        "from": "countries",     
        "localField": "country",     
        "foreignField": "_id",     
        "as": "countryInfo"   
    }},
    { "$addFields": {
        "countryInfo": {
            "$arrayElemAt": [ "$countryInfo", 0 ]
        }
    }}
])
Run Code Online (Sandbox Code Playgroud)