如何编写带重试机制的高韧性SQL更新面向对象方法？附代码有效性验证

你写的这段递归重试代码在使用Microsoft SqlClient执行SQL更新时不具备高韧性，核心问题和改进方向如下：

现存问题 #

• 无重试延迟：失败后立即递归重试，会短时间内给数据库发起大量重复请求，不仅无法解决问题，还可能加重数据库负载，甚至触发连接限制。
• 无异常过滤：不管是什么异常都重试，比如主键冲突、SQL语法错误这类根本无法通过重试修复的问题，纯粹是浪费资源。
• 递归栈溢出风险：如果后续调整重试次数到较大值，递归调用会持续占用栈空间，可能触发栈溢出异常。
• 无失败反馈：重试耗尽后没有任何日志或错误通知，失败被静默忽略，排查问题完全没有线索。
• 事务处理缺失：如果SQL更新涉及事务，递归时没有正确回滚失败的事务，容易导致数据不一致。

改进建议 #

要实现高韧性的SQL更新重试，需要调整为以下模式：

• 用循环替代递归：避免栈溢出，逻辑更易维护。
• 添加指数退避延迟：重试间隔随次数递增（比如1秒、2秒、4秒），给数据库留出恢复时间。
• 只重试可恢复异常：针对SqlException中特定错误码（比如死锁1205、超时-2、连接错误4060等）进行重试，其他异常直接抛出。
• 完善事务与资源管理：每次重试前确保事务回滚，连接等资源正确释放。
• 添加日志记录：记录每次重试的异常信息和最终失败状态，方便排查问题。

改进后的示例代码 #

void UpdateSomeSQLRows(int maxRetries = 3)
{
    int retryCount = 0;
    bool updateSuccess = false;
    var retryableErrorCodes = new HashSet<int> { 1205, -2, 4060, 10928, 10929 };

    while (!updateSuccess && retryCount < maxRetries)
    {
        using (var connection = new SqlConnection("你的连接字符串"))
        {
            SqlTransaction transaction = null;
            try
            {
                connection.Open();
                transaction = connection.BeginTransaction();

                // 执行SQL更新逻辑
                using (var command = new SqlCommand("UPDATE YourTable SET Column = Value WHERE Id = @Id", connection, transaction))
                {
                    command.Parameters.AddWithValue("@Id", 1);
                    command.ExecuteNonQuery();
                }

                transaction.Commit();
                updateSuccess = true;
            }
            catch (SqlException ex)
            {
                transaction?.Rollback();
                if (!retryableErrorCodes.Contains(ex.Number))
                {
                    throw; // 不可重试的异常直接抛出，不浪费重试次数
                }

                retryCount++;
                // 指数退避延迟
                Thread.Sleep((int)Math.Pow(2, retryCount) * 1000);
            }
            catch (Exception ex)
            {
                transaction?.Rollback();
                throw; // 非SQL异常直接抛出
            }
        }
    }

    if (!updateSuccess)
    {
        // 记录失败日志，可替换为你的日志框架
        Console.WriteLine($"SQL更新失败，已完成{maxRetries}次重试");
    }
}

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