.Net Core對MongoDB執行多條件查詢

来源:https://www.cnblogs.com/carroty/archive/2020/03/26/12573072.html

MongoDB多條件查詢的寫法著實費了些功夫, 撰文記錄一下 ...


以前項目基本上全部使用MySQL資料庫, 最近項目排期空出了一點時間leader決定把日誌模塊遷移到插入/查詢性能更好的MongoDB上. 多條件查詢的寫法著實費了些功夫, 撰文記錄一下.

一、準備工作

1. 安裝過程, 不贅述了

2. 添加ReferencePackage

dotnet add package mongodb.bson
dotnet add package mongodb.driver

3. appsetting.json添加連接配置

"MongodbHost": {
    "Connection": "mongodb://[username]:[password]@[ip]:[port]",
    "DataBase": "[database]",
    "Table": ""
  },

4. 獲取MongoDBConfig 的方法

public static MongodbHostOptions MongodbConfig()
{
    var builder = new ConfigurationBuilder()
                .SetBasePath(Directory.GetCurrentDirectory())
                .AddJsonFile("appsettings.json");

  IConfiguration Configuration = builder.Build();
  var option = Configuration.GetSection("MongodbHost");
  return new MongodbHostOptions { Connection = option["Connection"], DataBase = option["DataBase"], Table = option["Table"] };
}

 

二、查詢方法

這裡的查詢方法是網上找的, 直接拿來用了. 如果是單一數據源的話, 這裡的host可以提取出來成為helper類的屬性.

 1 #region FindListByPage 分頁查詢集合
 2     /// <summary>
 3     /// 分頁查詢集合
 4     /// </summary>
 5     /// <param name="filter">查詢條件</param>
 6     /// <param name="pageIndex">當前頁</param>
 7     /// <param name="pageSize">頁容量</param>
 8     /// <param name="count">總條數</param>
 9     /// <param name="field">要查詢的欄位,不寫時查詢全部</param>
10     /// <param name="sort">要排序的欄位</param>
11     /// <returns></returns>
12     public static List<T> FindListByPage(FilterDefinition<T> filter, int pageIndex, int pageSize, out int count, string[] field = null, SortDefinition<T> sort = null)
13     {
14         try
15         {
16             MongodbHostOptions host = Tools.AppSettingsTools.MongodbConfig();
17             host.Table = "WSMessageLog";
18             var client = MongodbClient<T>.MongodbInfoClient(host);
19             count = Convert.ToInt32(client.CountDocuments(filter));
20             //不指定查詢欄位
21             if (field == null || field.Length == 0)
22             {
23                 if (sort == null) return client.Find(filter).Skip((pageIndex - 1) * pageSize).Limit(pageSize).ToList();
24                 //進行排序
25                 return client.Find(filter).Sort(sort).Skip((pageIndex - 1) * pageSize).Limit(pageSize).ToList();
26             }
27 
28             //指定查詢欄位
29             var fieldList = new List<ProjectionDefinition<T>>();
30             for (int i = 0; i < field.Length; i++)
31             {
32                 fieldList.Add(Builders<T>.Projection.Include(field[i].ToString()));
33             }
34             var projection = Builders<T>.Projection.Combine(fieldList);
35             fieldList?.Clear();
36 
37             //不排序
38             if (sort == null) return client.Find(filter).Project<T>(projection).Skip((pageIndex - 1) * pageSize).Limit(pageSize).ToList();
39 
40             //排序查詢
41             return client.Find(filter).Sort(sort).Project<T>(projection).Skip((pageIndex - 1) * pageSize).Limit(pageSize).ToList();
42 
43         }
44         catch (Exception ex)
45   {
46     throw ex;
47   }
48 }
49 #endregion

 

三、調用查詢方法

這裡還踩了一個坑. MongoDB里存儲的時間是格林尼治時間, 插入8:00, 查詢時會發現變成了0:00,所以定義時間屬性的時候需要加個標簽
[BsonDateTimeOptions(Kind = DateTimeKind.Local)]
public DateTime logtime { get; set; }

   這裡的OprLogModel是定義了查詢條件的類.

 1 public static LogPager<log_operate> Get_operate_log_mongo(OprLogModel qModel)
 2 {
 3   LogPager<log_operate> pager = new LogPager<log_operate>();
 4   FilterDefinition<log_operate> filters;
 5 
 6   var sortbuilder = Builders<log_operate>.Sort;
 7   var sort = sortbuilder.Descending("operate_time");
 8 
 9   #region 用戶許可權過濾
10   IEnumerable<string> IdList = dev_deviceRepository.GetBinding(qModel.user_id);
11   filters = Builders<log_operate>.Filter.In("device_id", IdList);
12   #endregion
13 
14   if (!string.IsNullOrEmpty(qModel.device_id))
15    {
16      var filters_did = Builders<log_operate>.Filter.Eq("device_id", qModel.device_id);
17      filters = Builders<log_operate>.Filter.And(filters, filters_did);
18   }
19   if (qModel.sDate != null)
20   {
21     var filters_sdate = Builders<log_operate>.Filter.Gte<DateTime>("operate_time", Convert.ToDateTime(qModel.sDate));
22     filters = Builders<log_operate>.Filter.And(filters, filters_sdate);
23   }
24   if (qModel.eDate != null)
25   {
26     var filters_edate = Builders<log_operate>.Filter.Lte<DateTime>("operate_time", Convert.ToDateTime(qModel.eDate));
27     filters = Builders<log_operate>.Filter.And(filters, filters_edate);
28   } 
29   int total;
30   pager.data = MongoTools<log_operate>.FindListByPage(filters, qModel.pageindex, (qModel.pageindex - 1) * qModel.pagesize, out total, null, sort);
31   pager.total = total;
32   return pager;
33 }
34 #endregion

也可以先定義一個空的filterdefinition, 然後與各查詢條件通過And聚合:

FilterDefinition<log_operate> filters = FilterDefinition<log_operate>.Empty;
var filters_idlist = Builders<log_operate>.Filter.In("device_id", IdList);
filters = Builders<log_operate>.Filter.And(filters, filters_idlist);

 


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

更多相關文章
  • @ + function表示忽略警告。 eval() 是可以執行php代碼 system() 是可以執行系統命令 ...
  • 原創聲明 本文首發於微信公眾號【程式員黃小斜】 本文作者:黃小斜 轉載請務必在文章開頭註明出處和作者。 本文思維導圖 什麼是Spring,為什麼你要學習spring? 你第一次接觸spring框架是在什麼時候?相信很多人和我一樣,第一次瞭解spring都不是做項目的時候用到,而是在網上看到或者是聽到 ...
  • 什麼是protobuf protocol buffers 是一種語言無關、平臺無關、可擴展的序列化結構數據的方法,它可用於(數據)通信協議、數據存儲等。是一種靈活,高效,自動化機制的結構數據序列化方法-可類比 XML,但是比 XML 更小(3 ~ 10倍)、更快(20 ~ 100倍)、更為簡單。 p ...
  • 集合類型及操作 集合元素之間無序,集合元素不可更改。 創建 set("pypy123") {'1', '3', 'p', 'y', '2'} 空集合不能用{}生成,留個字典了, 用set() 關係操作 交 & 並 | 差 - 補^ 支持(&=, |=, -=, ^=) 關係操作符 <,<=,>,>= ...
  • 點點這個鏈接免費獲取:本人免費整理了Java高級資料,涵蓋了Java、Redis、MongoDB、MySQL、Zookeeper、Spring Cloud、Dubbo高併發分散式等教程,一共30G,需要自己領取。傳送門:https://mp.weixin.qq.com/s/osB-BOl6W-ZLT ...
  • (來自《電腦網路:自頂向下方法》) 程式實現將小寫字母變為大寫 伺服器端: from socket import * serverPort = 12000 #創建一個伺服器埠 serverSocket = socket(AF_INET, SOCK_STREAM) #創建一個TCP套接字 serv ...
  • 1. 前言 什麼是故障藝術(Glitch Art 風)?我們熟知的抖音的 LOGO 正是故障藝術其中一種表現形式。它有一種魔幻的感覺,看起來具有閃爍、震動的效果,很吸引人眼球。故障藝術它模擬了畫面信號出現故障導致成像錯誤的感覺。青色色塊與紅色色塊無法重合就是這種故障的體現。從膠片時代開始到今天的數位 ...
  • wpf 程式集中 類命名空間名稱和類名不能相同,否則在 xaml生成 i.g.cs時,會導致 自動生成代碼無法推到處是類型還是命名空間的問題。 觸發這個錯誤的條件是類命名空間 與 類名相同 並 在usercontrol中 使用usercontrol 並給 第二個usercontrol 設置x:nam ...
一周排行
  • 在上篇文章中我們已經知道了多線程是什麼了,那麼它到底可以幹嘛呢?這裡特別聲明一個前面的委托沒看的同學可以到上上上篇博文查看,因為多線程要經常使用到委托。源碼 一、非同步、同步 1.同步(在計算的理解總是要你措不及防,同步當線程做完一件事情之後,才會執行後續動作),同步方法慢,只有一個線程執行,非同步方法 ...
  • 本文主要是講解stopwatch對程式運行時間的準確測量 僅僅介紹裡面的StartNew()方法,Restart()方法和ElapsedMilliseconds { get;}屬性 public void StartNew():作用是對新的 System.Diagnostics.Stopwatch ...
  • 一、引言 RabbitMQ是Rabbit Message Queue的簡寫,但不能僅僅理解其為消息隊列,消息代理更合適。RabbitMQ是一個由 Erlang 語言開發的AMQP(高級消息隊列協議)的開源實現,其內部結構如下: RabbitMQ作為一個消息代理,主要和消息打交道,負責接收並轉發消息。 ...
  • TerminalMACS(Terminal Manager And Check System) 遠程終端管理和檢測系統 本文同步更新地址:https://dotnet9.com/11429.html 一、本系統可監控多種終端資源: 移動端 Android iOS PC端 Windows Linux ...
  • 首先,好消息是Goole將於2020年2月份發佈Chrome 80版本。本次發佈將推進Google的“漸進改良Cookie”策略,打造一個更為安全和保障用戶隱私的網路環境。 壞消息是,本次更新可能導致瀏覽器無法向服務端發送Cookie。如果你有多個不同功能變數名稱的應用,部分用戶很有可能出現會話時常被打斷的 ...
  • 在偶然一次調試某程式時,遇到提示: 無法載入程式集*****.XmlSerializers.dll,文件找不到(Could not load file or assembly ****.XmlSerializers.dll , FileNotFoundException...)。於是嘗試在項目屬性中 ...
  • 在上一篇abp(net core)+easyui+efcore實現倉儲管理系統——入庫管理之五(四十一) 文章中實現了入庫管理的列表頁面,並實現了控制器的代碼。在今天我們學習如何在前端實現新增入庫單信息界面。 ...
  • 面向對象 面向對象是一個抽象的概念,其本質就是對事物以抽象的方式建立對應的模型。 簡單來講,比如我有一隻鋼筆,那麼我就可以通過分析,可以得到 這隻鋼筆的材第是塑料,品牌是個雜牌 ,裡面裝的墨是黑色的,可以用。這時候就能建立一個鋼筆的模型,它在這裡應該有這些屬性: 圖是一個不正確的UML類圖,但是可以 ...
  • 在ASP.NET MVC中有四種過濾器類型 Action 1、在ASP.NET MVC項目中,新建文件夾Filter,然後新建類MyCustormFilter,繼承自ActionFilterAttribute類,我們來看下ActionFilterAttribute類有如下四個方法,從命名我應該就可以 ...
  • 你需要瞭解的 HTTP Status Code Intro 現在前後端分離的開發模式越來越流行,後端負責開發對應的 API,前端只需要 關註前端頁面的數據展示和前端邏輯即可。 對於前後端分離這種開發模式,我個人還是比較喜歡的,因為這樣可以讓更專業的人做更專業的事情,後端專註於做 API 的開發設計, ...
x