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

以前项目基本上全部使用MySQL数据库, 最近项目排期空出了一点时间leader决定把日志模块迁移到插入/查询性能更好的MongoDB上. 多条件查询的写法着实费了些功夫, 撰文记录一下.

相关学习推荐：C#.Net开发图文教程

一、准备工作

1. 安装过程, 不赘述了

2. 添加ReferencePackage

dotnet add package mongodb.bsondotnet 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 分页查询集合  /// summary>
      /// 分页查询集合  /// /summary>
      /// param name="filter">
    查询条件/param>
      /// param name="pageindex">
    当前页/param>
      /// param name="pageSize">
    页容量/param>
      /// param name="count">
    总条数/param>
      /// param name="field">
    要查询的字段,不写时查询全部/param>
      /// param name="sort">
    要排序的字段/param>
      /// returns>
    /returns>
      public static ListT>
     FindListByPage(FilterDefinITionT>
     filter, int pageIndex, int pageSize, out int count, string[] field = null, SortDefinitionT>
 sort = null)  {
    try    {
          MongodbHostOptions host = Tools.AppSettingsTools.MongodbConfig();
          host.Table = "WSMessageLOG";
          var client = MongodbClientT>
    .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 ListPRojectionDefinitionT>
    >
    ();
          for (int i = 0;
     i  field.Length;
 i++)      {
            fieldList.Add(BuildersT>
    .Projection.Include(field[i].ToString()));
      }
          var projection = BuildersT>
    .Projection.COMbine(fieldList);
          fieldList?.Clear();
          //不排序      if (sort == null) return client.Find(filter).ProjectT>
    (projection).Skip((pageIndex - 1) * pageSize).Limit(pageSize).ToList();
          //排序查询      return client.Find(filter).Sort(sort).ProjectT>
    (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 LogPagerlog_operate>
 Get_operate_log_mongo(OprLogModel qModel){
    　　LogPagerlog_operate>
     pager = new LogPagerlog_operate>
    ();
    　　FilterDefinitionlog_operate>
     filters;
    　　 var sortbuilder = Builderslog_operate>
    .Sort;
    　　var sort = sortbuilder.Descending("operate_time");
    　　#region 用户权限过滤　　IEnumerablestring>
     IdList = dev_deviceRepository.GetBinding(qModel.user_id);
    　　 filters = Builderslog_operate>
    .Filter.In("device_id", IdList);
　　#endregion　　if (!string.IsNullOrEmpty(qModel.device_id))  {
      　　var filters_did = Builderslog_operate>
    .Filter.Eq("device_id", qModel.device_id);
      　　filters = Builderslog_operate>
    .Filter.And(filters, filters_did);
　　}
　　if (qModel.sDate != null)　　{
    　　　　var filters_sdate = Builderslog_operate>
    .Filter.GteDateTime>
    ("operate_time", Convert.ToDateTime(qModel.sDate));
    　　　　filters = Builderslog_operate>
    .Filter.And(filters, filters_sdate);
　　}
　　if (qModel.eDate != null)　　{
    　　　　var filters_edate = Builderslog_operate>
    .Filter.LteDateTime>
    ("operate_time", Convert.ToDateTime(qModel.eDate));
    　　　　filters = Builderslog_operate>
    .Filter.And(filters, filters_edate);
　　}
    　　int total;
    　　pager.data = MongoToolslog_operate>
    .FindListByPage(filters, qModel.pageindex, (qModel.pageindex - 1) * qModel.pagesize, out total, null, sort);
    　　pager.total = total;
    　　return pager;
}
    #endregion

也可以先定义一个空的filterdefinition, 然后与各查询条件通过And聚合:

FilterDefinitionlog_operate>
     filters = FilterDefinitionlog_operate>
    .Empty;
    var filters_idlist = Builderslog_operate>
    .Filter.In("device_id", IdList);
    filters = Builderslog_operate>
    .Filter.And(filters, filters_idlist);
    

以上就是.Net Core对MongoDB执行多条件查询的详细内容，更多请关注其它相关文章！

声明：本文内容由网友自发贡献，本站不承担相应法律责任。对本内容有异议或投诉，请联系2913721942#qq.com核实处理，我们将尽快回复您，谢谢合作！