使用事务执行 SqlCommand 时出现 InvalidOperationException

Question

我有这段代码，在两个单独的线程中并行运行。 有几次它工作正常，但在某个随机点它会抛出 InvalidOperationException：

事务要么与当前连接不关联，要么已完成。

在异常情况下，我正在使用 Visual Studio 查看事务内部并验证其连接是否设置正常。 还有command.Transaction._internalTransaction。 _transactionState 设置为 Active，IsZombied 属性设置为 false。

这是一个测试应用程序，我使用 Thread.Sleep 来创建更长的事务并导致重叠。

为什么会抛出异常以及我该怎么办？

IDbCommand command = new SqlCommand("Select * From INFO");
IDbConnection connection = new SqlConnection(connectionString);
command.Connection = connection;
IDbTransaction transaction = null;
try
{
    connection.Open();
    transaction = connection.BeginTransaction();
    command.Transaction = transaction;
    command.ExecuteNonQuery(); // Sometimes throws exception
    Thread.Sleep(forawhile); // For overlapping transactions running in parallel
    transaction.Commit();
}
catch (ApplicationException exception)
{
    if (transaction != null)
    {
        transaction.Rollback();
    }
}
finally
{
    connection.Close();
}

Answer 1

找到了解决方案。 事实证明，调用此方法

command.Connection = connection;

并不意味着您设置了与该命令的连接。 调用此函数后，我检查了结果

command.Connection.GetHashCode();
command.GetHashCode();

，发现它们不相等。 重构代码以使用connection.CreateCommand，问题得到解决。