.Net Core如何对MongoDB执行多条件查询
以前项目基本上全部使用MySQL数据库,最近项目排期空出了一点时间leader决定把日志模块迁移到插入/查询性能更好的MongoDB上.多条件查询的写法着实费了些功夫,撰文记录一下.
一、准备工作
1.安装过程,不赘述了
2.添加ReferencePackage
dotnetaddpackagemongodb.bson dotnetaddpackagemongodb.driver
3.appsetting.json添加连接配置
"MongodbHost":{ "Connection":"mongodb://[username]:[password]@[ip]:[port]", "DataBase":"[database]", "Table":"" },
4.获取MongoDBConfig的方法
publicstaticMongodbHostOptionsMongodbConfig() { varbuilder=newConfigurationBuilder() .SetBasePath(Directory.GetCurrentDirectory()) .AddJsonFile("appsettings.json"); IConfigurationConfiguration=builder.Build(); varoption=Configuration.GetSection("MongodbHost"); returnnewMongodbHostOptions{Connection=option["Connection"],DataBase=option["DataBase"],Table=option["Table"]}; }
二、查询方法
这里的查询方法是网上找的,直接拿来用了.如果是单一数据源的话,这里的host可以提取出来成为helper类的属性.
#regionFindListByPage分页查询集合 //////分页查询集合 /// ///查询条件 /// 当前页 /// 页容量 /// 总条数 /// 要查询的字段,不写时查询全部 /// 要排序的字段 /// publicstaticList FindListByPage(FilterDefinition filter,intpageIndex,intpageSize,outintcount,string[]field=null,SortDefinition sort=null) { try { MongodbHostOptionshost=Tools.AppSettingsTools.MongodbConfig(); host.Table="WSMessageLog"; varclient=MongodbClient .MongodbInfoClient(host); count=Convert.ToInt32(client.CountDocuments(filter)); //不指定查询字段 if(field==null||field.Length==0) { if(sort==null)returnclient.Find(filter).Skip((pageIndex-1)*pageSize).Limit(pageSize).ToList(); //进行排序 returnclient.Find(filter).Sort(sort).Skip((pageIndex-1)*pageSize).Limit(pageSize).ToList(); } //指定查询字段 varfieldList=newList >(); for(inti=0;i .Projection.Include(field[i].ToString())); } varprojection=Builders .Projection.Combine(fieldList); fieldList?.Clear(); //不排序 if(sort==null)returnclient.Find(filter).Project (projection).Skip((pageIndex-1)*pageSize).Limit(pageSize).ToList(); //排序查询 returnclient.Find(filter).Sort(sort).Project (projection).Skip((pageIndex-1)*pageSize).Limit(pageSize).ToList(); } catch(Exceptionex) { throwex; } } #endregion
三、调用查询方法
这里还踩了一个坑.MongoDB里存储的时间是格林尼治时间,插入8:00,查询时会发现变成了0:00,所以定义时间属性的时候需要加个标签
[BsonDateTimeOptions(Kind=DateTimeKind.Local)] publicDateTimelogtime{get;set;}
这里的OprLogModel是定义了查询条件的类.
publicstaticLogPagerGet_operate_log_mongo(OprLogModelqModel) { LogPager pager=newLogPager (); FilterDefinition filters; varsortbuilder=Builders .Sort; varsort=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)) { varfilters_did=Builders .Filter.Eq("device_id",qModel.device_id); filters=Builders .Filter.And(filters,filters_did); } if(qModel.sDate!=null) { varfilters_sdate=Builders .Filter.Gte ("operate_time",Convert.ToDateTime(qModel.sDate)); filters=Builders .Filter.And(filters,filters_sdate); } if(qModel.eDate!=null) { varfilters_edate=Builders .Filter.Lte ("operate_time",Convert.ToDateTime(qModel.eDate)); filters=Builders .Filter.And(filters,filters_edate); } inttotal; pager.data=MongoTools .FindListByPage(filters,qModel.pageindex,(qModel.pageindex-1)*qModel.pagesize,outtotal,null,sort); pager.total=total; returnpager; } #endregion
也可以先定义一个空的filterdefinition,然后与各查询条件通过And聚合:
FilterDefinitionfilters=FilterDefinition .Empty; varfilters_idlist=Builders .Filter.In("device_id",IdList); filters=Builders .Filter.And(filters,filters_idlist);
以上就是.NetCore如何对MongoDB执行多条件查询的详细内容,更多关于.NetCore对MongoDB多条件查询的资料请关注毛票票其它相关文章!