用Microsoft.net实现数据库事务(2)

　　数据库事务
　　数据库事务是其他事务模型的基础，本文讨论的事务都是基于数据库事务实现的，他们仅是隐藏了处理事务的复杂的或者容器专有的代码。当一个事务创建时不同数据库系统都有自己的规则。缺省地，SQL Server工作在自动提交的模式下，每个语句执行完后会立即提交，与此对照的是Oracle需要你包含一个提交语句。但是当一个语句通过OLEDB执行时，它执行完后一个提交动作会被附加上去。为了使下面的例子适用于Oracle，你需要去掉begin transation和commit transation两个语句，因为这两个语句会当作一个单独的事务来运行。
　　
　　优势
　　
　　◆ 所有的事务逻辑包含在一个单独的调用中
　　◆ 拥有运行一个事务的最佳性能
　　◆ 独立于应用程序
　　
　　限制
　　
　　◆ 事务上下文仅存在于数据库调用中
　　◆ 数据库代码与数据库系统有关
　　
　　例子：
　　
　　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()方法之前检查事务对象是否存在是一种良好的习惯。这样的一个例子是当一个死锁发生的同时，数据库正在执行自动回滚。
　　
　　优势：
　　
　　◆ 简单性
　　◆ 和数据库事务差不多的快
　　◆ 事务可以跨越多个数据库访问
　　◆ 独立于数据库，不同数据库的专有代码被隐藏了
　　
　　限制：
　　
　　事务执行在数据库连接层上，所以你需要在事务过程中手动的维护一个连接
　　
　　例子：
　　
　　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() 中国网管论坛bbs.bitsCN.com

　　+ \" 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\";

　　cmd.CommandText = insertsqltext;

　　// Retrieve the order id from the identity column

　　orderId = Convert.ToInt32(cmd.ExecuteScalar());

　　cmd.Dispose();

　　tx.Commit();

　　}

　　catch (SqlException sqlex)

　　{

　　// Specific catch for deadlock

　　if (sqlex.Number != 1205)

　　{

　　tx.Rollback();

　　}

　　orderId = 0;

　　throw(sqlex);

　　}

　　catch (Exception ex)

　　{

　　tx.Rollback(); 中国网管联盟bitsCN.com

　　orderId = 0;

　　throw (ex);

　　}

　　finally

　　{

　　tx.Dispose();

　　con.Close();

　　}

　　}
　　
　　ASP.NET事务
　　ASP.NET事务可以说是在.Net平台上事务实现方式中最简单的一种，你仅仅需要加一行代码。在ASPX的页面声明中加一个额外的属性，即是事务属性，它可以有 如下的值：Disabled (缺省), NotSupported, Supported, Required 和 RequiresNew，这些设置和COM+以及企业级服务中的设置一样，典型地如果你想在页面上下文中运行事务，那么要设置为Required。如果页面中包含有用户控件，那么这些控件也会包含到事务中，事务会存在于页面的每个地方。
　　
　　优势：
　　
　　◆ 实现简单，不需要额外的编码
　　
　　限制：
　　
　　◆ 页面的所有代码都是同一个事务，这样的事务可能会很大，而也许我们需要的是分开的、小的事务
　　◆ 事务实在Web层
　　
　　例子：
　　
　　ASPX page

　　<%@ Page Transaction="Required" language="c#" Codebehind="ASPNET_Transaction.aspx.cs"
　　

　　Inherits=\"TransTest.ASPNET_Transaction\" AutoEventWireup=\"false\"%>

网管u家u.bitscn@com

　　

　　

　　

　　

　　

　　

　　

　　

　　

　　ASPX Code behind page

　　using System;

　　using System.Collections;

　　using System.ComponentModel;

　　using System.Data;

　　using System.Data.SqlClient;

　　using System.Drawing;

　　using System.Web;

　　using System.Web.SessionState;

　　using System.Web.UI;

　　using System.Web.UI.WebControls;

　　using System.Web.UI.HtmlControls;

　　namespace TransTest

　　{

　　/// Summary description for ASPNET_Transaction.

　　public class ASPNET_Transaction : System.Web.UI.Page

　　{

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

　　{

　　SqlConnection con = null;

　　int orderId = 0; 网管联盟bitsCN@com

　　try

　　{

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

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

　　con.Open();

　　String updatesqltext = \"UPDATE inventory SET qtyinstock = qtyinstock

　　- \" + itemQty.ToString() + \" WHERE inventory.productid = \" +

　　itemId.ToString();

　　SqlCommand cmd = new SqlCommand(updatesqltext, con);

　　cmd.ExecuteNonQuery();

　　String insertsqltext = \"INSERT INTO orders VALUES

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

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

　　cmd.CommandText = insertsqltext;

　　orderId = Convert.ToInt32(cmd.ExecuteScalar());

　　cmd.Dispose();

　　}

　　catch (Exception ex)

　　{

　　orderId = 0;

　　throw (ex);

　　}

　　finally

　　{

　　con.Close();

　　}

　　return orderId;

　　}

网管网www_bitscn_com

　　private void Page_Load(object sender, System.EventArgs e)

　　{

　　int orderid = purchaseitem(1, 1, 10);

　　Response.Write(orderid);

　　}

　　#region Web Form Designer generated code

　　…

　　}

　　}
　　
　　注意到这些和ADO.NET事务的代码基本一样，我们只是移除了对SqlTransation对象