二十四、MongoDB 聚合运算( aggregate )

文章永久连接：https://tech.souyunku.com/?p=3679
MongoDB 聚合( aggregate ) 用于处理数据，比如统计平均值,求和等。然后返回计算后的数据结果

MongoDB 聚合有点类似 SQL 语句中的 COUNT( * )

aggregate() 方法

MongoDB aggregate() 为 MongoDB 数据库提供了聚合运算

语法

aggregate() 方法的语法如下

> db.COLLECTION_NAME.aggregate(AGGREGATE_OPERATION)

范例

使用以下命令添加范例所需要的数据

> db.lession.remove({});
WriteResult({ "nRemoved" : 0 })

> db.lession.insert({
   title: 'MongoDB 基础教程', 
   by_user: 'penglei',
   tags: ['MongoDB', 'database', 'NoSQL'],
   favorite: 100
});
WriteResult({ "nInserted" : 1 })

> db.lession.insert({
  title: 'NoSQL 基础教程', 
  by_user: 'penglei',
  tags: ['MongoDB', 'database', 'NoSQL'],
  favorite: 10
});
WriteResult({ "nInserted" : 1 })

> db.lession.insert({
   title: 'Neo4j 基础教程', 
   by_user: 'Neo4j',
   tags: ['Neo4j', 'database', 'NoSQL'],
   favorite: 750
});
WriteResult({ "nInserted" : 1 })

现在，我们使用 aggregate() 方法统计每个作者的课程数量

> db.lession.aggregate([{$group : {_id : "$by_user", num_lession : {$sum : 1}}}]);
{ "_id" : "Neo4j", "num_lession" : 1 }
{ "_id" : "penglei", "num_lession" : 2 }

上面的例子，通过字段 by_user 字段对数据进行分组，并计算 by_user 字段相同值的总和

上面的命令类似于 SQL 中的

select by_user, count(*) from lession group by by_user

下面罗列出了一些聚合的表达式

1、 $sum

计算总和

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

2、 $avg

计算平均值

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

3、 $min

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

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

4、 $max

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

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

5、 $push

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

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

6、 $addToSet

在结果文档中插入值到一个数组中，但不创建副本

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

7、 $first

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

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

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

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

干货推荐

本站推荐：精选优质专栏

附录：MongoDB 教程：系列文章

• 一、MongoDB 基础教程
• 二、NoSQL 简介
• 三、什么是 MongoDB ?
• 四、Windows 平台安装 MongoDB
• 五、Linux 平台安装 MongoDB
• 六、Mac OSX 平台安装 MongoDB
• 七、MongoDB 术语
• 八、MongoDB -连接
• 九、MongoDB 创建数据库
• 十、MongoDB 切换数据库
• 十一、MongoDB 删除数据库
• 十二、MongoDB 备份数据( mongodump )
• 十三、MongoDB 插入文档
• 十四、MongoDB 更新文档
• 十五、MongoDB 删除文档
• 十六、MongoDB 删除集合
• 十七、MongoDB 查询文档
• 十八、MongoDB 条件操作符
• 十九、MongoDB $type操作符
• 二十、MongoDB 限制条数 (limit 方法)
• 二十一、MongoDB 跳过 (skip 方法)
• 二十二、MongoDB 排序
• 二十三、MongoDB 索引
• 【当前读到】二十四、MongoDB 聚合运算( aggregate )
• 二十五、MongoDB 聚合运算 – 管道
• 二十六、MongoDB 副本集群复制
• 二十七、MongoDB 分片集群技术
• 二十八、MongoDB 备份数据( mongodump )
• 二十九、MongoDB 恢复数据( mongorestore )
• 三十、MongoDB 性能跟踪 ( mongotop )
• 三十一、MongoDB 状态检测 ( mongostat )
• 三十二、MongoDB Java
• 三十三、MongoDB PHP 扩展
• 三十四、MongoDB PHP
• 三十五、PHP7 MongDB 扩展安装与使用
• 三十六、MongoDB 关系
• 三十七、MongoDB 数据库引用
• 三十八、MongoDB 覆盖索引查询
• 三十九、MongoDB 查询分析
• 四十、MongoDB 原子操作
• 四十一、MongoDB 高级索引
• 四十二、MongoDB 索引限制
• 四十三、MongoDB ObjectId
• 四十四、MongoDB Map Reduce
• 四十五、MongoDB 全文检索
• 四十六、MongoDB 正则表达式
• 四十七、MongoDB 管理工具: Rockmongo
• 四十八、MongoDB GridFS
• 四十九、MongoDB 固定集合（Capped Collections）
• 五十、MongoDB 自增 ID