一个DbContext实例跨越多个存储库

Question

 builder.RegisterType<MyContext>().As<MyContext>().InstancePerRequest();
 builder.RegisterType<TestRepository>().InstancePerRequest();
 builder.RegisterType<SchoolclassCodeRepository>().InstancePerRequest();
 builder.RegisterType<TestService>().InstancePerRequest();

但是，共享上下文还有其他很好的理由，其中之一(IMHO)是上下文必须跟踪实体的状态，如果您要获得一个实体，处理该上下文，对该实体进行一些修改，然后附加到一个新的上下文，这个新的上下文必须访问数据库，以便它能够计算出该实体的状态。同样，如果您正在处理实体（发票和它们的所有InvoiceItems）的图，那么新的上下文必须获取图中的所有实体来确定它们的状态。

但现在我用这种建筑撞上了单行道！

如果我必须做一个跨越多个存储库的事务怎么办？

using(NorthwindEntities db = new NorthwindEntities())
{
    DbContextTransaction transaction = db.Database.BeginTransaction();

    try
    {
        //insert record 1
        Customer obj1 = new Customer();
        obj1.CustomerID = "ABCDE";
        db.Customers.Add(obj1);
        db.SaveChanges();

        //insert record 2
        Customer obj2 = new Customer();
        obj2.CustomerID = "PQRST";
        db.Customers.Add(obj2);   
        db.SaveChanges();

        transaction.Commit();
    }
    catch
    {
        transaction.Rollback();
    }
}

null

如何在不更改存储库的情况下在多个存储库上创建事务？

示例我想要的东西：

在我的TestService中，我想大致做以下操作：

public void Save()
{
  // Open Transaction
  // testRepo.Insert();
  // schoolclassCodeRepo.Delete();
  // Commit Transaction
}

null

更新3解决方案代码

public async Task<bool> DeleteSchoolyearAsync(int id)
{
    using (var scope = new TransactionScope(TransactionScopeAsyncFlowOption.Enabled))
    {
        try
        {
            await testRepository.DeleteTestTypes(id);
            await schoolyearRepository.DeleteAsync(id);
            scope.Complete(); // Rollback is done due to using statement...
            return true;

        }
        catch (System.Exception)
        {
            return false;
        }
    }
}

这个代码工作得很好！

Answer 1

您不改变存储库，但您的体系结构中肯定缺少工作单元。这是您为多个存储库共享单个上下文的地方。

将UoW视为DbContext，其中存储库是DBSet。

UoW uow = new UoW( context );

uow.BeginTransaction();

uow.Repository1.... // query, insert, update, delete
uow.Repository2....

uow.Commit();

典型的实现只公开多个存储库：

public class UoW {

   public UoW( DbContext ctx ) {

      this._ctx = ctx;

   }

   private Repository1 _repo1;

   public Repository1 Repo1
   {
      get
      {
          if ( _repo1 == null )
              _repo1 = new Repository1( this._ctx );
          return _repo1;
      }

      ...