1. 程式人生 > >C#開啟事務處理

C#開啟事務處理

在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("出錯");
            }