EF 6中异常发生时如何重复执行之前的操作

看起来你尝试给DbContext写一个带重试逻辑的SaveChanges扩展方法，但目前的实现大概率会遇到状态不一致的问题——当第一次SaveChanges()抛出异常后，EF的ChangeTracker并不会自动重置实体状态，直接重试往往无法成功。我来帮你梳理问题并给出可行的修复方案：

核心问题分析 #

当SaveChanges()失败时，ChangeTracker里的实体状态会停留在异常前的状态：

• 标记为Added的实体，即使保存失败，状态依然是Added，重试时可能触发主键冲突
• 如果是并发冲突（比如DbUpdateConcurrencyException），实体的当前值和数据库最新值已经不一致，直接重试毫无意义
• 部分临时异常（如网络波动、数据库死锁）可以重试，但非临时异常（如约束违反）重试只会重复失败

修复后的完整实现 #

下面是优化后的带重试逻辑的扩展方法，包含状态备份、异常分类处理和状态重置：

public static int SaveChangesWithRetry(this DbContext db, int maxRetryCount = 3)
{
    int result = -1;
    int retryCount = 0;
    bool shouldRetry;

    // 备份初始的实体状态和数据，避免重试时状态混乱
    var entityBackup = db.ChangeTracker.Entries()
        .Where(e => e.State != EntityState.Detached && e.State != EntityState.Unchanged)
        .Select(e => new
        {
            Entity = e.Entity,
            OriginalState = e.State,
            OriginalValues = e.State switch
            {
                EntityState.Added => null, // 新增实体无原始值
                EntityState.Modified => e.OriginalValues.Clone(),
                EntityState.Deleted => e.OriginalValues.Clone(),
                _ => null
            }
        }).ToList();

    do
    {
        shouldRetry = false;
        try
        {
            result = db.SaveChanges();
        }
        catch (DbUpdateConcurrencyException ex)
        {
            // 处理并发冲突：重新加载数据库最新值，让调用方决定是否合并修改后重试
            foreach (var entry in ex.Entries)
            {
                entry.OriginalValues.SetValues(entry.GetDatabaseValues());
            }
            shouldRetry = retryCount < maxRetryCount;
            retryCount++;
        }
        catch (DbUpdateException ex)
        {
            // 仅对临时异常（如网络波动、死锁）重试
            if (IsTransientDbException(ex) && retryCount < maxRetryCount)
            {
                // 重置实体到初始备份状态
                ResetEntityStates(db, entityBackup);
                shouldRetry = true;
                retryCount++;
            }
            else
            {
                throw; // 非临时异常直接抛出，不重试
            }
        }
        catch (Exception)
        {
            // 其他非数据库异常直接抛出
            throw;
        }
    } while (shouldRetry);

    return result;
}

// 辅助方法：判断是否是可重试的临时数据库异常
private static bool IsTransientDbException(Exception ex)
{
    // 以SQL Server为例，判断常见的可重试错误码
    var sqlEx = ex.InnerException as SqlException;
    if (sqlEx != null)
    {
        // 死锁、连接超时、服务繁忙等错误码
        var transientCodes = new[] { 1205, 4060, 40197, 40501, 40613 };
        return transientCodes.Contains(sqlEx.Number);
    }
    // 其他数据库的判断逻辑可在此扩展
    return false;
}

// 辅助方法：重置实体状态到初始备份
private static void ResetEntityStates(DbContext db, IEnumerable<dynamic> entityBackup)
{
    foreach (var backup in entityBackup)
    {
        var entry = db.Entry(backup.Entity);
        entry.State = backup.OriginalState;
        if (backup.OriginalValues != null)
        {
            entry.OriginalValues.SetValues(backup.OriginalValues);
        }
    }
}

关键优化点说明 #

• 实体状态备份与重置：在执行前备份实体的初始状态和原始值，重试时重置到初始状态，避免异常导致的状态混乱
• 异常分类处理：
  • 并发冲突单独处理：重新加载数据库最新值，让业务代码可以选择合并修改后重试
  • 仅对临时异常重试，非临时异常直接抛出，避免无效重试
• 可配置重试次数：通过参数控制最大重试次数，防止无限循环

使用示例 #

using (var context = new MyDbContext())
{
    // 执行实体修改操作
    context.Products.Add(new Product { Name = "New Product", Price = 99.9m });
    try
    {
        int affectedRows = context.SaveChangesWithRetry();
        Console.WriteLine($"保存成功，影响行数：{affectedRows}");
    }
    catch (Exception ex)
    {
        Console.WriteLine($"最终保存失败：{ex.Message}");
    }
}

内容的提问来源于stack exchange，提问作者Mehmet Emin Yalçın