Raf*_*nte 4 mongoose mongodb aggregation-framework
我想弄清楚是否有办法在MongoDB的聚合框架中编写条件展开代码.
我有一个像这样的聚合命令:
models.Users.aggregate(
{ // SELECT
$project : { "sex" : 1,
"salesIndex":1
}
},
{ // WHERE
$match: {"salesIndex": {$gte: index}}
},
{ // GROUP BY y agregadores
$group: {
_id : "$sex",
sexCount : { $sum: 1 }
}
},
{ $sort: { sexCount: -1 } }
, function(err, dbres) {
(...)
});
Run Code Online (Sandbox Code Playgroud)
我想按部门添加一个可选的过滤器.用户可以在一个或多个部门中,这是它在db中的样子:
user _id sex salesIndex部门{[d1,d2,d3]}
如果我想搜索特定部门的用户,我会编写$ unwind子句,然后按部门编写$ match.但是,我想对两个场景使用相同的聚合命令,如下所示:
models.Users.aggregate(
{ // SELECT
$project : { "sex" : 1,
"salesIndex":1
}
},
{ // WHERE
$match: {"salesIndex": {$gte: index}}
},
IF (filteringByDepartment){
$unwind departments here
$match by departmentId here
}
{ // GROUP BY y agregadores
$group: {
_id : "$sex",
sexCount : { $sum: 1 }
}
},
{ $sort: { sexCount: -1 } }
, function(err, dbres) {
(...)
});
Run Code Online (Sandbox Code Playgroud)
这有可能,或者我需要2个聚合命令?
在调用之前以编程方式构建聚合管道aggregate:
var pipeline = [];
pipeline.push(
{ // SELECT
$project : { "sex" : 1,
"salesIndex":1
}
},
{ // WHERE
$match: {"salesIndex": {$gte: index}}
}
);
if (filteringByDepartment) {
pipeline.push(
{ $unwind: '$departments' },
{ $match: { departments: departmentId }}
);
}
pipeline.push(
{ // GROUP BY y agregadores
$group: {
_id : "$sex",
sexCount : { $sum: 1 }
}
},
{ $sort: { sexCount: -1 } }
);
models.Users.aggregate(pipeline, function(err, dbres) {
//...
});
Run Code Online (Sandbox Code Playgroud)
| 归档时间: |
|
| 查看次数: |
4605 次 |
| 最近记录: |