使用 transactionscope 时阻止事务升级为分布式的推荐实践

Question

使用 TransactionScope 对象来设置不需要跨函数调用传递的隐式事务非常棒！但是，如果一个连接在另一个连接已打开的情况下打开，则事务协调器会默默地升级要分发的事务（需要运行 MSDTC 服务并占用更多的资源和时间）。

所以，这很好：

        using (var ts = new TransactionScope())
        {
            using (var c = DatabaseManager.GetOpenConnection())
            {
                // Do Work
            }
            using (var c = DatabaseManager.GetOpenConnection())
            {
                // Do more work in same transaction using different connection
            }
            ts.Complete();
        }

但这会升级​​事务：

        using (var ts = new TransactionScope())
        {
            using (var c = DatabaseManager.GetOpenConnection())
            {
                // Do Work
                using (var nestedConnection = DatabaseManager.GetOpenConnection())
                {
                    // Do more work in same transaction using different nested connection - escalated transaction to distributed
                }
            }
            ts.Complete();
        }

是否有推荐的做法来避免以这种方式升级事务，同时仍然使用嵌套连接？

我目前能想到的最好办法是拥有一个 ThreadStatic 连接并在设置了 Transaction.Current 的情况下重用该连接，如下所示：

public static class DatabaseManager
{
    private const string _connectionString = "data source=.\\sql2008; initial catalog=test; integrated security=true";

    [ThreadStatic]
    private static SqlConnection _transactionConnection;

    [ThreadStatic] private static int _connectionNesting;

    private static SqlConnection GetTransactionConnection()
    {
        if (_transactionConnection == null)
        {
            Transaction.Current.TransactionCompleted += ((s, e) =>
            {
                _connectionNesting = 0;
                if (_transactionConnection != null)
                {
                    _transactionConnection.Dispose();
                    _transactionConnection = null;
                }
            });

            _transactionConnection = new SqlConnection(_connectionString);
            _transactionConnection.Disposed += ((s, e) =>
            {
                if (Transaction.Current != null)
                {
                    _connectionNesting--;
                    if (_connectionNesting > 0)
                    {
                        // Since connection is nested and same as parent, need to keep it open as parent is not expecting it to be closed!
                        _transactionConnection.ConnectionString = _connectionString;
                        _transactionConnection.Open();
                    }
                    else
                    {
                        // Can forget transaction connection and spin up a new one next time one's asked for inside this transaction
                        _transactionConnection = null;
                    }
                }
            });
        }
        return _transactionConnection;
    }

    public static SqlConnection GetOpenConnection()
    {
        SqlConnection connection;
        if (Transaction.Current != null)
        {
            connection = GetTransactionConnection();
            _connectionNesting++;
        }
        else
        {
            connection = new SqlConnection(_connectionString);
        }
        if (connection.State != ConnectionState.Open)
        {
            connection.Open();
        }
        return connection;
    }
}

编辑：因此，如果答案是在嵌套在 transactionscope 内时重用相同的连接，如上面的代码确实如此，我想知道在事务中处理此连接的含义。

据我所知（使用 Reflector 检查代码），连接的设置（连接字符串等）已重置并且连接已关闭。因此（理论上），重新设置连接字符串并在后续调用中打开连接应该“重用”连接并防止升级（我的初始测试也同意这一点）。

不过，这看起来确实有点老套……而且我确信一定有一个最佳实践，规定人们在处理掉一个对象后不应该继续使用它！

但是，由于我无法对密封的 SqlConnection 进行子类化，并且希望维护与事务无关的连接池友好方法，因此我很难（但很高兴）找到更好的方法。

另外，意识到如果应用程序代码尝试打开嵌套连接（在我们的代码库中，在大多数情况下是不必要的），我可以通过抛出异常来强制非嵌套连接

public static class DatabaseManager
{
    private const string _connectionString = "data source=.\\sql2008; initial catalog=test; integrated security=true; enlist=true;Application Name='jimmy'";

    [ThreadStatic]
    private static bool _transactionHooked;
    [ThreadStatic]
    private static bool _openConnection;

    public static SqlConnection GetOpenConnection()
    {
        var connection = new SqlConnection(_connectionString);
        if (Transaction.Current != null)
        {
            if (_openConnection)
            {
                throw new ApplicationException("Nested connections in transaction not allowed");
            }

            _openConnection = true;
            connection.Disposed += ((s, e) => _openConnection = false);

            if (!_transactionHooked)
            {
                Transaction.Current.TransactionCompleted += ((s, e) =>
                {
                    _openConnection = false;
                    _transactionHooked = false;
                });
                _transactionHooked = true;
            }
        }
        connection.Open();
        return connection;
    }
}

仍然会重视一个不那么hacky的解决方案:)

Answer 1

事务升级的主要原因之一是事务中涉及多个（不同的）连接。这几乎总是升级为分布式事务。这确实是一种痛苦。

这就是为什么我们确保所有事务都使用单个连接对象。有几种方法可以做到这一点。大多数情况下，我们使用线程静态对象来存储连接对象，而执行数据库持久化工作的类则使用线程静态连接对象（当然这是共享的）。这可以防止使用多个连接对象并消除事务升级。您还可以通过简单地将连接对象从一个方法传递到另一个方法来实现此目的，但这并不那么干净，IMO。