如何在 (C#) ASP.NET 和 SQL Server 中回滚多个事务

Question

我有更多事务要插入到 sql server。 我的交易有一个标题和行详细信息，我的数据是这样的

[
  {

    "orderH_List": {
      "NetAmt": 10512.0,
      "DocType": "PO",
      "DocID": "PO0001900088"

    },

    "orderD_List": [
      {

        "Uom": "EA",
        "Qty": 50,
        "LineID": 1,
        "ItemCode": "1010035",
        "DocID": "PO0001900088"

      },
      {

        "Uom": "EA",
        "Qty": 42,
        "LineID": 2,
        "ItemCode": "1010034",
        "DocID": "PO0001900088"

      } 
    ]
},
{

    "orderH_List": {

      "NetAmt": 10512.0,
      "DocType": "PO",
      "DocID": "PO0001900089"

    },
    "orderD_List": [
      {

        "Uom": "EA",
        "Qty": 42,
        "LineID": 1,
        "ItemCode": "1010034",
        "DocID": "PO0001900089"

      },
      {

        "Uom": "EA",
        "Qty": 22,
        "LineID": 2,
        "ItemCode": "1010035",
        "DocID": "PO0001900089"

      } 
    ]
  } 
]

然后，如果某行数据​​为假，我想将所有交易排回。

我尝试回滚数据，但如果我调用 DB.Commit()，我将无法执行我的查询 行详细信息执行后。但是如果我在 head 执行它的工作之后调用 DB.commit() 。

            for (var x = 0; x < All_Order.Count; x++) {

                JObject OrderHead = (JObject)(All_Order[x]["orderH_List"]);  
                JArray OrderLine = (JArray)(All_Order[x]["orderD_List"]);  

                String connectionString = @"Data Source =xxxxxxx; Integrated Security=false;Persist Security Info=true; User ID=xxxxx; Password=xxxxxx; Initial Catalog=xxxxxx";
                SqlConnection myConnection = new SqlConnection(connectionString);
                myConnection.Open();
                System.Diagnostics.Debug.WriteLine("myConnection : " + myConnection );
                SqlTransaction Trans;
                Trans = myConnection.BeginTransaction(IsolationLevel.ReadCommitted);

                string query2 = "INSERT INTO SF_OrderH ( DocType,DocID,RefDocNo,DocDate,SentDT,BillDT,CusRecDT,BillRetDT,ShipTo,Remark1,Remark2,Status,NetAmt,CreateDT,TransferDT)";
                query2 += "VALUES   ( @DocType, @DocID, @RefDocNo, @DocDate, @SentDT, @BillDT, @CusRecDT, @BillRetDT, @ShipTo, @Remark1, @Remark2, @Status, @NetAmt, @CreateDT, @TransferDT)";
                SqlCommand myCommand2 = new SqlCommand();
                myCommand2.Connection = myConnection;
                myCommand2.Transaction = Trans;
                myCommand2.CommandText = query2;

                try
                {

                        myCommand2.Parameters.AddWithValue("@DocType", (string)OrderHead["DocType"] == null ? null : (string)OrderHead["DocType"]);
                        myCommand2.Parameters.AddWithValue("@DocID", (string)OrderHead["DocID"] == null ? null : (string)OrderHead["DocID"]);
                        myCommand2.Parameters.AddWithValue("@RefDocNo", (string)OrderHead["RefDocNo"] == null ? "" : (string)OrderHead["RefDocNo"]);
                        myCommand2.Parameters.AddWithValue("@DocDate", (string)OrderHead["DocDate"] == null ? null : (string)OrderHead["DocDate"]);
                        myCommand2.Parameters.AddWithValue("@SentDT", DateTime.Parse((string)OrderHead["SentDT"]));  
                        myCommand2.Parameters.AddWithValue("@BillDT", DateTime.Parse((string)OrderHead["BillDT"])); 
                        myCommand2.Parameters.AddWithValue("@CusRecDT", DateTime.Parse((string)OrderHead["CusRecDT"])); 
                        myCommand2.Parameters.AddWithValue("@BillRetDT", DateTime.Parse((string)OrderHead["BillRetDT"]));  
                        myCommand2.Parameters.AddWithValue("@ShipTo", (string)OrderHead["ShipTo"] == null ? null : (string)OrderHead["ShipTo"]);
                        myCommand2.Parameters.AddWithValue("@Remark1", (string)OrderHead["Remark1"] == null ? "" : (string)OrderHead["Remark1"]);
                        myCommand2.Parameters.AddWithValue("@Remark2", (string)OrderHead["Remark2"] == null ? "" : (string)OrderHead["Remark2"]);
                        myCommand2.Parameters.AddWithValue("@Status", (string)OrderHead["Status"] == null ? "" : (string)OrderHead["Status"]);
                        myCommand2.Parameters.AddWithValue("@NetAmt", (double)OrderHead["NetAmt"] == null ? 0 : (double)OrderHead["NetAmt"]);
                        myCommand2.Parameters.AddWithValue("@CreateDT", DateTime.Now);
                        myCommand2.Parameters.AddWithValue("@TransferDT", DateTime.Now);  
                        myCommand2.CommandType = CommandType.Text;
                        myCommand2.ExecuteNonQuery();
                        //Trans.Commit(); *** if i commit() on this position it's work!!!    


                    for (var i = 0; i < OrderLine.Count; i++)
                    {
                        string query = "INSERT INTO SF_OrderD ( DocType, DocID, LineID, ItemCode, Qty, Uom, IsFree, ProfitID, NetAmt )";
                        query += "VALUES   ( @DocType, @DocID, @LineID, @ItemCode, @Qty, @Uom, @IsFree, @ProfitID, @NetAmt )";
                        SqlCommand myCommand = new SqlCommand(query, myConnection);

                        myCommand.Parameters.AddWithValue("@DocType", (string)OrderLine[i]["DocType"] == null ? null : (string)OrderLine[i]["DocType"]);
                        myCommand.Parameters.AddWithValue("@DocID", (string)OrderLine[i]["DocID"] == null ? null : (string)OrderLine[i]["DocID"]);
                        myCommand.Parameters.AddWithValue("@LineID", (int)OrderLine[i]["LineID"] == null ? 0 : (int)OrderLine[i]["LineID"]);
                        myCommand.Parameters.AddWithValue("@ItemCode", (string)OrderLine[i]["ItemCode"] == "" ? null : (string)OrderLine[i]["ItemCode"]);
                        myCommand.Parameters.AddWithValue("@Qty", (int)OrderLine[i]["Qty"] == null ? 0 : (int)OrderLine[i]["Qty"]);
                        myCommand.Parameters.AddWithValue("@Uom", (string)OrderLine[i]["Uom"] == null ? "" : (string)OrderLine[i]["Uom"]);
                        myCommand.Parameters.AddWithValue("@IsFree", (string)OrderLine[i]["IsFree"] == null ? "" : (string)OrderLine[i]["IsFree"]);
                        myCommand.Parameters.AddWithValue("@ProfitID", (string)OrderLine[i]["ProfitID"] == null ? "" : (string)OrderLine[i]["ProfitID"]);
                        myCommand.Parameters.AddWithValue("@NetAmt", (int)OrderLine[i]["NetAmt"] == null ? 0 : (int)OrderLine[i]["NetAmt"]);
                        myCommand.ExecuteNonQuery();

                        System.Diagnostics.Debug.Write("INSERT LINE TO SQL COMPLETE!");
                    }
                    Trans.Commit(); // *** if i commit() on this position it's error
                }
                catch (Exception ex)
                {
                    Trans.Rollback();
                }
            }

* * 我的错误信息

System.InvalidOperationException：ExecuteNonQuery 需要命令 当分配给命令的连接为时进行事务处理 在待处理的本地事务中。的交易属性 命令尚未初始化。在 System.Data.SqlClient.SqlCommand.ValidateCommand（字符串方法， 布尔异步）在 System.Data.SqlClient.SqlCommand.InternalExecuteNonQuery（TaskCompletionSource`1 完成，字符串方法名，布尔型 sendToPipe，Int32 超时， Boolean& usedCache, Boolean asyncWrite, Boolean inRetry) at System.Data.SqlClient.SqlCommand.ExecuteNonQuery() 在 SaleForceAPI.Controllers.GetSaleForce_AccountController.GetSFTokens（字符串 输入 C:\Users\Administrator\source\repos\SaleForceAPI\SaleForceAPI\Controllers\GetSaleForce_AccountController.cs:line 232

和

当分配给命令的连接处于挂起的本地事务中时，ExecuteNonQuery 要求该命令具有事务。该命令的 Transaction 属性尚未初始化。

** 第 232 行是 myCommand.ExecuteNonQuery();

Answer 1

我不完全确定您的代码出了什么问题。但是尝试像这样对其进行重组，它应该可以工作：

using (SqlConnection conn = new SqlConnection(@"Data Source =xxxxxxx; Integrated Security=false;Persist Security Info=true; User ID=xxxxx; Password=xxxxxx; Initial Catalog=xxxxxx"))
{
    conn.Open();

    using (SqlTransaction trans = conn.BeginTransaction(System.Data.IsolationLevel.ReadCommitted))
    {
        try 
        {
            string query = <Define your inserts here>;
            SqlCommand cmd = new SqlCommand(query, conn, trans);
            cmd.ExecuteNonQuery();

            trans.Commit();
        }
        catch(Exception ex) 
        { 
            trans.Rollback();    
        }
     }

    conn.Close();
}

Answer 2

您忘记将事务对象分配给新创建的 SQLCommand“myCommand”。在执行查询之前试试这个

...
myCommand.Transaction = Trans;
myCommand.ExecuteNonQuery();
...