Repository,UnitOfWork,DbContext(1)

一、前言

终于到EF了，实在不好意思，最近有点忙，本篇离上一篇发布已经一个多星期了，工作中的小迭代告一段落，终于有点时间来继续我们的架构设计了，在这里先对大家表示歉意。

其实这段时间我并不是把这个系列给忘记了，而是一直在思考，想着接下来应该怎么写。因为园子里已经有很多非常优秀的EF的文章了，比如：

Entity Framework Code First 学习日记
【译著】Code First ：使用Entity. Framework编程
Entity Framework技术系列
EF框架step by step
这些系列都写得非常好，基本涵盖了EF的所有常见技术点。我再详写这些就显得多余了，但为了整个系列的完整性，还是要提上一提，不然后面就没法继续了。

本篇会比较长，主要讲解UnitOfWork、Repository模式以及DbContext实现类的构造，来给架构demo添加数据访问功能，实现数据库验证的用户登录功能。

二、Repository

在数据库系统中，对于数据层来说，所有的操作归根结底无非“C（增加）、R（读取）、U（修改）、D（删除）”这四种操作。四种操作当中，与与业务相关度最大的是读取操作，根据各种不同的业务需求提交不同的查询，其最终执行应该放到业务层面中去进行，而增加，修改，删除这三种操作较为通用，可以作为通用数据操作封装到Repository中。在Repository中，唯一的变化点就是各种不同的实体类型，既然是变化点就应该进行封装，这里使用泛型来封装这个变化点。

对于实体的查询操作，需要着重说明一下。EF是ORM，ORM最大的特点就是看到的使用的都是对象，读取一个对象，就相当于执行了一个“select * from table”的查询操作，稍微了解数据库的同学都知道，这是非常消耗性能与内存的，数据查询最好还是应该按需查询，要什么取什么。EF的查询操作如果不处理好，很容易造成巨大的性能问题，比如有些同学喜欢在Repository中定义诸如GetByName，GetByXX，GetByXXX的操作，这些操作通常并不是每个实体都需要，即使需要也很有局限性，最后这些操作大都伦为“鸡肋”，限制了使用场景，也不能按需查询。还有些同学定义考虑到了按条件查询，定义了比如GetByPredicate(predicate)的操作，但使用了IEnumerable<T>的返回值，相当于把这部分数据都加载到内存中，再进行后续操作。甚至还有定义 IEnumerable<T> GetAll(); 操作的，明白的同学都知道这是件多么恐怖的事，相当于把整个表的数据都加载到内存中，再进行后续操作！！！诸如此类，问题多多……其实，数据查询，只要在Repository中定义一个只读的IQueryable<T>的数据集，其他的事就完全不用管了，业务层中想要什么就取什么就好了，当然，为了充分利用EF对主键查询的缓存特性，定义一个 GetByKey 的查询操作还是可以接受的。PS：关于EF数据查询的问题，后面还会专门有一篇文章来探讨。总之，EF的数据查询做不好，影响很大，这也是很多同学说EF性能不好的重要原因。

不知不觉说了那么多，呵呵，主要是关于数据查询有太多的话想说了，但这不是本文的重点，严重跑题了。直接上接口定义吧：

namespace GMF.Component.Data  
{  
    /// <summary>  
    ///     定义仓储模型中的数据标准操作  
    /// </summary>  
    /// <typeparam name="TEntity">动态实体类型</typeparam>  
    public interface IRepository<TEntity> where TEntity : Entity  
    {  
        #region 属性  
 
        /// <summary>  
        ///     获取 当前实体的查询数据集  
        /// </summary>  
        IQueryable<TEntity> Entities { get; }  
 
        #endregion  
 
        #region 公共方法  
 
        /// <summary>  
        ///     插入实体记录  
        /// </summary>  
        /// <param name="entity"> 实体对象 </param>  
        /// <param name="isSave"> 是否执行保存 </param>  
        /// <returns> 操作影响的行数 </returns>  
        int Insert(TEntity entity, bool isSave = true);  
 
        /// <summary>  
        ///     批量插入实体记录集合  
        /// </summary>  
        /// <param name="entities"> 实体记录集合 </param>  
        /// <param name="isSave"> 是否执行保存 </param>  
        /// <returns> 操作影响的行数 </returns>  
        int Insert(IEnumerable<TEntity> entities, bool isSave = true);  
 
        /// <summary>  
        ///     删除指定编号的记录  
        /// </summary>  
        /// <param name="id"> 实体记录编号 </param>  
        /// <param name="isSave"> 是否执行保存 </param>  
        /// <returns> 操作影响的行数 </returns>  
        int Delete(object id, bool isSave = true);  
 
        /// <summary>  
        ///     删除实体记录  
        /// </summary>  
        /// <param name="entity"> 实体对象 </param>  
        /// <param name="isSave"> 是否执行保存 </param>  
        /// <returns> 操作影响的行数 </returns>  
        int Delete(TEntity entity, bool isSave = true);  
 
        /// <summary>  
        ///     删除实体记录集合  
        /// </summary>  
        /// <param name="entities"> 实体记录集合 </param>  
        /// <param name="isSave"> 是否执行保存 </param>  
        /// <returns> 操作影响的行数 </returns>  
        int Delete(IEnumerable<TEntity> entities, bool isSave = true);  
 
        /// <summary>  
        ///     删除所有符合特定表达式的数据  
        /// </summary>  
        /// <param name="predicate"> 查询条件谓语表达式 </param>  
        /// <param name="isSave"> 是否执行保存 </param>  
        /// <returns> 操作影响的行数 </returns>  
        int Delete(Expression<Func<TEntity, bool>> predicate, bool isSave = true);  
 
        /// <summary>  
        ///     更新实体记录  
        /// </summary>  
        /// <param name="entity"> 实体对象 </param>  
        /// <param name="isSave"> 是否执行保存 </param>  
        /// <returns> 操作影响的行数 </returns>  
        int Update(TEntity entity, bool isSave = true);  
 
        /// <summary>  
        ///     查找指定主键的实体记录  
        /// </summary>  
        /// <param name="key"> 指定主键 </param>  
        /// <returns> 符合编号的记录，不存在返回null </returns>  
        TEntity GetByKey(object key);  
 
        #endregion  
    }  
} 
还要说明一下，每个操作方法都带有一个 isSave 可选参数，是为了单个实体操作的需要，免去了每次都要调用 context.SaveChanged()的麻烦。如果是进行多个实体的单元事务操作，就需要把这个参数设置为 false 。

Repository的通用实现如下：

namespace GMF.Component.Data  
{  
    /// <summary>  
    ///     EntityFramework仓储操作基类  
    /// </summary>  
    /// <typeparam name="TEntity">动态实体类型</typeparam>  
    public abstract class EFRepositoryBase<TEntity> : IRepository<TEntity> where TEntity : Entity  
    {  
        #region 属性  
 
        /// <summary>  
        ///     获取 仓储上下文的实例  
        /// </summary>  
        [Import]  
        public IUnitOfWork UnitOfWork { get; set; }  
 
        /// <summary>  
        ///     获取或设置 EntityFramework的数据仓储上下文  
        /// </summary>  
        protected IUnitOfWorkContext EFContext  
        {  
            get 
            {  
                if (UnitOfWork is IUnitOfWorkContext)  
                {  
                    return UnitOfWork as IUnitOfWorkContext;  
                }  
                throw new DataAccessException(string.Format("数据仓储上下文对象类型不正确，应为IUnitOfWorkContext，实际为 {0}", UnitOfWork.GetType().Name));  
            }  
        }  
 
        /// <summary>  
        ///     获取 当前实体的查询数据集  
        /// </summary>  
        public virtual IQueryable<TEntity> Entities  
        {  
            get { return EFContext.Set<TEntity>(); }  
        }  
 
        #endregion  
 
        #region 公共方法  
 
        /// <summary>  
        ///     插入实体记录  
        /// </summary>  
        /// <param name="entity"> 实体对象 </param>  
        /// <param name="isSave"> 是否执行保存 </param>  
        /// <returns> 操作影响的行数 </returns>  
        public virtual int Insert(TEntity entity, bool isSave = true)  
        {  
            PublicHelper.CheckArgument(entity, "entity");  
            EFContext.RegisterNew(entity);  
            return isSave ? EFContext.Commit() : 0;  
        }  
 
        /// <summary>  
        ///     批量插入实体记录集合  
        /// </summary>  
        /// <param name="entities"> 实体记录集合 </param>  
        /// <param name="isSave"> 是否执行保存 </param>  
        /// <returns> 操作影响的行数 </returns>  
        public virtual int Insert(IEnumerable<TEntity> entities, bool isSave = true)  
        {  
            PublicHelper.CheckArgument(entities, "entities");  
            EFContext.RegisterNew(entities);  
            return isSave ? EFContext.Commit() : 0;  
        }  
 
        /// <summary>  
        ///     删除指定编号的记录  
        /// </summary>  
        /// <param name="id"> 实体记录编号 </param>  
        /// <param name="isSave"> 是否执行保存 </param>  
        /// <returns> 操作影响的行数 </returns>  
        public virtual int Delete(object id, bool isSave = true)  
        {  
            PublicHelper.CheckArgument(id, "id");  
            TEntity entity = EFContext.Set<TEntity>().Find(id);  
            return entity != null ? Delete(entity, isSave) : 0;  
        }  
 
        /// <summary>  
        ///     删除实体记录  
        /// </summary>  
        /// <param name="entity"> 实体对象 </param>  
        /// <param name="isSave"> 是否执行保存 </param>  
        /// <returns> 操作影响的行数 </returns>  
        public virtual int Delete(TEntity entity, bool isSave = true)  
        {  
            PublicHelper.CheckArgument(entity, "entity");  
            EFContext.RegisterDeleted(entity);  
            return isSave ? EFContext.Commit() : 0;  
        }  
 
        /// <summary>  
        ///     删除实体记录集合  
        /// </summary>  
        /// <param name="entities"> 实体记录集合 </param>  
        /// <param name="isSave"> 是否执行保存 </param>  
        /// <returns> 操作影响的行数 </returns>  
        public virtual int Delete(IEnumerable<TEntity> entities, bool isSave = true)  
        {  
            PublicHelper.CheckArgument(entities, "entities");  
            EFContext.RegisterDeleted(entities);  
            return isSave ? EFContext.Commit() : 0;  
        }  
 
        /// <summary>  
        ///     删除所有符合特定表达式的数据  
        /// </summary>  
        /// <param name="predicate"> 查询条件谓语表达式 </param>  
        /// <param name="isSave"> 是否执行保存 </param>  
        /// <returns> 操作影响的行数 </returns>  
        public virtual int Delete(Expression<Func<TEntity, bool>> predicate, bool isSave = true)  
        {  
            PublicHelper.CheckArgument(predicate, "predicate");  
            List<TEntity> entities = EFContext.Set<TEntity>().Where(predicate).ToList;  
            return entities.Count > 0 ? Delete(entities, isSave) : 0;  
        }  
 
        /// <summary>  
        ///     更新实体记录  
        /// </summary>  
        /// <param name="entity"> 实体对象 </param>  
        /// <param name="isSave"> 是否执行保存 </param>  
        /// <returns> 操作影响的行数 </returns>  
        public virtual int Update(TEntity entity, bool isSave = true)  
        {  
            PublicHelper.CheckArgument(entity, "entity");  
            EFContext.RegisterModified(entity);  
            return isSave ? EFContext.Commit() : 0;  
        }  
 
        /// <summary>  
        ///     查找指定主键的实体记录  
        /// </summary>  
        /// <param name="key"> 指定主键 </param>  
        /// <returns> 符合编号的记录，不存在返回null </returns>  
        public virtual TEntity GetByKey(object key)  
        {  
            PublicHelper.CheckArgument(key, "key");  
            return EFContext.Set<TEntity>().Find(key);  
        }  
 
        #endregion  
    }  
} 
实现类中所有操作最终都是通过单元操作来提交的，关于单元操作，马上就会讲到。

三、UnitOfWork

引入单元操作，主要是为了给各个实体维护一个共同的DbContext上下文对象，保证所有的操作都是在共同的上下文中进行的。EF的操作提交 context.SaveChanged() 默认就是事务性的，只要保证了当前的所有实体的操作都是在一个共同的上下文中进行的，就实现了事务操作了。

在业务层中，各个实体的增删改操作都是通过各个实体的Repository进行的，只需要提供一个提交保存的功能作为最后调用，即可保证当前的提交是事务性的。因此定义给业务层引用的单元操作接口如下：

namespace GMF.Component.Data  
{  
    /// <summary>  
    ///     业务单元操作接口  
    /// </summary>  
    public interface IUnitOfWork  
    {  
        #region 属性  
 
        /// <summary>  
        ///     获取 当前单元操作是否已被提交  
        /// </summary>  
        bool IsCommitted { get; }  
 
        #endregion  
 
        #region 方法  
 
        /// <summary>  
        ///     提交当前单元操作的结果  
        /// </summary>  
        /// <returns></returns>  
        int Commit();  
 
        /// <summary>  
        ///     把当前单元操作回滚成未提交状态  
        /// </summary>  
        void Rollback();  
 
        #endregion  
    }  
} 
在数据组件内部，数据操作最终都提交到一个与IUnitOfWork接口的实现类中进行操作，以保证各个实体的Repository与IUnitOfWork使用的是同一个DbContext上下文。定义数据单元操作接口如下：

namespace GMF.Component.Data  
{  
    /// <summary>  
    ///     数据单元操作接口  
    /// </summary>  
    public interface IUnitOfWorkContext : IUnitOfWork, IDisposable  
    {  
        /// <summary>  
        ///   为指定的类型返回 System.Data.Entity.DbSet，这将允许对上下文中的给定实体执行 CRUD 操作。  
        /// </summary>  
        /// <typeparam name="TEntity"> 应为其返回一个集的实体类型。 </typeparam>  
        /// <returns> 给定实体类型的 System.Data.Entity.DbSet 实例。 </returns>  
        DbSet<TEntity> Set<TEntity>() where TEntity : Entity;  
 
        /// <summary>  
        ///   注册一个新的对象到仓储上下文中  
        /// </summary>  
        /// <typeparam name="TEntity"> 要注册的类型 </typeparam>  
        /// <param name="entity"> 要注册的对象 </param>  
        void RegisterNew<TEntity>(TEntity entity) where TEntity : Entity;  
 
        /// <summary>  
        ///   批量注册多个新的对象到仓储上下文中  
        /// </summary>  
        /// <typeparam name="TEntity"> 要注册的类型 </typeparam>  
        /// <param name="entities"> 要注册的对象集合 </param>  
        void RegisterNew<TEntity>(IEnumerable<TEntity> entities) where TEntity : Entity;  
 
        /// <summary>  
        ///   注册一个更改的对象到仓储上下文中  
        /// </summary>  
        /// <typeparam name="TEntity"> 要注册的类型 </typeparam>  
        /// <param name="entity"> 要注册的对象 </param>  
        void RegisterModified<TEntity>(TEntity entity) where TEntity : Entity;  
 
        /// <summary>  
        ///   注册一个删除的对象到仓储上下文中  
        /// </summary>  
        /// <typeparam name="TEntity"> 要注册的类型 </typeparam>  
        /// <param name="entity"> 要注册的对象 </param>  
        void RegisterDeleted<TEntity>(TEntity entity) where TEntity : Entity;  
 
        /// <summary>  
        ///   批量注册多个删除的对象到仓储上下文中  
        /// </summary>  
        /// <typeparam name="TEntity"> 要注册的类型 </typeparam>  
        /// <param name="entities"> 要注册的对象集合 </param>  
        void RegisterDeleted<TEntity>(IEnumerable<TEntity> entities) where TEntity : Entity;  
    }  
} 
在单元操作的实现基类中，定义一个只读的DbContext抽象属性，实际的DbContext上下文需要在实现类中进行重写赋值。

namespace GMF.Component.Data  
{  
    /// <summary>  
    ///     单元操作实现  
    /// </summary>  
    public abstract class UnitOfWorkContextBase : IUnitOfWorkContext  
    {  
        /// <summary>  
        /// 获取 当前使用的数据访问上下文对象  
        /// </summary>  
        protected abstract DbContext Context { get; }  
 
        /// <summary>  
        ///     获取 当前单元操作是否已被提交  
        /// </summary>  
        public bool IsCommitted { get; private set; }  
 
        /// <summary>  
        ///     提交当前单元操作的结果  
        /// </summary>  
        /// <returns></returns>  
        public int Commit()  
        {  
            if (IsCommitted)  
            {  
                return 0;  
            }  
            try 
            {  
                int result = Context.SaveChanges();  
                IsCommitted = true;  
                return result;  
            }  
            catch (DbUpdateException e)  
            {  
                if (e.InnerException != null && e.InnerException.InnerException is SqlException)  
                {  
                    SqlException sqlEx = e.InnerException.InnerException as SqlException;  
                    string msg = DataHelper.GetSqlExceptionMessage(sqlEx.Number);  
                    throw PublicHelper.ThrowDataAccessException("提交数据更新时发生异常：" + msg, sqlEx);  
                }  
                throw;  
            }  
        }  
 
        /// <summary>  
        ///     把当前单元操作回滚成未提交状态  
        /// </summary>  
        public void Rollback()  
        {  
            IsCommitted = false;  
        }  
 
        public void Dispose()  
        {  
            if (!IsCommitted)  
            {  
                Commit();  
            }  
            Context.Dispose();  
        }  
 
        /// <summary>  
        ///   为指定的类型返回 System.Data.Entity.DbSet，这将允许对上下文中的给定实体执行 CRUD 操作。  
        /// </summary>  
        /// <typeparam name="TEntity"> 应为其返回一个集的实体类型。 </typeparam>  
        /// <returns> 给定实体类型的 System.Data.Entity.DbSet 实例。 </returns>  
        public DbSet<TEntity> Set<TEntity>() where TEntity : Entity  
        {  
            return Context.Set<TEntity>();  
        }  
 
        /// <summary>  
        ///     注册一个新的对象到仓储上下文中  
        /// </summary>  
        /// <typeparam name="TEntity"> 要注册的类型 </typeparam>  
        /// <param name="entity"> 要注册的对象 </param>  
        public void RegisterNew<TEntity>(TEntity entity) where TEntity : Entity  
        {  
            EntityState state = Context.Entry(entity).State;  
            if (state == EntityState.Detached)  
            {  
                Context.Entry(entity).State = EntityState.Added;  
            }  
            IsCommitted = false;  
        }  
 
        /// <summary>  
        ///     批量注册多个新的对象到仓储上下文中  
        /// </summary>  
        /// <typeparam name="TEntity"> 要注册的类型 </typeparam>  
        /// <param name="entities"> 要注册的对象集合 </param>  
        public void RegisterNew<TEntity>(IEnumerable<TEntity> entities) where TEntity : Entity  
        {  
            try 
            {  
                Context.Configuration.AutoDetectChangesEnabled = false;  
                foreach (TEntity entity in entities)  
                {  
                    RegisterNew(entity);  
                }  
            }  
            finally 
            {  
                Context.Configuration.AutoDetectChangesEnabled = true;  
            }  
        }  
 
        /// <summary>  
        ///     注册一个更改的对象到仓储上下文中  
        /// </summary>  
        /// <typeparam name="TEntity"> 要注册的类型 </typeparam>  
        /// <param name="entity"> 要注册的对象 </param>  
        public void RegisterModified<TEntity>(TEntity entity) where TEntity : Entity  
        {  
            if (Context.Entry(entity).State == EntityState.Detached)  
            {  
                Context.Set<TEntity>().Attach(entity);  
            }  
            Context.Entry(entity).State = EntityState.Modified;  
            IsCommitted = false;  
        }  
 
        /// <summary>  
        ///   注册一个删除的对象到仓储上下文中  
        /// </summary>  
        /// <typeparam name="TEntity"> 要注册的类型 </typeparam>  
        /// <param name="entity"> 要注册的对象 </param>  
        public void RegisterDeleted<TEntity>(TEntity entity) where TEntity : Entity  
        {  
            Context.Entry(entity).State = EntityState.Deleted;  
            IsCommitted = false;  
        }  
 
        /// <summary>  
        ///   批量注册多个删除的对象到仓储上下文中  
        /// </summary>  
        /// <typeparam name="TEntity"> 要注册的类型 </typeparam>  
        /// <param name="entities"> 要注册的对象集合 </param>  
        public void RegisterDeleted<TEntity>(IEnumerable<TEntity> entities) where TEntity : Entity  
        {  
            try 
            {  
                Context.Configuration.AutoDetectChangesEnabled = false;  
                foreach (TEntity entity in entities)  
                {  
                    RegisterDeleted(entity);  
                }  
            }  
            finally 
            {  
                Context.Configuration.AutoDetectChangesEnabled = true;  
            }  
        }  
    }  
} 
实体数据操作中，需要特别说明一下的是批量操作。EF不支持批量操作（直接执行SQL语句的方式除外），但我们可以使用多次变更一次提交的方式来进行批量的插入，删除等操作。在进行数据的变更时，EF默认会自动的跟踪数据的变化（AutoDetectChangesEnabled = true），当变更的数据量较大的时候，EF的跟踪工作量就会骤增，使指定操作变得非常缓慢（这也是部分同学怀疑EF的性能问题的一个怀疑点），其实，只要在批量操作的时候把自动跟踪关闭（AutoDetectChangesEnabled = false），即可解决缓慢的问题。如以上代码 144 行与 152 行所示。

特别说明：本文的UnitOfWork实现方案参考了 dax.net 的 《深度剖析Byteart Retail案例：仓储（Repository）及其上下文（Repository Context）》，在此表示感谢。

至此，我们回顾一下解决方案的结构：



与业务实体无关的数据组件 GMF.Component.Data 已经搭建完成，下面的工作将与业务实体密切相关。

四、业务整合应用

与业务实体相关的数据功能代码定义在 GMF.Demo.Core.Data 项目中。

(一) 业务实体的仓储实现

首先，实现各个实体的 Repository 仓储操作，这里只以 用户信息（Member）实体为例：

namespace GMF.Demo.Core.Data.Repositories  
{  
    /// <summary>  
    ///     仓储操作接口——用户信息  
    /// </summary>  
    public interface IMemberRepository : IRepository<Member> { }  
} 
namespace GMF.Demo.Core.Data.Repositories.Impl  
{  
    /// <summary>  
    ///     仓储操作实现——用户信息  
    /// </summary>  
    [Export(typeof(IMemberRepository))]  
    public class MemberRepository : EFRepositoryBase<Member>, IMemberRepository { }  
} 
可以发现，通用仓储操作在数据组件中封装好后，在实际业务中只需要编写非常少量的代码即可实现各个实体的仓储操作，这就是封装的好处。

(二) 数据上下文实现

DbContext上下文的实现，这里先使用微软官方示例中的传统方案：

namespace GMF.Demo.Core.Data.Context  
{  
    /// <summary>  
    ///     Demo项目数据访问上下文  
    /// </summary>  
    [Export(typeof (DbContext))]  
    public class DemoDbContext : DbContext  
    {  
        #region 构造函数  
 
        /// <summary>  
        ///     初始化一个 使用连接名称为“default”的数据访问上下文类 的新实例  
        /// </summary>  
        public DemoDbContext()  
            : base("default") { }  
 
        /// <summary>  
        /// 初始化一个 使用指定数据连接名称或连接串 的数据访问上下文类 的新实例  
        /// </summary>  
        public DemoDbContext(string nameOrConnectionString)  
            : base(nameOrConnectionString) {  }  
 
        #endregion  
 
        #region 属性  
 
        public DbSet<Role> Roles { get; set; }  
 
        public DbSet<Member> Members { get; set; }  
 
        public DbSet<MemberExtend> MemberExtends { get; set; }  
 
        public DbSet<LoginLog> LoginLogs { get; set; }  
 
        #endregion  
 
        protected override void OnModelCreating(DbModelBuilder modelBuilder)  
        {  
            //移除一对多的级联删除约定，想要级联删除可以在 EntityTypeConfiguration<TEntity>的实现类中进行控制  
            modelBuilder.Conventions.Remove<OneToManyCascadeDeleteConvention>();  
            //多对多启用级联删除约定，不想级联删除可以在删除前判断关联的数据进行拦截  
            //modelBuilder.Conventions.Remove<ManyToManyCascadeDeleteConvention>();  
        }  
    }  
} 
值得注意的是，在EF中提供了很多的规则来定义 EF生成数据库 的行为，如下图所示：



我们可以在 DbContext 的派生类中重写 OnModelCreating 方法来移除一些规则来达到某些需求，比如在此，我们移除 OneToManyCascadeDeleteConvention 来达到禁用数据库的 一对多的级联删除 ，需要时再在做实体映射时启用，就能防止由于误操作而导致实体相关的数据都被删除的情况。

当然，这里只定义的DbContext上下文的实现类，并没有进行使用，如何来使用这个上下文呢，只需实现一个单元操作实现类即可：

namespace GMF.Demo.Core.Data.Context  
{  
    /// <summary>  
    ///     Demo项目单元操作类  
    /// </summary>  
    [Export(typeof (IUnitOfWork))]  
    public class DemoUnitOfWorkContext : UnitOfWorkContextBase  
    {  
        /// <summary>  
        ///     获取或设置 当前使用的数据访问上下文对象  
        /// </summary>  
        protected override DbContext Context  
        {  
            get { return DemoDbContext; }  
        }  
 
        /// <summary>  
        ///     获取或设置 默认的Demo项目数据访问上下文对象  
        /// </summary>  
        [Import(typeof (DbContext))]  
        public DemoDbContext DemoDbContext { get; set; }  
    }  
} 
(三) 创建数据库时的数据初始化

在本系列前面的示例中，由于没有数据访问功能，使用了一个数据来模拟数据源，现在，我们可以通过创建数据库时初始化一些数据，以使得在下面的操作中有数据可用。

EF创建数据库的策略同样有多种可选：



由各个策略类的名称即可猜到具体的作用（可见代码的语义化很重要），这里使用CreateDatabaseIfNotExists，即数据库不存在时创建。

namespace GMF.Demo.Core.Data.Initialize  
{  
    /// <summary>  
    /// 数据库初始化策略  
    /// </summary>  
    public class SampleData : CreateDatabaseIfNotExists<DemoDbContext>  
    {  
        protected override void Seed(DemoDbContext context)  
        {  
            List<Member> members = new List<Member>  
            {  
                new Member { UserName = "admin", Password = "123456", Email = "admin@gmfcn.net", NickName = "管理员" },  
                new Member { UserName = "gmfcn", Password = "123456", Email = "mf.guo@qq.com", NickName = "郭明锋" }  
            };  
            DbSet<Member> memberSet = context.Set<Member>();  
            members.ForEach(m => memberSet.Add(m));  
            context.SaveChanges();  
        }  
    }  
} 
为了不使业务代码与EF的耦合过大，我们规定：项目中对 EntityFramework.dll 的引用到 GMF.Demo.Core.Data项目止，再上层的代码不依赖于EF组件。因此还需要在这定义一个执行初始化的辅助类：

namespace GMF.Demo.Core.Data.Initialize  
{  
    /// <summary>  
    /// 数据库初始化操作类  
    /// </summary>  
    public static class DatabaseInitializer  
    {  
        /// <summary>  
        /// 数据库初始化  
        /// </summary>  
        public static void Initialize( )  
        {  
            Database.SetInitializer(new SampleData());  
            using (var db = new DemoDbContext())  
            {  
                db.Database.Initialize(false);  
            }  
        }  
    }  
} 
此辅助类将在程序初始化时调用，网站项目里，在Global的Application_Start方法中调用：



(四) 业务整合，实现登录功能

为了在业务实现中方便调用 IUnitOfWork 进行多实体的单元操作，定义一个核心与业务实现基类

namespace GMF.Demo.Core.Impl  
{  
    /// <summary>  
    /// 核心业务实现基类  
    /// </summary>  
    public abstract class CoreServiceBase  
    {  
        /// <summary>  
        /// 获取或设置 工作单元对象，用于处理同步业务的事务操作  
        /// </summary>  
        [Import]  
        protected IUnitOfWork UnitOfWork { get; set; }  
    }  
} 
在核心业务实现中添加用到的各个实体Repository仓储操作接口对象的属性，并更新登录方法，使其调用仓储操作完成登录业务

namespace GMF.Demo.Core.Impl  
{  
    /// <summary>  
    ///     账户模块核心业务实现  
    /// </summary>  
    public abstract class AccountService : CoreServiceBase, IAccountContract  
    {  
        #region 属性  
 
        #region 受保护的属性  
 
        /// <summary>  
        /// 获取或设置 用户信息数据访问对象  
        /// </summary>  
        [Import]  
        protected IMemberRepository MemberRepository { get; set; }  
 
        /// <summary>  
        /// 获取或设置 登录记录信息数据访问对象  
        /// </summary>  
        [Import]  
        protected ILoginLogRepository LoginLogRepository { get; set; }  
 
        #endregion  
 
        #endregion  
 
        /// <summary>  
        /// 用户登录  
        /// </summary>  
        /// <param name="loginInfo">登录信息</param>  
        /// <returns>业务操作结果</returns>  
        public virtual OperationResult Login(LoginInfo loginInfo)  
        {  
            PublicHelper.CheckArgument(loginInfo, "loginInfo");  
            Member member = MemberRepository.Entities.SingleOrDefault(m => m.UserName == loginInfo.Access || m.Email == loginInfo.Access);  
            if (member == null)  
            {  
                return new OperationResult(OperationResultType.QueryNull, "指定账号的用户不存在。");  
            }  
            if (member.Password != loginInfo.Password)  
            {  
                return new OperationResult(OperationResultType.Warning, "登录密码不正确。");  
            }  
            LoginLog loginLog = new LoginLog { IpAddress = loginInfo.IpAddress, Member = member };  
            LoginLogRepository.Insert(loginLog);  
            return new OperationResult(OperationResultType.Success, "登录成功。", member);  
        }  
    }  
} 
在此需要特别说明的是，为了保持项目结构的整洁与规范，实体数据操作的Repository与UnitOfWork只能被业务层（核心层及其派生层次）调用，而不能被业务层的上层调用，比如MVC项目中，不能被控制器调用，防止开发人员不遵守规范，在控制器中进行业务实现导致项目结构的混乱。因此给实体的Repository接口属性与业务基类中的UnitOfWork属性的可访问性都要设置为 protected，而不能为 public。

在MVC的Web.Config中添加一个数据连接配置：

<connectionStrings> 
    <add name="default" connectionString="Data Source=.; Integrated Security=True; Initial Catalog=DemoContext; Pooling=True; MultipleActiveResultSets=True;" providerName="System.Data.SqlClient" /> 
  </connectionStrings> 
至此，我们的项目结构变成了如下图所示：



运行项目，尝试登录并成功，查看登录记录表，我们可以发现新增了一条登录记录：



五、源码下载

 GMFrameworkForBlog3.zip

为了让大家能第一时间获取到本架构的最新代码，也为了方便我对代码的管理，本系列的源码已加入微软的开源项目网站 http://www.codeplex.com，地址为：

https://gmframework.codeplex.com/

原文链接：http://www.cnblogs.com/guomingfeng/archive/2013/05/28/mvc-ef-repository.html