MongoDB学习day06--高级查询aggregate聚合管道和nodejs操做aggregate

1、MongoDB聚合管道（Aggregation Pilpeline）

使用聚合管道能够对集合中的文档进行变换和组合。

主要功能：表的关联查询、数据统计

2、aggregate 管道操做符与表达式

管道操做符：

sql 和 nosql 对比：

管道表达式：

管道操做符做为“键”,所对应的“值”叫作管道表达式。 

例如{$match:{status:"A"}}， $match 称为管道操做符， 而 status:"A"称为管道表达式，是管道操做符的操做数(Operand)。

3、数据模拟：

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

4、$project

修改文档的结构，能够用来重命名、增长或者删除文档中的字段

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

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

5、$match

用于过滤文档。相似where

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

6、$group

分组

统计每一个订单的订单数量， 按照订单号分组

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

7、$sort

排序

-1：降序；1：升序

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

8、$limit

查询前几条

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

9、$skip

跳过几条

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

10、$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}
　　},
])

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


})