MongoDB聚合(二)2.3 $group
$group操作可以将文档根据给定字段的不同值进行分组。
如果选定了需要分组的字段，可以将选定的字段传递给"$group"函数的"_id"字段。
{ "$group" : {"_id" : "$day"} }
{ "$group" : {"_id" : "$grade"} }
{ "$group" : {"_id" : {"state" : "$state", "city" : "$city"}} }
2.3.1 分组操作符
允许对每个分组进行计算，得到相应的结果。
2.3.2 算术操作符
两个操作符用于对数值类型的字段的值进行计算："$sum"和"$average"。
"$sum"，对于分组中的每个文档，将value与计算结果相加。
例如：
插入测试数据：
countrys = ["china", "japan", "germany", "canada", "india"]
for (var i = 1; i < 100; i ++) {name = countrys[Math.floor(Math.random() * countrys.length)]money =  Math.floor(1000 * Math.random())db.foo.insert({"country" : name, "_id" : i, "money" : money})
}
分组：
db.foo.aggregate(
{"$group" : {"_id" : "$country","total" : {"$sum" : "$money"}}
})
返回结果：
{ "_id" : "canada", "total" : 11316 }
{ "_id" : "china", "total" : 7225 }
{ "_id" : "india", "total" : 11190 }
{ "_id" : "germany", "total" : 10288 }
{ "_id" : "japan", "total" : 9330 }
$avg，返回每个分组的平均值。
例如：
聚合：
db.foo.aggregate(
{"$group" : {"_id" : "$country","average" : {"$avg" : "$money"}}
})
返回结果：
{ "_id" : "canada", "average" : 595.578947368421 }
{ "_id" : "china", "average" : 481.6666666666667 }
{ "_id" : "india", "average" : 559.5 }
{ "_id" : "germany", "average" : 411.52 }
{ "_id" : "japan", "average" : 466.5 }
2.3.3 极值操作符
极值操作符获取数据集合的边缘值。
"$max" : expr
返回最大值。
"$min" : expr
返回最小值。
"$first" : expr
返回分组第一个值。
"$last" : expr
返回分组最后一个值。
"$max"和"$min"会查看文档没一个值。
例如：
db.foo.aggregate(
{"$group" : {"_id" : "$country","lowest" : {"$min" : "$money"},"highest" : {"$max" : "$money"},}
})
返回结果：
{ "_id" : "canada", "lowest" : 130, "highest" : 950 }
{ "_id" : "china", "lowest" : 15, "highest" : 949 }
{ "_id" : "india", "lowest" : 98, "highest" : 994 }
{ "_id" : "germany", "lowest" : 36, "highest" : 960 }
{ "_id" : "japan", "lowest" : 28, "highest" : 850 }
如果结果集是有序的，则使用"$first"和"$last"操作。
例如：
插入测试数据：
for (var i = 1; i < 100; i++) {name = "caoqing",age = idb.foo1.insert({"name" : name, "age" : age})
}
聚合：
db.foo1.aggregate(
{"$group" : {"_id" : "$name","lowest" : {"$first" : "$age"},"highest" : {"$last" : "$age"},    }
}
)
查询结果：
{ "_id" : "caoqing", "lowest" : 1, "highest" : 99 }
2.3.4 数组操作符
对数组进行操作。
"$addToSet" : expr
如果当前数组不包含expr，则添加。返回结果集中，每个元素最多出现一次。
"$push" : expr
添加expr到数组，返回包含所有值的数组。
2.3.5 分组行为
大多数操作符都是流式工作的，只要有新文档进入，就可以处理，但是"$group"必须等到收入所有文档后，才能分组，然后将分组发送给管道中的下一操作符。
在分片情况下，"$group"先在每个分片上执行，然后把分组结果发送到mongos再进行统一分组，剩余的管道操作也都是在mongos上运行的。2.4 $unwind
拆分可以将数组的每一个值拆分为单独的文档。
例如：
db.blog.insert({"auther" : "caoqing","comments" : [{"CEO" : "Bill Gates","corp" : "MicroSoft"},{"CEO" : "Mark Zuckerberg","corp" : "Facebook"},{"CEO" : "Dick Costolo","corp" : "Twitter"}]
})
拆分：
db.blog.aggregate(
{"$unwind" : "$comments"
})
结果：
{ "_id" : ObjectId("5360c4f909e603f892b1457c"), "auther" : "caoqing", "comments" : { "CEO" : "Bill Gates", "corp" : "MicroSoft" } }
{ "_id" : ObjectId("5360c4f909e603f892b1457c"), "auther" : "caoqing", "comments" : { "CEO" : "Mark Zuckerberg", "corp" : "Facebook" } }
{ "_id" : ObjectId("5360c4f909e603f892b1457c"), "auther" : "caoqing", "comments" : { "CEO" : "Dick Costolo", "corp" : "Twitter" } }
如果希望得到特定的子文档，可以先拆分，再"$match"得到结果。
db.blog.aggregate(
{"$project" : {"comments" : "$comments"}},{"$unwind" : "$comments"},{"$match" : {"comments.CEO" : "Mark Zuckerberg"}}
)
结果：
{ "_id" : ObjectId("5360c4f909e603f892b1457c"), "comments" : { "CEO" : "Mark Zuckerberg", "corp" : "Facebook" } }2.5 $sort
可以根据任意字段或多个字段进行排序。如果需要大量排序，最好在管道的第一阶段进行排序，这时可以使用索引。否则排序会很慢，占用大量内存。
例如：
db.foo.aggregate(
{"$group" : {"_id" : "$country","total" : {"$sum" : "$money"}}},{"$sort" : {"total" : -1, "country" : 1}}
)
结果：
{ "_id" : "canada", "total" : 11316 }
{ "_id" : "india", "total" : 11190 }
{ "_id" : "germany", "total" : 10288 }
{ "_id" : "japan", "total" : 9330 }
{ "_id" : "china", "total" : 7225 }2.6 $limit
$limit接受一个参数n，返回结果集中前n个文档。
例如：
db.foo.aggregate(
{"$group" : {"_id" : "$country","total" : {"$sum" : "$money"}}},{"$sort" : {"total" : -1, "country" : 1}},{"$limit" : 3}
)
结果：
{ "_id" : "canada", "total" : 11316 }
{ "_id" : "india", "total" : 11190 }
{ "_id" : "germany", "total" : 10288 }2.7 $skip
$skip接受一个参数n,丢弃结果集中前n个文档，将剩余文档返回。如果需要丢弃大量数据，效率会很低。
例如：
db.foo.aggregate(
{"$group" : {"_id" : "$country","total" : {"$sum" : "$money"}}},{"$sort" : {"total" : -1, "country" : 1}},{"$skip" : 2}
)
结果：
{ "_id" : "germany", "total" : 10288 }
{ "_id" : "japan", "total" : 9330 }
{ "_id" : "china", "total" : 7225 }2.8 使用管道
应该在管道开始阶段(执行"$project", "$group", "$unwind"操作前)将尽可能多的文档和字段过滤掉，管道如果不是直接从原来的集合中使用数据，就无法在筛选和排序过程中使用索引。
Mongodb不允许单一的聚合操作占用过多的内存，如果某个操作占用20%以上内存，操作会直接输出错误。
可以将结果集放入一个集合方便以后调用。