我知道答案有点晚，但我认为分享还是有用的。
现在在EF6中，使用dbContext.Database.BeginTransaction()更容易实现此目标。
像这样：
using (var context = new BloggingContext())
{
using (var dbContextTransaction = context.Database.BeginTransaction())
{
try
{
// do your changes
context.SaveChanges();
// do another changes
context.SaveChanges();
dbContextTransaction.Commit();
}
catch (Exception ex)
{
//Log, handle or absorbe I don't care ^_^
}
}
}
更多信息请查看此链接
这是在EF6及以后版本中实现的。
在相关实体应该在单个事务中持久化时，调用SaveChanges多次（没有事务范围）是一个不好的做法。你所创建的是一个有缺陷的抽象。可以创建一个单独的工作单元类或直接使用ObjectContext/DbContext本身。
SaveChanges 调用周围使用显式事务，尽可能避免不一致性。不幸的是，我生活在一个预算往往胜过质量的国家，特别是在大型政府项目中。客户不接受改进遗留数据结构的想法，因为这可能需要重新设计与其他系统的现有集成，这将导致未计划的费用。我们的应用程序必须使用已经存在的数据，并尽可能少地进行更改。 - JustAMartin这是我目前使用的另一种处理多个 context.SaveChanges() 的 UnitOfWork 方法。
我们将 context.SaveChanges() 方法暂存，直到最后一个被调用时再一次性保存。
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading;
using System.Threading.Tasks;
using Microsoft.EntityFrameworkCore;
namespace DataAccess
{
public class UnitOfWork : IUnitOfWork
{
private readonly Context context;
private readonly Dictionary<Type, object> repositories = new Dictionary<Type, object>();
private int beginChangeCount;
private bool selfManagedTransaction = true;
public UnitOfWork(Context context)
{
this.context = context;
}
//Use generic repo or init the instance of your repos here
public IGenericRepository<TEntity> GetRepository<TEntity>() where TEntity : BaseEntityModel
{
if (repositories.Keys.Contains(typeof(TEntity)))
return repositories[typeof(TEntity)] as IGenericRepository<TEntity>;
var repository = new Repository<TEntity>(context);
repositories.Add(typeof(TEntity), repository);
return repository;
}
public void SaveChanges()
{
if (selfManagedTransaction)
{
CommitChanges();
}
}
public void BeginChanges()
{
selfManagedTransaction = false;
Interlocked.Increment(ref beginChangeCount);
}
public void CommitChanges()
{
if (Interlocked.Decrement(ref beginChangeCount) > 0)
{
return;
}
beginChangeCount = 0;
context.SaveChanges();
selfManagedTransaction = true;
}
}
}
使用示例。
在下面的代码中查找我的注释
using System.Linq;
using System.Threading.Tasks;
using Microsoft.AspNetCore.Identity;
namespace BusinessServices.Domain
{
public class AService : BaseBusinessService, IAService
{
private readonly IBService BService;
private readonly ICService CService;
private readonly IUnitOfWork uow;
public AService (IBService BService, ICService CService, IUnitOfWork uow)
{
this.BService = BService;
this.CService = CService;
this.uow = uow;
}
public void DoSomeThingComplicated()
{
uow.BeginChanges();
//Create object B - already have uow.SaveChanges() inside
//still not save to database yet
BService.CreateB();
//Create object C - already have uow.SaveChanges() inside
//still not save to databse yet
CService.CreateC();
//if there are no exceptions, all data will be saved in database
//else nothing in database
uow.CommitChanges();
}
}
}
DbContext是一个工作单元并且是可被释放的。但是如果你想要最小化数据库调用，那么你需要实现一个工作单元方法。你的IUnitOfWork将有一个SaveChanges方法，而你的UnitOfWork将继承IUnitOfWork和IDisposable。 - Colin Bacon在这种情况下，建议采用此处所述的新的现代方法。
如果您熟悉TransactionScope类，则已经知道如何使用DbContextScope。它们在本质上非常相似 - 唯一的区别是DbContextScope创建和管理DbContext实例而不是数据库事务。但与TransactionScope一样，DbContextScope是环境感知的，可以嵌套，可以禁用其嵌套行为，并且可以很好地处理异步执行流程。
public void MarkUserAsPremium(Guid userId)
{
using (var dbContextScope = _dbContextScopeFactory.Create())
{
var user = _userRepository.Get(userId);
user.IsPremiumUser = true;
dbContextScope.SaveChanges();
}
}
DbContextScope 中，您可以通过两种方式访问范围管理的 DbContext 实例。您可以通过以下方式通过 DbContextScope.DbContexts 属性获取它们：public void SomeServiceMethod(Guid userId)
{
using (var dbContextScope = _dbContextScopeFactory.Create())
{
var user = dbContextScope.DbContexts.Get<MyDbContext>.Set<User>.Find(userId);
[...]
dbContextScope.SaveChanges();
}
}
但这当然只在创建DbContextScope的方法中可用。如果您需要在任何其他地方访问环境DbContext实例（例如在存储库类中），您可以依赖于IAmbientDbContextLocator，使用方式如下：
public class UserRepository : IUserRepository
{
private readonly IAmbientDbContextLocator _contextLocator;
public UserRepository(IAmbientDbContextLocator contextLocator)
{
if (contextLocator == null) throw new ArgumentNullException("contextLocator");
_contextLocator = contextLocator;
}
public User Get(Guid userId)
{
return _contextLocator.Get<MyDbContext>.Set<User>().Find(userId);
}
}
using语句会在其作用范围结束时释放事务，如果在此之前没有成功调用Commit方法，则会将事务回滚。 - JohnnyHKSaveChanges()调用来减少此影响。 - binki