C#事務的創建及應用

1、創建事務的結構

SqlConnection sqlConnection = new SqlConnection(); 
...初始化連接 
// 開啟事務 
SqlTransaction sqlTransaction = sqlConnection.BeginTransaction(); 
// 將事務應用于Command 
SqlCommand sqlCommand = new SqlCommand(); 
sqlCommand.Connection = sqlConnection; 
sqlCommand.Transaction = sqlTransaction; 
try 
{ 
// 利用sqlcommand進行數據操作 
... 
// 成功提交 
sqlTransaction.Commit(); 
} 
catch(Exception ex) 
{ 
// 出錯回滾 
sqlTransaction.Rollback(); 
} 

2、簡單例子

{ 
DataTable dt = new DataTable(); 
System.Data.SqlClient.SqlConnection cnn = new System.Data.SqlClient.SqlConnection("連接字符串"); 
System.Data.SqlClient.SqlCommand cm = new System.Data.SqlClient.SqlCommand(); 
cm.Connection = cnn; 
cnn.Open(); 
System.Data.SqlClient.SqlTransaction trans = cnn.BeginTransaction(); 
try 
{ 
foreach(DataRow dr in dt.Rows) 
{ 
cm.CommandText = "update [表] set [數量] = @amount where productID = @productID"; 
cm.Parameters.Add("@amount",SqlDbType.Int); 
cm.Parameters["@amount"].Value = Convert.ToInt32(dr["amount"]); 
cm.Parameters.Add("@productID",SqlDbType.VarChar); 
cm.Parameters["@productID"].Value = dr["productID"].ToString(); 
cm.ExecuteNonQuery(); 
} 
trans.Commit(); 
} 
catch 
{ 
trans.Rollback(); 
} 
finally 
{ 
cnn.Close(); 
trans.Dispose(); 
cnn.Dispose(); 
} 
}

3、SQl server中的事務例子

begin transaction 
save transaction A 

insert into demo values('BB','B term')
rollback TRANSACTION A

create table demo2(name varchar(10),age int)
insert into demo2(name,age) values('lis',1)
rollback transaction

insert into demo values('BB','B term')

commit TRANSACTION A

commit TRANSACTION 

4、注意

1。事務必須在連接打開后BeginTransaction();

2.事務添加到SqlCommand（sqlCommand.Transaction = sqlTransaction; ）

3、其他數據庫對應做相應調整

4、可以用微軟提供的一個dll,很方便.