.NetCore怎么对MongoDB执行多条件查询-创新互联
小编给大家分享一下.Net Core怎么对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类的属性.
#region FindListByPage 分页查询集合 ////// 分页查询集合 /// /// 查询条件 /// 当前页 /// 页容量 /// 总条数 /// 要查询的字段,不写时查询全部 /// 要排序的字段 ///public static List FindListByPage(FilterDefinition filter, int pageIndex, int pageSize, out int count, string[] field = null, SortDefinition sort = null) { try { MongodbHostOptions host = Tools.AppSettingsTools.MongodbConfig(); host.Table = "WSMessageLog"; var client = MongodbClient .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(); //进行排序 return client.Find(filter).Sort(sort).Skip((pageIndex - 1) * pageSize).Limit(pageSize).ToList(); } //指定查询字段 var fieldList = new List >(); for (int i = 0; i < field.Length; i++) { fieldList.Add(Builders .Projection.Include(field[i].ToString())); } var projection = Builders .Projection.Combine(fieldList); fieldList?.Clear(); //不排序 if (sort == null) return client.Find(filter).Project (projection).Skip((pageIndex - 1) * pageSize).Limit(pageSize).ToList(); //排序查询 return client.Find(filter).Sort(sort).Project (projection).Skip((pageIndex - 1) * pageSize).Limit(pageSize).ToList(); } catch (Exception ex) { throw ex; } } #endregion
三、调用查询方法
这里还踩了一个坑. MongoDB里存储的时间是格林尼治时间, 插入8:00, 查询时会发现变成了0:00,所以定义时间属性的时候需要加个标签
[BsonDateTimeOptions(Kind = DateTimeKind.Local)] public DateTime logtime { get; set; }
这里的OprLogModel是定义了查询条件的类.
public static LogPagerGet_operate_log_mongo(OprLogModel qModel) { LogPager pager = new LogPager (); FilterDefinition filters; var sortbuilder = Builders .Sort; var sort = sortbuilder.Descending("operate_time"); #region 用户权限过滤 IEnumerable IdList = dev_deviceRepository.GetBinding(qModel.user_id); filters = Builders .Filter.In("device_id", IdList); #endregion if (!string.IsNullOrEmpty(qModel.device_id)) { var filters_did = Builders .Filter.Eq("device_id", qModel.device_id); filters = Builders .Filter.And(filters, filters_did); } if (qModel.sDate != null) { var filters_sdate = Builders .Filter.Gte ("operate_time", Convert.ToDateTime(qModel.sDate)); filters = Builders .Filter.And(filters, filters_sdate); } if (qModel.eDate != null) { var filters_edate = Builders .Filter.Lte ("operate_time", Convert.ToDateTime(qModel.eDate)); filters = Builders .Filter.And(filters, filters_edate); } int total; pager.data = MongoTools .FindListByPage(filters, qModel.pageindex, (qModel.pageindex - 1) * qModel.pagesize, out total, null, sort); pager.total = total; return pager; } #endregion
也可以先定义一个空的filterdefinition, 然后与各查询条件通过And聚合:
FilterDefinitionfilters = FilterDefinition .Empty; var filters_idlist = Builders .Filter.In("device_id", IdList); filters = Builders .Filter.And(filters, filters_idlist);
以上是“.Net Core怎么对MongoDB执行多条件查询”这篇文章的所有内容,感谢各位的阅读!相信大家都有了一定的了解,希望分享的内容对大家有所帮助,如果还想学习更多知识,欢迎关注创新互联行业资讯频道!
网站栏目:.NetCore怎么对MongoDB执行多条件查询-创新互联
分享链接:http://ybzwz.com/article/dijeoj.html