学习MongoDB 十一： MongoDB聚合（Aggregation Pipeline基础篇上）（三）
一、Aggregate簡介?
? ? ? ? ? ? ? ??db.collection.aggregate()是基于數(shù)據(jù)處理的聚合管道，每個文檔通過一個由多個階段（stage）組成的管道，可以對每個階段的管道進行分組、過濾等功能，然后經(jīng)過一系列的處理，輸出相應的結果。
? ? ? ? ? ? ? ?
? ? ???圖來自https://docs.mongodb.com/manual/aggregation/ 官方網(wǎng)
??? ? ? 我們通過這張圖，可以清晰的了解Aggregate處理的過程
??
? ? ? ? ?1、db.collection.aggregate()可以多個管道，能方便的進行數(shù)據(jù)的處理。
? ? ? ? ?2、db.collection.aggregate()使用了MongoDB內(nèi)置的原生操作，聚合效率非常高,支持類似于SQL Group By操作的功能，而不再需要用戶編寫自定義的JavaScript例程。
? ? ? ? ?3、?每個階段管道限制為100MB的內(nèi)存。如果一個節(jié)點管道超過這個極限,MongoDB將產(chǎn)生一個錯誤。為了能夠在處理大型數(shù)據(jù)集,可以設置allowDiskUse為true來在聚合管道節(jié)點把數(shù)據(jù)寫入臨時文件。這樣就可以解決100MB的內(nèi)存的限制。
? ? ? ? ?4、db.collection.aggregate()可以作用在分片集合，但結果不能輸在分片集合，MapReduce可以 作用在分片集合，結果也可以輸在分片集合。
? ? 5、db.collection.aggregate()方法可以返回一個指針（cursor），數(shù)據(jù)放在內(nèi)存中，直接操作。跟Mongo shell 一樣指針操作。
? ? ? ? ?6、db.collection.aggregate()輸出的結果只能保存在一個文檔中，BSON Document大小限制為16M。可以通過返回指針解決，版本2.6中后面：DB.collect.aggregate()方法返回一個指針，可以返回任何結果集的大小。
? ? ? ? ?
?二、aggregate語法：
?
? ? ? db.collection.aggregate(pipeline, options)
?
? ? ?【pipeline ?$group參數(shù)】
?
? ? ? ? ?pipeline?類型是Array ?語法：?db.collection.aggregate( [ { <stage> }, ... ] )?
? ? ? ?$group :?將集合中的文檔分組，可用于統(tǒng)計結果，$group首先將數(shù)據(jù)根據(jù)key進行分組。
? ? ? $group語法：?{ $group: { _id: <expression>, <field1>: { <accumulator1> : <expression1> }, ... } }
? ? ? ? ? _id?是要進行分組的key
? ? ? ?$group：可以分組的數(shù)據(jù)執(zhí)行如下的表達式計算：
? ? ? ? ? ?$sum：計算總和。
? ? ? ? ? ?$avg：計算平均值。
? ? ? ? ? ?$min：根據(jù)分組，獲取集合中所有文檔對應值得最小值。
? ? ? ? ? ?$max：根據(jù)分組，獲取集合中所有文檔對應值得最大值。
? ? ? ? ? ?$push：將指定的表達式的值添加到一個數(shù)組中。
? ? ? ? ? ?$addToSet：將表達式的值添加到一個集合中（無重復值）。
? ? ? ? ? ?$first：返回每組第一個文檔，如果有排序，按照排序，如果沒有按照默認的存儲的順序的第一個文檔。
? ? ? ? ? ?$last：返回每組最后一個文檔，如果有排序，按照排序，如果沒有按照默認的存儲的順序的最后個文檔。
?
? ? ?我們可以通過Aggregation pipeline一些使用跟sql用法一樣，我們能很清晰的怎么去使用
?
? ? ? ? ? ?pipeline ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? sql
? ? ? ? ? ?$avg ?? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ?avg
? ? ? ? ? ?$min ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ?min
? ? ? ? ? ?$max ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ??max?
? ? ? ? ? ?$group ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? group by
? ? ? ? ? ?$sort ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? order by
? ? ? ? ? ?$limit ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? limit? ? ? ? ? ? ? ? ? ?
? ? ? ? ? ?$sum ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ?sum()
? ? ? ? ? ?$sum ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ?count()
? ?三、pipeline $group 簡單的例子
? ? ??【數(shù)據(jù) 】?
[sql]?view plaincopy
? ??【$group】
?
??????1、將集合中的文檔分組，可用于統(tǒng)計結果，$group首先將數(shù)據(jù)根據(jù)key進行分組。
? ? ? ? ? ? ?_id?是要進行分組的key，如果_id為null ?相當于select ?count(*) from table
??【 $sum】 ?
?????1、 我們統(tǒng)計items有幾條，相當于SQL： ?select count(1) as count from items
[sql]?view plaincopy
????2、我們統(tǒng)計一下數(shù)量，相當于SQL： select sum(quantity) as total ?from ?items
[sql]?view plaincopy
? 3、我們通過產(chǎn)品類型來進行分組，然后在統(tǒng)計賣出的數(shù)量是多少，相當于SQL：select sum(quantity) as total from ?items ?group by pnumber
[sql]?view plaincopy
【$min?、?$max 】?
? ?1、我們通過相同的產(chǎn)品類型來進行分組，然后查詢相同產(chǎn)品類型賣出最多的訂單詳情 ，相當于SQL： select max(quantity) as quantity from ?items ?group by pnumber
[sql]?view plaincopy
? ??2、我們通過相同的產(chǎn)品類型來進行分組，然后查詢相同產(chǎn)品類型賣出最多的訂單詳情 ，相當于SQL：select min(quantity) as quantity from ?items ?group by pnumber
[sql]?view plaincopy
? 3、我們通過相同的產(chǎn)品類型來進行分組，統(tǒng)計各個產(chǎn)品數(shù)量，然后獲取最大的數(shù)量，相當于SQL：?select max(t.total) from (select sum(quantity) as total from ?items ?group by pnumber) t
[sql]?view plaincopy
【$avg】
??? 先根據(jù)$group，在計算平均值,只會針對數(shù)字的進行計算，會對字符串忽略
?
? ? 1、我們通過相同的產(chǎn)品類型來進行分組，然后查詢每個訂單詳情相同產(chǎn)品類型賣出的平均價格，相當于SQL：select avg(price) as price from ?items ?group by pnumber
[sql]?view plaincopy
【$push】
??????將指定的表達式的值添加到一個數(shù)組中，這個值不要超過16M，不然會出現(xiàn)錯誤
? ? 1、我們通過相同的產(chǎn)品類型來進行分組，然后查詢每個相同產(chǎn)品賣出的數(shù)量放在數(shù)組里面
[sql]?view plaincopy
【 $addToSet】
? ? ? ?將表達式的值添加到一個數(shù)組中（無重復值），這個值不要超過16M，不然會出現(xiàn)錯誤
[sql]?view plaincopy
? ? $first：返回每組第一個文檔，如果有排序，按照排序，如果沒有按照默認的存儲的順序的第一個文檔。
? ? $last：返回每組最后一個文檔，如果有排序，按照排序，如果沒有按照默認的存儲的順序的最后個文檔。
[sql]?view plaincopy
? ? ??我們這篇主要介紹了aggregate ?pipeline的$group 基礎操作，后續(xù)介紹了 pipeline其他參數(shù)和options使用
總結
以上是生活随笔為你收集整理的学习MongoDB 十一： MongoDB聚合（Aggregation Pipeline基础篇上）（三）的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。
- 上一篇： MySQL小误区：关于set globa
- 下一篇： Mongodb在renameCollec