откат данных, когда один из сохраненных продуктов обнаружил ошибку в .net c # - PullRequest
Новая
       40

откат данных, когда один из сохраненных продуктов обнаружил ошибку в .net c #

0 голосов
/ 17 мая 2011

Кто-нибудь знает, как мне выполнить откат всех данных в .net c #, если во время процесса произошел сбой одного из сохраненных процессов?

Пример: 

 protected void btnSave_Click(object sender, EventArgs e)
   {
      int ixTest= SaveTest("123");
      CreateTest(ixTest);

   }

   protected int SaveTest(int ixTestID)
   {
      SubSonic.StoredProcedure sp = Db.SPs.TestInsert(
         null,
         ixTestID);
      sp.Execute();
      int ixTest= (int)sp.OutputValues[0];
      return ixTest;
   }


   private long CreateTest(int ixTest)
   {
      long ixTestCustomer = CreateTestCustomer();

      TestCustomer testCustomer= new TestCustomer();
      try
      {
          testCustomer.TestCustomerId = ixTest;
          testCustomer.InteractionId = ixTestCustomer ;
          testCustomer.Save();
      }
      catch
      {
          Response.Redirect("pgCallSaveFailure.aspx");
      }

      m_saleDetail = new TestSaleDetail();
      try
      {
          m_saleDetail.SaleId = sale.SaleId;
          m_saleDetail.Save();
      }
      catch
      {
          Response.Redirect("pgCallSaveFailure.aspx");
      }

      return ixTestCustomer ;
   }

У меня следующий код вызовет btnSave_Click, затем он вызовет еще 2 функции Savetest () и CreateTest () для сохранения данных в базе данных. Как я могу откатить все транзакции данных в следующем коде, если проблема возникла только в CreateTest () и которые Savetest () были успешно выполнены. Как я могу откатить все данные для Savetest () и CreateTest ()?

Ответы [ 2 ]

2 голосов
/ 17 мая 2011

Используйте TransactionScope , класс

0 голосов
/ 17 мая 2011

Точный код выполнения приведен ниже. Надеюсь, вы можете получить идею. 

public void SaveData()
{
SqlConnection connDB = new SqlConnection();
SqlCommand cmdExecuting = new SqlCommand();


try {
    connDB = new SqlConnection(connection_string);
    cmdExecuting.Connection = connDB;
    connDB.Open();
    cmdExecuting.Transaction = connDB.BeginTransaction();


    int result = 0;

    result = Method1(cmdExecuting);

    if (result != 0) {
        cmdExecuting.Transaction.Rollback();
        return;
    }

    result = Method2(cmdExecuting);

    if (result != 0) {
        cmdExecuting.Transaction.Rollback();
        return;
    }

    cmdExecuting.Transaction.Commit();

} catch (Exception ex) {
    cmdExecuting.Transaction.Rollback();
} finally {
    cmdExecuting.Dispose();
    cmdExecuting = null;
    connDB.Close();
    connDB = null;
}


}

public int Method1(SqlCommand cmdExecuting)
{

cmdExecuting.Parameters.Clear();
cmdExecuting.CommandText = "stored proc 01";
cmdExecuting.CommandType = CommandType.StoredProcedure;

cmdExecuting.Parameters.Add("@para1", SqlDbType.Int);
cmdExecuting.Parameters("@para1").Value = value;

return cmdExecuting.ExecuteScalar();

}


public int Method2(SqlCommand cmdExecuting)
{

cmdExecuting.Parameters.Clear();
cmdExecuting.CommandText = "stored proc 02";
cmdExecuting.CommandType = CommandType.StoredProcedure;

cmdExecuting.Parameters.Add("@para1", SqlDbType.Int);
cmdExecuting.Parameters("@para1").Value = value;

return cmdExecuting.ExecuteScalar();

}
...