C#開啟事務處理
阿新 • • 發佈:2018-11-20
在C#中開啟事務的步驟 01.呼叫SqlConnection物件的BeginTransaction()方法,建立一個SqlTransaction物件,標誌事務開始。 02.將建立的SqlTransaction物件分配給要執行的SqlCommand的Transaction屬性。 03.呼叫相應的方法執行SqlCommand命令。 04.呼叫SqlTransaction的Commit()方法完成事務。或呼叫Rollback()方法終止事務。 例子 //準備連線字串 string str = "data source=.;initial catalog=Myschool;uid=sa;pwd=123"; //建立資料庫連線物件 SqlConnection con = new SqlConnection(str); //sql語句:新增一條記錄到年級表 string sql = "insert into grade values(@gradename)"; //建立SqlParameter物件,設定引數 SqlParameter sp = new SqlParameter("@gradename", txtgradename.Text); //建立命令物件 SqlCommand cmd = new SqlCommand(sql, con); //通過Parameter集合的add()方法天填充引數集合 cmd.Parameters.Add(sp); //開啟連線 con.Open(); //預設讓SqlTransaction物件為空 SqlTransaction trans = null; //開啟事務:標誌事務的開始 trans = con.BeginTransaction(); try { //將建立的SqlTransaction物件分配給要執行的sqlCommand的Transaction屬性 cmd.Transaction = trans; //執行sql如果新增成功放回1 int count=cmd.ExecuteNonQuery(); if (count > 0) { MessageBox.Show("成功"); //事務提交 trans.Commit(); } else { MessageBox.Show("失敗"); //事務回滾 trans.Rollback(); } } catch (Exception) { //如果某個環節出現問題,則將整個事務回滾 trans.Rollback(); } ///迴圈事務程式碼 public static bool SqlTransSqlStr(List<string> SQLStringList, ref string ErrorMsg) { bool i = false; string connectionString = ConfigurationManager.ConnectionStrings["demo"].ConnectionString; using (SqlConnection connection = new SqlConnection(connectionString)) { connection.Open(); SqlCommand cmd = new SqlCommand(); cmd.Connection = connection; SqlTransaction tx = connection.BeginTransaction(); cmd.Transaction = tx; try { for (int n = 0; n < SQLStringList.Count; n++) { string strsql = SQLStringList[n].ToString(); if (strsql.Trim().Length > 1) { cmd.CommandText = strsql; cmd.ExecuteNonQuery(); cmd.Parameters.Clear(); } } tx.Commit(); i = true; } catch (System.Data.SqlClient.SqlException E) { tx.Rollback(); ErrorMsg = E.Message; i = false; } } return i; } //下面的具體程式碼為個人實際專案測試成功 SqlConnection con = DB.lianjie(); con.Open(); SqlCommand cmd = new SqlCommand(); cmd.Connection = con; SqlTransaction tx = con.BeginTransaction(); cmd.Transaction = tx; try { for (int i = 1; i < dt.Rows.Count; i++) { DateTime a1 = Convert.ToDateTime(dt.Rows[i][1]); DateTime a2 = Convert.ToDateTime(dt.Rows[i][2]); DateTime a3 = Convert.ToDateTime(dt.Rows[i][3]); DateTime a4 = Convert.ToDateTime(dt.Rows[i][4]); DateTime a5 = Convert.ToDateTime(dt.Rows[i][10]); DateTime a6 = Convert.ToDateTime(dt.Rows[i][11]); string sqlstr = "insert into xuhao(shebeirukudata,shebeichukudata,SIMrukudata,SIMchukudata,shebeileixing,shebeiSN,SIMkahao,zhanghu,changshang,jiaofeiri,daoqiri,rukujia,chukujia,beizhu,flagkehu,flagguangbu)values('" + a1 + "','" + a2 + "','" + a3 + "','" + a4 + "','" + dt.Rows[i][5] + "','" + dt.Rows[i][6] + "','" + dt.Rows[i][7] + "','" + dt.Rows[i][8] + "','" + dt.Rows[i][9] + "','" + a5 + "','" + a6 + "','" + dt.Rows[i][12] + "','" + dt.Rows[i][13] + "','" + dt.Rows[i][14] + "',0,0)"; //插入的insert語句??c1?c2?c3?是資料在資料庫中的列名?table1是表名 cmd.CommandText = sqlstr; cmd.ExecuteNonQuery(); cmd.Parameters.Clear(); } tx.Commit(); int cc = dt.Rows.Count - 1; MessageBox.Show("您成功添加了'" + cc + "'條資料"); textBox2.Text = Convert.ToString(cc); } catch { tx.Rollback(); MessageBox.Show("出錯"); }