.Net Core如何對(duì)MongoDB執(zhí)行多條件查詢
以前項(xiàng)目基本上全部使用MySQL數(shù)據(jù)庫(kù), 最近項(xiàng)目排期空出了一點(diǎn)時(shí)間leader決定把日志模塊遷移到插入/查詢性能更好的MongoDB上. 多條件查詢的寫法著實(shí)費(fèi)了些功夫, 撰文記錄一下.
一、準(zhǔn)備工作
1. 安裝過(guò)程, 不贅述了
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"] };
}
二、查詢方法
這里的查詢方法是網(wǎng)上找的, 直接拿來(lái)用了. 如果是單一數(shù)據(jù)源的話, 這里的host可以提取出來(lái)成為helper類的屬性.
#region FindListByPage 分頁(yè)查詢集合
/// <summary>
/// 分頁(yè)查詢集合
/// </summary>
/// <param name="filter">查詢條件</param>
/// <param name="pageIndex">當(dāng)前頁(yè)</param>
/// <param name="pageSize">頁(yè)容量</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)簽
[BsonDateTimeOptions(Kind = DateTimeKind.Local)]
public DateTime logtime { get; set; }
這里的OprLogModel是定義了查詢條件的類.
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)限過(guò)濾
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, 然后與各查詢條件通過(guò)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);
以上就是.Net Core如何對(duì)MongoDB執(zhí)行多條件查詢的詳細(xì)內(nèi)容,更多關(guān)于.Net Core對(duì)MongoDB 多條件查詢的資料請(qǐng)關(guān)注腳本之家其它相關(guān)文章!
相關(guān)文章
詳解.NET Core中的數(shù)據(jù)保護(hù)組件
在本篇文章中我們給大家整理了關(guān)于返回主頁(yè).NET Core中的數(shù)據(jù)保護(hù)組件的相關(guān)知識(shí)點(diǎn)內(nèi)容,有興趣的朋友們參考下。2018-09-09
ASP.NET MVC4中使用Html.DropDownListFor的方法示例
這篇文章主要介紹了ASP.NET MVC4中使用Html.DropDownListFor的方法,結(jié)合實(shí)例形式分析了控制器數(shù)據(jù)源及Html.DropDownListFor顯示操作的相關(guān)技巧,需要的朋友可以參考下2016-08-08
vs.net控件updatePanel實(shí)現(xiàn)無(wú)刷新的方法
vs.net控件updatePanel實(shí)現(xiàn)無(wú)刷新的方法,需要的朋友可以參考一下2013-04-04
.net客戶端導(dǎo)出Excel實(shí)現(xiàn)代碼及注意事項(xiàng)
將DataGrid導(dǎo)出為Excel文件及導(dǎo)出dgData中0-3列的數(shù)據(jù)到excel文件中的優(yōu)缺點(diǎn)介紹,感興趣的朋友可以了解下,希望本文對(duì)你有所幫助2013-02-02
.Net中如何操作IIS的虛擬目錄原理分析及實(shí)現(xiàn)方案
編程控制IIS實(shí)際上很簡(jiǎn)單,和ASP一樣,.Net中需要使用ADSI來(lái)操作IIS,但是此時(shí)我們不再需要GetObject這個(gè)東東了,因?yàn)镹et為我們提供了更加強(qiáng)大功能的新東東2012-12-12
MVC+EasyUI+三層新聞網(wǎng)站建立 tabs標(biāo)簽制作方法(六)
這篇文章主要為大家詳細(xì)介紹了MVC+EasyUI+三層新聞網(wǎng)站建立的第六篇,教大家如何制作tabs標(biāo)簽,具有一定的參考價(jià)值,感興趣的小伙伴們可以參考一下2017-07-07
使用Hangfire+.NET?6實(shí)現(xiàn)定時(shí)任務(wù)管理(推薦)
這篇文章主要介紹了使用Hangfire+.NET?6實(shí)現(xiàn)定時(shí)任務(wù)管理,通過(guò)引入Hangfire相關(guān)的Nuget包并對(duì)Hangfire進(jìn)行服務(wù)配置,本文給大家介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值,需要的朋友可以參考下2022-10-10
ASP.NET Mvc開(kāi)發(fā)之刪除修改數(shù)據(jù)
這篇文章主要介紹了ASP.NET Mvc開(kāi)發(fā)中的刪除修改數(shù)據(jù)功能,感興趣的小伙伴們可以參考一下2016-03-03

