MongoDB學習day06--高級查詢aggregate聚合管道和nodejs操作aggregate

一、MongoDB聚合管道（Aggregation Pilpeline）

使用聚合管道可以對集合中的文檔進行變換和組合。

主要功能：表的關聯查詢、數據統計

二、aggregate 管道操作符與表達式

管道操作符：

sql 和 nosql 對比：

管道表達式：

管道操作符作為“鍵”,所對應的“值”叫做管道表達式。 

例如{$match:{status:"A"}}， $match 稱為管道操作符， 而 status:"A"稱為管道表達式，是管道操作符的操作數(Operand)。

三、數據模擬：

db.order.insert({"order_id":"1","uid":10,"trade_no":"111","all_price":100,"all_num":2})
db.order.insert({"order_id":"2","uid":7,"trade_no":"222","all_price":90,"all_num":2})
db.order.insert({"order_id":"3","uid":9,"trade_no":"333","all_price":20,"all_num":6})
db.order_item.insert({"order_id":"1","title":"商品鼠標 1","price":50,num:1})
db.order_item.insert({"order_id":"1","title":"商品鍵盤 2","price":50,num:1})
db.order_item.insert({"order_id":"1","title":"商品鍵盤 3","price":0,num:1})
db.order_item.insert({"order_id":"2","title":"牛奶","price":50,num:1})
db.order_item.insert({"order_id":"2","title":"酸奶","price":40,num:1})
db.order_item.insert({"order_id":"3","title":"礦泉水","price":2,num:5})
db.order_item.insert({"order_id":"3","title":"毛巾","price":10,num:1})

四、$project

修改文檔的結構，可以用來重命名、增加或者刪除文檔中的字段

例如：要求查找order只返回trade_no和all_price字段

db.order.aggregate([
　　{
　　　　$project:{ trade_no:1, all_price:1 }
　　}
])

五、$match

用於過濾文檔。類似where

db.order.aggregate([
　　{
　　　　$project:{ trade_no:1, all_price:1 }
　　},
　　{
　　　　$match:{"all_price":{$gte:90}}
　　}
])

六、$group

分組

統計每個訂單的訂單數量， 按照訂單號分組

db.order_item.aggregate(
[
　　{
　　　　$group: {_id: "$order_id", total: {$sum: "$num"}}
　　}
]

七、$sort

排序

-1：降序；1：升序

db.order.aggregate([
　　{
　　　　$project:{ trade_no:1, all_price:1 }
　　},
　　{
　　　　$match:{"all_price":{$gte:90}}
　　},
　　{
　　　　$sort:{"all_price":-1}
　　}
])

八、$limit

查詢前幾條

db.order.aggregate([
　　{
　　　　$project:{ trade_no:1, all_price:1 }
　　},
　　{
　　　　$match:{"all_price":{$gte:90}}
　　},
　　{
　　　　$sort:{"all_price":-1}
　　},
　　{
　　　　$limit:1
　　}
])

九、$skip

跳過幾條

db.order.aggregate([
　　{
　　　　$project:{ trade_no:1, all_price:1 }
　　},
　　{
　　　　$match:{"all_price":{$gte:90}}
　　},
　　{
　　　　$sort:{"all_price":-1}
　　},{
　　　　$skip:1
　　}
])

十、$lookup

表關聯查詢

db.order.aggregate([
　　{
　　　　$lookup:
　　　　　　{
　　　　　　　　from: "order_item", 　　//關聯表
　　　　　　　　localField: "order_id",　　//主表的字段
　　　　　　　　foreignField: "order_id",　　//關聯表的字段
　　　　　　　　as: "items"　　//存儲的字段
　　　　　　}
　　}
])

當然也可以使用其他操作符

db.order.aggregate([
　　{
　　　　$lookup:{
　　　　　　from: "order_item",
　　　　　　localField: "order_id",
　　　　　　foreignField: "order_id",
　　　　　　as: "items"
　　　　　}
　　},
　　{
　　　　$match:{"all_price":{$gte:90}}
　　}
])

db.order.aggregate([
　　{
　　　　$lookup:
　　　　{
　　　　　　from: "order_item",
　　　　　　localField: "order_id",
　　　　　　foreignField: "order_id",
　　　　　　as: "items"
　　　　}
　　},
　　{
　　　　$project:{ trade_no:1, all_price:1,items:1 }
　　},
　　{
　　　　$match:{"all_price":{$gte:90}}
　　},
　　{
　　　　$sort:{"all_price":-1}
　　},
])

十一、nodejs操作aggregate聚合管道

var MongoClient = require('mongodb').MongoClient;


//定義連接數據庫的地址

const  url = 'mongodb://localhost:27017/';
var dbName = 'eggcms';

//連接數據庫
MongoClient.connect(url,(err,client)=>{

        if(err){
             console.log('數據連接失敗');
             return false;
         }
         let db=client.db(dbName);   /*獲取db對象*/


         db.collection("order").aggregate([
                {
                    $lookup:
                    {
                        from: "order_item",
                        localField: "order_id",
                        foreignField: "order_id",
                        as: "items"
                    }
                },
                {
                    $match:{"all_price":{$gte:90}}
                }

            ]).toArray(function(err,docs){
                 console.log(docs)
            })


})