使用 mapReduce 在 mongodb 中检索 sum 和 count

Question

如何使用 mapReduce 将以下 SQL 查询转换为 mongoDB

SELECT mobile, SUM( amount ),count(mobile) as noOfTimesRecharges
FROM recharge
WHERE recharge_date  between  '2015-02-26' AND  '2015-03-27'
GROUP BY mobile
having noOfTimesRecharges > 0 and  noOfTimesRecharges < 5

我试过了

db.users.mapReduce(
function(){
emit(this.mobile,this.amount);
},
function(k,v){
return Array.sum(v)
},
{
query:{
recharge_date:{$gte:ISODate("2014-06-17"),$lte:ISODate("2014-06-20")}
},
out:"one_month_data" 
}).find();

这给了我结果，但不是计数。

Answer 1

所以在这种情况下，您可能真的想要aggregation framework。它在本机代码操作中运行，比 mapReduce 的 JavaScript 评估要快得多。

db.users.aggregate([
    { "$match": {
        "recharge_date": {
            "$gte": ISODate("2014-06-17"),
            "$lte": ISODate("2014-06-20")
        }
    }},
    { "$group": {
        "_id": "$mobile",
        "amount": { "$sum": "$amount" },
        "count": { "$sum": 1 }
    }},
    { "$match": {
        "count": { "$gt": 1, "lt": 5 }
    }}
    { "$out": "newCollection" }
],
{ "allowDiskUse": true }
)

代码效率更高，代码也非常简单。

还可以查看SQL to agregation mapping chart 了解常见示例。

如果您确实需要 mapReduce（而且您可能不需要），那么正确的方法是：

db.users.mapReduce(
    function() { 
        emit( this.mobile, { "amount": this.amount, "count": 1 } );
    },
    function(key,values) {
        var doc = { "amount": 0, "count": 0 };
        values.forEach(function(value) {
            doc.amount += value.amount;
            doc.count += value.count;
        };
        return doc;
   },
   { 
       "out": { "replace": "newCollection" },
       "query": {
           "recharge_date": {
               "$gte": ISODate("2014-06-17"),
               "$lte": ISODate("2014-06-20")
            }
       }
   }
)

但是，在“限制”结果方面，您不会得到与聚合管道相同的情况，而无需对结果集合进行额外处理。