TransactionScope 不使用 SqlDataAdapter.Update 回滚

Question

我使用 SqlDataAdapter.Update 和 DataTables 在单个事务中更新两个 SQL 表。如果任一插入失败，我想回滚所有数据。这是我的代码：

using (var conn = new SqlConnection(_connectionString))
{
    conn.Open();

    using (var scope = new TransactionScope())
    {
        // Insert first table
        using (var command = conn.CreateCommand())
        {
            command.CommandText =
                @"INSERT INTO TableA(Id, Data)
                  VALUES(@id, @data)";

            command.CommandType = CommandType.Text;
            command.Parameters.Add(new SqlParameter("@id", SqlDbType.Int) { SourceColumn = "Id" });
            command.Parameters.Add(new SqlParameter("@data", SqlDbType.Char) { SourceColumn = "Data" });

            var adapter = new SqlDataAdapter();
            adapter.InsertCommand = command;
            adapter.Update(tableADataTable);
        }

        // Insert second table
        using (var command = conn.CreateCommand())
        {
            command.CommandText =
                @"INSERT INTO TableB(Id, Data)
                  VALUES(@id, @data)";

            command.CommandType = CommandType.Text;
            command.Parameters.Add(new SqlParameter("@id", SqlDbType.Int) { SourceColumn = "Id" });
            command.Parameters.Add(new SqlParameter("@data", SqlDbType.Char) { SourceColumn = "Data" });

            var adapter = new SqlDataAdapter();
            adapter.InsertCommand = command;
            adapter.Update(tableBDataTable);
        }

        scope.Complete();
    }
}

我遇到的问题是，如果在第二个命令执行期间引发异常，则仍然会提交第一个命令中的数据。我需要明确回滚吗？或者使用 SqlDataAdapter.Update 时 TransactionScope 应该如何表现？

需要注意的是，最初我在 TransactionScope using 语句中创建了 SqlConnection，但我将其移出，因为我收到错误消息，表明我的数据库服务器尚未针对分布式事务进行正确配置。我的 SqlConnection 创建超出 TransactionScope 的事实是否相关？

Answer 1

我认为您需要将 conn.Open() 调用移至事务范围内，以便它将自己纳入事务中。另外，请确保连接字符串中没有 enslist=false;。

Answer 2

尝试将 SqlConnection 放入 TransactionScope 中，然后它应该会自动加入事务。

我认为在您的代码中，您需要手动将连接登记到事务中...查看这些链接中的示例。

http:// /msdn.microsoft.com/en-us/library/system.data.sqlclient.sqlconnection.enlistdistributedtransaction(v=VS.71).aspx

http://msdn.microsoft.com/en-us/library/system.transactions.transactionscope.aspx

抱歉抓住了你的OP - 也许是因为连接没有配置为自动加入现有事务（我认为是连接字符串的成员）。

如果您不调用 Complete（或 SqlTransaction 上的 Commit），它将自动回滚。

当然，在当前的代码示例中 - 您可以安全地使用 SqlTransaction 对象，因为您不涉及多个连接/数据库。

Answer 3

尝试插入这段代码

command.CommandText = @"SET autocommit = 0";
command.ExecuteNonQuery();

command.CommandText = @"SET sql_mode=TRADITIONAL";
command.ExecuteNonQuery();