C#教程之C#事务处理（Execute Transaction）实例解析

当前位置:

首页 > 编程开发 > c#教程 >

C#教程之C#事务处理（Execute Transaction）实例解析
2017-07-16 20:54 来源：未知

本文所述为C#事务处理（Execute Transaction）的一个实例，包含了创建SqlTransaction 对象并用SqlConnection对象的BeginTransaction()方法开始事务，创建保存SQL语句，将SqlCommand对象的CommandText属性设置为第一个INSERT语句，第一个INSERT语句在Customers表中增加一行，提交事务，使INSERT语句增加的两行在数据库中保存起来。

具体的实例代码如下：

				?

									using System; 

									using System.Data; 

									using System.Data.SqlClient; 

									namespace ExecuteTransaction 

									{ 

									 /// <summary> 

									 /// ExecuteTransaction 的摘要说明。 

									 /// </summary> 

									 public class ExecuteTransaction 

									 { 

									 public static void Main() 

									 { 

									  SqlConnection mySqlConnection = 

									  new SqlConnection( 

									  "server=localhost;database=Northwind;uid=sa;pwd=sa"

									  ); 

									  mySqlConnection.Open(); 

									  // 创建SqlTransaction 对象并用SqlConnection对象的 

									  // BeginTransaction()方法开始事务 

									  SqlTransaction mySqlTransaction = 

									  mySqlConnection.BeginTransaction(); 

									  // 创建保存SQL语句 

									  SqlCommand mySqlCommand = mySqlConnection.CreateCommand(); 

									  // 将Transaction属性设置为上面所生成的SqlTransaction对象 

									  mySqlCommand.Transaction = mySqlTransaction; 

									  // 将SqlCommand对象的CommandText属性设置为第一个INSERT语句， 

									  // 第一个INSERT语句在Customers表中增加一行 

									  mySqlCommand.CommandText = 

									  "INSERT INTO Customers (" + 

									  " CustomerID, CompanyName" + 

									  ") VALUES (" + 

									  " 'Micro', 'Microsoft Corporation'" + 

									  ")"; 

									  // 执行第一个INSERT语句 

									  Console.WriteLine("Running first INSERT statement"); 

									  mySqlCommand.ExecuteNonQuery(); 

									  // 将SqlCommand对象的CommandText属性设置为第二个INSERT语句， 

									  // 第二个INSERT语句在Orders表中增加一行 

									  mySqlCommand.CommandText = 

									  "INSERT INTO Orders (" + 

									  " CustomerID" + 

									  ") VALUES (" + 

									  " 'Micro'" + 

									  ")"; 

									  // 执行第二个INSERT语句 

									  Console.WriteLine("Running second INSERT statement"); 

									  mySqlCommand.ExecuteNonQuery(); 

									  // 提交事务，使INSERT语句增加的两行在数据库中保存起来 

									  Console.WriteLine("Committing transaction"); 

									  mySqlTransaction.Commit(); 

									  mySqlConnection.Close(); 

									 } 

									 } 

									}