MongoDB学习笔记之分组(group)使用示例
//准备测试数据 db.user.drop(); for(vari=10;i<100;i++){ db.user.insert({ name:"user"+i, age:Math.floor(Math.random()*10)+20, sex:Math.floor(Math.random()*3)%2==0?'M':'F', chinese:Math.floor(Math.random()*50)+50, math:Math.floor(Math.random()*50)+50, english:Math.floor(Math.random()*50)+50, class:"C"+i%5 }) } //group函数 //按照class进行分组,显示每个class中的用户姓名和性别 db.user.group({ key:{"class":true}, initial:{"person":[]}, reduce:function(cur,prev){ prev.person.push({name:cur.name,sex:cur.sex,age:cur.age}); } }); //对age>25的用户,按照class进行分组,显示每个class中的用户姓名和性别,并统计每组的人数 db.user.group({ key:{"class":true}, initial:{"person":[]}, reduce:function(doc,out){ out.person.push({name:doc.name,sex:doc.sex,age:doc.age}); }, finalize:function(out){ out.count=out.person.length; }, condition:{"age":{$gt:25}} }) //分组计算每个class中,chinese最大值和最小值 db.user.group({ key:{"class":true}, initial:{"chinese_min":0,"chinese_max":0}, reduce:function(doc,out){ out.chinese_min=doc.chinese; out.chinese_min=doc.chinese; out.chinese_min=Math.min(out.chinese_min,doc.chinese); out.chinese_max=Math.max(out.chinese_max,doc.chinese) }, }) //利用分组,计算每个总成绩和成绩平均值 db.user.group({ key:{"_id":true}, initial:{name:"",total:0,avg:0}, reduce:function(doc,out){ out.name=doc.name; out.total=doc.chinese+doc.math+doc.english; out.avg=Math.floor(out.total/3); } })
group参数选项:
1.key:这个就是分组的key
2.initial:每组都分享一个初始化函数,特别注意:是每一组initial函数。
3.reduce:这个函数的第一个参数是当前的文档对象,第二个参数是上一次function操作的累计对象。有多少个文档,$reduce就会调用多少次。
4.condition:这个就是过滤条件。
5.finalize:这是个函数,每一组文档执行完后,多会触发此方法。