У меня есть еще транзакция для вставки на сервер SQL.
И моя транзакция имеет заголовок и строку Подробно мои данные, как это
[
{
"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 ()
после детализации строки выполните. Но если я позвоню DB.commit () после того, как head выполнит свою работу.
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 требует команду
иметь транзакцию, когда соединение, назначенное команде
в ожидающей локальной транзакции. Свойство Transaction
Команда не была инициализирована. в
System.Data.SqlClient.SqlCommand.ValidateCommand (метод String,
Логическое асинхронное) в
System.Data.SqlClient.SqlCommand.InternalExecuteNonQuery (TaskCompletionSource`1
завершение, String methodName, логическое значение sendToPipe, время ожидания Int32,
Boolean & usedCache, Boolean asyncWrite, Boolean inRetry) в
System.Data.SqlClient.SqlCommand.ExecuteNonQuery () в
SaleForceAPI.Controllers.GetSaleForce_AccountController.GetSFTokens (String
Введите
C: \ Users \ Administrator \ Source \ Repos \ SaleForceAPI \ SaleForceAPI \ Контроллеры \ GetSaleForce_AccountController.cs: линия
232
и
ExecuteNonQuery требует, чтобы команда имела транзакцию, когда назначенное команде соединение находится в ожидающей локальной транзакции. Свойство Transaction команды не было инициализировано.
** Строка 232 - это myCommand.ExecuteNonQuery ();