c# - 使用 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;
    }
}

编辑:因此，如果答案是在嵌套在事务范围内时重用相同的连接，就像上面的代码所做的那样，我想知道在事务中处理此连接的含义。

据我所知(使用 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;
    }
}

仍然会看重一个不那么骇人听闻的解决方案 :)

Answer 1

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

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