聚合操作處理數(shù)據(jù)記錄并返回計算結果。聚合操作將來自多個文檔的值分組在一起，并且可以對分組的數(shù)據(jù)執(zhí)行各種操作以返回單個結果。在SQL中，count（*）和 group by 等效于MongoDB聚合。
對于MongoDB中的聚合，您應該使用 aggregate() 方法。
aggregate()方法的基本語法如下-
>db.COLLECTION_NAME.aggregate(AGGREGATE_OPERATION)
在集合中，您具有以下數(shù)據(jù)-
{
_id: ObjectId(7df78ad8902c)
title: 'MongoDB Overview',
description: 'MongoDB不是SQL數(shù)據(jù)庫',
by_user: '(cainiaoplus.com)',
url: '',
tags: ['mongodb', 'database', 'NoSQL'],
likes: 100
},
{
_id: ObjectId(7df78ad8902d)
title: 'NoSQL Overview',
description: 'No SQL數(shù)據(jù)庫是非常快的',
by_user: '(cainiaoplus.com)',
url: '',
tags: ['mongodb', 'database', 'NoSQL'],
likes: 10
},
{
_id: ObjectId(7df78ad8902e)
title: 'Neo4j Overview',
description: 'Neo4j 是No SQL數(shù)據(jù)庫',
by_user: 'Neo4j',
url: 'http://www.neo4j.com',
tags: ['neo4j', 'database', 'NoSQL'],
likes: 750
},現(xiàn)在，從上述集合中，如果要顯示一個列表，說明每個用戶編寫了多少教程，那么您將使用以下aggregate()方法-
> db.mycol.aggregate([{$group : {_id : "$by_user", num_tutorial : {$sum : 1}}}])
{ "_id" : "cainiaoplus.com", "num_tutorial" : 2 }
{ "_id" : "Neo4j", "num_tutorial" : 1 }
>以上用例的sql等效查詢將為 select by_user, count(*) from mycol group by by_user。
在上面的示例中，我們已經按字段by_user對文檔進行了分組，并且在每次按用戶分組時，先前的sum值都會增加。以下是可用的聚合表達式的列表。
| 表達式 | 描述 | 實例 |
|---|---|---|
| $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 | 在結果文檔中插入值到一個數(shù)組中。 | db.mycol.aggregate([{$group : {_id : "$by_user", url : {$push: "$url"}}}]) |
| $addToSet | 在結果文檔中插入值到一個數(shù)組中，但不創(chuàng)建副本。 | db.mycol.aggregate([{$group : {_id : "$by_user", url : {$addToSet : "$url"}}}]) |
| $first | 根據(jù)資源文檔的排序獲取第一個文檔數(shù)據(jù)。 | db.mycol.aggregate([{$group : {_id : "$by_user", first_url : {$first : "$url"}}}]) |
| $last | 根據(jù)資源文檔的排序獲取最后一個文檔數(shù)據(jù) | db.mycol.aggregate([{$group : {_id : "$by_user", last_url : {$last : "$url"}}}]) |
管道在Unix和Linux中一般用于將當前命令的輸出結果作為下一個命令的參數(shù)。
MongoDB的聚合管道將MongoDB文檔在一個管道處理完畢后將結果傳遞給下一個管道處理。管道操作是可以重復的。
表達式：處理輸入文檔并輸出。表達式是無狀態(tài)的，只能用于計算當前聚合管道的文檔，不能處理其它的文檔。
這里我們介紹一下聚合框架中常用的幾個操作：
$project：修改輸入文檔的結構?？梢杂脕碇孛?、增加或刪除域，也可以用于創(chuàng)建計算結果以及嵌套文檔。
$match：用于過濾數(shù)據(jù)，只輸出符合條件的文檔。$match使用MongoDB的標準查詢操作。
$limit：用來限制MongoDB聚合管道返回的文檔數(shù)。
$skip：在聚合管道中跳過指定數(shù)量的文檔，并返回余下的文檔。
$unwind：將文檔中的某一個數(shù)組類型字段拆分成多條，每條包含數(shù)組中的一個值。
$group：將集合中的文檔分組，可用于統(tǒng)計結果。
$sort：將輸入文檔排序后輸出。
$geoNear：輸出接近某一地理位置的有序文檔。
1、$project 實例
db.article.aggregate(
{ $project : {
title : 1 ,
author : 1 ,
}}
);這樣的話結果中就只還有_id,tilte和author三個字段了，默認情況下_id字段是被包含的，如果要想不包含_id話可以這樣:
db.article.aggregate(
{ $project : {
_id : 0 ,
title : 1 ,
author : 1
}});2.$match 實例
db.articles.aggregate( [
{ $match : { score : { $gt : 70, $lte : 90 } } },
{ $group: { _id: null, count: { $sum: 1 } } }
] );$match用于獲取分數(shù)大于70小于或等于90記錄，然后將符合條件的記錄送到下一階段$group管道操作符進行處理。
3.$skip 實例
db.article.aggregate(
{ $skip : 5 });經過$skip管道操作符處理后，前五個文檔被"過濾"掉。