.Net - 多个 ORM 的工作单元模式解耦

Question

我当前的应用程序结构是：

• 模型组装
• 数据组装
  • 定义由 ORM 实现的存储库接口
• 定义由 ORM ORM 程序集
  • 通过数据组装实现存储库接口
  • 使用 unity（IoC 容器）将 Data.IRepository 注册到 ORM.GenericRepository
• 业务组件
  • 引用数据和模型程序集
  • 使用 unity 来解析 IRepository 的类型
• UI 程序集 的类型
  • 引用业务程序集

此结构本质上将业务层与实现 IRepository 的 ORM 解耦。

这种解耦结构的好处之一是我应该能够相对轻松地替换 ORM - 例如，从实体框架迁移到 NHibernate 或只是升级现有的 ORM。我目前首先使用 EF 4.1 代码，并正在为 NHibernate 构建另一个程序集。

我正在考虑实施工作单元模式。

我读到该模式应该在业务层中使用（在我的数据程序集中定义接口，并在 ORM 程序集中实现，就像我对存储库模式所做的那样）。目前，所有实例化存储库都有自己的 DbContext / 会话，并且其生命周期设置为存储库的生命周期 - 这可能很糟糕 - 我的问题是我不确定是否可以实现可以使用的工作单元模式不同的 ORM（呃，更确切地说，它可能是，我只是不跟上速度）。

这是我唯一想到的事情：

在我的 Data 程序集中创建 IUnitOfWork，它具有以下功能： object GetCurrentSession(); ，然后在 ORM 程序集中的存储库的构造函数中添加一个参数并进行强制转换它到适当的会话/DbContext（如果是NHibernate则为ISession，如果为Entity Framework则为DbContext）

如果有人对这种情况有一些见解，我将不胜感激。

Answer 1

最近，我做了一个研究项目，其中使用工作单元和存储库模式实现了一个简单的 ASP.NET Core CRUD API。我这样做是为了让我的 API 控制器仅通过 IUnitOfWork 抽象与持久存储一起工作。我有 Dapper、Entity Framework Core 和 NHibernate 的单独项目，每个项目都为特定的 ORM 实现了 IUnitOfWork。

这是项目链接： https://github.com/pkirilin/UnitOfWorkExample

这是一个简单的示例：

class SomeService
{
    private readonly IAppUnitOfWork _unitOfWork;

    // IAppUnitOfWork is inherited from base IUnitOfWork and added to DI container
    public SomeService(IAppUnitOfWork unitOfWork)
    {
        _unitOfWork = unitOfWork;
    }

    public async Task DoSomethingAsync(CancellationToken cancellationToken)
    {
        var entity = await _unitOfWork.WeatherForecasts.GetByIdAsync(..., cancellationToken);
        _unitOfWork.WeatherForecasts.Delete(entity);

        var newEntity = new WeatherForecast(...);
        _unitOfWork.WeatherForecasts.Add(newEntity);

        await _unitOfWork.SaveChangesAsync(cancellationToken);
    }
}

Answer 2

我可能已经找到了解决方案（尚未尝试过）：

在数据程序集中：

public interface IUnitOfWork : IDisposable
{
   void Start();
   T Current<T>();
   // IDisposable stuff
}

在 ORM 程序集中：

public class GenericRepository<T> : IRepository<T>
    where T : PersistentEntity
{
    private ISession CurrentSession;

    public GenericRepository(IUnitOfWork uow)
    {
         CurrentSession = uow.Current<ISession>();
    }

    // other repository stuff here
}

public class NHhibernateUnitOfWork : IUnitOfWork
{
   private ISession CurrentSession;

   public void Start()
   {
      // instantiate CurrentSession
   }

   T Current<T>()
   {
      if(typeof(T) is ISession)
         return (T)CurrentSession;
      else
         return new NotImplementedException();
   }
}

// in the prism module
container.Resolve(typeof(IUnitOfWork), typeof(NHhibernateUnitOfWork));

在业务程序集中：

IUnitOfWork uow = container.Resolve<IUnitOfWork>();
using(uow.Start())
{
    IRepository custRepo = container.Resolve<IRepository<Customer>>(uow);
    // do stuff here with cust repo
}

这只是将 IUnitOfWork 与具体实现解耦的概念证明。