环境事务中的 TransactionScope 错误不会回滚事务

Question

我使用这样的环境事务：

---

using(TransactionScope tran = new TransactionScope()) {
    CallAMethod1();//INSERT
    CallAMethod2();//INSERT
    tran.Complete();
}

方法CallAMethod2(); 返回affected rows =-264 所以它无法插入，但是第一个插入已经提交！

我想知道如何使用ambient transaction，如果第二种方法有多个需要内部事务的操作，我应该将这些操作放在内部事务中吗？ 像这样：

     DAL_Helper.Begin_Transaction();

              //------Fill newKeysDictioanry

                affectedRow = DBUtilities.InsertEntityWithTrans("table2", newKeysDictioanry, DAL_Helper);

                if (affectedRow == 1)
                {
                    if (!string.IsNullOrEmpty(sp_confirm))
                    {
                        result_dt = UserTransactionDAL.Run_PostConfirm_SP(sp_PostConfirm, OBJ.ValuesKey, DAL_Helper);
                        if (result_dt.Rows.Count > 0 && result_dt.Rows[0][0].ToString() == "0")
                        {
                            DAL_Helper.current_trans.Commit();

                            if (DAL_Helper.connectionState == ConnectionState.Open)
                            {
                                DAL_Helper.Close_Connection();
                            }
                            return 1;// affectedRow;
                        }
                        else
                        {
                            DAL_Helper.current_trans.Rollback();
                            if (DAL_Helper.connectionState == ConnectionState.Open)
                            {
                                DAL_Helper.Close_Connection();
                            }
                            return -2; 
                        }
                    }
//etc

Answer 1

1) 需要检查tran.Complete();是否被调用。如果调用tran.Complete();，则认为TransactionScope 已成功完成。

来自MSDN

当您的应用程序完成它想要在一个 交易，你应该只调用一次 Complete 方法来通知 该事务管理器可以接受提交 交易。未能调用此方法会中止事务。

调用tran.Complete();是通知事务管理器完成事务。实际上，事务管理器不会跟踪您的 Db 适配器，也不知道连接中的操作是成功还是失败。您的应用程序必须通过调用 Complete

来告知它

How does TransactionScope roll back transactions?

要使您的交易失败，只需确保您没有在代码中调用tran.Complete();：

如果事务范围内没有发生异常（即在 TransactionScope 对象的初始化和调用 它的 Dispose 方法），然后是作用域所在的事务 允许继续进行。如果异常确实发生在 事务范围，其参与的事务将 被回滚。

在您的情况下，如果您认为操作失败，也许您可​​以在 CallAMethod2(); 中抛出异常，因此 不 调用 tran.Complete(); 并回滚事务。

2) 您可以检查的第二件事是您的连接是否在事务中登记。如果未登记连接，则 TransactionScope 不会回滚。可能的问题是：

• 如果连接在进入事务作用域之前已经存在，则不入队：Does TransactionScope work with pre-existing connections?
• 您的基础连接不支持自动登记。

在这些情况下，您可以尝试手动注册您的连接（从上面的链接中提取）：

connection.EnlistTransaction(Transaction.Current)

关于你的第二个问题：

如果第二种方法有多个需要内部的操作怎么办？ 事务，我应该把这些动作放在内部事务中吗？

我想说这真的取决于您是否将CallAMethod2(); 视为自动 操作，这意味着您可以直接在其他地方调用它，而无需将其包装在事务中。大多数情况下，创建内部事务是有意义的，因为事务可以嵌套。在您的情况下，建议在您的CallAMethod2(); 中也使用 TransactionScope，我们在创建新的事务范围时有一些选项：

TransactionScope 类提供了几个重载的构造函数 接受 TransactionScopeOption 类型的枚举，其中 定义范围的事务行为。事务范围 对象有三个选项：

加入环境事务，如果不存在则创建一个新事务。

成为一个新的根作用域，即开始一个新事务并让该事务成为它自己作用域内的新环境事务。

根本不参与交易。结果没有环境事务。

选择哪一个取决于您的应用程序。在你的情况下，我想你可以选择第一个选项。以下是来自MSDN的示例

void RootMethod()
{
     using(TransactionScope scope = new TransactionScope())
     {
          /* Perform transactional work here */
          SomeMethod();
          scope.Complete();
     }
}

void SomeMethod()
{
     using(TransactionScope scope = new TransactionScope())
     {
          /* Perform transactional work here */
          scope.Complete();
     }
}

Answer 2

您可以使用范围内和外的事务：

string connectionString = ConfigurationManager.ConnectionStrings["db"].ConnectionString;
var option = new TransactionOptions
{
     IsolationLevel = IsolationLevel.ReadCommitted,
     Timeout = TimeSpan.FromSeconds(60)
};
using (var scopeOuter = new TransactionScope(TransactionScopeOption.Required, option))
{
    using (var conn = new SqlConnection(connectionString))
    {
        using (SqlCommand cmd = conn.CreateCommand())
        {
            cmd.CommandText="INSERT INTO Data(Code, FirstName)VALUES('A-100','Mr.A')";
            cmd.Connection.Open();
            cmd.ExecuteNonQuery();
        }
    }
    using (var scopeInner = new TransactionScope(TransactionScopeOption.Required, option))
    {
        using (var conn = new SqlConnection(connectionString))
        {
            using (SqlCommand cmd = conn.CreateCommand())
            {
                cmd.CommandText="INSERT INTO Data(Code, FirstName) VALUES('B-100','Mr.B')";
                cmd.Connection.Open();
                cmd.ExecuteNonQuery();
            }
        }
        scopeInner.Complete();
    }
    scopeOuter.Complete();
}

Answer 3

阅读 Khanh TO 所说的内容。如果您的连接是在外部事务范围之外打开的，则连接不会被征用。

这就是为什么第二个调用失败时第一个调用没有回滚的原因。您必须注册您的连接：

using (TransactionScope tran = new TransactionScope(TransactionScopeOption.Required))
{
   connection.EnlistTransaction(Transaction.Current);
   CallAMethod1();//INSERT
   CallAMethod2();//INSERT
   tran.Complete();
}