代码之家 › 专栏 › 技术社区 › Milad Aghamohammadi

MongoDB聚合管道查询

aggregation-framework mongodb node.js

Milad Aghamohammadi · 技术社区 · 6 年前

我有两个集合,“组”和“用户”:

group:
[  
   {  
      "_id":1,
      "groupName":"group1",
      "users":[  
         {  
            "userId":1,
            "isAdmin":"false"
         },
         {  
            "userId":2,
            "isAdmin":"true"
         }
      ]
   },
   {  
      "_id":2,
      "groupName":"group2",
      "users":[  
         {  
            "userId":2,
            "isAdmin":"false"
         },
         {  
            "userId":3,
            "isAdmin":"true"
         }
      ]
   }
]

user:
[  
   {  
      "_id":1,
      "username":"user1",
      "firstname":"a",
      "lastname":"aa",
      "mobileNo":"+1111111"
   },
   {  
      "_id":2,
      "username":"user2",
      "firstname":"b",
      "lastname":"bb",
      "mobileNo":"+2222222"
   },
   {  
      "_id":3,
      "username":"user3",
      "firstname":"c",
      "lastname":"cc",
      "mobileNo":"+3333333"
   }
]

我需要一个聚合来返回如下内容:

[  
   {  
      "_id":1,
      "groupName":"group1",
      "members":[  
         {  
            "isAdmin":"false",
            "username":"user1",
            "firstname":"a",
            "lastname":"aa"
         },
         {  
            "isAdmin":"true",
            "username":"user2",
            "firstname":"b",
            "lastname":"bb"
         }
      ]
   },
   {  
      "_id":2,
      "groupName":"group2",
      "members":[  
         {  
            "isAdmin":"false",
            "username":"user2",
            "firstname":"b",
            "lastname":"bb"
         },
         {  
            "isAdmin":"true",
            "username":"user3",
            "firstname":"c",
            "lastname":"cc"
         }
      ]
   }
]

在结果中的“members”处,“isAdmin”从组集合中的“users”返回,“username”、“firstname”和“lastname”来自用户集合

非常感谢,

1 回复 | 直到 6 年前

Ashh 6 年前

您可以在mongodb中尝试以下聚合

db.group.aggregate([
  { "$unwind": "$users" },
  { "$lookup": {
    "from": Users.collection.name,
    "let": { "userId": "$users.userId", "isAdmin": "$users.isAdmin" },
    "pipeline": [
      { "$match": { "$expr": { "$eq": [ "$_id", "$$userId" ] } } },
      { "$project": { "isAdmin": "$$isAdmin", "username": 1, "firstName": 1, "lastName": 1 }}
    ],
    "as": "members"
  }},
  { "$unwind": "$members" },
  { "$group": {
    "_id": "$_id",
    "members": { "$push": "$members" },
    "groupName": { "$first": "$groupName" }
  }}
])

推荐文章

user433342 · 流式传输SheetJS-xlsx以在节点中形成数据

4 月前

servvs · 如何从javascript中的另一个类回调读取修改后的类属性?

4 月前

Vanortton · 使用Docker开始应用程序开发还是在开发过程中配置Docker?[关闭]

4 月前

ProfessorFinesse · 在默认表单中完成帖子请求时,“res.send”会去哪里?

4 月前

LifeAsPixels · 试图使用Node.js读取我的本地html文件时,此错误的来源是什么?

4 月前

Josue Abotsidia · 创建NextJS项目时出错

4 月前

Soon Winner · TypeError:superheroes.random在使用“超级英雄”npm包时不是函数[关闭]

5 月前

Null Salad · 如何使用postgresql和nodejs将变量安全地插入数组?

5 月前

Zak · 令牌认证路由的页面刷新重定向到React中的404页面

5 月前

DSATH · 我的lambda在代码完成之前就结束了,我不知道为什么

5 月前