這篇文章介紹的是使用Entity Framework實現的Repositoy模式設計，歡迎各位拍磚.

閱讀目錄:

一、實現的思路和結構圖

二、Repository設計具體的實現程式碼

三、Repository設計的具體的使用

四、總結

一，實現的思路和結構圖

總結一下，Repository在實際使用中，有下面三種特點:

Repository的共同性

有一些公共的方法(增刪改查)， 這些方法無關於Repository操作的是哪個實體類，可以把這些方法定義成介面IRepository<TEntity>, 然後有個基類BaseRepository<TEntity>實現該介面的方法。

常見的方法，比如Find, Filter, Delete, Create等

Repository的差異性

每個Repository類又會有一些差異性，應當允許它們能夠繼承BaseRepository<TEntity>之外，還能夠再擴充套件自己的一些方法。所以每個類都可以再定義一個自己特有的介面，定義一些屬於自己Repository的方法。

Repository的協同性

不同的Repository可能需要協同，Repository對資料的修改，需要在統一的儲存.

最終實現的類結構圖如下:

二，Repository設計具體的實現程式碼

IRepository<TEntity>介面定義了Repository共有的方法, BaseRepository<TEntity>實現了這些介面的方法。其它的Repository類再整合BaseRepository<TEntity>方法，就天然的得到了對資料操作的基本方法。

IRepository<TEntity>程式碼

public interface IRepository<TEntity> where TEntity : class
{
      IQueryable<TEntity> All();
      IQueryable<TEntity> Filter(Expression<Func<TEntity, bool>> predicate);
      IQueryable<TEntity> Filter(Expression<Func<TEntity, bool
 
>> filter, out int total, int index = 0, int size = 50);
      bool Contains(Expression<Func<TEntity, bool>> predicate);
      TEntity Find(params object[] keys);
      TEntity Find(Expression<Func<TEntity, bool>> predicate);
      TEntity Create(TEntity t);
      void Delete(TEntity t);
      void Delete(Expression<Func<TEntity, bool>> predicate);
      void Update(TEntity t);
      TEntity Single(Expression<Func<TEntity, bool>> expression);
}

BaseRepository<TEntity>程式碼

 public class BaseRepository<TEntity> : IRepository<TEntity> where TEntity : class
    {
        protected readonly DbContext Context;

        public BaseRepository(DbContext context)
        {
            Context = context;
        }

        public TEntity FirstOrDefault(Expression<Func<TEntity, bool>> expression)
        {
            return All().FirstOrDefault(expression);
        }

        public IQueryable<TEntity> All()
        {
            return Context.Set<TEntity>().AsQueryable();
        }

        public virtual IQueryable<TEntity> Filter(Expression<Func<TEntity, bool>> predicate)
        {
            return Context.Set<TEntity>().Where<TEntity>(predicate).AsQueryable<TEntity>();
        }

        public virtual IQueryable<TEntity> Filter(Expression<Func<TEntity, bool>> filter, out int total, int index = 0,
                                               int size = 50)
        {
            var skipCount = index * size;
            var resetSet = filter != null
                                ? Context.Set<TEntity>().Where<TEntity>(filter).AsQueryable()
                                : Context.Set<TEntity>().AsQueryable();
            resetSet = skipCount == 0 ? resetSet.Take(size) : resetSet.Skip(skipCount).Take(size);
            total = resetSet.Count();
            return resetSet.AsQueryable();
        }

        public virtual void Create(TEntity TObject)
        {
            Context.Set<TEntity>().Add(TObject);
        }

        public virtual void Delete(TEntity TObject)
        {
            Context.Set<TEntity>().Remove(TObject);
        }

        public virtual void Update(TEntity TObject)
        {
            try
            {
                var entry = Context.Entry(TObject);
                Context.Set<TEntity>().Attach(TObject);
                entry.State = EntityState.Modified;
            }
            catch (OptimisticConcurrencyException ex)
            {
                throw ex;
            }
        }

        public virtual int Delete(Expression<Func<TEntity, bool>> predicate)
        {
            var objects = Filter(predicate);
            foreach (var obj in objects)
                Context.Set<TEntity>().Remove(obj);
            return Context.SaveChanges();
        }

        public bool Contains(Expression<Func<TEntity, bool>> predicate)
        {
            return Context.Set<TEntity>().Any(predicate);
        }

        public virtual TEntity Find(params object[] keys)
        {
            return Context.Set<TEntity>().Find(keys);
        }

        public virtual TEntity Find(Expression<Func<TEntity, bool>> predicate)
        {
            return Context.Set<TEntity>().FirstOrDefault<TEntity>(predicate);
        }
    }

IUnitOfWork介面定義了方法獲取特定的Repository, 執行儲存過程, SaveChange方法提交修改，統一更新資料。

IUnitOfWork介面程式碼:

public interface IUnitOfWork : IDisposable
{
      TRepository GetRepository<TRepository>() where TRepository : class;
      void ExecuteProcedure(string procedureCommand, params object[] sqlParams);
      void SaveChanges();
}

UnitOfWork程式碼, 程式碼中使用到了Autofac中的IComponentContext來獲取Repository例項

public class UnitOfWork : IUnitOfWork
{
       private readonly IComponentContext _componentContext;
       protected readonly DbContext Context;

       public UnitOfWorkRepository(DbContext context, IComponentContext componentContext)
       {
           Context = context;
           _componentContext = componentContext;
       }

       public TRepository GetRepository<TRepository>() where TRepository : class
       {
           return _componentContext.Resolve<TRepository>();
       }

       public void ExecuteProcedure(string procedureCommand, params object[] sqlParams)
       {
           Context.Database.ExecuteSqlCommand(procedureCommand, sqlParams);
       }

       public void SaveChanges()
       {
           Context.SaveChanges();
       }

       public void Dispose()
       {
           if (Context != null)
               Context.Dispose();
       }
}

三, Repository設計的具體的使用

這裡我們定義一個操作Student的Repository類，看看如何實際用於開發中。這裡加入StudentRepository有自己特定的方法，需要獲取所有的Students，這個擴充套件的方法名字叫GetAllStudents

那麼定義一個介面IStudentRepository, 包含了方法GetAllStudents(), 同時繼承IRepository<Student>介面

public interface IStudentRepository : IRepository<Student>
{
      IEnumerable<dynamic> GetAllStudents();
}

然後定義StudentRepository類來實現這個介面

public class StudentRepository : BaseRepository<Student>, IStudentRepository
{
       private readonly SchoolContext _context;

       public StudentRepository(SchoolContext context)
           : base(context)
       {
           _context = context;
       }

       public IEnumerable<dynamic> GetAllStudents()
       {
           return _context.Students;
       }
}

使用Repository的程式碼如下:

IUnitOfWork unitOfWork = new UnitOfWork();

var studentRepository = unitOfWork.GetRepository<IStudentRepository>();
var students = studentRepository.GetAllStudents();

//同時你也可以使用定義於IRepository<Student>中的方法， 比如
//unitOfWork.Delete(students.First());
//unitOfWork.SaveChanges();

四，總結

上面的設計，把Repository的通用程式碼剝離到父類中，同時又允許每個Repository擴充套件自己的方法，達到了比較理想的狀態。

只是現在的設計和Autofac耦合了，但是想剝離Autofac的話，直接使用下面的方式獲取IStudentRepository的例項就很困難。

unitOfWorkRepository.GetRepository<IStudentRepository>();

如果有什麼好的辦法，歡迎指教。也歡迎各位拍磚。

最後，附上本文的相關原始碼. RepositoryDesign.zip有朋友反映這個設計有問題，希望大家批判的看待。如果有不同看法，歡迎指教。

五， 反饋及更新

感謝熱心的園友提供的意見。 這個Repository的設計是不成熟的，在使用了一段EF和看了一些文章之後，自己的一些探索和思考，還沒有應用到實際專案中。

提到的Single方法不合適，已經改成FirstOrDefault()