使用聚合框架,结果将与您的“所需”输出略有不同,因为您获得的不是散列键,而是带有 _id 键的对象数组,其值代表您按字段分组。例如,而不是
{
"28-10-2016":{
"success_count": 10,
"failure_count": 10
},
"29-10-2016": {
"success_count": 10,
"failure_count": 10
}
}
你会有一个更好的结构,比如
[
{
"_id": "28-10-2016",
"success_count": 10,
"failure_count": 10
},
"_id": "29-10-2016",
"success_count": 10,
"failure_count": 10
}
]
实现上述结果需要在 $sum 累加器运算符中使用 $cond 运算符。 $cond 运算符将根据其第一个参数 (if) 计算逻辑条件,然后返回计算结果为 true (then) 的第二个参数或返回 false (else) 的第三个参数。这会将真/假逻辑转换为分别输入 $sum 的 1 和 0 数值:
"success_count": {
"$sum": {
"$cond": [ { "$eq": [ "$status", "success" ] }, 1, 0 ]
}
}
作为结果管道,需要运行聚合操作,该操作在 $group 管道的 _id 键表达式中使用 $dateToString 运算符:
Orders.aggregate([
{
"$group": {
"_id": {
"$dateToString": {
"format": "%Y-%m-%d",
"date": "$created_at"
}
},
"success_count": {
"$sum": {
"$cond": [ { "$eq": [ "$status", "success" ] }, 1, 0 ]
}
},
"failure_count": {
"$sum": {
"$cond": [ { "$eq": [ "$status", "failure" ] }, 1, 0 ]
}
}
}
}
], function (err, orders){
if (err) throw err;
console.log(orders);
})
但是,有一种更灵活、性能更好的方法,它的执行速度比上述方法快得多,其中聚合结果的最有效数据结构遵循以下架构,例如:
orders = [
{
"_id": "28-10-2016",
"counts": [
{ "status": "success", "count": 10 },
{ "status": "failure", "count": 10 }
]
},
{
"_id": "29-10-2016",
"counts": [
{ "status": "success", "count": 10 },
{ "status": "failure", "count": 10 }
]
}
]
然后考虑运行如下替代管道
Orders.aggregate([
{
"$group": {
"_id": {
"date": {
"$dateToString": {
"format": "%Y-%m-%d",
"date": "$created_at"
}
},
"status": { "$toLower": "$status" }
},
"count": { "$sum": 1 }
}
},
{
"$group": {
"_id": "$_id.date",
"counts": {
"$push": {
"status": "$_id.status",
"count": "$count"
}
}
}
}
], function (err, orders){
if (err) throw err;
console.log(orders);
})