代码之家 › 专栏 › 技术社区 › Apoorva

多字段$lookup

aggregation-framework mongodb-query mongodb node.js

Apoorva · 技术社区 · 6 年前

我有两个集合,并试图在两个不同的条件下得到总额。
Heere是我的代码:

db.drivers.aggregate([
  {
    $lookup: {
      from: "bookings",
      let: { driver_id: "$_id" },
      pipeline: [
        { $match: { $expr: { $eq: ["$driverId", "$$driver_id"] } } },
        {
          $group: {
            _id: "$driverId",
            totalAmount: { $sum: "$driverAmount" }
          }
        }
      ],
      as: "bookingdata",
      pipeline: [
        {
          $match: {
            $expr: {
              $and: [
                { $eq: ["$driverId", "$$driver_id"] },
                { $eq: ["$payment.settled", false] }
              ]
            }
          }
        },
        {
          $group: {
            _id: "$driverId",
            totaldues: { $sum: "$driverAmount" }
          },
          bookingdata: {
            $push: "$totaldues"
          }
        },
        { $project: { _id: 0, totalAmount: 1, totaldues: 1 } }
      ]
    }
  }
]);

其结果要么是总金额,要么是总应付款,但不能两者兼而有之。如何获取驾驶员详细信息以及总金额和总费用?

1 回复 | 直到 6 年前

Ashh 6 年前

不能在同一对象中多次使用同一字段 pipeline 在这里。

代替使用 $facet 内部聚合 $lookup 一次处理多条管道。

db.drivers.aggregate([
  { "$lookup": {
    "from": "bookings",
    "let": { "driver_id": "$_id" },
    "pipeline": [
      { "$facet": {
        "totaldues": [
          { "$match": {
            "$expr": {
              "$and": [
                { "$eq": ["$driverId", "$$driver_id"] },
                { "$eq": ["$payment.settled", false] }
              ]
            }
          }},
          { "$group": {
            "_id": "$driverId",
            "totaldues": { "$sum": "$driverAmount" },
            "bookingdata": { "$push": "$totaldues" }
          }},
          { "$project": { "_id": 0, "totalAmount": 1, "totaldues": 1 } }
        ],
        "totalAmount": [
          { "$match": { "$expr": { "$eq": ["$driverId", "$$driver_id"] } }},
          { "$group": {
            "_id": "$driverId",
            "totalAmount": { "$sum": "$driverAmount" }
          }}
        ]
      }}
    ],
    "as": "bookingdata"
  }}
])

推荐文章

Adrien Chapelet · MongoDB聚合与阵列内的外部模型

2 年前

nishant kumar · mongodb匹配表达式的返回数

7 年前

Deepak Aggarwal · 如何在python中为包含嵌套文档列表的文档创建mongoDB聚合查询?

7 年前

Jaybruh · Mongo aggregate-如何在对象数组字段中使用$match和$group?

7 年前

Tiago Ávila · 如何在字符串字段和ObjectId之间进行查找-MongoDB C#驱动程序

7 年前

Abhishek Mathur · 将mongo db查询简化为纯数组

7 年前

GregH · 是否可以在MongoDB中执行子查询以返回$nin运算符的数组?

7 年前

Ashh · $嵌套数组ID的查找聚合

7 年前

Vikas Valechha · 如何在mongodb聚合中使用$geoNear和$lookup

7 年前

Shrabanee · 在记录上使用$unwind后,仅与一条记录匹配

7 年前