如何等待 SQL Server 数据库回滚完成？

Question

使用 ADO.NET SqlClient 类时，有几种方法可以回滚事务。通过显式调用SqlTransaction.Rollback，或具有命令超时，或事务范围内的事务超时等。

但是，在使用 SQL Server（2012 或更高版本）时，如何检测此回滚何时完成？对于长时间运行的事务，回滚可能需要很长时间，并且通常在数据库上相当 IO 密集，因此立即重试事务可能不明智。在我们的情况下，我们希望等待回滚完成。

（在我们的特定情况下，由于使用 TransactionScope 类的事务超时而发生回滚，但我更喜欢适用于任何类型回滚的方法）。

我看过sys.dm_exec_requests，起初看起来很有希望。它最初的命令类型为KILL/ROLLBACK，并报告了进度百分比。 （如果我从原始事务中捕获 SPID，我将能够轮询该表并等待它完成）。然而，大约在进行到一半时，我注意到它改为AWAITING COMMAND（而回滚仍在执行中）。

我还看了KILL <SPID> WITH STATUSONLY。如果没有正在进行的回滚，这似乎会产生错误，因此它也可以用于轮询方法，但我注意到如果我从 SSMS 运行 BEGIN TRAN ... ROLLBACK TRAN 批处理，则会报告一个错误，指出没有回滚回滚时的进度。在这种情况下，dm_exec_requests 表将 ROLLBACK TRANSACTION 报告为命令类型。

那么如何才能以可靠的方式等待回滚完成呢？

Answer 1

您可以查看基于spid 的sp_who 的交易活动。 status 列将告诉您当前的事务状态并从 rollback 更改或在完成时消失。

如果您想获得有关 .NET 的反馈，请使用 SqlChangeMonitor(example) 缓存您的结果并等待您的 SqlChangeMonitor 通知来自 rollback 的更改。

---

如果您解决了超时问题，您可以查看：

使用 IsolationLevel.ReadCommitted。这样，您的 .NET 代码将等待您的 Commit 或 Rollback 完成。

（它看起来像 cmd.Connection.BeginTransaction(IsolationLevel.ReadCommitted) 和 cmd 类型为 SqlCommand ）

Answer 2

SqlRollback.cs 

using System;
using System.Data.SqlClient;
using System.Threading;

namespace Events
{
    public class SqlRollback
    {
        private string _connString = "Server=(localdb)\\mssqllocaldb;Database=QueryIt.EmployeeDb;Trusted_Connection=true";
        public event EventHandler TransactionRolledBack;

        public void Transact()
        {
            using (SqlConnection conn = new SqlConnection(_connString))
            {
                conn.Open();

                var command = conn.CreateCommand();
                SqlTransaction transaction;
                transaction = conn.BeginTransaction("Transaction");

                command.Connection = conn;
                command.Transaction = transaction;

                try
                {
                    transaction.Save("checkpoint");
                    command.CommandText = "INSERT INTO Employees (name, discriminator) VALUES ('Dimitar', 'Bastun')";
                    command.ExecuteNonQuery();
                    throw new Exception();

                } catch (Exception ex)
                {
                    transaction.Rollback("checkpoint"); //Rolling back to the checkpoint
                    Thread.Sleep(5000); //Simulating some time
                    transaction.Commit();
                    this.OnTransactionRollingBack(EventArgs.Empty);
                }
            }
        }

        private void OnTransactionRollingBack(EventArgs e)
        {
            EventHandler handler = TransactionRolledBack;
            if(handler != null)
            {
                handler(this, EventArgs.Empty);
            }
        }
    }
}

Program.cs

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

namespace Events
{
    class Program
    {
        static void Main(string[] args)
        {
            var rollBack = new SqlRollback();
            rollBack.TransactionRolledBack += RollBack_TransactionRolledBack;

            try
            {
                rollBack.Transact();
            } catch (Exception e)
            {

            }
        }

        private static void RollBack_TransactionRolledBack(object sender, EventArgs e)
        {
            Console.WriteLine("Rooled!");
        }
    }
}