Azure数据库清理日志触发SqlTransaction ZombieCheck异常排查

我看了你的代码和问题描述，这个异常在大数据量删除时必现，主要有两个核心原因：事务超时被Azure SQL自动终止，以及代码里的事务处理逻辑存在漏洞。下面给你一步步分析和修复方案：

1. 先修复代码里的事务逻辑漏洞 #

你的ExecuteDatabaseTransaction方法里，transaction.Commit()放在了try-catch块的外面，虽然catch块里的throw会跳出执行，但更规范且安全的做法是把Commit放在try块的末尾——这样只有当所有操作都正常完成时，才会提交事务，避免任何意外的提交尝试。另外，当Azure SQL因为事务过大自动终止事务后，再调用Rollback就会触发这个"事务已完成"的异常，所以需要在回滚前先检查事务的状态。

修改后的代码如下：

private static void ExecuteDatabaseTransaction(IConfiguration configuration, string commandText) {
    using (var connection = new SqlConnection(configuration.GetSection("ConnectionStrings")["SignupDatabase"])) {
        connection.Open();
        using (var transaction = connection.BeginTransaction()) {
            try {
                using (var command = connection.CreateCommand()) {
                    command.Transaction = transaction;
                    command.CommandText = commandText;
                    // 增加超时时间，适配大数据量操作，比如设置为5分钟（300秒）
                    command.CommandTimeout = 300;
                    var rowsDeleted = command.ExecuteNonQuery();
                    Console.WriteLine("Rows Affected: " + rowsDeleted);
                }
                // 只有当所有操作正常完成时才提交事务
                transaction.Commit();
                Console.WriteLine("Records are deleted from database.");
            } catch (Exception ex) {
                Console.WriteLine("Commit Exception Type: {0}", ex.GetType());
                Console.WriteLine(" Message: {0}", ex.Message);
                try {
                    // 回滚前先检查事务状态，避免操作已完成的事务
                    if (transaction.Connection != null) {
                        transaction.Rollback();
                    }
                } catch (Exception ex2) {
                    Console.WriteLine("Rollback Exception Type: {0}", ex2.GetType());
                    Console.WriteLine(" Message: {0}", ex2.Message);
                    throw;
                }
                throw;
            }
        }
    }
}

2. 解决大数据量删除的事务超时问题 #

一次性删除大量数据会导致事务体积过大，不仅容易触发Azure SQL的事务超时限制，还会占用大量资源影响数据库性能。更好的做法是分批次删除，每次删除一小部分数据，直到所有符合条件的记录都被清理。

比如修改你的SQL逻辑，改成循环删除：

private static void ExecuteBatchDelete(IConfiguration configuration) {
    var daysToKeep = configuration.GetSection("ProfilingData")["DaysToKeep"];
    var batchSize = 1000; // 每次删除1000条，可根据实际情况调整
    using (var connection = new SqlConnection(configuration.GetSection("ConnectionStrings")["SignupDatabase"])) {
        connection.Open();
        while (true) {
            using (var transaction = connection.BeginTransaction()) {
                try {
                    using (var command = connection.CreateCommand()) {
                        command.Transaction = transaction;
                        command.CommandTimeout = 300;
                        // 分批次删除的SQL
                        command.CommandText = $@"
DELETE TOP ({batchSize}) profiling.MiniProfilerTimings 
FROM profiling.MiniProfilerTimings 
WHERE EXISTS(
    SELECT * FROM profiling.MiniProfilers 
    WHERE profiling.MiniProfilers.Id = MiniProfilerId 
    AND profiling.MiniProfilers.Started < GETDATE() - {daysToKeep}
)";
                        var rowsDeleted = command.ExecuteNonQuery();
                        Console.WriteLine("Rows Deleted in Batch: " + rowsDeleted);
                        if (rowsDeleted == 0) {
                            // 没有更多数据可以删除，退出循环
                            transaction.Commit();
                            break;
                        }
                    }
                    transaction.Commit();
                    Console.WriteLine("Batch deleted successfully.");
                } catch (Exception ex) {
                    Console.WriteLine("Batch Delete Exception Type: {0}", ex.GetType());
                    Console.WriteLine(" Message: {0}", ex.Message);
                    try {
                        if (transaction.Connection != null) {
                            transaction.Rollback();
                        }
                    } catch (Exception ex2) {
                        Console.WriteLine("Rollback Exception Type: {0}", ex2.GetType());
                        Console.WriteLine(" Message: {0}", ex2.Message);
                        throw;
                    }
                    throw;
                }
            }
            // 可选：批次之间加短暂延迟，避免过度占用数据库资源
            Thread.Sleep(500);
        }
        Console.WriteLine("All old profiling records have been deleted.");
    }
}

额外建议 #

• 检查Azure SQL的事务日志空间：大量删除操作会快速增长事务日志，如果日志空间不足，也可能导致事务提前终止。可以考虑在删除前切换到简单恢复模式（如果业务允许），或者定期备份日志。
• 给profiling.MiniProfilers.Started和profiling.MiniProfilerTimings.MiniProfilerId建立合适的索引，提升删除操作的查询效率，减少事务执行时间。

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