.Net Core如何对MongoDB执行多条件查询_实用技巧_

 dotnet add package mongodb.bson dotnet add package mongodb.driver

 "MongodbHost": { "Connection": "mongodb://[username]:[password]@[ip]:[port]", "DataBase": "[database]", "Table": "" },

 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"] }; }

 #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

 [BsonDateTimeOptions(Kind = DateTimeKind.Local)] public DateTime logtime { get; set; }

 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 filters = FilterDefinition.Empty; var filters_idlist = Builders.Filter.In("device_id", IdList); filters = Builders.Filter.And(filters, filters_idlist);