[EntLib]微软企业库6 基于Data Access Application Block的Repository

名字起得有点夸张了，其实就是实现基于Data Access Application Block的DAL基类和约束

首先Repository部分没什么好描述的，如果有不了解的可以直接百度或者谷歌相关内容，直接上具体代码

注意此部分没有写批量查询的方法（比如FindAll，这跟后面的基类设定有关）

    /// <summary>
    /// DataAccess Repository
    /// </summary>
    /// <typeparam name="T1"></typeparam>
    /// <typeparam name="T2"></typeparam>
    public interface IRepository<T1, T2>
    {
        /// <summary>
        /// 根据主键获取对应的实体对象
        /// </summary>
        /// <param name="key"></param>
        /// <returns></returns>
        T1 GetEntityByKey(T2 key);
        /// <summary>
        /// 单个新增
        /// </summary>
        /// <param name="entity"></param>
        /// <returns></returns>
        bool Insert(T1 entity);
        /// <summary>
        /// 单个编辑
        /// </summary>
        /// <param name="entity"></param>
        /// <returns></returns>
        bool Update(T1 entity);
        /// <summary>
        /// 单个删除
        /// </summary>
        /// <param name="key"></param>
        /// <returns></returns>
        bool Delete(T2 key);
    }

    /// <summary>
    /// DAL基类，基于EntLib，读写分离
    /// </summary>
    public abstract class DataAccessBase
    {
        private Database _readDB;
        private Database _writeDB;
        /// <summary>
        /// 要使用的读数据库配置节，如果配置为null或者空则会调用默认配置节
        /// </summary>
        protected abstract string ReadDBName { get; }
        /// <summary>
        /// 要使用的写数据库配置节，如果配置为null或者空则会调用默认配置节
        /// </summary>
        protected abstract string WriteDBName { get; }
        /// <summary>
        /// 读库
        /// </summary>
        protected Database ReadDB
        {
            get
            {
                if (this._readDB == null)
                {
                    this._readDB = this.GetDatabase(this._writeDB, this.ReadDBName);
                }
                return this._readDB;
            }
        }
        private Database GetDatabase(Database db, string dbName)
        {
            if (this.ReadDBName == this.WriteDBName && db != null)
            {
                return db;
            }
            else
            {
                return this.CreateDatabase(dbName);
            }
        }
        /// <summary>
        /// 写库
        /// </summary>
        protected Database WriteDB
        {
            get
            {
                if (this._writeDB == null)
                {
                    this._writeDB = this.GetDatabase(this._readDB, this.WriteDBName);
                }
                return this._writeDB;
            }
        }

        private Database CreateDatabase(string dbName)
        {
            DatabaseProviderFactory factory = new DatabaseProviderFactory();
            if (string.IsNullOrWhiteSpace(dbName))
            {
                return factory.CreateDefault();
            }
            else
            {
                return factory.Create(dbName);
            }
        }
    }

    /// <summary>
    /// 单表DataAccess基类，所有单表DataAccess应当继承此类，建议非共用部分同样实现接口
    /// 多表但单数据库操作的DataAccess不能继承此类，而应继承DataAccessBase
    /// </summary>
    /// <typeparam name="T1"></typeparam>
    /// <typeparam name="T2"></typeparam>
    public abstract class SingleDataAccessBase<T1, T2> : DataAccessBase, IRepository<T1, T2>
    {
        #region IRepository<T1,T2> 成员
        /// <summary>
        /// 根据主键获取对应的实体对象
        /// </summary>
        /// <param name="key"></param>
        /// <returns></returns>
        public abstract T1 GetEntityByKey(T2 key);
        /// <summary>
        /// 单个新增
        /// </summary>
        /// <param name="entity"></param>
        /// <returns></returns>
        public abstract bool Insert(T1 entity);
        /// <summary>
        /// 单个编辑
        /// </summary>
        /// <param name="entity"></param>
        /// <returns></returns>
        public abstract bool Update(T1 entity);
        /// <summary>
        /// 单个删除
        /// </summary>
        /// <param name="key"></param>
        /// <returns></returns>
        public abstract bool Delete(T2 key);

        #endregion
    }

可能很多人觉得区分多表操作的DAL和单表操作的DAL没有必要或者没有意义，的确，在功能上，写在一个里面和写在多个里面没有区别，系统较小时还没有什么问题，如果系统较大，经由的开发人员较多时，很可能会出现某个开发人员想要用到某个表的某些字段，但因为系统较大又没有相关约束，导致该开发人员不知道去哪里找是否该方法已经存在，为了简易起见，最常见的做法是直接在自己需要的地方新写这部分代码，而最终的后果就是，代码分布越来越混乱，当表结构发生变化时，此部分尤其变成了灾难，因为如果不通过查表名，你根本无法预见到底哪些地方用到了这张表！而区分单表及多表操作，就是要解决这样的问题，当表结构发生变化时，也只需要找该表对应的单表DAL以及以数据库对应的多表DAL两个地方