我在 mongodb 2.6 中使用 nodejs + mongoosejs。我在一个模型上有一个静态函数,可以对集合中所有项目的值求和。每个项目都使用 projectNo 属性分配给一个项目。我需要静态函数能够为我提供集合的总数,如果传递了 projectNo 参数,则向聚合添加 $match 管道运算符。这将使我不必制作 2 个基本上做同样事情的静态函数。
为了让事情更有趣,我使用 bluebird promisifyAll 方法让聚合框架返回一个承诺。
我对整个集合求和的静态函数:
db.collection.aggregateAsync([
{$group:{_id: null, amount: { $sum: "$amount" }}}
])
我的静态函数只对具有匹配项目号的记录求和:
db.collection.aggregateAsync([
{$match: { projectNo: projectNo }},
{$group:{_id: null, amount: { $sum: "$amount" }}}
])
我真的想使用Aggregate.append方法仅在包含 req.params.projectNo 时附加 $match 管道。
当我尝试将它添加到异步聚合时,它会收到一个错误,这是有道理的,因为它只是一个承诺。如果我试试这个:
db.collection.aggregateAsync([
{$group:{_id: null, amount: { $sum: "$amount" }}}
]).then(function(aggregate){
aggregate.append({$match: { projectNo: projectNo }})
})
我收到一个错误,(追加未定义)。我该怎么做呢?或者只是接受这样一个事实,即我有两个功能可以做同样的事情?