2019獨(dú)角獸企業(yè)重金招聘Python工程師標(biāo)準(zhǔn)>>>

mongoDB的管道是個(gè)好東西，它可以將很多操作批處理實(shí)現(xiàn)，即將多個(gè)命令放入一個(gè)管道，然后去順序的執(zhí)行它們，今天我要說的是，利用管道中的分組來實(shí)現(xiàn)實(shí)現(xiàn)中的ditinct+group的效果，即先對(duì)一個(gè)元素去重，然后即一個(gè)字段進(jìn)行分組，如你的userinfoID，它對(duì)應(yīng)多個(gè)planID,而我們?cè)趐lanID在表中肯定是重復(fù)的，這時(shí)，我們需要統(tǒng)計(jì)userinfo對(duì)應(yīng)多個(gè)種planID，這時(shí)問題就來了，尤于planID是重復(fù)的，所以分組的結(jié)果可能是錯(cuò)誤的，它并不是真正意思上的（planID種類），正確的作法應(yīng)該是先對(duì)planID去重復(fù)，然后再根據(jù)userinfoID去作分組，而這個(gè)在大多數(shù)的數(shù)據(jù)庫里，是通過多重分組實(shí)現(xiàn)的，即選對(duì)userinfoID和planID進(jìn)行分組，然后對(duì)結(jié)果進(jìn)行userinfoID的分組，這種就把多于的planID去掉了。

具體作法：

//多分組(group+distinct) db.M_User_Footprints.aggregate([{ $group: { _id: { UserInfoID: "$UserInfoID", ObjID: "$PlayVideo.ObjID" } } },{ $group: { _id: "$_id.UserInfoID", count: { $sum: 1 } } },{ $sort: { "_id": 1 } } ]);

注意，這里的第二個(gè)分組用的是第一個(gè)分組的_id，所以加上了$_id，這表示使用上面group的數(shù)據(jù)源來作為第二個(gè)分組的鍵。

而如果只是單個(gè)分組，就很容易實(shí)現(xiàn)了，也看一下代碼

//單分組 db.M_User_Footprints.aggregate([{ $group: { _id: "$UserInfoID", result: { $sum: 1 } } } ])

從上面兩段代碼我們可以看到，分組鍵必須用_id，分組的結(jié)果名稱可以自己定義，{$sum:1}每次自加1。

下面使用map...reduce也可以實(shí)現(xiàn)分組的功能

db.runCommand({mapreduce: "M_User_Footprints",map: function Map() {emit({ "UserInfoID": this.UserInfoID, "ObjID": this.PlayVideo.ObjID },{ count: 1 });},reduce: function Reduce(key, values) {total = 0;//定義一個(gè)變量total , values是一個(gè)數(shù)組for (var i in values) {total += values[i].count}return { "count": total };},finalize: function Finalize(key, reduced) {return reduced;},out: { inline: 1 } });

?

轉(zhuǎn)載于:https://my.oschina.net/mickelfeng/blog/1558012

創(chuàng)作挑戰(zhàn)賽新人創(chuàng)作獎(jiǎng)勵(lì)來咯，堅(jiān)持創(chuàng)作打卡瓜分現(xiàn)金大獎(jiǎng)

總結(jié)

以上是生活随笔為你收集整理的MongoDB学习笔记~管道中的分组实现group+distinct的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。