单个 sqlconnection 中的多个 sqltransactions

Question

我有一些想要执行的代码，如下所示。但我在第二次迭代时不断收到异常“此 SqlTransaction 已完成；它不再可用”。有人可以帮我指出我在这里做错了什么吗？谢谢！

    SqlConnection cn = (SqlConnection)SqlConnectionManager.Instance.GetUserConnection(user);
 cn.Open();
 try
 {
    foreach (Master mRecord in masterList)
  {
   if (sqlTransaction == null)
       sqlTransaction = cn.BeginTransaction();
   SqlCommand cm = cn.CreateCommand();
   cm.Transaction = sqlTransaction;
   cm.CommandType = CommandType.StoredProcedure;
   cm.CommandText = "pr_InsertRecords";
       try
   {
    cm.ExecuteNonQuery();
    Debug.WriteLine("Auditor.Write: end sql table value param");
    sqlTransaction.Commit();
    sqlTransaction.Dispose();
   }
   catch (Exception Ex)
   {
    Debug.WriteLine(" Exception message: " + Ex.Message);
    if (Ex.InnerException != null)
    {
     Debug.WriteLine("Inner exception message" + Ex.InnerException.Message);
    }
    sqlTransaction.Rollback();
   }
  }
 }
 finally
 {
        cn.Close();
      }

Answer 1

在循环内，您可以提交或回滚，但不会将引用重置为 null。 SqlTransaction 通常不这样使用，而是在 using() 块中使用，就像 SqlConnection 一样：

using (SqlConnection cn = SqlConnectionManager.Instance.GetUserConnection(user)) 
{
  foreach (Master mRecord in masterList)
  {
  try
  {
    using (SqlTransaction sqlTransaction = cn.BeginTransaction()) 
    {
      using (SqlCommand cm = cn.CreateCommand()) 
      {
        cm.Transaction = sqlTransaction;
        cm.CommandType = CommandType.StoredProcedure;
        cm.CommandText = "pr_InsertRecords";
        cm.ExecuteNonQuery();
      }
      sqlTransaction.Commit();
      Debug.WriteLine("Auditor.Write: end sql table value param");
    }
  }
  catch (Exception Ex)
  {
    Debug.WriteLine(" Exception message: " + Ex.Message);
  }
}

Answer 2

尝试在处置后将 sqlTransaction 对象设置为 null。旁注，您确实应该将这些 IDisposable 对象包装在 using 块中，以便始终调用 Dispose。

sqlTransaction.Commit();
sqlTransaction.Dispose();
sqlTransaction = null;

Answer 3

您需要在每次迭代时创建一个新的 SqlTransaction 对象，或者如果您希望循环内的所有操作都在单个事务中发生，则需要将事务完全移出循环。提交事务后，需要在连接上再次调用 BeginTransaction 以启动新事务。您无法重用旧的事务对象。