首先介紹user collection

user {'username':, 'age':, 'account':}

下面是正常的group_by 和count實作

//SQL實作

select username,count(sku) from user group by username

//MapReduce實作

map=function (){ emit(this.username,{count:1}) } reduce=function (key,values){ var cnt=0; values.forEach(function(val){ cnt+=val.count;}); return {"count":cnt} }

//執行mapreduce

db.test.mapReduce(map,reduce,{out:"mr1"})

db.mr1.find()

{ "_id" : "Joe", "value" : { "count" : 416 } } { "_id" : "Josh", "value" : { "count" : 287 } } { "_id" : "Ken", "value" : { "count" : 297 } }

然後

//SQL實作

select sum(age * account) from user

//MapReduce實現，或用其他方法實作也可以
？ ？ ？ ？ ？ ？ ？ ？ ？ ？ ？ ？ ？ ？ ？ ？ ？ ？ ？

db.user.aggregate([ {$group: {_id: '$username', count: {$sum: 1}}} ]);

db.user.aggregate([ {$group: {_id: "$username", temp_result: {$multiply: ["$age", "$account"]}}}, {$group: {_id: null, result: {$sum: "$temp_result"}}} ]);

emit("sum",this.age*this.account); }

var cnt = 0; values.forEach(function(val){cnt+=val;}); return {"sumAll":cnt}; }