错误 - 与当前连接关联的事务已完成但尚未处理

Question

我在使用TransactionScope 将多个数据库查询包装到一个事务中时遇到了问题，我正在使用批处理大小为 500 的 SqlBulkCopy。当我将批处理大小增加到 1000 时，我收到了错误：

与当前连接相关的事务已经完成 但尚未处置。交易必须在 连接可用于执行 SQL 语句。

这是我正在使用的代码：

using (var scope = new TransactionScope())
{
    using (var connection = (SqlConnection)customerTable.OpenConnection())
    {
        var table1BulkCopy = new SqlBulkCopy(connection)
        {
            BatchSize = BATCH_SIZE,
            DestinationTableName = TableName1
        };

        table1BulkCopy.WriteToServer(table1DataTable);

        var table2BulkCopy = new SqlBulkCopy(connection)
        {
            BatchSize = BATCH_SIZE,
            DestinationTableName = TableName2
        };

        table2BulkCopy.WriteToServer(table2DataTable);

        var table3BulkCopy = new SqlBulkCopy(connection)
        {
            BatchSize = BATCH_SIZE,
            DestinationTableName = TableName3
        };

        table1BulkCopy.WriteToServer(table3DataTable);

        var table4BulkCopy = new SqlBulkCopy(connection)
        {
            BatchSize = BATCH_SIZE,
            DestinationTableName = TableName4
        };

        table4BulkCopy.WriteToServer(table4DataTable);

        scope.Complete();
    }
}

Answer 1

这可能在事务超时时发生。您可以像这样增加事务的超时时间（使用适合预期事务长度的值）。下面的代码是15分钟：

using (TransactionScope scope = 
             new TransactionScope(TransactionScopeOption.Required, 
                                   new System.TimeSpan(0, 15, 0)))
  {
      // working code here
  }

这就是为什么它适用于 500 而不是 1000 的原因。

Answer 2

我发现在 TransactionScope 中设置超时对我不起作用。我还需要将以下配置键添加到 end of machine.config <configuration> 标记以延长默认的最大超时 10 分钟。

<system.transactions>
    <machineSettings maxTimeout="00:30:00" /> <!-- 30 minutes -->
</system.transactions>

信用： http://thecodesaysitall.blogspot.com.au/2012/04/long-running-systemtransactions.html

Answer 3

将scope.Complete(); 移出connection 块。

using (var scope = new TransactionScope())
{
  using (var connection = (SqlConnection)customerTable.OpenConnection())
   {
    //
   }
  scope.Complete();
}

Answer 4

超时问题很明显，但是如果将 TransactionOptions.Timeout 设置得更高，则不会生效。 即使您设置了 TimeSpan.MaxValue，您实际上也不会获得利润。将 TransactionOptions 的 Timeout 属性设置为更高的值无关紧要，TransactionOptions.Timeout 不能超过 maxTimeout 属性。 您应该在 ma​​chine.config 中进行一些更改。

很快你就会找到 machine.config 文件 %windir%\Microsoft.NET\Framework\你的版本\config\machine.config
并将其添加到<configuration> 标签中：

<system.transactions>
    <machineSettings maxTimeout="00:30:00"/>
</system.transactions>

您可以在此处将 maxTimeout 属性设置为 30 分钟。
更多详情请看以下http://thecodesaysitall.blogspot.com/2012/04/long-running-systemtransactions.html

Answer 5

完整的答案必须更完整。

您必须在 .Net 代码或服务器配置中指定 - 在哪里确定最大事务超时时间

<sectionGroup name="system.transactions".... 
    ...allowDefinition="MachineOnly"
</sectionGroup>

在这种情况下，您可以在 machine.config 中设置最大超时时间

<configuration>
 <system.transactions>
 <machineSettings maxTimeout="01:00:00" />
 </system.transactions>
</configuration> 

或者您可能想在应用程序中覆盖此行为。然后 在 machine.config 你应该设置属性 velue:

...allowDefinition="MachineToApplication"

这是一篇好文章：https://blogs.msdn.microsoft.com/ajit/2008/06/18/override-the-system-transactions-default-timeout-of-10-minutes-in-the-code/

Answer 6

应用这个：

TransactionScope(TransactionScopeOption.Required, new System.TimeSpan(0, 30, 0));
(0, 30, 0) = (hour,minute,seconds)

如果你想测试，用这个 (0, 0, 1) 应用时间跨度，试试你会得到错误。之后，增加秒或分钟或小时并尝试。它会起作用的。

Answer 7

C# 9 朗版本。 TransactionScopeOption.Suppress 对我来说就像魔术一样。

// TransactionScopeOption.Suppress works and fixed my issue
using TransactionScope Scope = new TransactionScope(TransactionScopeOption.Suppress);
try
{
    using var CentralConnection = SQLConnection("Other connection string here");
    using var LocalConnection = SQLConnection("Other connection string here");

    // Central
    using var cmd0 = new SqlCommand("OtherSQLCommandTextHere", CentralConnection)
    {
         CommandTimeout = 0 // I just add zero timeout here
    };
    cmd0.ExecuteNonQuery();

    // Local
    using var cmd1 = new SqlCommand("OtherSQLCommandTextHere", LocalConnection)
    {
         CommandTimeout = 0 // I just add zero timeout here
    };
    cmd1.ExecuteNonQuery();

    // The Complete method commits the transaction. If an exception has been thrown,
    // Complete is not called and the transaction is rolled back.
    Scope.Complete();
}
catch (Exception ex)
{
    Scope.Dispose();
    MessageBox.Show(ex.ToString());
}

public SqlConnection SQLConnection(string ISQLConnection)
{
     SqlConnection conn = null;
     try
     {
         conn = new SqlConnection(ISQLConnection);
         conn.Open();            
     }
     catch 
     {
         // skipping here error message
     }
     return conn;
 }