TransactionScope与MySQL和分布式事务

Question

我有一个ASP.Net WebAPI实例安装程序，它使用MySQL数据库进行存储。我编写了一个ActionFilter，它处理为单个端点请求的生命周期创建一个TransactionScope。

public async Task<HttpResponseMessage> ExecuteActionFilterAsync(
    HttpActionContext actionContext,
    CancellationToken cancellationToken,
    Func<Task<HttpResponseMessage>> continuation)
{
    var transactionScopeOptions = new TransactionOptions { IsolationLevel = IsolationLevel.ReadUncommitted };
    using (var transaction = new TransactionScope(TransactionScopeOption.RequiresNew, transactionScopeOptions, TransactionScopeAsyncFlowOption.Enabled))
    {
        var handledTask = await continuation();

        transaction.Complete();

        return handledTask;
    }
}

然后，在整个端点中，我有不同的查询/命令，这些查询/命令使用autoenlist=true的DbConnection功能打开/关闭连接。

public async Task<IHttpActionResult> CreateStuffAsync()
{
    var query = this.queryService.RetrieveAsync();

    // logic to do stuff

    var update = this.updateService.Update(query);

    return this.Ok();
}

我不创建一个DbConnection并从顶部传递它，因为这是一个简单的例子，在实践中传递服务之间的连接需要一个大的重构(尽管如果必要的话，这是可以做到的)。我还读到，最好在必要时打开/关闭连接(即尽可能少地打开它们)。queryService和updateService通过using语句打开/关闭DbConnection：

var factory = DbProviderFactories.GetFactory("MySql.Data.MySqlClient");
using (var connection = factory.CreateConnection())
{
    connection.ConnectionString = "Data Source=localhost;Initial Catalog=MyDatabase;User ID=user;Password=password;Connect Timeout=300;AutoEnlist=true;";

    if (connection.State != ConnectionState.Open)
    {
        connection.Open();
    }

    var result = await connection.QueryAsync(Sql).ConfigureAwait(false);

    return result;
}

相同的DbConnection通常不用于同一个API端点请求中的多个查询--但相同的连接字符串是。

在尝试打开连接时，间歇地看到一个异常：

"ExceptionType": "System.NotSupportedException",
"ExceptionMessage": "System.NotSupportedException: MySQL Connector/Net does not currently support distributed transactions.\r\n   at MySql.Data.MySqlClient.ExceptionInterceptor.Throw(Exception exception)\r\n   at MySql.Data.MySqlClient.MySqlConnection.EnlistTransaction(Transaction transaction)\r\n   at MySql.Data.MySqlClient.MySqlConnection.Open()"

当所有连接都针对同一个数据库时，我不明白为什么它试图将事务升级到分布式事务。还是我误解/误用了TransactionScope和DbConnection实例？

Answer 1

System.Transactions.Transaction对象根据事务中有多少单独的“资源管理器”(例如，数据库)来确定是否升级到分布式事务。

它没有区分到不同物理数据库的连接(它们确实需要分布式事务)和多个MySqlConnection连接，它们具有相同的连接字符串并连接到同一个数据库(可能不是这样)。(很难确定两个单独的“资源管理器”1代表相同的物理DB，2是按顺序使用，而不是并行使用)。因此，当多个MySqlConnection对象在事务中登记时，它总是升级为分布式事务。

当发生这种情况时，您会遇到MySQL bug #70587，在Connector/NET中不支持分布式事务。

解决办法是：

1. 确保在任何MySqlConnection中只打开一个TransactionScope对象。
2. 更改为支持分布式事务的独立连接器。您可以使用MySqlConnector (NuGet，GitHub)代替连接器/网。我听说dotConnect for MySQL也支持他们(但还没试过)。