MongoDB關(guān)聯(lián)(聚合)查詢,關(guān)聯(lián)集合篩選

場景:商品列表中包含訂單統(tǒng)計(jì)信息,商品和訂單是一對多的關(guān)系
注: 這里把商品和訂單分成兩個(gè)集合舆吮,僅做演示揭朝!具體場景,具體分析

image

插入數(shù)據(jù)

創(chuàng)建goods和orders集合

goods

db.goods.insert([
    {name: 'iphone XS', price: 8999}, 
    {name: '小米 9', price: 3299}, 
    {name: '華為 p30 Pro', price: 4988}
])
image

orders

/**
* goodsId為剛才goods生成的_id
* idDelete: 0 未刪除  1 已刪除   
*/
db.orders.insert([
    {sum: 1, goodsId: ObjectId('5d522fd20ec3b11bf17a91e2'), isDelete: 0}, 
    {sum: 2, goodsId: ObjectId('5d522fd20ec3b11bf17a91e2'), isDelete: 0}, 
    {sum: 1, goodsId: ObjectId('5d522fd20ec3b11bf17a91e2'), isDelete: 1}, 
    {sum: 1, goodsId: ObjectId('5d5230870ec3b11bf17a91e4'), isDelete: 0}, 
    {sum: 1, goodsId: ObjectId('5d5230870ec3b11bf17a91e5'), isDelete: 0}, 
    {sum: 1, goodsId: ObjectId('5d5230870ec3b11bf17a91e5'), isDelete: 1}, 
])

// 在mongoose的schame中定義為:
goodsId:{
            type: mongoose.Schema.ObjectId,
            ref: 'Article'
        }

image

查詢

1色冀、查詢某一個(gè)商品的所有訂單

// 查詢語句
db.orders.find({goodsId: ObjectId("5d522fd20ec3b11bf17a91e2")})

// 結(jié)果
// 1
{
    "_id": ObjectId("5d5376580ec3b11bf17a91ec"),
    "sum": 1,
    "goodsId": ObjectId("5d522fd20ec3b11bf17a91e2"),
    "isDelete": 0
}

// 2
{
    "_id": ObjectId("5d5376580ec3b11bf17a91ed"),
    "sum": 2,
    "goodsId": ObjectId("5d522fd20ec3b11bf17a91e2"),
    "isDelete": 0
}

// 3
{
    "_id": ObjectId("5d5376580ec3b11bf17a91ee"),
    "sum": 1,
    "goodsId": ObjectId("5d522fd20ec3b11bf17a91e2"),
    "isDelete": 1
}

// 過濾已刪除的訂單
db.orders.find({goodsId: ObjectId("5d522fd20ec3b11bf17a91e2"), isDelete: 0})

// 結(jié)果
// 1
{
    "_id": ObjectId("5d5376580ec3b11bf17a91ec"),
    "sum": 1,
    "goodsId": ObjectId("5d522fd20ec3b11bf17a91e2"),
    "isDelete": 0
}

// 2
{
    "_id": ObjectId("5d5376580ec3b11bf17a91ed"),
    "sum": 2,
    "goodsId": ObjectId("5d522fd20ec3b11bf17a91e2"),
    "isDelete": 0
}

2潭袱、查詢所有商品對應(yīng)的所有訂單

這里使用的是MongoDB中的aggregate

查詢所有商品以及對應(yīng)的訂單

// 關(guān)聯(lián)查詢
db.goods.aggregate([
        {
            $lookup: {
                from: "orders", // 要關(guān)聯(lián)查詢的集合
                localField: "_id", // goods集合中的_id
                foreignField: "goodsId", // 要查詢的集合的 關(guān)聯(lián)id
                as: "child"
            }
        }
    ])

// 結(jié)果
// 1
{
    "_id": ObjectId("5d522fd20ec3b11bf17a91e2"),
    "name": "iphone XS",
    "price": 8999,
    "child": [
        {
            "_id": ObjectId("5d5376580ec3b11bf17a91ec"),
            "sum": 1,
            "goodsId": ObjectId("5d522fd20ec3b11bf17a91e2"),
            "isDelete": 0
        },
        {
            "_id": ObjectId("5d5376580ec3b11bf17a91ed"),
            "sum": 2,
            "goodsId": ObjectId("5d522fd20ec3b11bf17a91e2"),
            "isDelete": 0
        },
        {
            "_id": ObjectId("5d5376580ec3b11bf17a91ee"),
            "sum": 1,
            "goodsId": ObjectId("5d522fd20ec3b11bf17a91e2"),
            "isDelete": 1
        }
    ]
}

// 2
{
    "_id": ObjectId("5d5230870ec3b11bf17a91e4"),
    "name": "小米 9",
    "price": 3299,
    "child": [
        {
            "_id": ObjectId("5d5376580ec3b11bf17a91ef"),
            "sum": 1,
            "goodsId": ObjectId("5d5230870ec3b11bf17a91e4"),
            "isDelete": 0
        }
    ]
}

// 3
{
    "_id": ObjectId("5d5230870ec3b11bf17a91e5"),
    "name": "華為 p30 Pro",
    "price": 4988,
    "child": [
        {
            "_id": ObjectId("5d5376580ec3b11bf17a91f0"),
            "sum": 1,
            "goodsId": ObjectId("5d5230870ec3b11bf17a91e5"),
            "isDelete": 0
        },
        {
            "_id": ObjectId("5d5376580ec3b11bf17a91f1"),
            "sum": 1,
            "goodsId": ObjectId("5d5230870ec3b11bf17a91e5"),
            "isDelete": 1
        }
    ]
}


查詢所有商品以及對應(yīng)的訂單數(shù)

// 關(guān)聯(lián)查詢
db.goods.aggregate([
        {
            $lookup: {
                from: "orders",
                localField: "_id",
                foreignField: "goodsId",
                as: "child"
            }
        },
        {
            $project: {
                name:1, // 篩選要返回的數(shù)據(jù),值為:0不返回锋恬,1返回
                price:1,
                orderNm: { 
                     "$size": "$child" 
                }
            }
        }
    ])
    
//結(jié)果
// 1
{
    "_id": ObjectId("5d522fd20ec3b11bf17a91e2"),
    "name": "iphone XS",
    "price": 8999,
    "orderNm": NumberInt("3")
}

// 2
{
    "_id": ObjectId("5d5230870ec3b11bf17a91e4"),
    "name": "小米 9",
    "price": 3299,
    "orderNm": NumberInt("1")
}

// 3
{
    "_id": ObjectId("5d5230870ec3b11bf17a91e5"),
    "name": "華為 p30 Pro",
    "price": 4988,
    "orderNm": NumberInt("2")
}

查詢單價(jià)大于5000商品以及對應(yīng)的訂單

// 關(guān)聯(lián)查詢屯换,加入刪選條件
db.goods.aggregate([
        {
            $match: {
                price: {
                    $gt : 5000 
                    }
                }
            },
        {
            $lookup: {
                from: "orders",
                localField: "_id",
                foreignField: "goodsId",
                as: "child"
            }
        }
    ])

查詢所有商品以及未刪除的訂單,是對關(guān)聯(lián)集合的篩選

因?yàn)槭菍﹃P(guān)聯(lián)集合的篩選与学,所以不能簡單通過match去處理

db.goods.aggregate([
        {
            $lookup: {
               from: "orders",
                let: {
                    isDelete: "$isDelete", // 定義要篩選的條件
                    id: "$_id", // 當(dāng)前集合的_id
                },
                pipeline: [{
                    "$match": {
                        isDelete: 0, // 篩選條件彤悔,未刪除的訂單
                        $expr: {
                            $eq: ["$$id","$goodsId"] // 商品對應(yīng)的訂單
                        }
                    },
                }],
                as: "child",
            }
        }
    ])

// 結(jié)果
// 1
{
    "_id": ObjectId("5d522fd20ec3b11bf17a91e2"),
    "name": "iphone XS",
    "price": 8999,
    "child": [
        {
            "_id": ObjectId("5d5376580ec3b11bf17a91ec"),
            "sum": 1,
            "goodsId": ObjectId("5d522fd20ec3b11bf17a91e2"),
            "isDelete": 0
        },
        {
            "_id": ObjectId("5d5376580ec3b11bf17a91ed"),
            "sum": 2,
            "goodsId": ObjectId("5d522fd20ec3b11bf17a91e2"),
            "isDelete": 0
        }
    ]
}

// 2
{
    "_id": ObjectId("5d5230870ec3b11bf17a91e4"),
    "name": "小米 9",
    "price": 3299,
    "child": [
        {
            "_id": ObjectId("5d5376580ec3b11bf17a91ef"),
            "sum": 1,
            "goodsId": ObjectId("5d5230870ec3b11bf17a91e4"),
            "isDelete": 0
        }
    ]
}

// 3
{
    "_id": ObjectId("5d5230870ec3b11bf17a91e5"),
    "name": "華為 p30 Pro",
    "price": 4988,
    "child": [
        {
            "_id": ObjectId("5d5376580ec3b11bf17a91f0"),
            "sum": 1,
            "goodsId": ObjectId("5d5230870ec3b11bf17a91e5"),
            "isDelete": 0
        }
    ]
}
最后編輯于
?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請聯(lián)系作者
  • 序言:七十年代末,一起剝皮案震驚了整個(gè)濱河市索守,隨后出現(xiàn)的幾起案子晕窑,更是在濱河造成了極大的恐慌,老刑警劉巖卵佛,帶你破解...
    沈念sama閱讀 206,723評論 6 481
  • 序言:濱河連續(xù)發(fā)生了三起死亡事件杨赤,死亡現(xiàn)場離奇詭異,居然都是意外死亡截汪,警方通過查閱死者的電腦和手機(jī)疾牲,發(fā)現(xiàn)死者居然都...
    沈念sama閱讀 88,485評論 2 382
  • 文/潘曉璐 我一進(jìn)店門,熙熙樓的掌柜王于貴愁眉苦臉地迎上來衙解,“玉大人阳柔,你說我怎么就攤上這事◎韭停” “怎么了盔沫?”我有些...
    開封第一講書人閱讀 152,998評論 0 344
  • 文/不壞的土叔 我叫張陵医咨,是天一觀的道長。 經(jīng)常有香客問我架诞,道長拟淮,這世上最難降的妖魔是什么? 我笑而不...
    開封第一講書人閱讀 55,323評論 1 279
  • 正文 為了忘掉前任谴忧,我火速辦了婚禮很泊,結(jié)果婚禮上,老公的妹妹穿的比我還像新娘沾谓。我一直安慰自己委造,他們只是感情好,可當(dāng)我...
    茶點(diǎn)故事閱讀 64,355評論 5 374
  • 文/花漫 我一把揭開白布均驶。 她就那樣靜靜地躺著昏兆,像睡著了一般。 火紅的嫁衣襯著肌膚如雪妇穴。 梳的紋絲不亂的頭發(fā)上爬虱,一...
    開封第一講書人閱讀 49,079評論 1 285
  • 那天,我揣著相機(jī)與錄音腾它,去河邊找鬼跑筝。 笑死,一個(gè)胖子當(dāng)著我的面吹牛瞒滴,可吹牛的內(nèi)容都是我干的曲梗。 我是一名探鬼主播,決...
    沈念sama閱讀 38,389評論 3 400
  • 文/蒼蘭香墨 我猛地睜開眼妓忍,長吁一口氣:“原來是場噩夢啊……” “哼虏两!你這毒婦竟也來了?” 一聲冷哼從身側(cè)響起世剖,我...
    開封第一講書人閱讀 37,019評論 0 259
  • 序言:老撾萬榮一對情侶失蹤定罢,失蹤者是張志新(化名)和其女友劉穎,沒想到半個(gè)月后搁廓,有當(dāng)?shù)厝嗽跇淞掷锇l(fā)現(xiàn)了一具尸體引颈,經(jīng)...
    沈念sama閱讀 43,519評論 1 300
  • 正文 獨(dú)居荒郊野嶺守林人離奇死亡耕皮,尸身上長有42處帶血的膿包…… 初始之章·張勛 以下內(nèi)容為張勛視角 年9月15日...
    茶點(diǎn)故事閱讀 35,971評論 2 325
  • 正文 我和宋清朗相戀三年境蜕,在試婚紗的時(shí)候發(fā)現(xiàn)自己被綠了。 大學(xué)時(shí)的朋友給我發(fā)了我未婚夫和他白月光在一起吃飯的照片凌停。...
    茶點(diǎn)故事閱讀 38,100評論 1 333
  • 序言:一個(gè)原本活蹦亂跳的男人離奇死亡粱年,死狀恐怖,靈堂內(nèi)的尸體忽然破棺而出罚拟,到底是詐尸還是另有隱情台诗,我是刑警寧澤完箩,帶...
    沈念sama閱讀 33,738評論 4 324
  • 正文 年R本政府宣布,位于F島的核電站拉队,受9級特大地震影響弊知,放射性物質(zhì)發(fā)生泄漏。R本人自食惡果不足惜粱快,卻給世界環(huán)境...
    茶點(diǎn)故事閱讀 39,293評論 3 307
  • 文/蒙蒙 一秩彤、第九天 我趴在偏房一處隱蔽的房頂上張望。 院中可真熱鬧事哭,春花似錦漫雷、人聲如沸。這莊子的主人今日做“春日...
    開封第一講書人閱讀 30,289評論 0 19
  • 文/蒼蘭香墨 我抬頭看了看天上的太陽。三九已至谤辜,卻和暖如春蓄坏,著一層夾襖步出監(jiān)牢的瞬間,已是汗流浹背每辟。 一陣腳步聲響...
    開封第一講書人閱讀 31,517評論 1 262
  • 我被黑心中介騙來泰國打工剑辫, 沒想到剛下飛機(jī)就差點(diǎn)兒被人妖公主榨干…… 1. 我叫王不留,地道東北人渠欺。 一個(gè)月前我還...
    沈念sama閱讀 45,547評論 2 354
  • 正文 我出身青樓妹蔽,卻偏偏與公主長得像,于是被迫代替她去往敵國和親挠将。 傳聞我的和親對象是個(gè)殘疾皇子胳岂,可洞房花燭夜當(dāng)晚...
    茶點(diǎn)故事閱讀 42,834評論 2 345