以前項(xiàng)目基本上全部使用MySQL數(shù)據(jù)庫, 最近項(xiàng)目排期空出了一點(diǎn)時(shí)間leader決定把日志模塊遷移到插入/查詢性能更好的MongoDB上. 多條件查詢的寫法著實(shí)費(fèi)了些功夫, 撰文記錄一下.
一、準(zhǔn)備工作
1. 安裝過程, 不贅述了
2. 添加ReferencePackage
|
1
2
|
dotnet add package mongodb.bsondotnet add package mongodb.driver |
3. appsetting.json添加連接配置
|
1
2
3
4
5
|
"MongodbHost": { "Connection": "mongodb://[username]:[password]@[ip]:[port]", "DataBase": "[database]", "Table": "" }, |
4. 獲取MongoDBConfig 的方法
|
1
2
3
4
5
6
7
8
9
10
|
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"] };} |
二、查詢方法
這里的查詢方法是網(wǎng)上找的, 直接拿來用了. 如果是單一數(shù)據(jù)源的話, 這里的host可以提取出來成為helper類的屬性.
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
|
#region FindListByPage 分頁查詢集合 /// <summary> /// 分頁查詢集合 /// </summary> /// <param name="filter">查詢條件</param> /// <param name="pageIndex">當(dāng)前頁</param> /// <param name="pageSize">頁容量</param> /// <param name="count">總條數(shù)</param> /// <param name="field">要查詢的字段,不寫時(shí)查詢?nèi)?lt;/param> /// <param name="sort">要排序的字段</param> /// <returns></returns> public static List<T> FindListByPage(FilterDefinition<T> filter, int pageIndex, int pageSize, out int count, string[] field = null, SortDefinition<T> sort = null) { try { MongodbHostOptions host = Tools.AppSettingsTools.MongodbConfig(); host.Table = "WSMessageLog"; var client = MongodbClient<T>.MongodbInfoClient(host); count = Convert.ToInt32(client.CountDocuments(filter)); //不指定查詢字段 if (field == null || field.Length == 0) { if (sort == null) return client.Find(filter).Skip((pageIndex - 1) * pageSize).Limit(pageSize).ToList(); //進(jìn)行排序 return client.Find(filter).Sort(sort).Skip((pageIndex - 1) * pageSize).Limit(pageSize).ToList(); } //指定查詢字段 var fieldList = new List<ProjectionDefinition<T>>(); for (int i = 0; i < field.Length; i++) { fieldList.Add(Builders<T>.Projection.Include(field[i].ToString())); } var projection = Builders<T>.Projection.Combine(fieldList); fieldList?.Clear(); //不排序 if (sort == null) return client.Find(filter).Project<T>(projection).Skip((pageIndex - 1) * pageSize).Limit(pageSize).ToList(); //排序查詢 return client.Find(filter).Sort(sort).Project<T>(projection).Skip((pageIndex - 1) * pageSize).Limit(pageSize).ToList(); } catch (Exception ex) { throw ex; }}#endregion |
三、調(diào)用查詢方法
這里還踩了一個(gè)坑. MongoDB里存儲(chǔ)的時(shí)間是格林尼治時(shí)間, 插入8:00, 查詢時(shí)會(huì)發(fā)現(xiàn)變成了0:00,所以定義時(shí)間屬性的時(shí)候需要加個(gè)標(biāo)簽
|
1
2
|
[BsonDateTimeOptions(Kind = DateTimeKind.Local)]public DateTime logtime { get; set; } |
這里的OprLogModel是定義了查詢條件的類.
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
|
public static LogPager<log_operate> Get_operate_log_mongo(OprLogModel qModel){ LogPager<log_operate> pager = new LogPager<log_operate>(); FilterDefinition<log_operate> filters; var sortbuilder = Builders<log_operate>.Sort; var sort = sortbuilder.Descending("operate_time"); #region 用戶權(quán)限過濾 IEnumerable<string> IdList = dev_deviceRepository.GetBinding(qModel.user_id); filters = Builders<log_operate>.Filter.In("device_id", IdList); #endregion if (!string.IsNullOrEmpty(qModel.device_id)) { var filters_did = Builders<log_operate>.Filter.Eq("device_id", qModel.device_id); filters = Builders<log_operate>.Filter.And(filters, filters_did); } if (qModel.sDate != null) { var filters_sdate = Builders<log_operate>.Filter.Gte<DateTime>("operate_time", Convert.ToDateTime(qModel.sDate)); filters = Builders<log_operate>.Filter.And(filters, filters_sdate); } if (qModel.eDate != null) { var filters_edate = Builders<log_operate>.Filter.Lte<DateTime>("operate_time", Convert.ToDateTime(qModel.eDate)); filters = Builders<log_operate>.Filter.And(filters, filters_edate); } int total; pager.data = MongoTools<log_operate>.FindListByPage(filters, qModel.pageindex, (qModel.pageindex - 1) * qModel.pagesize, out total, null, sort); pager.total = total; return pager;}#endregion |
也可以先定義一個(gè)空的filterdefinition, 然后與各查詢條件通過And聚合:
|
1
2
3
|
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); |
以上就是.Net Core如何對(duì)MongoDB執(zhí)行多條件查詢的詳細(xì)內(nèi)容，更多關(guān)于.Net Core對(duì)MongoDB 多條件查詢的資料請(qǐng)關(guān)注服務(wù)器之家其它相關(guān)文章！
原文鏈接：https://www.cnblogs.com/carroty/p/12573072.html
