一个基于Dapper的DbContext封装

开篇：　　

各位博客园的园友好，这是我第一次在园子里写些东西。我是一个技术菜鸟，伴随着苦与乐，已经渡过了8年的IT技术生涯，准备利用这片天地向大家交流学习。

正题：

今天上午闲来无事，利用上午时间写了一个基于Dapper的DbContext封装。还有很多地方没有完善，敬请期待下次更新。

 1、RepositoryContext存储上下文

     接口：

　　

 public interface IRepositoryContext : IDisposable
    {
        IDbConnection Conn { get; }
        void InitConnection();
    }

　　实现：　　　　

　　

    public class RepositoryContext : DisposableObject, IUnitOfWork, IRepositoryContext
    {
        private readonly ConnectionStringSettings _connectionSeting =
            ConfigurationManager.ConnectionStrings["BudisengFirstDemoInfo"];

        public RepositoryContext()
        {
            InitConnection();
        }

        public RepositoryContext(ConnectionStringSettings connectionSeting)
        {
            // TODO: Complete member initialization
            this._connectionSeting = connectionSeting;
            InitConnection();
        }

        public IDbConnection Conn { private set; get; }

        public void InitConnection()
        {
            DbProviderFactory dbfactory = DbProviderFactories.GetFactory(this._connectionSeting.ProviderName);
            this.Conn = dbfactory.CreateConnection();
            if (Conn != null) this.Conn.ConnectionString = this._connectionSeting.ConnectionString;
        }

        private bool _committed = true;
        private readonly object _sync = new object();

        public bool Committed
        {
            set { _committed = value; }
            get { return _committed; }
        }
        public IDbTransaction Tran { private set; get; }
        public void BeginTran()
        {
            this.Tran = this.Conn.BeginTransaction();
            this.Committed = false;
        }

        public void Commit()
        {
            if (Committed) return;
            lock (_sync)
            {
                this.Tran.Rollback();
                this._committed = true;
            }
        }

        public void Rollback()
        {
            if (Committed) return;
            lock (_sync)
            {
                this.Tran.Rollback();
                this._committed = true;
            }
        }

        protected override void Dispose(bool disposing)
        {
            if (!disposing)
            {
                return;
            }
            if (this.Conn.State != ConnectionState.Open) return;
            Commit();
            this.Conn.Close();
            this.Conn.Dispose();
        }
    }

 2、存储库

     接口：

　　

    public interface IRepository<T>
        where T : class
    {
        T Add(T model);
        List<T> Add(IList<T> modeList ); 
        void Update(T model);
        void Update(IList<T> modeList);
        T Find(int id);
        void Remove(int id);
        void Remove(T model);
        T QueryFirst(object sqlParas);
        T QueryFirst(string sql, object sqlParas);
        IList<T> Query(object sqlParas);
        IList<T> Query(string sql, object sqlParas);
        IList<T> Query(object sqlParas,int pageSize,int pageIndex);
        
    }

　　实现：

　　

public class Repository<T> : IRepository<T> where T : class, IEntity
       {
       protected IRepositoryContext Context;
       protected IDbConnection Conn;

       public Repository(IRepositoryContext context)
       {
           Context = context;
           Conn = Context.Conn;
       }

        public T Add(T model)
        {
           return this.Conn.Insert(model);
        }

        public void Update(T model)
        {
            this.Conn.Update(model);
        }

        public T QueryFirst(object sqlParas)
        {
            return Conn.Select<T>(sqlParas).FirstOrDefault();
        }





        public System.Collections.Generic.List<T> Add(System.Collections.Generic.IList<T> modeList)
        {
            throw new System.NotImplementedException();
        }

        public void Update(System.Collections.Generic.IList<T> modeList)
        {
            throw new System.NotImplementedException();
        }

        public T Find(int id)
        {
            throw new System.NotImplementedException();
        }

        public void Remove(int id)
        {
            throw new System.NotImplementedException();
        }

        public void Remove(T model)
        {
            throw new System.NotImplementedException();
        }

        public T QueryFirst(string sql, object sqlParas)
        {
            throw new System.NotImplementedException();
        }

        public System.Collections.Generic.IList<T> Query(object sqlParas)
        {
            throw new System.NotImplementedException();
        }

        public System.Collections.Generic.IList<T> Query(string sql, object sqlParas)
        {
            throw new System.NotImplementedException();
        }

        public System.Collections.Generic.IList<T> Query(object sqlParas, int pageSize, int pageIndex)
        {
            throw new System.NotImplementedException();
        }
       }

3、基础架构

　　IUnitOfWork 　　

　　

    public interface IUnitOfWork
    {
        bool Committed { set; get; }
        IDbTransaction Tran { get; }
        void BeginTran();
        void Commit();
        void Rollback();
    }

　　DisposableObject

　　

    public abstract class DisposableObject : IDisposable
    {
        ~DisposableObject()
        {
            this.Dispose(false);
        }

        protected void ExplicitDispose()
        {
            this.Dispose(true);
            GC.SuppressFinalize(this);
        }

        public void Dispose()
        {
            this.ExplicitDispose();
        }
    }

4、Dapper扩展

　　

  public static class DapperExtensions
    {
        public static T Insert<T>(this IDbConnection con, T item, IDbTransaction transaction = null) where T : IEntity
        {
            return con.Query<T>(DynamicQuery.GetInsertQuery(typeof(T).Name, item), item, transaction).First();
        }

        public static void Update<T>(this IDbConnection con,  T item, IDbTransaction transaction = null) where T : IEntity
        {
            con.Execute(DynamicQuery.GetUpdateQuery(typeof(T).Name, item), item, transaction);
        }
        public static IEnumerable<T> Select<T>(this IDbConnection con,object criteria = null)
        {
            var properties =PropertyManage.ParseProperties(criteria);
            var sqlPairs = PropertyManage.GetSqlPairs(properties.AllNames, " AND ");
            var sql = string.Format("SELECT * FROM [{0}] WHERE {1}", typeof(T).Name, sqlPairs);
            return con.Query<T>(sql, properties.AllPairs);
        }

    }

　　详见附件：

      DbContext for Dapper