using System; using System.Collections.Generic; using System.Linq; using System.Text; using System.Data.SqlClient; namespace TransactionPractice { class Program { static void Main(string[] args) { TransactionTraining(); } private static void TransactionTraining() { SqlConnection conn = new SqlConnection("server =.;database = zhao722;uid = sa;pwd = 3221682;"); if (conn.State!= System.Data.ConnectionState.Open) { conn.Open(); } //经过链接通道取得事务 SqlTransaction tran = conn.BeginTransaction(); SqlCommand cmd = conn.CreateCommand(); try { //事务传给sql操做语句 cmd.Transaction = tran; cmd.CommandText = "update test2 set name = '这是新修改的各类姓名' "; cmd.ExecuteNonQuery(); //此处注意,一次只能执行一行 cmd.CommandText = "insert into test2(name,score,id) values('zhao','50',50)"; //cmd.CommandText = "update test2 set name = '测试姓名' "; cmd.ExecuteNonQuery(); //提交事务 tran.Commit(); } catch (Exception e) { tran.Rollback(); } finally { conn.Close(); } } } }