MongoDB聚合与数组值的总和

Question

我有一个包含以下数据的集合:

{
    "_id" : ObjectId("5516d416d0c2323619ddbca8"),
    "date" : "28/02/2015",
    "driver" : "user1",
    "passengers" : [
        {
            "user" : "user2",
            "times" : 2
        },
        {
            "user" : "user3",
            "times" : 3
        }
    ]
}
{
    "_id" : ObjectId("5516d517d0c2323619ddbca9"),
    "date" : "27/02/2015",
    "driver" : "user2",
    "passengers" : [
        {
            "user" : "user1",
            "times" : 2
        },
        {
            "user" : "user3",
            "times" : 2
        }
    ]
}

并且我想执行聚合，以便我知道某个乘客的时间，它与某个司机在一起，在我的示例中它将是: 对于 user1:[{ driver: user2, times: 2}] 对于 user2:[{ driver: user1, times: 2}] 对于 user3:[{ driver: user1, times: 3}, {driver: user2, times:2}]

我对 mongo 很陌生，并且知道如何使用 sum 执行简单的聚合，但不是当它在数组内部时，以及当我的主题本身在数组中时。 执行这种聚合的适当方法是什么，更具体地说，我如何在基于 express.js 的服务器中执行它？

Answer 1

要使用聚合框架满足您的需求，第一个管道阶段将是 $match对相关乘客的操作，将文档与乘客数组中的用户匹配，然后是 $unwind从前一个操作中的输入文档中解构乘客数组的操作，为每个元素输出一个文档。解构后的数组上的另一个 $match 操作进一步过滤先前的文档流，只允许匹配的文档未经修改地传递到下一个管道阶段，即投影所需字段与 $project运算符(operator)。所以基本上你的 user3 聚合管道将像:

db.collection.aggregate([
     {
        "$match": {
            "passengers.user": "user3"
        }
     },
     {
         "$unwind": "$passengers"
     },
     {
        "$match": {
            "passengers.user": "user3"
        }
     },
     {
         "$project": {
             "_id": 0,
            "driver": "$driver",
            "times": "$passengers.times"
        }
     }
])

结果:

/* 0 */
{
    "result" : [ 
        {
            "driver" : "user1",
            "times" : 3
        }, 
        {
            "driver" : "user2",
            "times" : 2
        }
    ],
    "ok" : 1
}

更新:

如您所提到的，要对具有不同日期的驱动程序上的重复项进行分组，您可以执行 $group在最后一个 $project 管道阶段之前的操作，您使用 $sum 运算符计算总乘客时间:

db.collection.aggregate([
     {
        "$match": {
            "passengers.user": "user3"
        }
     },
     {
         "$unwind": "$passengers"
     },
     {
        "$match": {
            "passengers.user": "user3"
        }
     },
     {
         "$group": {
             "_id": "$driver", 
             "total": {
                 "$sum": "$passengers.times"
             }
         }
     },
     {
         "$project": {
            "_id": 0,
            "driver": "$_id",
            "total": 1
        }
     }
])

结果:

/* 0 */
{
    "result" : [ 
        {
            "total" : 2,
            "driver" : "user2"
        }, 
        {
            "total" : 3,
            "driver" : "user1"
        }
    ],
    "ok" : 1
}