创新互联www.cdcxhl.cn八线动态BGP香港云服务器提供商，新人活动买多久送多久，划算不套路！
成都创新互联公司是专业的下冶网站建设公司，下冶接单;提供
成都网站设计、网站建设,网页设计,网站设计,建网站,PHP网站建设等专业做网站服务;采用PHP框架,可快速的进行下冶网站开发网页制作和功能扩展;专业做搜索引擎喜爱的网站,专业的做网站团队,希望更多企业前来合作!
.Net Core对MongoDB如何执行多条件查询？相信很多没有经验的人对此束手无策，为此本文总结了问题出现的原因和解决方法，通过这篇文章希望你能解决这个问题。
以前项目基本上全部使用MySQL数据库, 最近项目排期空出了一点时间leader决定把日志模块迁移到插入/查询性能更好的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 LogPager Get_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聚合:
FilterDefinition filters = FilterDefinition.Empty;
var filters_idlist = Builders.Filter.In("device_id", IdList);
filters = Builders.Filter.And(filters, filters_idlist);
看完上述内容，你们掌握.Net Core对MongoDB如何执行多条件查询的方法了吗？如果还想学到更多技能或想了解更多相关内容，欢迎关注创新互联-成都网站建设公司行业资讯频道，感谢各位的阅读！
当前文章：.NetCore对MongoDB如何执行多条件查询-创新互联
分享地址：
http://bjjierui.cn/article/cdhdig.html
