Entity Framework - 混合存储过程和实体的回滚
Entity Framework - Rollback for Mix of Stored Procedures and Entities
我需要调用一些存储过程(数据插入)并将实体值更新到数据库。
我希望这些操作是原子的,所以如果发生错误,它们都会回滚。
在我的代码中,如果我强制异常以观察回滚行为,我的实体更改会回滚,但我的存储过程更改不会回滚。
查看工作单元的实现,只是查看 _context.ChangeTracker.Entries()
- 我假设完全忽略任何存储过程更改?
当我更改要使用的工作单元实现时
new System.Transactions.TransactionScope()
回滚按预期进行。
我应该使用 new System.Transactions.TransactionScope()
吗?有什么问题吗?
代码
...
using (var scope = _unitOfWork.Begin())
{
try
{
var outcome = _context.Database.ExecuteSqlCommand("SOME EXEC COMMAND", parameters);
throw new Exception("Something happened");
scope.Commit(); // Never gets called because of Exception
}
catch (Exception e)
{
scope.Rollback();
}
}
工作单元:
public class UnitOfWork : IUnitOfWork, ITransaction
{
private readonly DbContext _context;
private bool _committed;
public UnitOfWork(DbContext context)
{
_context = context;
}
public ITransaction Begin()
{
_committed = false;
return this;
}
public void Commit()
{
_context.SaveChanges();
_committed = true;
}
public void Rollback()
{
foreach (var entry in _context.ChangeTracker.Entries())
{
switch (entry.State)
{
case EntityState.Modified:
entry.State = EntityState.Unchanged;
break;
case EntityState.Added:
entry.State = EntityState.Detached;
break;
case EntityState.Deleted:
entry.Reload();
break;
case EntityState.Detached:
break;
case EntityState.Unchanged:
break;
default:
throw new ArgumentOutOfRangeException();
}
}
}
public void Dispose(bool disposing)
{
if (!disposing)
return;
if (!_committed)
{
Rollback();
}
}
public void Dispose()
{
Dispose(true);
GC.SuppressFinalize(this);
}
}
是的 - Change Tracker 当然只能跟踪您通过 DbContext
class.
更改/修改/添加的任何内容
运行 存储过程超出了 EF 变更跟踪器的范围 - 因此,如果您的“回滚”仅基于变更跟踪器中的内容,您将无法正确处理您的任何事情存储过程已经完成。
使用 TransactionScope
是根本不同的 - 这是所有数据库操作的“保护伞” - 包括正在执行的任何存储过程 - 因为它基本上是在数据库级别上。因此,基于事务范围的回滚将回滚所有数据库操作——无论是通过 EF DbContext
还是通过其他方式处理。
我需要调用一些存储过程(数据插入)并将实体值更新到数据库。
我希望这些操作是原子的,所以如果发生错误,它们都会回滚。
在我的代码中,如果我强制异常以观察回滚行为,我的实体更改会回滚,但我的存储过程更改不会回滚。
查看工作单元的实现,只是查看 _context.ChangeTracker.Entries()
- 我假设完全忽略任何存储过程更改?
当我更改要使用的工作单元实现时
new System.Transactions.TransactionScope()
回滚按预期进行。
我应该使用 new System.Transactions.TransactionScope()
吗?有什么问题吗?
代码
...
using (var scope = _unitOfWork.Begin())
{
try
{
var outcome = _context.Database.ExecuteSqlCommand("SOME EXEC COMMAND", parameters);
throw new Exception("Something happened");
scope.Commit(); // Never gets called because of Exception
}
catch (Exception e)
{
scope.Rollback();
}
}
工作单元:
public class UnitOfWork : IUnitOfWork, ITransaction
{
private readonly DbContext _context;
private bool _committed;
public UnitOfWork(DbContext context)
{
_context = context;
}
public ITransaction Begin()
{
_committed = false;
return this;
}
public void Commit()
{
_context.SaveChanges();
_committed = true;
}
public void Rollback()
{
foreach (var entry in _context.ChangeTracker.Entries())
{
switch (entry.State)
{
case EntityState.Modified:
entry.State = EntityState.Unchanged;
break;
case EntityState.Added:
entry.State = EntityState.Detached;
break;
case EntityState.Deleted:
entry.Reload();
break;
case EntityState.Detached:
break;
case EntityState.Unchanged:
break;
default:
throw new ArgumentOutOfRangeException();
}
}
}
public void Dispose(bool disposing)
{
if (!disposing)
return;
if (!_committed)
{
Rollback();
}
}
public void Dispose()
{
Dispose(true);
GC.SuppressFinalize(this);
}
}
是的 - Change Tracker 当然只能跟踪您通过 DbContext
class.
运行 存储过程超出了 EF 变更跟踪器的范围 - 因此,如果您的“回滚”仅基于变更跟踪器中的内容,您将无法正确处理您的任何事情存储过程已经完成。
使用 TransactionScope
是根本不同的 - 这是所有数据库操作的“保护伞” - 包括正在执行的任何存储过程 - 因为它基本上是在数据库级别上。因此,基于事务范围的回滚将回滚所有数据库操作——无论是通过 EF DbContext
还是通过其他方式处理。