聚合

聚合操作能夠處理數(shù)據(jù)記錄并返回計(jì)算結(jié)果。聚合操作能將多個(gè)文檔中的值組合起來，對(duì)成組數(shù)據(jù)執(zhí)行各種操作，返回單一的結(jié)果。它相當(dāng)于 SQL 中的 count(*) 組合 group by。

aggregate() 方法

對(duì)于 MongoDB 中的聚合操作，應(yīng)該使用 aggregate() 方法。

語法格式

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

>db.COLLECTION_NAME.aggregate(AGGREGATE_OPERATION)

范例

假如某個(gè)集合包含下列數(shù)據(jù)：

{
   _id: ObjectId(7df78ad8902c)
   title: 'MongoDB Overview', 
   description: 'MongoDB is no sql database',
   by_user: 'tutorials point',
   url: 'http://www.tutorialspoint.com',
   tags: ['mongodb', 'database', 'NoSQL'],
   likes: 100
},
{
   _id: ObjectId(7df78ad8902d)
   title: 'NoSQL Overview', 
   description: 'No sql database is very fast',
   by_user: 'tutorials point',
   url: 'http://www.tutorialspoint.com',
   tags: ['mongodb', 'database', 'NoSQL'],
   likes: 10
},
{
   _id: ObjectId(7df78ad8902e)
   title: 'Neo4j Overview', 
   description: 'Neo4j is no sql database',
   by_user: 'Neo4j',
   url: 'http://www.neo4j.com',
   tags: ['neo4j', 'database', 'NoSQL'],
   likes: 750
},

假如想從上述集合中，歸納出一個(gè)列表，以顯示每個(gè)用戶寫的教程數(shù)量，需要像下面這樣使用 aggregate() 方法：

> db.mycol.aggregate([{$group : {_id : "$by_user", num_tutorial : {$sum : 1}}}])
{
   "result" : [
      {
         "_id" : "tutorials point",
         "num_tutorial" : 2
      },
      {
         "_id" : "Neo4j",
         "num_tutorial" : 1
      }
   ],
   "ok" : 1
}
>

假如用 SQL 來處理上述查詢，則需要使用這樣的命令：select by_user, count(*) from mycol group by by_user。

上例使用 by_user 字段來組合文檔，每遇到一次 by_user，就遞增之前的合計(jì)值。下面是聚合表達(dá)式列表。

管道的概念

在 UNIX 命令 Shell 中，管道（pipeline）概念指的是能夠在一些輸入上執(zhí)行一個(gè)操作，然后將輸出結(jié)果用作下一個(gè)命令的輸入。MongoDB 的聚合架構(gòu)也支持這種概念。管道中有很多階段（stage），在每一階段中，管道操作符都會(huì)將一組文檔作為輸入，產(chǎn)生一個(gè)結(jié)果文檔（或者管道終點(diǎn)所得到的最終 JSON 格式的文檔），然后再將其用在下一階段。

聚合架構(gòu)中可能采取的管道操作符有：

• $project 用來選取集合中一些特定字段。
• $match 過濾操作。減少用作下一階段輸入的文檔的數(shù)量。
• $group 如上所述，執(zhí)行真正的聚合操作。
• $sort 對(duì)文檔進(jìn)行排序。
• $skip 在一組文檔中，跳過指定數(shù)量的文檔。
• $limit 將查看文檔的數(shù)目限制為從當(dāng)前位置處開始的指定數(shù)目。
• $unwind 解開使用數(shù)組的文檔。當(dāng)使用數(shù)組時(shí)，數(shù)據(jù)處于預(yù)連接狀態(tài)，通過該操作，數(shù)據(jù)重新回歸為各個(gè)單獨(dú)的文檔的狀態(tài)。利用該階段性操作可增加下一階段性操作的文檔數(shù)量。