如何解耦我的存储库和工作单元以使它们可测试

Question

实际上我已经实现了我的存储库和 unitofwork this way 并且我还发现了 informative answer 的 Mr.qujck 关于我的问题，这在很大程度上帮助了我，但我唯一的问题是根据他的主题回答我不知道应该如何以及在哪里实施我的 CRUD 操作。我还有 this question 仍未得到答复。如果有人可以帮助我，我将不胜感激。

Answer 1

EntityFramework 已经为您提供了有关 CRUD 操作的所有功能，一般来说，您不需要测试 EntityFramework，因为我们只是假设它可以工作。它在该网站上显示的方式是，您创建一个比简单的 CRUD 操作更高的抽象层，将其构建在 EF 之上，并将其命名为 Repository（数据访问层）。所以在这种情况下，您只需要确保您的 DAL（在这种情况下也称为存储库）是解耦的。存储库唯一耦合到的是 EntityFramework 的 DbContext，它并不能真正解耦，因此您真正需要测试和向上解耦的最低抽象级别是您的 Repository 类。

Answer 2

在该示例中使用工作单元模式的方式并不能真正代表 UoW 的行为方式。存储库应该了解 UoW，但 UoW 不应该对您的存储库有任何引用。 UoW 应该只知道您的上下文。在下面的示例中，您从 UoW 中删除了存储库依赖项。对于测试，如果你真的需要，你可以实现一个假的 DbContext，但是这可能是矫枉过正。

我的另一个建议是向您的存储库添加一个进一步的抽象并创建一个服务层。这将充当您的业务层，这些将被注入到您的 MVC 控制器中。这样，如果您使用 DTO 或视图模型，您可以在该层中映射实体和 DTO，因此应用程序永远不会真正暴露您的底层 DAL。

    public interface IUnitOfWork : IDisposable
    {
        /// <summary>
        /// Flushes content of unit of work to the underlying data storage. 
        /// Causes unsaved entities to be written to the data storage.
        /// </summary>
        void Flush();

        /// <summary>
        /// Begins the transaction.
        /// </summary>
        ITransaction BeginTransaction();

        /// <summary>
        /// Ends transaction.
        /// Note: suggested pattern to manage a transaction is via *using* construct.
        /// You should set input param to null after calling the method.
        /// </summary>
        /// <example>
        /// using ( var tnx = uow.BeginTransaction() ) { /* do some work */ }
        /// </example>
        /// See also <seealso cref="ITransaction"/> interface for more details.
        void EndTransaction(ITransaction transaction);

        /// <summary>
        /// Inserts entity to the storage.
        /// </summary>
        void Create<TEntity>(TEntity entity) where TEntity : class;

        /// <summary>
        /// Updates entity in the storage.
        /// </summary>
        void Update<TEntity>(TEntity entity) where TEntity : class;

        /// <summary>
        /// Updates entity in the storage.
        /// </summary>
        void Merge<TEntity>(TEntity original, TEntity current) where TEntity : class;


        /// <summary>
        /// Deletes entity in the storage.
        /// </summary>
        void Delete<TEntity>(TEntity entity) where TEntity : class;


    }

    public interface IRepository<TEntity> where TEntity: class
    {
        void Create(TEntity entity);
        TEntity GetById(object id);
        IEnumerable<TEntity> Get(Expression<Func<TEntity, bool>> criteria);
          IEnumerable<TEntity> GetAll();
        void Delete(object id);
        void Delete(TEntity entity);
        void Update(TEntity entity);
        void Merge(TEntity original, TEntity current);
        IUnitOfwork UnitOfWork { get; }
    }




    public class EntityFrameworkUnitOfWork: DbContext, IUnitOfwork
    {
        public virtual void Flush()
        {
            //The DbContext Save Changes method..
            SaveChanges();
        }    

        public virtual void Create<TEntity>(TEntity entity) where TEntity : class
        {
            base.Set<TEntity>().Add(entity);
        }

       ..other method implementations...
     }


 public class Repository<TEntity> : IRepository<TEntity> where TEntity : class
    {
        private readonly IUnitOfWork _unitOfWork;

        public Repository(IUnitOfWork unitOfWork)
        {
            _unitOfWork = unitOfWork;
        }

        ...other method implementations...
    }