mongodb的聚合

mongodb的聚合

MongoDB中聚合(aggregate)主要用于处理数据(诸如统计平均值,求和等)，并返回计算后的数据结果。有点类似sql语句中的 count(*)。

aggregate() 方法

MongoDB中聚合的方法使用aggregate() 语法

aggregate() 方法的基本语法格式如下所示：

db.COLLECTION_NAME.aggregate(AGGREGATE_OPERATION)

首先我们新建一个数据库，articleDB，创建一个article的集合

创建数据源输入一下数据

{     
title: 'MongoDB Overview',      
description: 'MongoDB is no sql database',   
by_user: 'w3cschool.cc',   
url: 'http://www.w3cschool.cc',  
tags: ['mongodb', 'database', 'NoSQL'],  
likes: 100  
}, 

{       
title: 'NoSQL Overview',    
description: 'No sql database is very fast',    
by_user: 'w3cschool.cc',   
url: 'http://www.w3cschool.cc',   
tags: ['mongodb', 'database', 'NoSQL'],   
likes: 10  
},  

{    
title: 'Neo4j Overview',  
description: 'Neo4j is no sql database',   
by_user: 'Neo4j',   
url: 'http://www.neo4j.com',  
tags: ['neo4j', 'database', 'NoSQL'],  
likes: 750  
}, 

管道的概念

管道在Unix和Linux中一般用于将当前命令的输出结果作为下一个命令的参数。

MongoDB的聚合管道将MongoDB文档在一个管道处理完毕后将结果传递给下一个管道处理。管道操作是可以重复的。

表达式：处理输入文档并输出。表达式是无状态的，只能用于计算当前聚合管道的文档，不能处理其它的文档。

这里我们介绍一下聚合框架中常用的几个操作：

$group：将集合中的文档分组，可用于统计结果。

$project：修改输入文档的结构。可以用来重命名、增加或删除域，也可以用于创建计算结果以及嵌套文档。

match使用MongoDB的标准查询操作。

$limit：用来限制MongoDB聚合管道返回的文档数。

$skip：在聚合管道中跳过指定数量的文档，并返回余下的文档。

$unwind：将文档中的某一个数组类型字段拆分成多条，每条包含数组中的一个值。

$sort：将输入文档排序后输出。

聚合的表达式:

$sum 计算总和。

db.mycol.aggregate([{$group : {_id : "$by_user", num_tutorial : {$sum : "$likes"}}}])

$avg 计算平均值

db.mycol.aggregate([{$group : {_id : "$by_user", num_tutorial : {$avg : "]$likes"}}}])

$min 获取集合中所有文档对应值得最小值。

db.mycol.aggregate([{$group : {_id : "$by_user", num_tutorial : {$min : "$likes"}}}])

$max 获取集合中所有文档对应值得最大值。

db.mycol.aggregate([{$group : {_id : "$by_user", num_tutorial : {$max : "$likes"}}}])

$push 在结果文档中插入值到一个数组中。

db.mycol.aggregate([{$group : {_id : "$by_user", url : {$push: "$url"}}}])

$first 根据资源文档的排序获取第一个文档数据。

db.mycol.aggregate([{$group : {_id : "$by_user", first_url : {$first : "$url"}}}])

$last 根据资源文档的排序获取最后一个文档数据

db.mycol.aggregate([{$group : {_id : "$by_user", last_url : {$last : "$url"}}}])

$group

将集合中的文档分组，可用于统计结果

_id表示分组的依据，使用某个字段的格式为'$字段'

例1：统计每个作家写书的总数

db.article.aggregate([{by_user',counter:{$sum:1}}}])

例1：统计每个作家的总的点赞数

db.article.aggregate([{$group:{_id:'$by_user',like:{$sum:"$likes"}}}])

Group by null

将集合中所有文档分为一组

例2：求集合中作者总书数量作者的平均点赞数

db.article.aggregate([{$group:{_id:null,counter:{$sum:1},likes:{$avg:"$likes"}}}])

$project

修改输入文档的结构, 可以用来重命名增加或删除域也可以用于创建计算结果以及嵌套文档

db.article.aggregate([{$project:{by_user:1}}])

db.article.aggregate([{$project:{by_user:1,id:0}}])

$match：

用于过滤数据，只输出符合条件的文档。

$match使用MongoDB的标准查询操作

查找集合中书籍点赞量在0到20之间的数，并返回书籍的名称

db.article.aggregate([{$match:{likes:{$gt:0,$lte:20}}},{$project:{title:1,_id:0}}])

思考下面语句的含义？

db.article.aggregate([{gt:0,group:{_id:"sum:1},avglikes:{likes'}}}])

$limit：

用来限制MongoDB聚合管道返回的文档数。

从集合的起始位置查找，限制返回两条

db.article.aggregate({$limit:2})

思考下面语句的含义？

db.article.aggregate([{gt:0,project:{title:1}},{$limit:2}])

$skip在聚合管道中跳过指定数量的文档，并返回余下的文档

db.article.aggregate({$skip:2}) #在聚合管道中跳过指定数量的文档，并返回余下的文档。

db.article.aggregate([{$match:{likes:{$gt:0,$lte:20}}},{$skip:2},{$project:{title:1}}])

db.article.aggregate([{$match:{likes:{$gt:0,$lte:20}}},{$skip:1},{$limit:1},{$project:{title:1}}])

$sort：

将输入文档排序后输出

例：查询出点赞量大于0小于等于800的书籍，并且按照降序排列

db.article.aggregate([{$match:{likes:{$gt:0,$lte:800}}},{$sort:{likes:-1}}])

例：查询出点赞量大于0小于等于800的书籍，并且按照升序排列

db.article.aggregate([{$match:{likes:{$gt:0,$lte:800}}},{$sort:{likes:1}}])

$unwind 将文档中的某一个数组类型字段拆分成多条，每条包含数组中的一个值。

db.article.aggregate([{$unwind:'$tags'}])

思考下面这个语句的含义?

db.article.aggregate([{tags'},{$project:{tags:1,title:1,user:1}}])