mongodb聚合函数

1.count

这个函数很好理解，和其他数据库一样，就是做一个count操作

select count(*) from tab1 =db.tab1.count()

以上例子很好理解，但是如果在操作中有skip，limit这种操作的话，那么count会忽略掉这些操作，必须加入一个true参数

比如：db.tab1.find().skip(1),limit(2).count()和db.tab1.find().count()得出的结果是一样的

必须修改为db.tab1.find().skip(1).limit(2).count(true)

2.distinct

去重函数，这个也应该很熟悉，各种关系数据库都有

具体操作：db.runCommand({"distinct":"collection","key":"xxxx"})=db.collections.distinct("xxxx");

3.group

select a,b,sum(c) csum from coll where active=1 group by a,b

db.coll.group( {key: { a:true, b:true },

cond: { active:1 },

reduce:function(obj,prev){ prev.csum += obj.c; },

initial: { csum: 0 }

});

参数解释：

Key:group字段

Reduce：聚合函数，典型的有sum和count操作，包含两个参数，当前遍历对象以及聚合计数器

Initial：初始化计数器值

Cond：查询条件筛选选项，如果是空，那么默认对当前collection的所有行操作

Group不能在sharding中使用,结果输出不能多于10000个keys

举例：

> db.mtb1.find()

{ "_id" : ObjectId("4fb4be52aa814943b788095c"), "name" : "aaa", "score" : 77 }

{ "_id" : ObjectId("4fb4be5caa814943b788095d"), "name" : "bbb", "score" : 79 }

{ "_id" : ObjectId("4fb4be61aa814943b788095e"), "name" : "ccc", "score" : 79 }

{ "_id" : ObjectId("4fb4be69aa814943b788095f"), "name" : "ddd", "score" : 79 }

{ "_id" : ObjectId("4fb4be74aa814943b7880960"), "name" : "eee", "score" : 100 }

{ "_id" : ObjectId("4fb4be7aaa814943b7880961"), "name" : "fff", "score" : 100 }

{ "_id" : ObjectId("4fb4be82aa814943b7880962"), "name" : "ggg", "score" : 100 }

{ "_id" : ObjectId("4fb4be9eaa814943b7880963"), "name" : "hhh", "score" : 200}

> db.mtb1.group(

... {key:{score:true},

... reduce:function(obj,prev){prev.count++;},

... initial:{count:0}

... });

[

{

"score" : 77,

"count" : 1

{

"score" : 79,

"count" : 3

{

"score" : 100,

"count" : 3

{

"score" : 200,

"count" : 1

}

]

一个简单的例子，应该很明白了。其实这里group还是建立在reduce上面

4.map/reduce

这个工具的功能可以实现以上三种任何一种，它是分两步完成，先做map，再reduce，map首先对数据进行分解映射，map执行完，紧接着会进行reduce，map后会的到key-values，像{key：[value1,value2,value3...]}，然后通过reduce处理后得到key-value，也就是单一的值。

语法：

db.runCommand(

{ mapreduce : ,

map : ,

reduce :

[, query : ]

[, sort : ]

[, limit : ]

[, out : ]

[, keeptemp: ]

[, finalize : ]

[, scope :

mongodb聚合函数(一)