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

.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://myzitong.com/article/pgescc.html