TransactionScope() 和并行查询执行

Answer 1

是否可以在事务范围内执行并行查询，如果可以，正确的方法是什么？

是的。您必须为每个查询使用单独的 SqlConnection，并正确配置和运行 MSDTC。但这样做很少有用，因为每个命令都可以在 SQL Server 上并行运行，因此同时运行多个命令通常不会减少整体运行时间。

Answer 2

我认为最好在数据库中创建运行所有查询的过程。 然后您可以使用数据集在一个请求中获取它。 现在在数据集中使用每个数据表。

Answer 3

您可以尝试几个选项：

1. 启用 MARS 后，使用 TransactionScopeAsyncFlowOption.Enabled 参数创建事务范围：

   using(var tran = new TransactionScope(TransactionScopeAsyncFlowOption.Enabled)
   {...
   

   我使用带有 dapper 的 System.Data.SqlClient.SqlConnection 来读取/写入数据并且它有效。

   2. 如果您使用的是 Entity Framework Core，您可以使用 SemaphoreSlim 同步访问您的 DbContext 以避免此问题。例子：

   // declare semaphore
   var syncSemaphore = new SemaphoreSlim(1);
   // [...]
   // and use it in all your async functions like this:
   async Task queryMethod1Async()
   {
       await syncSemaphore.WaitAsync();
       try
       {
          // Use your database connection - read or write and release semaphore so other tasks can access
       }
       finally
       {
           syncSemaphore.Release();
       }            
   }
   

Answer 4

您的任何queryMethodXAsync 是否会产生它自己的事务（作为嵌套事务）并且在您尝试完成TransactionScope 之前不会回滚或提交它

如果您调用在其中使用事务并且没有以正确方式处理它的存储过程，则可能会发生类似的事情。

您的异常中有更多详细信息的 InnerExcpetion 吗？

Answer 5

你解决了这个问题吗？我也有同样的情况，还没有找到合适的解决方案。我的情况类似：

我有 -

           using (var transaction = new TransactionScope(TransactionScopeAsyncFlowOption.Enabled))
           {
               var task1 = _repository1.SaveAsync(dto);
               var task2 = _repository2.SaveAsync(dto1, false);

               await Task.WhenAll(task1 , task2).ConfigureAwait(false);

               transaction.Complete();
           }

有时它会失败：

   System.Data.SqlClient.SqlException: Current Microsoft Distributed    Transaction Coordinator (MS DTC) transaction must be committed by remote client.

MSDTC 配置正确，并且为 MSDTC 和 RPC 配置了防火墙

有什么建议吗？