【经验分享】Mongodb操作类实现CRUD

一.背景

公司项目中在做数据存储时使用到Mongodb，所以想着将Mongodb的操作封装后可供项目中其他成员方便使用。

附上Mongodb的下载地址： 下载

1.Mongodb类 此类主要是用来构造Mongodb数据库实例的。

 public class MongoDb
    {
        public MongoDb(string host, string DbName, string timeOut)
        {
            this.Connect_TimeOut = timeOut;
            this.Mongo_Conn_Host = host;
            this.Db_Name = DbName;
        }
        /// <summary>
        /// 数据库所在主机
        /// </summary>
        private readonly string Mongo_Conn_Host;
        /// <summary>
        /// 数据库所在主机的端口
        /// </summary>
        private readonly int Mongo_Conn_Port = 27017;
        //private readonly int Mongo_Conn_Port = 8635;
        /// <summary>
        /// 连接超时设置 秒
        /// </summary>
        private readonly string Connect_TimeOut;

        /// <summary>
        /// 数据库名称
        /// </summary>
        private readonly string Db_Name;

        /// <summary>  
        /// 得到数据库实例  
        /// </summary>  
        /// <returns></returns>  
        public IMongoDatabase GetDataBase()
        {

            MongoClientSettings mongoSetting = new MongoClientSettings();
            //设置连接超时时间  
            //mongoSetting.ConnectTimeout = new TimeSpan(int.Parse(Connect_TimeOut) * TimeSpan.TicksPerSecond);
            mongoSetting.ConnectTimeout = TimeSpan.FromSeconds(1000);
            //设置数据库服务器  
            mongoSetting.Server = new MongoServerAddress(Mongo_Conn_Host, Mongo_Conn_Port);

            //创建Mongo的客户端  
            MongoClient client = new MongoClient(mongoSetting);
            //得到服务器端并且生成数据库实例  
            return client.GetDatabase(Db_Name);
        }
    }

2.MongoEntityBase类 包含Mongodb的主键 _id

    public class MongoEntityBase
    {
        public ObjectId _id { get; set; }

    }

3.MongodbConfig类，包含Mongodb的连接地址，数据库名称和集合名称

    public class MongoDBConfig
    {
        public string ConnectionString { get; set; }
        public string DbName { get; set; }
        public string CollectionName { get; set; }
    }

4.MongodbRepository泛型类，传入要操作的对象实现CRUD

  public class MongoDbRepository<T>where T : MongoEntityBase
    {
        public IMongoCollection<T> Collection { get; private set; }
        public IMongoDatabase Database { get; private set; }

        public MongoDbRepository(MongoDBConfig config)
        {
            Database = new MongoClient(config.ConnectionString).GetDatabase(config.DbName);
            Collection = Database.GetCollection<T>(config.CollectionName);
        }
        #region +Add 添加一条数据
        public void Add(T t)
        {
            try
            {
                this.Collection.InsertOne(t);
            }
            catch (Exception e)
            {

                throw e;
            }
        }
        #endregion

        #region +AddAsync 异步添加一条数据
        /// <summary>
        /// 异步添加一条数据
        /// </summary>
        /// <param name="t">添加的实体</param>
        /// <param name="host">mongodb连接信息</param>
        /// <returns></returns>
        public async Task AddAsync(T t)
        {
            try
            {
                await Collection.InsertOneAsync(t);
            }
            catch (Exception e)
            {
                throw e;
            }
        }
        #endregion

        #region +InsertMany 批量插入
        /// <summary>
        /// 批量插入
        /// </summary>
        /// <param name="host">mongodb连接信息</param>
        /// <param name="t">实体集合</param>
        /// <returns></returns>
        public void InsertMany(List<T> t)
        {
            try
            {
                if (t != null && t.Count > 0)
                {
                    Collection.InsertMany(t);
                }
            }
            catch (Exception ex)
            {
                throw new UserFriendlyException(ex.Message);
            }
        }
        public async Task InsertManyAsync(List<T> t)
        {
            try
            {
                if (t != null && t.Count > 0)
                {
                    await Collection.InsertManyAsync(t);
                }
            }
            catch (Exception ex)
            {
                throw ex;
            }
        }
        #endregion

        #region +Update 修改一条数据
        /// <summary>
        /// 修改一条数据
        /// </summary>
        /// <param name="t">添加的实体</param>
        /// <param name="host">mongodb连接信息</param>
        /// <returns></returns>
        public ReplaceOneResult UpdateOne(T t)
        {
            try
            {
                //修改条件
                FilterDefinition<T> filter = Builders<T>.Filter.Eq("_id", t._id);
                //Collection.UpdateOne(filter,Builders<T>.Update)
                return Collection.ReplaceOne(filter, t, new UpdateOptions { IsUpsert = true });
            }
            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(Expression<Func<T, bool>> filter, dynamic modifyFields)
        {
            try
            {
                var list = new List<UpdateDefinition<T>>();
                foreach (PropertyInfo item in modifyFields.GetType().GetProperties())
                {
                    if (item.Name.ToLower() == "id") continue;
                    list.Add(Builders<T>.Update.Set(item.Name, item.GetValue(modifyFields)));
                }
                return Collection.UpdateMany(filter, Builders<T>.Update.Combine(list));
            }
            catch (Exception ex)
            {
                throw new UserFriendlyException(ex.Message);
            }
        }
        #endregion

        #region Delete 删除一条数据
        /// <summary>
        /// 删除一条数据
        /// </summary>
        /// <param name="host">mongodb连接信息</param>
        /// <param name="id">objectId</param>
        /// <returns></returns>
        public DeleteResult DeleteOne(ObjectId id)
        {
            try
            {
                var filter = Builders<T>.Filter.Eq("_id", id);
                return Collection.DeleteOne(filter);
            }
            catch (Exception ex)
            {
                throw ex;
            }

        }
        /// <summary>
        /// 删除一条数据
        /// </summary>
        /// <param name="host">mongodb连接信息</param>
        /// <param name="filter">删除条件</param>
        /// <returns></returns>
        public DeleteResult DeleteMany(Expression<Func<T, bool>> filter)
        {
            try
            {
                return Collection.DeleteMany(filter);
            }
            catch (Exception ex)
            {
                throw ex;
            }

        }
        #endregion

        #region Count 根据条件获取总数
        /// <summary>
        /// 根据条件获取总数
        /// </summary>
        /// <param name="host">mongodb连接信息</param>
        /// <param name="filter">条件</param>
        /// <returns></returns>
        public long Count(Expression<Func<T, bool>> filter)
        {
            try
            {
                return Collection.CountDocuments(filter);
            }
            catch (Exception ex)
            {
                throw ex;
            }
        }
        #endregion


        #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(ObjectId id)
        {
            try
            {
                return Collection.Find(x => x._id == id).FirstOrDefault<T>();
            }
            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<U> FindList<U>(Expression<Func<T, bool>> exp, Expression<Func<T, U>> select)
        {
            try
            {
                return Collection.AsQueryable().Where(exp).Select(select).ToList();
            }
            catch (Exception ex)
            {
                throw new UserFriendlyException(ex.Message);
            }
        }
        public List<T> FindList(Expression<Func<T, bool>> exp)
        {
            try
            {
                return Collection.AsQueryable().Where(exp).ToList();
            }
            catch (Exception ex)
            {
                throw ex;
            }
        }
        #endregion



        #region FindListByPage 分页查询集合
        /// <summary>
        /// 分页查询集合
        /// </summary>
        /// <param name="host">mongodb连接信息</param>
        /// <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 List<U> FindListByPage<U>(string field, string dir, Expression<Func<T, bool>> filter, int SkipCount, int pageSize, out long count, Expression<Func<T, U>> select)
        {
            try
            {
                count = Collection.CountDocuments(filter);
                var query = Collection.AsQueryable().Where(filter).OrderBy(field, dir);
                var data = query.Skip(SkipCount).Take(pageSize).Select(select).ToList();
                return data;
            }
            catch (Exception ex)
            {
                throw new UserFriendlyException(ex.Message);
            }
        }

        #endregion

        public async Task<bool> AnyAsync(Expression<Func<T, bool>> filter)
        {
            try
            {
                long count = await Collection.CountDocumentsAsync(filter);
                return count > 0;
            }
            catch (Exception ex)
            {
                throw new UserFriendlyException(ex.Message);
            }
        }

        public bool Any(string collName, Expression<Func<T, bool>> filter)
        {
            try
            {
                long count = Collection.CountDocuments(filter);
                return count > 0;
            }
            catch (Exception ex)
            {
                throw ex;
            }
        }

    }

 5.初始化MongodbHelper

  string dbName = "测试CRUD";
  string collectionName ="mongdb";
  var InventoryHelper = new MongoDbRepository<Customer>
(new MongoDBConfig { CollectionName = collectionName, DbName = dbName, ConnectionString ="mongodb://localhost");
var list=InventoryHelper.FindList(x=>true);// 得到集合所有的元素