表單生成器(Form Builder)之mongodb表單數據查詢——統計查詢求和

来源:https://www.cnblogs.com/du-blog/archive/2019/11/12/11840660.html
-Advertisement-
Play Games

上一篇筆記僅是記錄了一下簡單的關聯查詢，根據筆記中的場景：將某一車輛關聯的耗損記錄全部放在了一個欄位當中。不知道現在中有沒有這種場景，我們的應用中沒有類似的場景，可能我們更關註的是某車輛的總耗損金額和總營收金額、總里程數等，因此這篇筆記記錄一下怎麼得到這些數據。要想獲取這些記錄我們首先想到的就是先按 ...


　　上一篇筆記僅是記錄了一下簡單的關聯查詢，根據筆記中的場景：將某一車輛關聯的耗損記錄全部放在了一個欄位當中。不知道現在中有沒有這種場景，我們的應用中沒有類似的場景，可能我們更關註的是某車輛的總耗損金額和總營收金額、總里程數等，因此這篇筆記記錄一下怎麼得到這些數據。要想獲取這些記錄我們首先想到的就是先按照車輛ID分組之後再對指定欄位求和，可能是先入為主的原因（有了上一篇筆記），我沒有按照傳統的思路走下去，而是想著看看能不能在上一篇筆記的基礎之上得到想要的結果。

　　我們沿著這條路在分析一下，車輛相關的耗損和營收都可以放到一個欄位中。也就是說我們不用分組了，車輛相關的耗損和營收記錄都冗餘到了車輛信息記錄中，那麼接下來就是對數組中的某一欄位或者多個進行求和了……查了半天並沒有找到類似$sum這樣的聚合管道可以對數組中的欄位求和，不過得益於mongodb管道的強大，用另外一個管道間接實現了這個功能。

db.getCollection('FormInstace').aggregate([
    {
        $match: {
            "_id": { $in: ["1","2","3"] },
            "FormItems.key": { $ne: null }
        }
    },
    {
        $addFields: {
            FormValueObj: {
                $arrayToObject: {
                    $map: {
                        input: "$FormItems",
                        as: "field",
                        in: [ "$$field.key", "$$field.value" ]
                    }
                }
            }
        }
    },
    {
      $replaceRoot: { newRoot: { $mergeObjects: [ "$FormValueObj", "$$ROOT" ] } }
    },
    {
        $project: {
            FormItems:0,
            FormValueObj:0
        }
    },
    {   
        $lookup:{
            from:"FormInstace",
            let: { tempMainRelationKey: "$_id" },
            pipeline:[
                {
                    $match: { 
                        FormId: "507048044944692000",
                        "FormItems.key": { $ne: null }                        
                    }
                },
                {
                    $addFields: {
                        FormValueObj: {
                            $arrayToObject: {
                                $map: {
                                    input: "$FormItems",
                                    as: "field",
                                    in: [ "$$field.key", "$$field.value" ]
                                }
                            }
                        }
                    }
                },
                {
                  $replaceRoot: { newRoot: { $mergeObjects: [ "$FormValueObj", "$$ROOT" ] } }
                },
                {
                    $project: {
                        FormItems:0,
                        FormValueObj:0
                    }
                },
                { $match:
                     { $expr:
                            { $eq: [ "$1572493552001.id","$$tempMainRelationKey" ] }
                     }
                },
            ],
            as:'carWastage'
        }
    },
    {   
        $lookup:{
            from:"FormInstace",
            let: { tempMainRelationKey: "$_id" },
            pipeline:[
                {
                    $match: { 
                        FormId: "507048044944693000",
                        "FormItems.key": { $ne: null }                        
                    }
                },
                {
                    $addFields: {
                        FormValueObj: {
                            $arrayToObject: {
                                $map: {
                                    input: "$FormItems",
                                    as: "field",
                                    in: [ "$$field.key", "$$field.value" ]
                                }
                            }
                        }
                    }
                },
                {
                  $replaceRoot: { newRoot: { $mergeObjects: [ "$FormValueObj", "$$ROOT" ] } }
                },
                {
                    $project: {
                        FormItems:0,
                        FormValueObj:0
                    }
                },
                { $match:
                     { $expr:
                            { $eq: [ "$1572493553001.id","$$tempMainRelationKey" ] }
                     }
                },
            ],
            as:'carRevenue'
        }
    },
    {
        $addFields: {
            carWastageStatistics: {
               $reduce: {
                  input: "$carWastage",
                  initialValue: {wastageMoney:0},
                  in: {
                      wastageMoney:{ $add : ["$$value.wastageMoney", "$$this.1572493552005"] }
                  }
               }
            }
        }
    },
    {
        $addFields: {
            carRevenueStatistics: {
               $reduce: {
                  input: "$carRevenue",
                  initialValue: {revenueMoney:0,mileage:0},
                  in: { 
                    revenueMoney:{$add : ["$$value.revenueMoney", "$$this.1572493553005"]},
                    mileage:{$add : ["$$value.mileage", "$$this.1572493553006"]}
                  }
               }
            }
        }
    }
]);

　　這次統計查詢就查出了某些車輛的總耗損金額和總營收金額、總里程數；只不過將結果放到對象中了（方便統計一個表中的多個欄位），但是現在看不到具體的結果，將代碼在修改一下，看一下結果

db.getCollection('FormInstace').aggregate([
    {
        $match: {
            "_id": { $in: ["1","2","3"] },
            "FormItems.key": { $ne: null }
        }
    },
    {
        $addFields: {
            FormValueObj: {
                $arrayToObject: {
                    $map: {
                        input: "$FormItems",
                        as: "field",
                        in: [ "$$field.key", "$$field.value" ]
                    }
                }
            }
        }
    },
    {
      $replaceRoot: { newRoot: { $mergeObjects: [ "$FormValueObj", "$$ROOT" ] } }
    },
    {
        $project: {
            FormItems:0,
            FormValueObj:0
        }
    },
    {   
        $lookup:{
            from:"FormInstace",
            let: { tempMainRelationKey: "$_id" },
            pipeline:[
                {
                    $match: { 
                        FormId: "507048044944692000",
                        "FormItems.key": { $ne: null }                        
                    }
                },
                {
                    $addFields: {
                        FormValueObj: {
                            $arrayToObject: {
                                $map: {
                                    input: "$FormItems",
                                    as: "field",
                                    in: [ "$$field.key", "$$field.value" ]
                                }
                            }
                        }
                    }
                },
                {
                  $replaceRoot: { newRoot: { $mergeObjects: [ "$FormValueObj", "$$ROOT" ] } }
                },
                {
                    $project: {
                        FormItems:0,
                        FormValueObj:0
                    }
                },
                { $match:
                     { $expr:
                            { $eq: [ "$1572493552001.id","$$tempMainRelationKey" ] }
                     }
                },
            ],
            as:'carWastage'
        }
    },
    {   
        $lookup:{
            from:"FormInstace",
            let: { tempMainRelationKey: "$_id" },
            pipeline:[
                {
                    $match: { 
                        FormId: "507048044944693000",
                        "FormItems.key": { $ne: null }                        
                    }
                },
                {
                    $addFields: {
                        FormValueObj: {
                            $arrayToObject: {
                                $map: {
                                    input: "$FormItems",
                                    as: "field",
                                    in: [ "$$field.key", "$$field.value" ]
                                }
                            }
                        }
                    }
                },
                {
                  $replaceRoot: { newRoot: { $mergeObjects: [ "$FormValueObj", "$$ROOT" ] } }
                },
                {
                    $project: {
                        FormItems:0,
                        FormValueObj:0
                    }
                },
                { $match:
                     { $expr:
                            { $eq: [ "$1572493553001.id","$$tempMainRelationKey" ] }
                     }
                },
            ],
            as:'carRevenue'
        }
    },
    {
        $addFields: {
            carWastage_Money: {
               $reduce: {
                  input: "$carWastage",
                  initialValue: 0,
                  in: { $add : ["$$value", "$$this.1572493552005"] }
               }
            }
        }
    },
    {
        $addFields: {
            carRevenue_Money: {
               $reduce: {
                  input: "$carRevenue",
                  initialValue: 0,
                  in: { $add : ["$$value", "$$this.1572493553005"] }
               }
            }
        }
    },
    {
        $addFields: {
            carRevenue_Mileage: {
               $reduce: {
                  input: "$carRevenue",
                  initialValue: 0,
                  in: { $add : ["$$value", "$$this.1572493553006"] }
               }
            }
        }
    }
]);

　　這樣就一目瞭然了。統計結果對不對呢？我們用傳統的分組之後再求和在查詢一下，將結果做一下對比（順便記錄一下，分組求和）

db.getCollection('FormInstace').aggregate([
    {
        $match: {
            "FormId":"507048044944692000",
            "FormItems.key": { $ne: null }
        }
    },
    {
        $addFields: {
            FormValueObj: {
                $arrayToObject: {
                    $map: {
                        input: "$FormItems",
                        as: "field",
                        in: [ "$$field.key", "$$field.value" ]
                    }
                }
            }
        }
    },
    {
        $replaceRoot: { newRoot: { $mergeObjects: [ "$FormValueObj", "$$ROOT" ] } }
    },
    {
        $match: {
            "1572493552001.id": { $in:["1","2","3"]}
        }
    },
    {
        $project: {
            FormItems:0,
            FormValueObj:0
        }
    },
    {
        $group:{
           _id: "$1572493552001.id",
           wastageMoney: { $sum: "$1572493552005"}
        }
    },
    { $sort : { _id: 1 } }
]);
統計指定車輛的耗損總額 
db.getCollection('FormInstace').aggregate([
    {
        $match: {
            "FormId":"507048044944693000",
            "FormItems.key": { $ne: null }
        }
    },
    {
        $addFields: {
            FormValueObj: {
                $arrayToObject: {
                    $map: {
                        input: "$FormItems",
                        as: "field",
                        in: [ "$$field.key", "$$field.value" ]
                    }
                }
            }
        }
    },
    {
        $replaceRoot: { newRoot: { $mergeObjects: [ "$FormValueObj", "$$ROOT" ] } }
    },
    {
        $match: {
            "1572493553001.id": { $in:["1","2","3"]}
        }
    },
    {
        $project: {
            FormItems:0,
            FormValueObj:0
        }
    },
    {
        $group:{
           _id: "$1572493553001.id",
           wastageMoney: { $sum: "$1572493553005"},
           mileage: { $sum: "$1572493553006"}
        }
    },
    { $sort : { _id: 1 } }
]);
統計指定車輛的營收總額和里程數

　　對比兩次查詢結果，兩次不同的統計方式的結果相同。這樣就放心了。好了就到這裡了。

　　********************以下是修改補充部分********************

　　打臉了，好疼，┭┮﹏┭┮……曾記得以前使用$sum對數組中的某一屬性求和時沒有得到預期的結果，這篇筆記寫完之後，打算在按照常規思路（$unwind、$group、$sum等）在寫一種查詢方式，但是但是但是測試的時候發現$sum好使了，寫放一下代碼

db.getCollection('FormInstace').aggregate([
    {
        $match: {
            "_id": { $in: ["1","2","3"] },
            "FormItems.key": { $ne: null }
        }
    },
    {
        $addFields: {
            FormValueObj: {
                $arrayToObject: {
                    $map: {
                        input: "$FormItems",
                        as: "field",
                        in: [ "$$field.key", "$$field.value" ]
                    }
                }
            }
        }
    },
    {
      $replaceRoot: { newRoot: { $mergeObjects: [ "$FormValueObj", "$$ROOT" ] } }
    },
    {
        $project: {
            FormItems:0,
            FormValueObj:0
        }
    },
    {   
        $lookup:{
            from:"FormInstace",
            let: { tempMainRelationKey: "$_id" },
            pipeline:[
                {
                    $match: { 
                        FormId: "507048044944692000",
                        "FormItems.key": { $ne: null }                        
                    }
                },
                {
                    $addFields: {
                        FormValueObj: {
                            $arrayToObject: {
                                $map: {
                                    input: "$FormItems",
                                    as: "field",
                                    in: [ "$$field.key", "$$field.value" ]
                                }
                            }
                        }
                    }
                },
                {
                  $replaceRoot: { newRoot: { $mergeObjects: [ "$FormValueObj", "$$ROOT" ] } }
                },
                {
                    $project: {
                        FormItems:0,
                        FormValueObj:0
                    }
                },
                { $match:
                     { $expr:
                            { $eq: [ "$1572493552001.id","$$tempMainRelationKey" ] }
                     }
                },
            ],
            as:'carWastage'
        }
    },
    {   
        $lookup:{
            from:"FormInstace",
            let: { tempMainRelationKey: "$_id" },
            pipeline:[
                {
                    $match: { 
                        FormId: "507048044944693000",
                        "FormItems.key": { $ne: null }                        
                    }
                },
                {
                    $addFields: {
                        FormValueObj: {
                            $arrayToObject: {
                                $map: {
                                    input: "$FormItems",
                                    as: "field",
                                    in: [ "$$field.key", "$$field.value" ]
                                }
                            }
                        }
                    }
                },
                {
                  $replaceRoot: { newRoot: { $mergeObjects: [ "$FormValueObj", "$$ROOT" ] } }
                },
                {
                    $project: {
                        FormItems:0,
                        FormValueObj:0
                    }
                },
                { $match:
                     { $expr:
                            { $eq: [ "$1572493553001.id","$$tempMainRelationKey" ] }
                     }
                },
            ],
            as:'carRevenue'
        }
    },
    {
        $addFields: {
            "carWastageStatistics.wastageMoney": { $sum: "$carWastage.1572493552005"},
            "carRevenueStatistics.revenueMoney": { $sum: "$carRevenue.1572493553005"},
            "carRevenueStatistics.mileage": { $sum: "$carRevenue.1572493553006"}
        }
    }
]);
在文中第一個查詢語句基礎上修改 
db.getCollection('FormInstace').aggregate([
    {
        $match: {
            "_id": { $in: ["1","2","3"] },
            "FormItems.key": { $ne: null }
        }
    },
    {
        $addFields: {
            FormValueObj: {
                $arrayToObject: {
                    $map: {
                        input: "$FormItems",
                        as: "field",
                        in: [ "$$field.key", "$$field.value" ]
                    }
                }
            }
        }
    },
    {
      $replaceRoot: { newRoot: { $mergeObjects: [ "$FormValueObj", "$$ROOT" ] } }
    },
    {
        $project: {
            FormItems:0,
            FormValueObj:0
        }
    },
    {   
        $lookup:{
            from:"FormInstace",
            let: { tempMainRelationKey: "$_id" },
            pipeline:[
                {
                    $match: { 
                        FormId: "507048044944692000",
                        "FormItems.key": { $ne: null }                        
                    }
                },
                {
                    $addFields: {
                        FormValueObj: {
                            $arrayToObject: {
                                $map: {
                                    input: "$FormItems",
                                    as: "field",
                                    in: [ "$$field.key", "$$field.value" ]
                                }
                            }
                        }
                    }
                },
                {
                  $replaceRoot: { newRoot: { $mergeObjects: [ "$FormValueObj", "$$ROOT" ] } }
                },
                {
                    $project: {
                        FormItems:0,
                        FormValueObj:0
                    }
                },
                { $match:
                     { $expr:
                            { $eq: [ "$1572493552001.id","$$tempMainRelationKey" ] }
                     }
                },
            ],
            as:'carWastage'
        }
    },
    {   
        $lookup:{
            from:"FormInstace",
            let: { tempMainRelationKey: "$_id" },
            pipeline:[
                {
                    $match: { 
                        FormId: "507048044944693000",
                        "FormItems.key": { $ne: null }                        
                    }
                },
                {
                    $addFields: {
                        FormValueObj: {
                            $arrayToObject: {
                                $map: {
                                    input: "$FormItems",
                                    as: "field",
                                    in: [ "$$field.key", "$$field.value" ]
                                }
                            }
                        }
                    }
                },
                {
                  $replaceRoot: { newRoot: { $mergeObjects: [ "$FormValueObj", "$$ROOT" ] } }
                },
                {
                    $project: {
                        FormItems:0,
                        FormValueObj:0
                    }
                },
                { $match:
                     { $expr:
                            { $eq: [ "$1572493553001.id","$$tempMainRelationKey" ] }
                     }
                },
            ],
            as:'carRevenue'
        }
    },
    {
        $addFields: {
            "carWastage_Money": { $sum: "$carWastage.1572493552005"},
            "carRevenue_Money": { $sum: "$carRevenue.1572493553005"},
            "carRevenue_Mileage": { $sum: "$carRevenue.1572493553006"},
        }
    }
]);
在文中第二個查詢語句基礎上修改

　　下麵看一下對比圖，看一下改動情況

　　再看一下，執行結果截圖

 

　　和上面的結果一模一樣……對mongodb管道認識不夠深入，應用中有需求就是查一下，太片面了，沒有驗證的東西千萬別亂說，切記切記切記！！！特尷尬，￣□￣｜｜


您的分享是我們最大的動力!

-Advertisement-
Play Games
更多相關文章
  • chrony服務配置
    chrony軟體使用說明 chrony簡介 chrony是一個開源的自由軟體，它能保持系統時鐘與時間伺服器（ntp）同步，讓時間保持精確。 它由兩個程式組成：chrongd和chronyc。 chronyd是一個後臺運行的守護進程，用於調整內核運行的系統時鐘和時間伺服器同步。 它確定電腦增減時間的 ...
  • [Flink]測試用的fake溫度感測器
    Flink-測試用的fake溫度感測器 Flink中，測試時，會用到自定義的source。 下為一例。。 該例使用溫度感測器的格式演示fake日誌數據源。 代碼用Scala寫的。 感測器... 感測器 - 樣例類 SensorReads.scala： ​x 1 package sr 2 ​ 3 /* ...
  • Service__cmd安裝MysSQL並連接SQLyog
    整理記錄關於使用cmd安裝mysql的過程 1.配置環境變數 1） 電腦->屬性->高級系統設置->環境變數 2）先添加變數 變數名：MYSQL_HOME 變數值：D:\mysql-8.0.13-winx64\bin (mysql存放地址） 3）然後配置Path系統變數 在系統變數里，找到Path ...
  • Mysql/Mariadb主從複製
    概念 什麼是·Mysql/Mariadb主從複製？ Mysql/Mariadb主從複製：當Master（主）資料庫發生變化的時候，變化實時會同步到slave（從）資料庫中； 類似於：Samba共用文件（C/S）、NFS網路文件共用（C/S），當服務端（Server）發生變化時，客戶端（client） ...
  • 索引介紹
    一.索引介紹 1.什麼是索引 1）索引就好比一本書的目錄，它能讓你更快的找到自己想要的內容。 2）讓獲取的數據更有目的性，從而提高資料庫檢索數據的性能。 2.索引類型介紹 1)BTREE:B+樹索引 2)HASH：HASH索引 3)FULLTEXT：全文索引 4)RTREE：R樹索引 Btree索引 ...
  • Windows安裝與配置—MongoDB
    1，下載安裝 打開下載鏈接：http://dl.mongodb.org/dl/win32/x86_64，選擇尾碼是2008plus-ssl-3.6.15.zip的版本，32位和64位通用。 2，安裝配置 第一步：解壓到一個盤上，例如我的解壓的目錄D:\MongoDB\mongodb-win32-x8 ...
  • Mysql中 instr與concat
    #INSTR(字元串, 子串)，#返回值：第一個子串的索引-1#類似indexOf()#例如：SELECT INSTR('人民萬歲，世界萬歲','萬')SELECT INSTR('人民萬歲，世界萬歲','中華') #INSTR(欄位名, 字元串)#例如SELECT *,INSTR(DEPART,'系 ...
  • [20191112]oracle共用連接模式埠.txt
    [20191112]oracle共用連接模式埠.txt--//如果使用共用服務模式,你可以發現每次重啟資料庫對應的埠號會發生變化.# netstat -tunlp | egrep "Active|Proto|ora_[ds]"Active Internet connections (only s ...
一周排行
    -Advertisement-
    Play Games
  • 移動開發（一）：使用.NET MAUI開發第一個安卓APP
    移動開發（一）：使用.NET MAUI開發第一個安卓APP 對於工作多年的C#程式員來說，近來想嘗試開發一款安卓APP，考慮了很久最終選擇使用.NET MAUI這個微軟官方的框架來嘗試體驗開發安卓APP，畢竟是使用Visual Studio開發工具，使用起來也比較的順手，結合微軟官方的教程進行了安卓 ...
  • wpf ToggleButton選中效果和一個登錄界面
    前言 QuestPDF 是一個開源 .NET 庫，用於生成 PDF 文檔。使用了C# Fluent API方式可簡化開發、減少錯誤並提高工作效率。利用它可以輕鬆生成 PDF 報告、發票、導出文件等。 項目介紹 QuestPDF 是一個革命性的開源 .NET 庫，它徹底改變了我們生成 PDF 文檔的方 ...
  • 彈幕樹洞項目功能新增篇
    項目地址 項目後端地址： https://github.com/ZyPLJ/ZYTteeHole 項目前端頁面地址： ZyPLJ/TreeHoleVue (github.com) https://github.com/ZyPLJ/TreeHoleVue 目前項目測試訪問地址： http://tree ...
  • 第27篇 sqlserver2022詳細安裝步驟
    話不多說，直接開乾 一.下載 1.官方鏈接下載： https://www.microsoft.com/zh-cn/sql-server/sql-server-downloads 2.在下載目錄中找到下麵這個小的安裝包 SQL2022-SSEI-Dev.exe，運行開始下載SQL server； 二. ...
  • .NET 開源高性能 MQTT 類庫
    前言 隨著物聯網（IoT）技術的迅猛發展，MQTT（消息隊列遙測傳輸）協議憑藉其輕量級和高效性，已成為眾多物聯網應用的首選通信標準。 MQTTnet 作為一個高性能的 .NET 開源庫，為 .NET 平臺上的 MQTT 客戶端與伺服器開發提供了強大的支持。 本文將全面介紹 MQTTnet 的核心功能 ...
  • Serilog文檔翻譯系列（六） - 可用的接收器、增強器、格式化輸出
    Serilog支持多種接收器用於日誌存儲，增強器用於添加屬性，LogContext管理動態屬性，支持多種輸出格式包括純文本、JSON及ExpressionTemplate。還提供了自定義格式化選項，適用於不同需求。 ...
  • 警惕 Visual Studio 屬性求值副作用導致邏輯不符合預期
    目錄簡介獲取 HTML 文檔解析 HTML 文檔測試參考文章 簡介 動態內容網站使用 JavaScript 腳本動態檢索和渲染數據，爬取信息時需要模擬瀏覽器行為，否則獲取到的源碼基本是空的。 本文使用的爬取步驟如下： 使用 Selenium 獲取渲染後的 HTML 文檔 使用 HtmlAgility ...
  • [使用目前最新版]HybridCLR6.9.0+YooAsset2.2.4實現純C# Unity熱更新方案 (一)
    1.前言 什麼是熱更新 游戲或者軟體更新時，無需重新下載客戶端進行安裝，而是在應用程式啟動的情況下，在內部進行資源或者代碼更新 Unity目前常用熱更新解決方案 HybridCLR，Xlua，ILRuntime等 Unity目前常用資源管理解決方案 AssetBundles，Addressable， ...
  • 在 ASP.NET Core Web API 中使用操作篩選器統一處理通用操作
    本文章主要是在C# ASP.NET Core Web API框架實現向手機發送驗證碼簡訊功能。這裡我選擇是一個互億無線簡訊驗證碼平臺，其實像阿裡雲，騰訊雲上面也可以。 首先我們先去 互億無線 https://www.ihuyi.com/api/sms.html 去註冊一個賬號 註冊完成賬號後，它會送 ...
  • 第28篇 如何.net中實現高效可靠數據同步api
    通過以下方式可以高效，並保證數據同步的可靠性 1.API設計 使用RESTful設計，確保API端點明確，並使用適當的HTTP方法（如POST用於創建，PUT用於更新）。 設計清晰的請求和響應模型，以確保客戶端能夠理解預期格式。 2.數據驗證 在伺服器端進行嚴格的數據驗證，確保接收到的數據符合預期格 ...
所有分類