是否可以使用 TransactionScope 回滚已提交的数据？

Question

目标很简单——回滚单元测试插入的数据。这是怎么回事。在单元测试中，会调用一个创建新连接并插入一些数据的方法。之后，单元测试会创建一个新连接并尝试查找已插入的内容并对其进行断言。我希望用TransactionScope 包装这两件事，而不是调用Complete 并查看插入的数据回滚。那没有发生。是我做错了什么还是我没抓住重点？

using (new TransactionScope())
{
    // call a method that inserts data
    var target = new ....
    target.DoStuffAndEndupWithDataInDb();

    // Now assert what has been added.
    using (var conn = new SqlConnection(connectionString))
    using (var cmd = conn.CreateCommand())
    {
        // Just read the data from DB
        cmd.CommandText = "SELECT...";
        conn.Open();
        int count = 0;
        using (var rdr = cmd.ExecuteReader())
        {
            // Read records here
            ...
            count++;
        }

        // Expecting, say, 3 records here
        Assert.AreEqual(3, count);
    }
}

编辑：我认为我的机器上没有运行和配置 DTC。所以我启动了服务并尝试配置 DTC，但我收到了这个错误。

Answer 1

您在使用 MSTest 吗？那么你可以使用MsTestExtensions 你的单元测试需要从MSTestExtensionsTestFixture派生，你的测试需要有TestTransaction的属性，它使用AOP自动启动事务并回滚。

Answer 2

我认为您没有错过重点，只是错误地解决了问题。

在 NUnit 术语中，概念是 [SetUp] 和 [TearDown] 方法。您已经在描述中定义了 setup 方法，并且您的 tear down 方法应该只是撤消 setup 方法所做的事情（假设您正在单元测试的内容没有残留的副作用）。

Answer 3

您是否正确配置了分布式事务协调器？当尝试像这样使用TransactionScope 时，这是一个很大的问题...如果未配置，有时您会收到错误，但其他时候事务只会提交而不是回滚。

I'd recommend looking at this article，它向您展示了使用 MSDTC 回滚单元测试所需完成的所有不同步骤。

Answer 4

您的代码应该可以按预期工作。您如何在DoStuffAndEndupWithDataInDb() 中添加数据？我想知道数据初始化是否没有参与事务。

作为参考，以下控制台应用程序正确输出3 rows，并且不会将行提交到数据库（使用 SSMS 检查）。

public class Program
{
    private static void Main(string[] args)
    {
        using (var trx = new TransactionScope())
        {
            InitializeData();

            using (var connection = new SqlConnection("server=localhost;database=Test;integrated security=true"))
            using (var command = connection.CreateCommand())
            {
                command.CommandText = "select count(*) from MyTable";
                connection.Open();
                Console.WriteLine("{0} rows", command.ExecuteScalar());
            }
        }
        Console.ReadLine();
    }

    private static void InitializeData()
    {
        using (var connection = new SqlConnection("server=localhost;database=Test;integrated security=true"))
        using (var command = connection.CreateCommand())
        {
            command.CommandText = "insert into MyTable values (1),(2),(3)";
            connection.Open();
            command.ExecuteNonQuery();
        }
    }
}