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)
            })


})