欧美bbbwbbbw肥妇,免费乱码人妻系列日韩,一级黄片

常用的MongoDB查詢語句的示例代碼

 更新時間:2021年07月24日 09:44:11   作者:青衫染紅塵  
最近做了幾個規(guī)則邏輯。用到mongo查詢比較多,就是查詢交易信息跑既定規(guī)則篩選出交易商戶,使用聚合管道進行統(tǒng)計和取出簡單處理后的數據,用SQL代替業(yè)務代碼邏輯的判斷,本文給大家介紹Mongodb查詢語句的示例代碼,一起看看吧

背景

最近做了幾個規(guī)則邏輯。用到mongo查詢比較多,就是查詢交易信息跑既定規(guī)則篩選出交易商戶,使用聚合管道進行統(tǒng)計和取出簡單處理后的數據,用SQL代替業(yè)務代碼邏輯的判斷。

方法

MongoDB聚合使用aggregate,聚合管道采取自動向下子執(zhí)行方式,基本語法格式:

db.COLLECTION_NAME.aggregate(AGGREGATE_OPERATION)

聚合框架中常用的操作:

  • $project:修改輸入文檔的結構??梢杂脕碇孛?、增加或刪除域,也可以用于創(chuàng)建計算結果以及嵌套文檔。
  • match:用于過濾數據,只輸出符合條件的文檔。match:用于過濾數據,只輸出符合條件的文檔。match使用MongoDB的標準查詢操作。
  • $limit:用來限制MongoDB聚合管道返回的文檔數。
  • $skip:在聚合管道中跳過指定數量的文檔,并返回余下的文檔。
  • $unwind:將文檔中的某一個數組類型字段拆分成多條,每條包含數組中的一個值。
  • $group:將集合中的文檔分組,可用于統(tǒng)計結果。
  • $sort:將輸入文檔排序后輸出。
  • $geoNear:輸出接近某一地理位置的有序文檔。

表達式 描述 實例
$sum 計算總和。 db.mycol.aggregate([{\(group : {_id : "\)by_user", num_tutorial : {likes"}}}])
$avg 計算平均值 db.mycol.aggregate([{\(group : {_id : "\)by_user", num_tutorial : {likes"}}}])
$min 獲取集合中所有文檔對應值得最小值。 db.mycol.aggregate([{\(group : {_id : "\)by_user", num_tutorial : {likes"}}}])
$max 獲取集合中所有文檔對應值得最大值。 db.mycol.aggregate([{\(group : {_id : "\)by_user", num_tutorial : {likes"}}}])
$push 在結果文檔中插入值到一個數組中。 db.mycol.aggregate([{\(group : {_id : "\)by_user", url : {url"}}}])
$addToSet 在結果文檔中插入值到一個數組中,但不創(chuàng)建副本。 db.mycol.aggregate([{\(group : {_id : "\)by_user", url : {url"}}}])
$first 根據資源文檔的排序獲取第一個文檔數據。 db.mycol.aggregate([{\(group : {_id : "\)by_user", first_url : {url"}}}])
$last 根據資源文檔的排序獲取最后一個文檔數據 db.mycol.aggregate([{\(group : {_id : "\)by_user", last_url : {url"}}}])

查詢示例

示例一

部分字段說明:transAmt:交易金額,transType:交易類型,transTime:交易時間,mercNum:商戶編號

查詢交易信息,交易商戶昨天交易筆數大于三百,交易金額累加大于三百萬,這里現根據$match將交易信息篩選出來,然后使用$group根據商戶編號分組,統(tǒng)計交易筆數和累加交易金額,將分組結果判斷匹配交易筆數大于三百,交易金額大于三百萬。

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

示例二

部分字段說明:cardNo:交易卡號,transType:交易類型,transTime:交易時間,mercNum:商戶編號

查詢時間段內指定卡號下的交易商戶信息。

根據卡號和交易時間將交易數據查出來,然后只顯示商戶號和卡號兩列字段,根據商戶號和卡號分組去重,再根據卡號分組,將商戶號轉化成一個字段變成數組。

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

示例三

根據指定商戶和其他條件查詢交易信息,根據卡號分組并組裝成一個字段的集合,最后篩選掉id只保留cardNos數組

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

查詢結果:

{
    "cardNos" : [
        "n2IwHHhfEAJcm6RFsoNPcBVAjW/hWAWj",
        "n2IwHHhfEAJcm6RFsoNPcBVAjW/hWAWj"
    ]
}

示例四

根據時間查詢交易信息后,根據商戶號分組,并將第一個交易信息存放入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
        }
    }
])

尾言

最近那個到查詢的大差不差,要注意的都是一些小改動,一般情況正常查就可以。后續(xù)有什么不一樣的會繼續(xù)補充。先到這里

到此這篇關于整理最近用的MongoDB查詢語句的文章就介紹到這了,更多相關Mongo查詢語句內容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關文章希望大家以后多多支持腳本之家!

相關文章

  • 【MongoDB for Java】Java操作MongoDB數據庫

    【MongoDB for Java】Java操作MongoDB數據庫

    本篇文章現在我們就用Java來操作MongoDB的數據。小編覺得挺不錯的,現在分享給大家,也給大家做個參考。一起跟隨小編過來看看吧
    2016-12-12
  • Mongo復制集同步驗證的實例詳解

    Mongo復制集同步驗證的實例詳解

    這篇文章主要介紹了mongo復制集同步驗證的實例詳解的相關資料,這里提供實現的方法及示例代碼,幫助大家學習理解,需要的朋友可以參考下
    2017-07-07
  • MongoDB加入到Windows服務的方法

    MongoDB加入到Windows服務的方法

    這篇文章主要介紹了Windows中把MongoDB加入到本地服務的方法,即把MongoDB加入到Windows服務中隨機啟動,需要的朋友可以參考下
    2014-10-10
  • MongoDB的分片集群基本配置教程

    MongoDB的分片集群基本配置教程

    MongoDB擁有經典的Sharding架構能將數據分散存儲在數個服務器上以作集群,這里我們就來看一下MongoDB的分片集群基本配置教程:
    2016-07-07
  • Mongodb副本集和分片示例詳解

    Mongodb副本集和分片示例詳解

    這篇文章主要給大家介紹了關于Mongodb副本集和分片的相關資料,文中通過示例代碼介紹的非常詳細,對大家學習或者使用Mongodb具有一定的參考學習價值,需要的朋友們下面來一起學習學習吧
    2019-08-08
  • Mongodb使用$pop刪除數組中元素的操作指南

    Mongodb使用$pop刪除數組中元素的操作指南

    本文描述怎樣從Mongodb的文檔數組字段中,使用$pop刪除數組中的元素,文中通過代碼示例給大家講解的非常詳細,對大家的學習或工作有一定的幫助,需要的朋友可以參考下
    2024-06-06
  • MongoDB查詢字段沒有創(chuàng)建索引導致的連接超時異常解案例分享

    MongoDB查詢字段沒有創(chuàng)建索引導致的連接超時異常解案例分享

    這篇文章主要介紹了MongoDB查詢字段沒有創(chuàng)建索引導致的連接超時異常解案例分享,本文是生產環(huán)境下總結而來,需要的朋友可以參考下
    2014-10-10
  • MongoDB高可用與分片

    MongoDB高可用與分片

    最近項目在使用MongoDB作為圖片和文檔的存儲數據庫,為啥不直接存MySQL里,還要搭個MongoDB集群,麻不麻煩?讓我們一起,一探究竟,繼續(xù)學習MongoDB高可用和片鍵策略,實現快速入門,感興趣的小伙伴可以參考閱讀
    2023-04-04
  • Mongoose find 查詢返回json數據處理方式

    Mongoose find 查詢返回json數據處理方式

    這篇文章主要介紹了Mongoose find 查詢返回json數據處理方式,具有很好的參考價值,希望對大家有所幫助。如有錯誤或未考慮完全的地方,望不吝賜教
    2023-04-04
  • 基于MongoDB數據庫的數據類型和$type操作符詳解

    基于MongoDB數據庫的數據類型和$type操作符詳解

    下面小編就為大家?guī)硪黄贛ongoDB數據庫的數據類型和$type操作符詳解。小編覺得挺不錯的,現在就分享給大家,也給大家做個參考。一起跟隨小編過來看看吧
    2017-07-07

最新評論