如何构建通用存储库

Question

我正在使用 NHibernate 在 ASP.NET MVC 中开发一个 Web 应用程序。

根据我在 Google 上找到的文章和教程，我将 Repository 用于我的课程。

我有 10 个类和 10 个存储库。今天我发现我的 90% 的存储库是完全相等的，除了类。这是一个例子：

public class PromocaoRepository:IPromocaoRepository {
    private ISession Session;

    public PromocaoRepository() {
        this.Session = NHibernateSessionFactory.OpenSession();
    }

    public void Add(Promocao promocao) {
        using(ITransaction transaction = this.Session.BeginTransaction()) {
            this.Session.Save(promocao);
            transaction.Commit();
        }
    }

    public void Edit(Promocao promocao) {
        using(ITransaction transaction = this.Session.BeginTransaction()) {
            this.Session.Update(promocao);
            transaction.Commit();
        }
    }

    public void Remove(Promocao promocao) {
        using(ITransaction transaction = this.Session.BeginTransaction()) {
            this.Session.Delete(promocao);
            transaction.Commit();
        }
    }

    public Promocao GetById(int id) {
        return this.Session.Get<Promocao>(id);
    }

}

有一种方法可以做一种我可以在所有课程中使用的通用存储库吗？

如果可能，如果我需要为特定类创建特定方法，我应该怎么做？

Answer 1

来自another thread：

public interface IRepository<T> : IQueryable<T>
{
  void Add(T entity);
  T Get(Guid id);
  void Remove(T entity);
}

public class Repository<T> : IQueryable<T>
{
  private readonly ISession session;

  public Repository(ISession session)
  {
    session = session;
  }

  public Type ElementType
  {
    get { return session.Query<T>().ElementType; }
  }

  public Expression Expression
  {
    get { return session.Query<T>().Expression; }
  }

  public IQueryProvider Provider
  {
    get { return session.Query<T>().Provider; } 
  }  

  public void Add(T entity)
  {
    session.Save(entity);
  }

  public T Get(Guid id)
  {
    return session.Get<T>(id);
  }

  IEnumerator IEnumerable.GetEnumerator()
  {
    return this.GetEnumerator();
  }

  public IEnumerator<T> GetEnumerator()
  {
    return session.Query<T>().GetEnumerator();
  }

  public void Remove(T entity)
  {
    session.Delete(entity);
  }   
}

• Wrapping up nHibernate in repositories

  ---

  话虽如此，您应该看看S#arp Architecture，它已经使用依赖注入帮助您完成这个重复的过程。

Answer 2

您应该创建一个通用存储库，您可以在一般情况下使用它，如果特定类需要任何额外的方法，请使用继承添加它。使用您的示例：

public class GenericRepository<TEntity> :IGenericRepository<TEntity> {
    private ISession Session;

    public GenericRepository() {
        this.Session = NHibernateSessionFactory.OpenSession();
    }

    public void Add(TEntity instance) {
        using(ITransaction transaction = this.Session.BeginTransaction()) {
            this.Session.Save(instance);
            transaction.Commit();
        }
    }

    /* other methods */ 
}

public class SpecificRepository : GenericRepository<SpecificEntity>, ISpecificRepository 
{
    public void SpecialQuery()  { /* added method implementation */ }
}

Answer 3

这是我对类似问题的回答（截至目前 28 票）：

Advantage of creating a generic repository vs. specific repository for each object?

这个想法是泛化实现，而不是接口。创建一个面向内部的通用存储库基类，而不是面向外部的通用存储库接口，您可以使用它轻松实现特定于实体的接口。

编辑：我应该指出，通用存储库提供的功能与特定存储库非常不同。存储库旨在封装实体查询背后的数据访问机制，包括所有查询逻辑。通用存储库封装了创建查询的能力，但它不封装关于实体的任何特定查询。

关键是不要让存储库消费者负责编写自己的查询。通用存储库与 ORM 处于同一抽象级别；特定的存储库位于高于此的级别。

Answer 4

Here's another example of a generic repository

Answer 5

看看我对“Asp.net MVC 2 Entity Framework Generic Repository Method. how to Update a specific Collumn”问题的回答——它应该让你知道该怎么做。

HTH， 查尔斯

例如

基础模型：

public interface IDbTable
{
    int Id { get; set; }
    DateTime DateCreated { get; set; }
    DateTime DateUpdated { get; set; }
}

public class DbTable
{
    public int Id { get; set; }
    public DateTime DateCreated { get; set; }
    public DateTime DateUpdated { get; set; }
}

你的模型

public class Category : DbTable
{
    public string Name { get; set; }
}

你的仓库

public interface IBaseRepository<T> where T : class, IDbTable
{
    void Add<T>(T entity);
    void Edit<T>(T entity);
    void Remove<T>(T entity);
    T GetById(int id);
}

public class BaseRepository<T> : IBaseRepository<T>
{
    private ISession Session;

    public BaseRepository()
    {
        this.Session = NHibernateSessionFactory.OpenSession();
    }

    public void Add(T entity)
    {
        entity.DateCreated = DateTime.UtcNow;
        entity.DateUpdated = DateTime.UtcNow;

        using(ITransaction transaction = this.Session.BeginTransaction())
        {
            this.Session.Save(entity);
            transaction.Commit();
        }
    }

    public void Edit(T entity)
    {
        entity.DateUpdated = DateTime.UtcNow;

        using(ITransaction transaction = this.Session.BeginTransaction())
        {
            this.Session.Update(entity);
            transaction.Commit();
        }
    }

    public void Remove(T entity)
    {
        using(ITransaction transaction = this.Session.BeginTransaction())
        {
            this.Session.Delete(entity);
            transaction.Commit();
        }
    }

    public T GetById(int id)
    {
        return this.Session.Get<T>(id);
    }
}

哦，别忘了具体的实现

public interface ICategoryRepository : IBaseRepository<Category>
{
    Category GetCategoryByName(string categoryName);
}

public CategoryRepository : BaseRepository<Category>
{
    public Category GetCategoryByName(string categoryName)
    {
        //blah
    }
}