.Net Core如何对MongoDB执行多条件查询

2023-07-21 23:02:04 89

以前项目基本上全部使用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分页查询集合
///
///分页查询集合
///
///查询条件
///当前页
///页容量
///总条数
///要查询的字段,不写时查询全部
///要排序的字段
///
publicstaticListFindListByPage(FilterDefinitionfilter,intpageIndex,intpageSize,outintcount,string[]field=null,SortDefinitionsort=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)
{
LogPagerpager=newLogPager();
FilterDefinitionfilters;

varsortbuilder=Builders.Sort;
varsort=sortbuilder.Descending("operate_time");

#region用户权限过滤
IEnumerableIdList=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多条件查询的资料请关注毛票票其它相关文章！

.Net Core如何对MongoDB执行多条件查询

热门推荐

随机推荐