日期:2008-06-14  浏览次数:20505 次

数据库事务
数据库事务是其他事务模型的基础,本文讨论的事务都是基于数据库事务实现的,他们仅是隐藏了处理事务的复杂的或者容器专有的代码。当一个事务创建时不同数据库系统都有自己的规则。缺省地,SQL Server工作在自动提交的模式下,每个语句执行完后会立即提交,与此对照的是Oracle需要你包含一个提交语句。但是当一个语句通过OLEDB执行时,它执行完后一个提交动作会被附加上去。为了使下面的例子适用于Oracle,你需要去掉begin transation和commit transation两个语句,因为这两个语句会当作一个单独的事务来运行。

优势

l 所有的事务逻辑包含在一个单独的调用中

l 拥有运行一个事务的最佳性能

l 独立于应用程序

限制

l 事务上下文仅存在于数据库调用中

l 数据库代码与数据库系统有关

例子:

CREATE PROCEDURE up_purchaseItem (

@customerId as int,

@itemId int,

@itemqty int)

AS



DECLARE @orderid int



BEGIN TRANSACTION



-- Update the inventory based on purchase

UPDATE inventory

SET qtyinstock = qtyinstock - @itemqty

WHERE inventory.productid = @itemid;



IF @@Error != 0 GOTO ERROR_HANDLER



-- Insert the order into the database

INSERT INTO orders

VALUES (@customerId, @itemId, @itemqty, getdate());



IF @@Error != 0 GOTO ERROR_HANDLER



SET @orderid = @@IDENTITY



COMMIT TRANSACTION



RETURN @orderid



ERROR_HANDLER:

ROLLBACK TRANSACTION

SET NOCOUNT OFF

RETURN 0

GO



ADO.NET事务
创建一个ADO.NET事务是很简单的,仅仅是标准代码的一个小的扩展。只要你知道如何使用ADO.NET来访问数据库,那就差不多知道了。区别仅仅是你需要把代码放到一个事务上下文中。

还是原来的ADO.NET类库引用,在实现事务的类里面引入System.Data和System.Data.SqlClient类库,为了执行一个事务,你需要创建一个SqlTransation对象,可以调用你的SqlConnection对象BeginTransation()方法来创建它,一旦你把SqlTransation对象存为本地变量,你就可以把它赋给你的SqlCommand对象的事务属性,或者把它作为构造器的一个参数来创建SqlCommand。在执行SqlCommand动作之前,你必须调用BeginTransaction()方法,然后赋给SqlCommand事务属性。

一单事务开始了,你就可以执行任何次数的SqlCommand动作,只要它是属于同一个事务和连接。最后你可以调用SqlTransation的Commit()方法来提交事务。

ADO.NET事务实际上是把事务上下文传递到数据库层,如果事务中发生一个错误,数据库会自动回滚。在你的错误处理代码中,每次调用Rollback()方法之前检查事务对象是否存在是一种良好的习惯。这样的一个例子是当一个死锁发生的同时,数据库正在执行自动回滚。



优势:

l 简单性

l 和数据库事务差不多的快

l 事务可以跨越多个数据库访问

l 独立于数据库,不同数据库的专有代码被隐藏了

限制:

事务执行在数据库连接层上,所以你需要在事务过程中手动的维护一个连接

例子:

public int purchaseitem(int customerId, int itemId, int itemQty)

{

SqlConnection con = null;

SqlTransaction tx = null;

int orderId = 0;



try

{

con = new SqlConnection("Data Source=localhost; user

Id=sa;password=;Initial Catalog=trans_db;");



con.Open();



tx = con.BeginTransaction(IsolationLevel.Serializable);



String updatesqltext = "UPDATE inventory SET qtyinstock

= qtyinstock - " + itemQty.ToString()

+ " WHERE inventory.productid = " + itemId.ToString();



SqlCommand cmd = new SqlCommand(updatesqltext, con, tx);



cmd.ExecuteNonQuery();



// String is 2 SQL statements: the first is the insert,

the second selects the identity column

String insertsqltext = "INSERT INTO orders VALUES

(" + customerId.ToString() + "," + itemId.ToString()

+ "," + itemQty.ToString() + " , getdate() ); SELECT @@IDENTITY&q