Entity Framework 7批量插入如何保证单事务（全成功或全失败）？

要确保批量插入操作的原子性（要么全部成功，要么全部失败），EF7提供了几种直接且可靠的方案，以下是具体实现方式：

方法1：利用SaveChanges的默认事务 #

EF7中，SaveChanges()/SaveChangesAsync()默认会将当前上下文所有待执行的变更（包括通过AddRange添加的批量实体）包裹在一个事务中。只需一次性将所有待插入实体添加到DbSet，再调用一次保存方法即可自动实现事务性。

using var context = new YourDbContext();

// 构造批量插入的实体集合
var entitiesToInsert = new List<YourEntity>
{
    new YourEntity { /* 赋值实体属性 */ },
    new YourEntity { /* 赋值实体属性 */ },
    // 更多实体...
};

// 批量添加到上下文
context.YourEntities.AddRange(entitiesToInsert);

try
{
    await context.SaveChangesAsync();
    Console.WriteLine("所有实体插入成功");
}
catch (Exception ex)
{
    Console.WriteLine($"插入失败，已自动回滚：{ex.Message}");
}

方法2：手动显式控制事务 #

如果批量插入逻辑涉及多批次操作、穿插其他数据库操作，可手动开启事务，统一控制提交与回滚。

using var context = new YourDbContext();
// 开启异步事务
using var transaction = await context.Database.BeginTransactionAsync();

try
{
    // 第一批次插入
    var batch1 = new List<YourEntity> { /* 实体集合 */ };
    context.YourEntities.AddRange(batch1);
    await context.SaveChangesAsync();

    // 第二批次插入或其他数据库操作
    var batch2 = new List<YourEntity> { /* 实体集合 */ };
    context.YourEntities.AddRange(batch2);
    await context.SaveChangesAsync();

    // 所有操作完成后提交事务
    await transaction.CommitAsync();
    Console.WriteLine("所有批次插入成功");
}
catch (Exception ex)
{
    // 发生异常时回滚所有操作
    await transaction.RollbackAsync();
    Console.WriteLine($"插入失败，已回滚所有操作：{ex.Message}");
}

方法3：使用TransactionScope（跨资源场景） #

如果批量操作涉及多个DbContext或其他事务性资源（如SQL Server存储过程），可使用TransactionScope实现分布式事务（需确保项目引用System.Transactions包）。

// 启用异步流支持
using var scope = new TransactionScope(TransactionScopeAsyncFlowOption.Enabled);

try
{
    using var context1 = new YourDbContext();
    var entities1 = new List<YourEntity> { /* 实体集合 */ };
    context1.YourEntities.AddRange(entities1);
    await context1.SaveChangesAsync();

    using var context2 = new AnotherDbContext();
    var entities2 = new List<AnotherEntity> { /* 实体集合 */ };
    context2.AnotherEntities.AddRange(entities2);
    await context2.SaveChangesAsync();

    // 标记事务完成，提交所有操作
    scope.Complete();
    Console.WriteLine("所有跨资源操作执行成功");
}
catch (Exception ex)
{
    Console.WriteLine($"操作失败，已自动回滚：{ex.Message}");
}

关键注意事项 #

• 避免在事务中执行耗时操作，防止数据库锁占用过久影响系统性能。
• 若使用第三方批量插入库（如EF Extensions），需确认库兼容EF7的事务机制，主流库均支持显式事务或默认事务。
• 异常处理需覆盖所有可能的错误场景，确保事务能正确触发回滚。

内容的提问来源于stack exchange，提问作者beseus