使用DapperExtensions實現簡單倉儲

Dapper是一個輕量級的ORM框架，它只是一個IDbConnection的擴展文件。所以我們需要手寫很多SQL，但是寫CRUD的代碼總是很無趣的。所有就有了DapperExtensions。DapperExtensions對Dapper提供了更多的擴展，可以不用寫SQL就實現CRUD操作跟簡單的查詢功能。話不多說還是直接上代碼吧。

  class ConnectionFactory
    {
        public static IDbConnection CreateConnection<T>() where T:IDbConnection,new ()
        {
            IDbConnection connection = new T();
            connection.ConnectionString = ConnectionConfig.ConnectionString;
            connection.Open();
            return connection;
        }

        public static IDbConnection CreateSqlConnection()
        {
            return CreateConnection<SqlConnection>();
        }
    }

interface IRepository<T>
    {
        IEnumerable<T> GetList();

        T Get(object id);

        bool Update(T t);

        T Insert(T apply);

        bool Delete(T t);

        IEnumerable<T> Find(Expression<Func<T, object>> expression, Operator op, object param);
    }

class SqlRepository<T> : IRepository<T> where T : class, IEntity
    {
        public virtual IEnumerable<T> GetList()
        {
            using (var conn = ConnectionFactory.CreateSqlConnection())
            {
                return conn.GetList<T>();
            }

        }

        public virtual T Get(object id)
        {
            using (var conn = ConnectionFactory.CreateSqlConnection())
            {
                return conn.Get<T>(id);
            }
        }

        public virtual bool Update(T t)
        {
            using (var conn = ConnectionFactory.CreateSqlConnection())
            {
                return conn.Update(t);
            }
        }

        public virtual T Insert(T apply)
        {
            using (var conn = ConnectionFactory.CreateSqlConnection())
            {
                conn.Insert(apply);
                return apply;
            }
        }

        public virtual bool Delete(T t)
        {
            using (var conn = ConnectionFactory.CreateSqlConnection())
            {
                return conn.Delete(t);
            }
        }

        public virtual IEnumerable<T> Find(Expression<Func<T,object>> expression,Operator op,object param)
        {
            using (var conn = ConnectionFactory.CreateSqlConnection())
            {
                return conn.GetList<T>(Predicates.Field<T>(expression, op, param));
            }
        }

    }

恩，就是這么簡單。