常用的MongoDB查詢(xún)語(yǔ)句的示例代碼
背景
最近做了幾個(gè)規(guī)則邏輯。用到mongo查詢(xún)比較多，就是查詢(xún)交易信息跑既定規(guī)則篩選出交易商戶，使用聚合管道進(jìn)行統(tǒng)計(jì)和取出簡(jiǎn)單處理后的數(shù)據(jù)，用SQL代替業(yè)務(wù)代碼邏輯的判斷。
方法
MongoDB聚合使用aggregate，聚合管道采取自動(dòng)向下子執(zhí)行方式，基本語(yǔ)法格式：
db.COLLECTION_NAME.aggregate(AGGREGATE_OPERATION)
聚合框架中常用的操作:
- $project：修改輸入文檔的結(jié)構(gòu)?？梢杂脕?lái)重命名、增加或刪除域，也可以用于創(chuàng)建計(jì)算結(jié)果以及嵌套文檔。
- match：用于過(guò)濾數(shù)據(jù)，只輸出符合條件的文檔。match：用于過(guò)濾數(shù)據(jù)，只輸出符合條件的文檔。match使用MongoDB的標(biāo)準(zhǔn)查詢(xún)操作。
- $limit：用來(lái)限制MongoDB聚合管道返回的文檔數(shù)。
- $skip：在聚合管道中跳過(guò)指定數(shù)量的文檔，并返回余下的文檔。
- $unwind：將文檔中的某一個(gè)數(shù)組類(lèi)型字段拆分成多條，每條包含數(shù)組中的一個(gè)值。
- $group：將集合中的文檔分組，可用于統(tǒng)計(jì)結(jié)果。
- $sort：將輸入文檔排序后輸出。
- $geoNear：輸出接近某一地理位置的有序文檔。
| 表達(dá)式 | 描述 | 實(shí)例 |
|---|---|---|
| $sum | 計(jì)算總和。 | db.mycol.aggregate([{\(group : {_id : "\)by_user", num_tutorial : {likes"}}}]) |
| $avg | 計(jì)算平均值 | db.mycol.aggregate([{\(group : {_id : "\)by_user", num_tutorial : {likes"}}}]) |
| $min | 獲取集合中所有文檔對(duì)應(yīng)值得最小值。 | db.mycol.aggregate([{\(group : {_id : "\)by_user", num_tutorial : {likes"}}}]) |
| $max | 獲取集合中所有文檔對(duì)應(yīng)值得最大值。 | db.mycol.aggregate([{\(group : {_id : "\)by_user", num_tutorial : {likes"}}}]) |
| $push | 在結(jié)果文檔中插入值到一個(gè)數(shù)組中。 | db.mycol.aggregate([{\(group : {_id : "\)by_user", url : {url"}}}]) |
| $addToSet | 在結(jié)果文檔中插入值到一個(gè)數(shù)組中，但不創(chuàng)建副本。 | db.mycol.aggregate([{\(group : {_id : "\)by_user", url : {url"}}}]) |
| $first | 根據(jù)資源文檔的排序獲取第一個(gè)文檔數(shù)據(jù)。 | db.mycol.aggregate([{\(group : {_id : "\)by_user", first_url : {url"}}}]) |
| $last | 根據(jù)資源文檔的排序獲取最后一個(gè)文檔數(shù)據(jù) | db.mycol.aggregate([{\(group : {_id : "\)by_user", last_url : {url"}}}]) |
查詢(xún)示例
示例一
部分字段說(shuō)明：transAmt:交易金額，transType:交易類(lèi)型，transTime:交易時(shí)間，mercNum:商戶編號(hào)
查詢(xún)交易信息，交易商戶昨天交易筆數(shù)大于三百，交易金額累加大于三百萬(wàn)，這里現(xiàn)根據(jù)$match將交易信息篩選出來(lái)，然后使用$group根據(jù)商戶編號(hào)分組，統(tǒng)計(jì)交易筆數(shù)和累加交易金額，將分組結(jié)果判斷匹配交易筆數(shù)大于三百，交易金額大于三百萬(wàn)。
db.getCollection('box_order').aggregate([
{
$match: {
"transTime":{$gte:ISODate("2020-01-03T00:00:00.000Z"),$lt:ISODate("2020-01-10T00:00:00.000Z")},
"transType":"consume",
"transStatus":{$in:["tsProcessing","success"]}
}
},
{
$group: {
"_id": "$mercNum",
"count": {"$sum": 1},
"totalAmt": {"$sum": "$transAmt"}
}
},
{
$match: {
"count": {"$gte": 300},
"totalAmt": {"$gte": 3000000}
}
}
])
示例二
部分字段說(shuō)明：cardNo:交易卡號(hào)，transType:交易類(lèi)型，transTime:交易時(shí)間，mercNum:商戶編號(hào)
查詢(xún)時(shí)間段內(nèi)指定卡號(hào)下的交易商戶信息。
根據(jù)卡號(hào)和交易時(shí)間將交易數(shù)據(jù)查出來(lái)，然后只顯示商戶號(hào)和卡號(hào)兩列字段，根據(jù)商戶號(hào)和卡號(hào)分組去重，再根據(jù)卡號(hào)分組，將商戶號(hào)轉(zhuǎn)化成一個(gè)字段變成數(shù)組。
db.getCollection('order_202011').aggregate([
{
"$match": {
"detailInfo.cardNo": {
"$in": [
"YtCZ7KhCVG5xerKUg8bzJhVAjW/hWAWj",
"cQ7QQ0yCVW6LhHtJNVRq2A==",
"6KDpHmQ9s+0SQAGAUyLJ4A==",
"cQ7QQ0yCVW7iSegn8uqIfg==",
"ZEOcXdI4rfvswAz7dQ80hw==",
"6KDpHmQ9s+2Nz61PPuOamw=="
]
},
"baseInfo.transTime": {
"$gte": new Date(2020,10,01),
"$lt": new Date(2020,10,24)
}
}
},
{
"$project": {
"merchantInfo.mercNum": 1,
"detailInfo.cardNo": 1
}
},
{
"$group": {
"_id": {
"mercNum": "$merchantInfo.mercNum",
"cardNo": "$detailInfo.cardNo"
}
}
},
{
"$group": {
"_id": "$_id.cardNo",
"mercNums": {
"$push": "$_id.mercNum"
}
}
}
])
示例三
根據(jù)指定商戶和其他條件查詢(xún)交易信息，根據(jù)卡號(hào)分組并組裝成一個(gè)字段的集合，最后篩選掉id只保留cardNos數(shù)組
db.getCollection('box_order_fxq_202104').aggregate([
{
"$match": {
"mercNum": "M15201812030753174730",
"transTime": {
"$gte": ISODate("2021-04-17T16:00:00.000Z"),
"$lt": ISODate("2021-04-18T16:00:00.000Z")
},
"mercLevel": {
"$in": [
"C",
"D",
"E"
]
},
"payType": "POSPAY",
"transType": "consume",
"cardType": "2"
}
},
{
"$group": {
"_id": null,
"cardNos": {
"$push": "$cardNo" //$addToSet
}
}
},
{
"$project":{
"cardNos":1,"_id":0
}
}
])
查詢(xún)結(jié)果：
{
"cardNos" : [
"n2IwHHhfEAJcm6RFsoNPcBVAjW/hWAWj",
"n2IwHHhfEAJcm6RFsoNPcBVAjW/hWAWj"
]
}
示例四
根據(jù)時(shí)間查詢(xún)交易信息后，根據(jù)商戶號(hào)分組，并將第一個(gè)交易信息存放入data字段中。（如果是需要全部的商戶交易信息那么將$first修改為$push）
db.getCollection('order').aggregate([
{
"$match": {
"startTrxTime": {
"$gte": ISODate("2021-07-20T16:00:00.000Z"),
"$lt": ISODate("2021-07-21T16:00:00.000Z")
}
}
},
{
"$group": {
"_id": "$subMerchantNo",
'data':{'$first': '$$ROOT'} //$push
}
},
{
"$sort": {
"_id": 1
}
}
])
尾言
最近那個(gè)到查詢(xún)的大差不差，要注意的都是一些小改動(dòng)，一般情況正常查就可以。后續(xù)有什么不一樣的會(huì)繼續(xù)補(bǔ)充。先到這里
到此這篇關(guān)于整理最近用的MongoDB查詢(xún)語(yǔ)句的文章就介紹到這了,更多相關(guān)Mongo查詢(xún)語(yǔ)句內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！
相關(guān)文章
【MongoDB for Java】Java操作MongoDB數(shù)據(jù)庫(kù)
本篇文章現(xiàn)在我們就用Java來(lái)操作MongoDB的數(shù)據(jù)。小編覺(jué)得挺不錯(cuò)的，現(xiàn)在分享給大家，也給大家做個(gè)參考。一起跟隨小編過(guò)來(lái)看看吧2016-12-12
Mongo復(fù)制集同步驗(yàn)證的實(shí)例詳解
這篇文章主要介紹了mongo復(fù)制集同步驗(yàn)證的實(shí)例詳解的相關(guān)資料,這里提供實(shí)現(xiàn)的方法及示例代碼，幫助大家學(xué)習(xí)理解，需要的朋友可以參考下2017-07-07
這篇文章主要介紹了Windows中把MongoDB加入到本地服務(wù)的方法,即把MongoDB加入到Windows服務(wù)中隨機(jī)啟動(dòng),需要的朋友可以參考下2014-10-10
MongoDB擁有經(jīng)典的Sharding架構(gòu)能將數(shù)據(jù)分散存儲(chǔ)在數(shù)個(gè)服務(wù)器上以作集群,這里我們就來(lái)看一下MongoDB的分片集群基本配置教程:2016-07-07
這篇文章主要給大家介紹了關(guān)于Mongodb副本集和分片的相關(guān)資料，文中通過(guò)示例代碼介紹的非常詳細(xì)，對(duì)大家學(xué)習(xí)或者使用Mongodb具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面來(lái)一起學(xué)習(xí)學(xué)習(xí)吧2019-08-08
Mongodb使用$pop刪除數(shù)組中元素的操作指南
本文描述怎樣從Mongodb的文檔數(shù)組字段中,使用$pop刪除數(shù)組中的元素,文中通過(guò)代碼示例給大家講解的非常詳細(xì),對(duì)大家的學(xué)習(xí)或工作有一定的幫助,需要的朋友可以參考下2024-06-06
MongoDB查詢(xún)字段沒(méi)有創(chuàng)建索引導(dǎo)致的連接超時(shí)異常解案例分享
這篇文章主要介紹了MongoDB查詢(xún)字段沒(méi)有創(chuàng)建索引導(dǎo)致的連接超時(shí)異常解案例分享,本文是生產(chǎn)環(huán)境下總結(jié)而來(lái),需要的朋友可以參考下2014-10-10
最近項(xiàng)目在使用MongoDB作為圖片和文檔的存儲(chǔ)數(shù)據(jù)庫(kù)，為啥不直接存MySQL里，還要搭個(gè)MongoDB集群，麻不麻煩？讓我們一起，一探究竟，繼續(xù)學(xué)習(xí)MongoDB高可用和片鍵策略，實(shí)現(xiàn)快速入門(mén)，感興趣的小伙伴可以參考閱讀2023-04-04
Mongoose find 查詢(xún)返回json數(shù)據(jù)處理方式
這篇文章主要介紹了Mongoose find 查詢(xún)返回json數(shù)據(jù)處理方式，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方，望不吝賜教2023-04-04
基于MongoDB數(shù)據(jù)庫(kù)的數(shù)據(jù)類(lèi)型和$type操作符詳解
下面小編就為大家?guī)?lái)一篇基于MongoDB數(shù)據(jù)庫(kù)的數(shù)據(jù)類(lèi)型和$type操作符詳解。小編覺(jué)得挺不錯(cuò)的，現(xiàn)在就分享給大家，也給大家做個(gè)參考。一起跟隨小編過(guò)來(lái)看看吧2017-07-07