Mongodb.Driver操作MongoDB
Posted Quebra
tags:
篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了Mongodb.Driver操作MongoDB相关的知识，希望对你有一定的参考价值。
上一篇博客主要介绍了MongoDB和它的的使用场景,这篇文章主要介绍一下如何用C#如何借助官方的Mongodb.Driver操作MongoDB
1.NuGet引入Mongodb.Dirver
安装后项目中会新增如下dll
MongoDB.Driver.dll：顾名思义，驱动程序
MongoDB.Bson.dll：序列化、Json相关
2.初始化集合,子类需重写集合名
#region 构造函数 /// <summary> /// 集合 /// </summary> public string _collName { get; set; } public MongoBaseRepository(string collName) { this._collName = collName; } #endregion
3..初始化链接和数据库
#region 连接配置 /// <summary> /// 链接 /// </summary> private static readonly string conneStr = "mongodb://127.0.0.1:27017"; /// <summary> /// 数据库 /// </summary> private static readonly string dbName = "TestDb"; #endregion #region 单例创建链接 private static IMongoClient _mongoclient { get; set; } private static IMongoClient CreateClient() { if (_mongoclient == null) { _mongoclient = new MongoClient(conneStr); } return _mongoclient; } #endregion #region 获取链接和数据库 private IMongoClient client = CreateClient(); public IMongoDatabase _database { get { return _mongoclient.GetDatabase(dbName); } } public IMongoDatabase GetDatabase() { return _database; } public IMongoCollection<T> GetClient<T>() where T : class, new() { return _database.GetCollection<T>(_collName); } #endregion
4.操作
Add：
#region +Add 添加一条数据 /// <summary> /// 添加一条数据 /// </summary> /// <param name="t">添加的实体</param> /// <param name="host">mongodb连接信息</param> /// <returns></returns> public int Add<T>(T t) where T : class, new() { try { var client = _database.GetCollection<T>(_collName); client.InsertOne(t); return 1; } catch (Exception ex) { return 0; } } #endregion #region +AddAsync 异步添加一条数据 /// <summary> /// 异步添加一条数据 /// </summary> /// <param name="t">添加的实体</param> /// <param name="host">mongodb连接信息</param> /// <returns></returns> public async Task<int> AddAsync<T>(T t) where T : class, new() { try { var client = _database.GetCollection<T>(_collName); await client.InsertOneAsync(t); return 1; } catch { return 0; } } #endregion #region +InsertMany 批量插入 /// <summary> /// 批量插入 /// </summary> /// <param name="host">mongodb连接信息</param> /// <param name="t">实体集合</param> /// <returns></returns> public int InsertMany<T>(List<T> t) where T : class, new() { try { var client = _database.GetCollection<T>(_collName); client.InsertMany(t); return 1; } catch (Exception ex) { return 0; } } #endregion #region +InsertManyAsync 异步批量插入 /// <summary> /// 异步批量插入 /// </summary> /// <param name="host">mongodb连接信息</param> /// <param name="t">实体集合</param> /// <returns></returns> public async Task<int> InsertManyAsync<T>(List<T> t) where T : class, new() { try { var client = _database.GetCollection<T>(_collName); await client.InsertManyAsync(t); return 1; } catch { return 0; } } #endregion
Modify:
#region +Update 修改一条数据 /// <summary> /// 修改一条数据 /// </summary> /// <param name="t">添加的实体</param> /// <param name="host">mongodb连接信息</param> /// <returns></returns> public UpdateResult Update<T>(T t, string id, bool isObjectId = true) where T : class, new() { try { var client = _database.GetCollection<T>(_collName); //修改条件 FilterDefinition<T> filter; if (isObjectId) { filter = Builders<T>.Filter.Eq("_id", new ObjectId(id)); } else { filter = Builders<T>.Filter.Eq("_id", id); } //要修改的字段 var list = new List<UpdateDefinition<T>>(); foreach (var item in t.GetType().GetProperties()) { if (item.Name.ToLower() == "id") continue; list.Add(Builders<T>.Update.Set(item.Name, item.GetValue(t))); } var updatefilter = Builders<T>.Update.Combine(list); return client.UpdateOne(filter, updatefilter); } catch (Exception ex) { throw ex; } } #endregion #region +UpdateAsync 异步修改一条数据 /// <summary> /// 异步修改一条数据 /// </summary> /// <param name="t">添加的实体</param> /// <param name="host">mongodb连接信息</param> /// <returns></returns> public async Task<UpdateResult> UpdateAsync<T>(T t, string id, bool isObjectId) where T : class, new() { try { var client = _database.GetCollection<T>(_collName); //修改条件 FilterDefinition<T> filter; if (isObjectId) { filter = Builders<T>.Filter.Eq("_id", new ObjectId(id)); } else { filter = Builders<T>.Filter.Eq("_id", id); } //要修改的字段 var list = new List<UpdateDefinition<T>>(); foreach (var item in t.GetType().GetProperties()) { if (item.Name.ToLower() == "id") continue; list.Add(Builders<T>.Update.Set(item.Name, item.GetValue(t))); } var updatefilter = Builders<T>.Update.Combine(list); return await client.UpdateOneAsync(filter, updatefilter); } catch (Exception ex) { throw ex; } } #endregion #region +UpdateManay 批量修改数据 /// <summary> /// 批量修改数据 /// </summary> /// <param name="dic">要修改的字段</param> /// <param name="host">mongodb连接信息</param> /// <param name="filter">修改条件</param> /// <returns></returns> public UpdateResult UpdateManay<T>(Dictionary<string, string> dic, FilterDefinition<T> filter) where T : class, new() { try { var client = _database.GetCollection<T>(_collName); T t = new T(); //要修改的字段 var list = new List<UpdateDefinition<T>>(); foreach (var item in t.GetType().GetProperties()) { if (!dic.ContainsKey(item.Name)) continue; var value = dic[item.Name]; list.Add(Builders<T>.Update.Set(item.Name, value)); } var updatefilter = Builders<T>.Update.Combine(list); return client.UpdateMany(filter, updatefilter); } catch (Exception ex) { throw ex; } } #endregion #region +UpdateManayAsync 异步批量修改数据 /// <summary> /// 异步批量修改数据 /// </summary> /// <param name="dic">要修改的字段</param> /// <param name="host">mongodb连接信息</param> /// <param name="filter">修改条件</param> /// <returns></returns> public async Task<UpdateResult> UpdateManayAsync<T>(Dictionary<string, string> dic, FilterDefinition<T> filter) where T : class, new() { try { var client = _database.GetCollection<T>(_collName); T t = new T(); //要修改的字段 var list = new List<UpdateDefinition<T>>(); foreach (var item in t.GetType().GetProperties()) { if (!dic.ContainsKey(item.Name)) continue; var value = dic[item.Name]; list.Add(Builders<T>.Update.Set(item.Name, value)); } var updatefilter = Builders<T>.Update.Combine(list); return await client.UpdateManyAsync(filter, updatefilter); } catch (Exception ex) { throw ex; } } #endregion
Remove:
#region Delete 删除一条数据 /// <summary> /// 删除一条数据 /// </summary> /// <param name="host">mongodb连接信息</param> /// <param name="id">objectId</param> /// <returns></returns> public DeleteResult Delete<T>(string id, bool isObjectId = true) where T : class, new() { try { var client = _database.GetCollection<T>(_collName); FilterDefinition<T> filter; if (isObjectId) { filter = Builders<T>.Filter.Eq("_id", new ObjectId(id)); } else { filter = Builders<T>.Filter.Eq("_id", id); } return client.DeleteOne(filter); } catch (Exception ex) { throw ex; } } #endregion #region DeleteAsync 异步删除一条数据 /// <summary> /// 异步删除一条数据 /// </summary> /// <param name="host">mongodb连接信息</param> /// <param name="id">objectId</param> /// <returns></returns> public async Task<DeleteResult> DeleteAsync<T>(string id, bool isObjectId = true) where T : class, new() { try { var client = _database.GetCollection<T>(_collName); //修改条件 FilterDefinition<T> filter; if (isObjectId) { filter = Builders<T>.Filter.Eq("_id", new ObjectId(id)); } else { filter = Builders<T>.Filter.Eq("_id", id); } return await client.DeleteOneAsync(filter); } catch (Exception ex) { throw ex; } } #endregion #region DeleteMany 删除多条数据 /// <summary> /// 删除一条数据 /// </summary> /// <param name="host">mongodb连接信息</param> /// <param name="filter">删除的条件</param> /// <returns></returns> public DeleteResult DeleteMany<T>(FilterDefinition<T> filter) where T : class, new() { try { var client = _database.GetCollection<T>(_collName); return client.DeleteMany(filter); } catch (Exception ex) { throw ex; } } #endregion #region DeleteManyAsync 异步删除多条数据 /// <summary> /// 异步删除多条数据 /// </summary> /// <param name="host">mongodb连接信息</param> /// <param name="filter">删除的条件</param> /// <returns></returns> public async Task<DeleteResult> DeleteManyAsync<T>(FilterDefinition<T> filter) where T : class, new() { try { var client = _database.GetCollection<T>(_collName); return await client.DeleteManyAsync(filter); } catch (Exception ex) { throw ex; } } #endregion
Find:
#region FindOne 根据id查询一条数据 /// <summary> /// 根据id查询一条数据 /// </summary> /// <param name="host">mongodb连接信息</param> /// <param name="id">objectid</param> /// <param name="field">要查询的字段，不写时查询全部</param> /// <returns></returns> public T FindOne<T>(string id, bool isObjectId = true, string[] field = null) where T : class, new() { try { var client = _database.GetCollection<T>(_collName); FilterDefinition<T> filter; if (isObjectId) { filter = Builders<T>.Filter.Eq("_id", new ObjectId(id)); } else { filter = Builders<T>.Filter.Eq("_id", id); } //不指定查询字段 if (field == null || field.Length == 0) { return client.Find(filter).FirstOrDefault<T>(); } //制定查询字段 var fieldList = new List<ProjectionDefinition<T>>(); for (int i = 0; i < field.Length; i++) { fieldList.Add(Builders<T>.Projection.Include(field[i].ToString())); } var projection = Builders<T>.Projection.Combine(fieldList); fieldList?.Clear(); return client.Find(filter).Project<T>(projection).FirstOrDefault<T>(); } catch (Exception ex) { throw ex; } } #endregion #region FindOneAsync 异步根据id查询一条数据 /// <summary> /// 异步根据id查询一条数据 /// </summary> /// <param name="host">mongodb连接信息</param> /// <param name="id">objectid</param> /// <returns></returns> public async Task<T> FindOneAsync<T>(string id, bool isObjectId = true, string[] field = null) where T : class, new() { try { var client = _database.GetCollection<T>(_collName); FilterDefinition<T> filter; if (isObjectId) { filter = Builders<T>.Filter.Eq("_id", new ObjectId(id)); } else { filter = Builders<T>.Filter.Eq("_id", id); } //不指定查询字段 if (field == null || field.Length == 0) { return await client.Find(filter).FirstOrDefaultAsync(); } //制定查询字段 var fieldList = new List<ProjectionDefinition<T>>(); for (int i = 0; i < field.Length; i++) { fieldList.Add(Builders<T>.Projection.Include(field[i].ToString())); } var projection = Builders<T>.Projection.Combine(fieldList); fieldList?.Clear(); return await client.Find(filter).Project<T>(projection).FirstOrDefaultAsync(); } catch (Exception ex) { throw ex; } } #endregion #region FindList 查询集合 /// <summary> /// 查询集合 /// </summary> /// <param name="host">mongodb连接信息</param> /// <param name="filter">查询条件</param> /// <param name="field">要查询的字段,不写时查询全部</param> /// <param name="sort">要排序的字段</param> /// <returns></returns> public List<T> FindList<T>(FilterDefinition<T> filter, string[] field = null, SortDefinition<T> sort = null) where T : class, new() { try { var client = _database.GetCollection<T>(_collName); //不指定查询字段 if (field == null || field.Length == 0) { if (sort == null) return client.Find(filter).ToList(); //进行排序 return client.Find(filter).Sort(sort).ToList(); } //制定查询字段 var fieldList = new List<ProjectionDefinition<T>>(); for (int i = 0; i < field.Length; i++) { fieldList.Add(Builders<T>.Projection.Include(field[i].ToString())); } var projection = Builders<T>.Projection.Combine(fieldList); fieldList?.Clear(); if (sort == null) return client.Find(filter).Project<T>(projection).ToList(); //排序查询 return client.Find(filter).Sort(sort).Project<T>MongoDB C# Driver 快速入门C# mongodb driver 2.0 - 如何在批量操作中更新插入？
C# .Net + MongoDB Atlas 连接字符串 MongoDB.Driver.Legacy 尝试运行客户端时出错