Mongodb for .Net Core 封装类库

本文内容纲要：

一：引用的mongodb驱动文件版本为Mongodb.Driver20.4.3

二：我只是进行了常用方法的封装，如有不当之处，请联系我

创建mongodb的连接

usingMongoDB.Bson; usingMongoDB.Driver; namespaceMongodbTest.Comon { publicstaticclassMongodbClient<T>whereT:class { #region+MongodbInfoClient获取mongodb实例 ///<summary> ///获取mongodb实例 ///</summary> ///<paramname="host">连接字符串，库，表</param> ///<returns></returns> publicstaticIMongoCollection<T>MongodbInfoClient(MongodbHosthost) { MongoClientclient=newMongoClient(host.Connection); vardataBase=client.GetDatabase(host.DataBase); returndataBase.GetCollection<T>(host.Table); } #endregion } publicclassMongodbHost { ///<summary> ///连接字符串 ///</summary> publicstringConnection{get;set;} ///<summary> ///库 ///</summary> publicstringDataBase{get;set;} ///<summary> ///表 ///</summary> publicstringTable{get;set;} } }

三：mongodb的增删改查

publicstaticclassTMongodbHelper<T>whereT:class,new() { #region+Add添加一条数据 ///<summary> ///添加一条数据 ///</summary> ///<paramname="t">添加的实体</param> ///<paramname="host">mongodb连接信息</param> ///<returns></returns> publicstaticintAdd(MongodbHosthost,Tt) { try { varclient=MongodbClient<T>.MongodbInfoClient(host); client.InsertOne(t); return1; } catch { return0; } } #endregion #region+AddAsync异步添加一条数据 ///<summary> ///异步添加一条数据 ///</summary> ///<paramname="t">添加的实体</param> ///<paramname="host">mongodb连接信息</param> ///<returns></returns> publicstaticasyncTask<int>AddAsync(MongodbHosthost,Tt) { try { varclient=MongodbClient<T>.MongodbInfoClient(host); awaitclient.InsertOneAsync(t); return1; } catch { return0; } } #endregion #region+InsertMany批量插入 ///<summary> ///批量插入 ///</summary> ///<paramname="host">mongodb连接信息</param> ///<paramname="t">实体集合</param> ///<returns></returns> publicstaticintInsertMany(MongodbHosthost,List<T>t) { try { varclient=MongodbClient<T>.MongodbInfoClient(host); client.InsertMany(t); return1; } catch(Exceptionex) { return0; } } #endregion #region+InsertManyAsync异步批量插入 ///<summary> ///异步批量插入 ///</summary> ///<paramname="host">mongodb连接信息</param> ///<paramname="t">实体集合</param> ///<returns></returns> publicstaticasyncTask<int>InsertManyAsync(MongodbHosthost,List<T>t) { try { varclient=MongodbClient<T>.MongodbInfoClient(host); awaitclient.InsertManyAsync(t); return1; } catch { return0; } } #endregion #region+Update修改一条数据 ///<summary> ///修改一条数据 ///</summary> ///<paramname="t">添加的实体</param> ///<paramname="host">mongodb连接信息</param> ///<returns></returns> publicstaticUpdateResultUpdate(MongodbHosthost,Tt,stringid) { try { varclient=MongodbClient<T>.MongodbInfoClient(host); //修改条件 FilterDefinition<T>filter=Builders<T>.Filter.Eq("_id",newObjectId(id)); //要修改的字段 varlist=newList<UpdateDefinition<T>>(); foreach(varitemint.GetType().GetProperties()) { if(item.Name.ToLower()=="id")continue; list.Add(Builders<T>.Update.Set(item.Name,item.GetValue(t))); } varupdatefilter=Builders<T>.Update.Combine(list); returnclient.UpdateOne(filter,updatefilter); } catch(Exceptionex) { throwex; } } #endregion #region+UpdateAsync异步修改一条数据 ///<summary> ///异步修改一条数据 ///</summary> ///<paramname="t">添加的实体</param> ///<paramname="host">mongodb连接信息</param> ///<returns></returns> publicstaticasyncTask<UpdateResult>UpdateAsync(MongodbHosthost,Tt,stringid) { try { varclient=MongodbClient<T>.MongodbInfoClient(host); //修改条件 FilterDefinition<T>filter=Builders<T>.Filter.Eq("_id",newObjectId(id)); //要修改的字段 varlist=newList<UpdateDefinition<T>>(); foreach(varitemint.GetType().GetProperties()) { if(item.Name.ToLower()=="id")continue; list.Add(Builders<T>.Update.Set(item.Name,item.GetValue(t))); } varupdatefilter=Builders<T>.Update.Combine(list); returnawaitclient.UpdateOneAsync(filter,updatefilter); } catch(Exceptionex) { throwex; } } #endregion #region+UpdateManay批量修改数据 ///<summary> ///批量修改数据 ///</summary> ///<paramname="dic">要修改的字段</param> ///<paramname="host">mongodb连接信息</param> ///<paramname="filter">修改条件</param> ///<returns></returns> publicstaticUpdateResultUpdateManay(MongodbHosthost,Dictionary<string,string>dic,FilterDefinition<T>filter) { try { varclient=MongodbClient<T>.MongodbInfoClient(host); Tt=newT(); //要修改的字段 varlist=newList<UpdateDefinition<T>>(); foreach(varitemint.GetType().GetProperties()) { if(!dic.ContainsKey(item.Name))continue; varvalue=dic[item.Name]; list.Add(Builders<T>.Update.Set(item.Name,value)); } varupdatefilter=Builders<T>.Update.Combine(list); returnclient.UpdateMany(filter,updatefilter); } catch(Exceptionex) { throwex; } } #endregion #region+UpdateManayAsync异步批量修改数据 ///<summary> ///异步批量修改数据 ///</summary> ///<paramname="dic">要修改的字段</param> ///<paramname="host">mongodb连接信息</param> ///<paramname="filter">修改条件</param> ///<returns></returns> publicstaticasyncTask<UpdateResult>UpdateManayAsync(MongodbHosthost,Dictionary<string,string>dic,FilterDefinition<T>filter) { try { varclient=MongodbClient<T>.MongodbInfoClient(host); Tt=newT(); //要修改的字段 varlist=newList<UpdateDefinition<T>>(); foreach(varitemint.GetType().GetProperties()) { if(!dic.ContainsKey(item.Name))continue; varvalue=dic[item.Name]; list.Add(Builders<T>.Update.Set(item.Name,value)); } varupdatefilter=Builders<T>.Update.Combine(list); returnawaitclient.UpdateManyAsync(filter,updatefilter); } catch(Exceptionex) { throwex; } } #endregion #regionDelete删除一条数据 ///<summary> ///删除一条数据 ///</summary> ///<paramname="host">mongodb连接信息</param> ///<paramname="id">objectId</param> ///<returns></returns> publicstaticDeleteResultDelete(MongodbHosthost,stringid) { try { varclient=MongodbClient<T>.MongodbInfoClient(host); FilterDefinition<T>filter=Builders<T>.Filter.Eq("_id",newObjectId(id)); returnclient.DeleteOne(filter); } catch(Exceptionex) { throwex; } } #endregion #regionDeleteAsync异步删除一条数据 ///<summary> ///异步删除一条数据 ///</summary> ///<paramname="host">mongodb连接信息</param> ///<paramname="id">objectId</param> ///<returns></returns> publicstaticasyncTask<DeleteResult>DeleteAsync(MongodbHosthost,stringid) { try { varclient=MongodbClient<T>.MongodbInfoClient(host); //修改条件 FilterDefinition<T>filter=Builders<T>.Filter.Eq("_id",newObjectId(id)); returnawaitclient.DeleteOneAsync(filter); } catch(Exceptionex) { throwex; } } #endregion #regionDeleteMany删除多条数据 ///<summary> ///删除一条数据 ///</summary> ///<paramname="host">mongodb连接信息</param> ///<paramname="filter">删除的条件</param> ///<returns></returns> publicstaticDeleteResultDeleteMany(MongodbHosthost,FilterDefinition<T>filter) { try { varclient=MongodbClient<T>.MongodbInfoClient(host); returnclient.DeleteMany(filter); } catch(Exceptionex) { throwex; } } #endregion #regionDeleteManyAsync异步删除多条数据 ///<summary> ///异步删除多条数据 ///</summary> ///<paramname="host">mongodb连接信息</param> ///<paramname="filter">删除的条件</param> ///<returns></returns> publicstaticasyncTask<DeleteResult>DeleteManyAsync(MongodbHosthost,FilterDefinition<T>filter) { try { varclient=MongodbClient<T>.MongodbInfoClient(host); returnawaitclient.DeleteManyAsync(filter); } catch(Exceptionex) { throwex; } } #endregion #regionCount根据条件获取总数 ///<summary> ///根据条件获取总数 ///</summary> ///<paramname="host">mongodb连接信息</param> ///<paramname="filter">条件</param> ///<returns></returns> publicstaticlongCount(MongodbHosthost,FilterDefinition<T>filter) { try { varclient=MongodbClient<T>.MongodbInfoClient(host); returnclient.Count(filter); } catch(Exceptionex) { throwex; } } #endregion #regionCountAsync异步根据条件获取总数 ///<summary> ///异步根据条件获取总数 ///</summary> ///<paramname="host">mongodb连接信息</param> ///<paramname="filter">条件</param> ///<returns></returns> publicstaticasyncTask<long>CountAsync(MongodbHosthost,FilterDefinition<T>filter) { try { varclient=MongodbClient<T>.MongodbInfoClient(host); returnawaitclient.CountAsync(filter); } catch(Exceptionex) { throwex; } } #endregion #regionFindOne根据id查询一条数据 ///<summary> ///根据id查询一条数据 ///</summary> ///<paramname="host">mongodb连接信息</param> ///<paramname="id">objectid</param> ///<paramname="field">要查询的字段，不写时查询全部</param> ///<returns></returns> publicstaticTFindOne(MongodbHosthost,stringid,string[]field=null) { try { varclient=MongodbClient<T>.MongodbInfoClient(host); FilterDefinition<T>filter=Builders<T>.Filter.Eq("_id",newObjectId(id)); //不指定查询字段 if(field==null||field.Length==0) { returnclient.Find(filter).FirstOrDefault<T>(); } //制定查询字段 varfieldList=newList<ProjectionDefinition<T>>(); for(inti=0;i<field.Length;i++) { fieldList.Add(Builders<T>.Projection.Include(field[i].ToString())); } varprojection=Builders<T>.Projection.Combine(fieldList); fieldList?.Clear(); returnclient.Find(filter).Project<T>(projection).FirstOrDefault<T>(); } catch(Exceptionex) { throwex; } } #endregion #regionFindOneAsync异步根据id查询一条数据 ///<summary> ///异步根据id查询一条数据 ///</summary> ///<paramname="host">mongodb连接信息</param> ///<paramname="id">objectid</param> ///<returns></returns> publicstaticasyncTask<T>FindOneAsync(MongodbHosthost,stringid,string[]field=null) { try { varclient=MongodbClient<T>.MongodbInfoClient(host); FilterDefinition<T>filter=Builders<T>.Filter.Eq("_id",newObjectId(id)); //不指定查询字段 if(field==null||field.Length==0) { returnawaitclient.Find(filter).FirstOrDefaultAsync(); } //制定查询字段 varfieldList=newList<ProjectionDefinition<T>>(); for(inti=0;i<field.Length;i++) { fieldList.Add(Builders<T>.Projection.Include(field[i].ToString())); } varprojection=Builders<T>.Projection.Combine(fieldList); fieldList?.Clear(); returnawaitclient.Find(filter).Project<T>(projection).FirstOrDefaultAsync(); } catch(Exceptionex) { throwex; } } #endregion #regionFindList查询集合 ///<summary> ///查询集合 ///</summary> ///<paramname="host">mongodb连接信息</param> ///<paramname="filter">查询条件</param> ///<paramname="field">要查询的字段,不写时查询全部</param> ///<paramname="sort">要排序的字段</param> ///<returns></returns> publicstaticList<T>FindList(MongodbHosthost,FilterDefinition<T>filter,string[]field=null,SortDefinition<T>sort=null) { try { varclient=MongodbClient<T>.MongodbInfoClient(host); //不指定查询字段 if(field==null||field.Length==0) { if(sort==null)returnclient.Find(filter).ToList(); //进行排序 returnclient.Find(filter).Sort(sort).ToList(); } //制定查询字段 varfieldList=newList<ProjectionDefinition<T>>(); for(inti=0;i<field.Length;i++) { fieldList.Add(Builders<T>.Projection.Include(field[i].ToString())); } varprojection=Builders<T>.Projection.Combine(fieldList); fieldList?.Clear(); if(sort==null)returnclient.Find(filter).Project<T>(projection).ToList(); //排序查询 returnclient.Find(filter).Sort(sort).Project<T>(projection).ToList(); } catch(Exceptionex) { throwex; } } #endregion #regionFindListAsync异步查询集合 ///<summary> ///异步查询集合 ///</summary> ///<paramname="host">mongodb连接信息</param> ///<paramname="filter">查询条件</param> ///<paramname="field">要查询的字段,不写时查询全部</param> ///<paramname="sort">要排序的字段</param> ///<returns></returns> publicstaticasyncTask<List<T>>FindListAsync(MongodbHosthost,FilterDefinition<T>filter,string[]field=null,SortDefinition<T>sort=null) { try { varclient=MongodbClient<T>.MongodbInfoClient(host); //不指定查询字段 if(field==null||field.Length==0) { if(sort==null)returnawaitclient.Find(filter).ToListAsync(); returnawaitclient.Find(filter).Sort(sort).ToListAsync(); } //制定查询字段 varfieldList=newList<ProjectionDefinition<T>>(); for(inti=0;i<field.Length;i++) { fieldList.Add(Builders<T>.Projection.Include(field[i].ToString())); } varprojection=Builders<T>.Projection.Combine(fieldList); fieldList?.Clear(); if(sort==null)returnawaitclient.Find(filter).Project<T>(projection).ToListAsync(); //排序查询 returnawaitclient.Find(filter).Sort(sort).Project<T>(projection).ToListAsync(); } catch(Exceptionex) { throwex; } } #endregion #regionFindListByPage分页查询集合 ///<summary> ///分页查询集合 ///</summary> ///<paramname="host">mongodb连接信息</param> ///<paramname="filter">查询条件</param> ///<paramname="pageIndex">当前页</param> ///<paramname="pageSize">页容量</param> ///<paramname="count">总条数</param> ///<paramname="field">要查询的字段,不写时查询全部</param> ///<paramname="sort">要排序的字段</param> ///<returns></returns> publicstaticList<T>FindListByPage(MongodbHosthost,FilterDefinition<T>filter,intpageIndex,intpageSize,outlongcount,string[]field=null,SortDefinition<T>sort=null) { try { varclient=MongodbClient<T>.MongodbInfoClient(host); count=client.Count(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<ProjectionDefinition<T>>(); for(inti=0;i<field.Length;i++) { fieldList.Add(Builders<T>.Projection.Include(field[i].ToString())); } varprojection=Builders<T>.Projection.Combine(fieldList); fieldList?.Clear(); //不排序 if(sort==null)returnclient.Find(filter).Project<T>(projection).Skip((pageIndex-1)*pageSize).Limit(pageSize).ToList(); //排序查询 returnclient.Find(filter).Sort(sort).Project<T>(projection).Skip((pageIndex-1)*pageSize).Limit(pageSize).ToList(); } catch(Exceptionex) { throwex; } } #endregion #regionFindListByPageAsync异步分页查询集合 ///<summary> ///异步分页查询集合 ///</summary> ///<paramname="host">mongodb连接信息</param> ///<paramname="filter">查询条件</param> ///<paramname="pageIndex">当前页</param> ///<paramname="pageSize">页容量</param> ///<paramname="field">要查询的字段,不写时查询全部</param> ///<paramname="sort">要排序的字段</param> ///<returns></returns> publicstaticasyncTask<List<T>>FindListByPageAsync(MongodbHosthost,FilterDefinition<T>filter,intpageIndex,intpageSize,string[]field=null,SortDefinition<T>sort=null) { try { varclient=MongodbClient<T>.MongodbInfoClient(host); //不指定查询字段 if(field==null||field.Length==0) { if(sort==null)returnawaitclient.Find(filter).Skip((pageIndex-1)*pageSize).Limit(pageSize).ToListAsync(); //进行排序 returnawaitclient.Find(filter).Sort(sort).Skip((pageIndex-1)*pageSize).Limit(pageSize).ToListAsync(); } //制定查询字段 varfieldList=newList<ProjectionDefinition<T>>(); for(inti=0;i<field.Length;i++) { fieldList.Add(Builders<T>.Projection.Include(field[i].ToString())); } varprojection=Builders<T>.Projection.Combine(fieldList); fieldList?.Clear(); //不排序 if(sort==null)returnawaitclient.Find(filter).Project<T>(projection).Skip((pageIndex-1)*pageSize).Limit(pageSize).ToListAsync(); //排序查询 returnawaitclient.Find(filter).Sort(sort).Project<T>(projection).Skip((pageIndex-1)*pageSize).Limit(pageSize).ToListAsync(); } catch(Exceptionex) { throwex; } } #endregion }

三：调用栗子

//1.批量修改,修改的条件 vartime=DateTime.Now; varlist=newList<FilterDefinition<PhoneEntity>>(); list.Add(Builders<PhoneEntity>.Filter.Lt("AddTime",time.AddDays(5))); list.Add(Builders<PhoneEntity>.Filter.Gt("AddTime",time)); varfilter=Builders<PhoneEntity>.Filter.And(list); //2.要修改的字段内容 vardic=newDictionary<string,string>(); dic.Add("UseAge","168"); dic.Add("Name","朝阳"); //3.批量修改 varkk=TMongodbHelper<PhoneEntity>.UpdateManay(host,dic,filter); //根据条件查询集合 vartime=DateTime.Now; varlist=newList<FilterDefinition<PhoneEntity>>(); list.Add(Builders<PhoneEntity>.Filter.Lt("AddTime",time.AddDays(20))); list.Add(Builders<PhoneEntity>.Filter.Gt("AddTime",time)); varfilter=Builders<PhoneEntity>.Filter.And(list); //2.查询字段 varfield=new[]{"Name","Price","AddTime"}; //3.排序字段 varsort=Builders<PhoneEntity>.Sort.Descending("AddTime"); varres=TMongodbHelper<PhoneEntity>.FindList(host,filter,field,sort); //分页查询，查询条件 vartime=DateTime.Now; varlist=newList<FilterDefinition<PhoneEntity>>(); list.Add(Builders<PhoneEntity>.Filter.Lt("AddTime",time.AddDays(400))); list.Add(Builders<PhoneEntity>.Filter.Gt("AddTime",time)); varfilter=Builders<PhoneEntity>.Filter.And(list); longcount=0; //排序条件 varsort=Builders<PhoneEntity>.Sort.Descending("AddTime"); varres=TMongodbHelper<PhoneEntity>.FindListByPage(host,filter,2,10,outcount,null,sort);

四，缺少sdk文件时，请自行安装

参考文章：http://www.cnblogs.com/yaozhenfa/p/4574898.html

本文内容总结：

原文链接：https://www.cnblogs.com/xiaoyaodijun/p/6861972.html