TransactionScope 是否适用于预先存在的连接？

Question

我有这样的代码：

try
{
    using (TransactionScope scope = new TransactionScope())
    {
        some_db_function();

        for (i = 0; i < 10; i++)
        {
            some_other_db_function();
        }

        scope.Complete();
    }
}
catch (Exception ex)
{
   MessageBox.Show(ex.Message + " all done transactions will rollback");   
}

在 db 函数内部会发生这样的事情：

private void some_db_functions()
{
    using (TransactionScope scope = new TransactionScope())
    {
       //some processing on db
       scope.Complete();
    }
}

应该是数据库事务出现问题，比如函数插入或更新出错；到目前为止已完成的所有事务都会回滚。但它不是那样工作的；尽管它抛出了一个异常并且父函数中的scope.Complete() 永远不会被触发，但仍然没有回滚。

问题出在哪里？

Answer 1

如果打开的连接已经存在，它将不会自动加入环境事务。您必须明确设置它。

不支持隐式登记连接。入伍 事务范围，您可以执行以下操作：

在事务范围内打开一个连接。

或者，如果连接已经打开，调用 EnlistTransaction 方法 在连接对象上。

Ref.

这将征用一个现有的连接：

connection.EnlistTransaction(Transaction.Current)

Answer 2

IIRC，在连接创建/打开时自动加入环境事务；如果您在事务范围内创建连接，一切都应该是好的。然而：

它们都使用相同的连接，之前声明过

如果连接存在于事务之外，则不会加入。

最佳做法是仅围绕一个工作单元创建/打开连接，而不是永远创建/打开连接（并且：让连接池完成其工作）。如果您遵循这种做法，它应该可以正常工作。所以：

这行不通：

using(var conn = CreateAndOpenConnection()) {
    // ...
    using(var tran = new TransactionScope()) {
        SomeOperations(conn);
        tran.Complete();
    }
    // ...
}

应该在哪里工作：

using(var tran = new TransactionScope()) {
    // ...
    using(var conn = CreateAndOpenConnection()) {
        SomeOperations(conn);
    }
    tran.Complete();
    // ...
}