十年网站开发经验 + 多家企业客户 + 靠谱的建站团队
量身定制 + 运营维护+专业推广+无忧售后,网站问题一站解决
在vb点虐 中要定义一个事务,需要使用Begin tran命令,在这一命令之后的任何语句都将被认为是事务的一部分。命令Commit用来完成VB.NET处理,并使事务对数据库所作的修改成为永久的。Rollback命令用来取消一个事务,并还原事务对数据库所作的修改。
10年的赤城网站建设经验,针对设计、前端、开发、售后、文案、推广等六对一服务,响应快,48小时及时工作处理。营销型网站的优势是能够根据用户设备显示端的尺寸不同,自动调整赤城建站的显示方式,使网站能够适用不同显示终端,在浏览器中调整网站的宽度,无论在任何一种浏览器上浏览网站,都能展现优雅布局与设计,从而大程度地提升浏览体验。创新互联公司从事“赤城网站设计”,“赤城网站推广”以来,每个客户项目都认真落实执行。
在本文中 您将了解到如何在 Visual Basic NET (VB NET) 和 Visual C# NET (C#) 中使用数据库事务 具体来讲 您将系统学习数据库事务 在 NET 程序中使用 OracleTransaction 对象以及如何设置事务保存点 本文中引用的所有脚本和文件都在这里提供 本文假定您大体上熟悉 C# 和 VB NET 编程
所需软件
如果您要跟随我们逐步完成本文中给出的示例 那么您需要安装以下软件
Windows NT Windows Windows XP Professional 或 Windows Server
能够访问一个已安装的 Oracle 数据库(Oracle i 版本 或更高版本)
Oracle 客户机(版本 或更高版本)
Oracle Net(版本 或更高版本)
Oracle Data Providers for NET(版本 或更高版本)
Microsoft NET Framework(版本 或更高版本)
Microsoft NET 框架 SDK(版本 或更高版本)
如果您打算使用企业服务事务或分布式事务来开发和运行应用程序 那么您还需要安装 Oracle Services for Microsoft Transaction Server( 或更高版本)
您需要分别下载和安装 NET 框架以及 SDK(先安装框架) 您还需要下载和安装 Oracle 数据库 g 它包括 Oracle Data Provider for NET (ODP NET) 您可以选择在不同计算机或同一计算机上安装 ODP NET 和数据库服务器
注意 ODP NET 驱动程序针对 Oracle 数据库访问进行了优化 因此可以获得最佳性能 并且它们还支持 Oracle 数据库的丰富特性 如 BFILE BLOB CLOB XMLType 等 如果您正在开发基于 Oracle 数据库的 NET 应用程序 那么就特性和性能来讲 ODP NET 无疑是最佳的选择
数据库模式设置
首先 您需要设置数据库模式 在此我们使用一个简化的 Web 商店示例 您必须首先创建一个名为 store 的用户并按以下方式将所需的权限授予该用户(您必须首先以拥有 CREATE USER 权限的用户身份登录数据库才能创建用户)
CREATE USER store IDENTIFIED BY store;GRANT connect resource TO store;
注意 您会在源代码文件 db sql 中找到前两个语句和该部分中出现的设置 store 模式的其他语句
接下的语句以 store 用户身份进行连接
CONNECT store/store;
以下语句创建了所需的两个数据库表 名称分别为 product_types 和 products
CREATE TABLE product_types (product_type_id INTEGERCONSTRAINT product_types_pk PRIMARY KEY name VARCHAR ( ) NOT NULL);
CREATE TABLE products (product_id INTEGERCONSTRAINT products_pk PRIMARY KEY product_type_id INTEGERCONSTRAINT products_fk_product_typesREFERENCES product_types(product_type_id) name VARCHAR ( ) NOT NULL description VARCHAR ( ) price NUMBER( ));
注意 如果您在一个不同的模式中为 store 用户创建了这些数据库表 那么您将需要修改示例配置文件(您稍后将看到)中的模式名称
表 product_types 用于存储示例在线商店可能库存的产品类型的名称 表 products 包含了所销售产品的详细信息
下面的 INSERT 语句为表 product_types 和 products 添加行
INSERT INTO product_types (product_type_id name) VALUES ( Book );INSERT INTO product_types (product_type_id name) VALUES ( DVD );
INSERT INTO products (product_id product_type_id name description price) VALUES ( Modern Science A description of modern science );INSERT INTO products (product_id product_type_id name description price) VALUES ( Chemistry Introduction to Chemistry );INSERT INTO products (product_id product_type_id name description price) VALUES ( Supernova A star explodes );INSERT INTO products (product_id product_type_id name description price) VALUES ( Tank War Action movie about a future war );
MIT;
接下来 您将了解有关数据库事务的内容
数据库事务简介
数据库事务是由一组 SQL 语句组成的一个逻辑工作单元 您可以把事务看作是一组不可分的 SQL 语句 这些语句作为一个整体永久记录在数据库中或一并撤销 比如在银行帐户之间转移资金 一条 UPDATE 语句将从一个帐户的资金总数中减去一部分 另一条 UPDATE 语句将把资金加到另一个帐户中 减操作和加操作必须永久记录在数据库中 或者必须一并撤销 ― 否则将损失资金 这个简单的示例仅使用了两条 UPDATE 语句 但一个更实际的事务可能包含许多 INSERT UPDATE 和 DELETE 语句
要永久记录一个事务中的 SQL 语句的结果 您可以通过 MIT 语句来执行提交 要撤销 SQL 语句的结果 您可以使用 ROLLBACK 语句来执行回滚 这会把所有的行重设为它们原来的状态 只要您事先没有与数据库断开 则您在执行回滚之前所做的任何修改都将被撤销 您还可以设置一个保存点 以便将事务回滚至该特定的点 同时保持事务中的其他语句原封不动
在 C# 和 VB NET 中使用数据库事务
您可以使用 OracleTransaction 类的一个对象来表示一个事务 OracleTransaction 类包含多个属性 其中的两个为 Connection(指定与事务关联的数据库连接)和 IsolationLevel(指定事务隔离级别) 本文稍后将向您介绍更多有关事务隔离级别的内容
OracleTransaction 类包含许多操控事务的方法 您可以使用 Commit() 方法永久提交 SQL 语句 并可以使用 Rollback() 撤销这些语句 您还可以使用 Save() 在事务中设置一个保存点
我现在将带着您逐步完成两个示例程序 ― 一个用 C# 编写 (TransExample cs) 另一个用 VB NET 编写 (TransExample vb) 这些程序演示了如何执行一个包含了两条 INSERT 语句的事务 第一条 INSERT 语句将在表 product_types 中添加一行 第二条将在表 products 中添加一行
导入命名空间
以下 C# 程序语句指定在程序中使用 System 和 Oracle DataAcess Client 命名空间
using System;using Oracle DataAccess Client;
下面是等价的 VB NET 语句
Imports SystemImports Oracle DataAccess Client
Oracle DataAccess Client 命名空间是 ODP NET 的一部分 它包含许多类 其中有 OracleConnection OracleCommand 和 OracleTransaction 示例程序用到了这些类
第 步
创建一个 OracleConnection 对象连接到 Oracle 数据库 然后打开该连接
在 C# 中
OracleConnection myOracleConnection =new OracleConnection( User Id=store;Password=store;Data Source=ORCL );myOracleConnection Open();在 VB NET 中
Dim myOracleConnection As New OracleConnection( _ User Id=store;Password=store;Data Source=ORCL )myOracleConnection Open()
User Id 和 Password 属性指定了您所要连接到的模式的数据库用户和口令 Data Source 属性指定了数据库的 Oracle Net 服务名称 初始数据库的默认服务名称为 ORCL 如果您使用的不是初始数据库 或者您的服务名称不同 那么您需要在程序中修改 Data Source 属性的设置
第 步
创建一个 OracleTransaction 对象 然后调用 OracleConnection 对象的 BeginTransaction() 方法启动事务
在 C# 中
OracleTransaction myOracleTransaction =myOracleConnection BeginTransaction();In VB NET:
Dim myOracleTransaction As OracleTransaction = _myOracleConnection BeginTransaction()
第 步
创建一个 OracleCommand 对象 用于存储 SQL 语句
在 C# 中
OracleCommand myOracleCommand = myOracleConnection CreateCommand();
在 VB NET 中
Dim myOracleCommand As OracleCommand =myOracleConnection CreateCommand
因为 OracleCommand 对象使用 OracleConnection 对象的 CreateCommand() 方法创建的 所以它自动使用在第 步中为 OracleConnection 对象设置的事务
第 步
将 OracleCommand 对象的 CommandText 属性设为向表 product_types 中添加一行的第一条 INSERT 语句
在 C# 中
myOracleCommand CommandText = INSERT INTO product_types ( + product_type_id name + ) VALUES ( + Magazine + ) ;
在 VB NET 中
myOracleCommand CommandText = _ INSERT INTO product_types ( _ product_type_id name _ ) VALUES ( _ Magazine _ ) 第 步
使用 OracleCommand 对象的 ExecuteNonQuery() 方法运行 INSERT 语句
在 C# 中
myOracleCommand ExecuteNonQuery();
在 VB NET 中
myOracleCommand ExecuteNonQuery()
第 和第 步
将 OracleCommand 对象的 CommandText 属性设为向表 Products 中添加一行的第二条 INSERT 语句 并运行它
在 C# 中
myOracleCommand CommandText = INSERT INTO products ( + product_id product_type_id name description price + ) VALUES ( + Oracle Magazine Magazine about Oracle + ) ;myOracleCommand ExecuteNonQuery();
在 VB NET 中
myOracleCommand CommandText = _ INSERT INTO products ( _ product_id product_type_id name description price _ ) VALUES ( _ Oracle Magazine Magazine about Oracle _ ) myOracleCommand ExecuteNonQuery()
第 步
使用 OracleTransaction 对象的 Commit() 方法提交数据库中的事务
在 C# 中
myOracleTransaction Commit();
在 VB NET 中
myOracleTransaction Commit()
在完成 Commit() 方法之后 由 INSERT 语句添加的两行将在数据库中永久记录
第 步
使用 Close() 方法关闭 OracleConnection 对象
在 C# 中
myOracleConnection Close();
在 VB NET 中
myOracleConnection Close()
编译并运行示例程序
要编译 C# 示例程序 您可以使用 csc 命令运行 C# 编译器 因为程序使用 Oracle Data Access DLL 所以您应使用 /r 选项指定该 DLL 的完整路径 例如
csc TransExample cs /r:C:\oracle\product\ \Client_ \bin\Oracle DataAccess dll
注意 您需要用您计算机上的相应路径来替换该 DLL 的路径 此外 如果您的计算机找不到 csc 编译器 那么您可能需要运行 Microsoft sdkvars bat 脚本来首先设置 NET SDK 的环境变量 您可以在安装 NET SDK 的 bin 目录中找到该脚本
如果您遇到以下错误
Example cs( ):error CS :The type or namespace name Oracle could not be found (are you missing a using directive or an assembly reference?)
这说明您没有在编译命令中正确指定 Oracle Data Access DLL (有关设置的信息 请参阅 John Paul Cook 的技术文章 在 Oracle 数据库上构建 NET 应用程序 )
下面是用于编译 VB NET 程序的等价命令
vbc TransExample vb /r:C:\oracle\product\ \Client_ \bin\Oracle DataAccess dll /r:system dll /r:system data dll
接下来 输入以下命令 运行示例
TransExample
您将看到程序的输出 不过 如果您遇到类似以下的异常
An exception was thrownMessage = ORA :TNS:listener does not currently knowof service requested in connect descriptor
这说明 OracleConnection 对象的连接字符串中的 Data Source 的设置不正确 您应当咨询您的 DBA 或查阅 Oracle Net 文档以获得更多详细信息
如果您使用的是 VS NET 那么您可以遵循以下指示来编译和运行 C# 程序 TransExample cs
创建一个新的 C# 控制台应用程序 FileNew Project 然后选择 Visual C# Projects Console Application
将项目命名为 TransExample
用 TransExample cs 中的代码替换 VS NET 生成的所有代码
选择 ProjectAdd Reference 添加对 Oracle DataAccess dll 的引用 然后浏览至您安装 ODP NET 的目录(在我的计算机上 它是 C:\oracle\product\ \Client_ \bin\Oracle DataAccess dll) 然后双击 Oracle DataAccess dll
选择 DebugStart without Debugging 运行该程序
要编译和运行 TransExample vb 您可以执行类似的一系列步骤 但第 步应选择一个 Visual Basic 控制台应用程序 并在第 步用 TransExample vb 中的代码替换生成的代码
查看程序的运行结果
当您运行完 C# 或 VB NET 程序时 您可以在 SQL*Plus 中使用以下 SELECT 语句查看事务的结果
SELECT p product_id p product_type_id pt name p name p description p priceFROM products p product_types ptWHERE p product_type_id = pt product_type_idAND p product_id = ;
您将看到以下结果
PRODUCT_ID PRODUCT_TYPE_ID NAME NAME DESCRIPTION PRICE Magazine Oracle MagazineMagazine about Oracle
接下来 您将了解如何设置事务保存点
在 NET 程序中设置事务保存点
正如本文前面所提到的那样 您可以设置一个保存点 以便将事务回滚至该特定的点 同时保持事务中的其他语句原封不动 您可以使用 OracleTransaction 类的 Save() 方法在事务中设置保存点
如果您有一个非常长的事务并且希望能够仅回滚到某个特定的时间点 那么您可能要使用保存点 例如 您可能想对 个产品做一些更改 然后设置一个保存点 然后再对另 个产品做更改 如果您在进行第二批更改时出现了错误 那么您可以回滚至保存点 使您的第一批更改原封不动
我将带您逐步完成演示如何使用保存点的 C# (TransExample cs) 示例程序和 VB NET (TransExample vb) 示例程序中的相关新步骤 这些程序向表 products 中添加一行 设置一个保存点 向表 products 中添加另一行 回滚至保存点 然后从表 products 中读取这些行 在回滚至保存点后 只有添加到表 products 中的第一行保留了下来 第二行将已被删除
第 到第 步与 在 C# 和 VB NET 中使用数据库事务 部分中所示的步骤相同 因此在这里将其省略
第 步
向表 products 中添加一行 该行的产品 ID 为
在 C# 中
myOracleCommand CommandText = INSERT INTO products ( + product_id product_type_id name description price + ) VALUES ( + Man from Another World Man from Venus lands on Earth + ) ;myOracleCommand ExecuteNonQuery();
在 VB NET 中
myOracleCommand CommandText = _ INSERT INTO products ( _ product_id product_type_id name description price _ ) VALUES ( _ Man from Another World Man from Venus lands on Earth _ ) myOracleCommand ExecuteNonQuery()
第 步
使用 OracleTransaction 的 Save() 方法设置一个名为 SaveProduct 的保存点
在 C# 中
myOracleTransaction Save( SaveProduct );
在 VB NET 中
myOracleTransaction Save( SaveProduct )
第 步
向表 products 中添加另一行 该行的产品 ID 为
在 C# 中
myOracleCommand CommandText = INSERT INTO products ( + product_id product_type_id name description price + ) VALUES ( + Z Files Mysterious stories + ) ;myOracleCommand ExecuteNonQuery();
在 VB NET 中
myOracleCommand CommandText = _ INSERT INTO products ( _ product_id product_type_id name description price _ ) VALUES ( _ Z Files Mysterious stories _ ) myOracleCommand ExecuteNonQuery()
第 步
回滚到先前在第 步中设置的 SaveProduct 保存点
在 C# 中
myOracleTransaction Rollback( SaveProduct );
在 VB NET 中
myOracleTransaction Rollback( SaveProduct )
完成回滚后 在第 步中添加的第二行已被删除 而在第 步中添加的第一行保留了下来
TransExample cs 和 TransExample vb 中剩下的步骤显示表 products 的内容 回滚整个事务并从数据库断开
用于 Microsoft Transaction Server 的 Oracle 事务服务的快速说明
Microsoft Transaction Server 是一个运行在互联网或网络服务器上的专有事务处理系统 Microsoft Transaction Server 为客户端计算机部署和管理应用程序和数据库事务请求
Microsoft Transaction Server 是以服务器为中心的三层体系结构模型的一个组件 这种方法实现了将应用程序的表示 业务逻辑和数据元素清晰地分布到在一个网络中连接的不同计算机上 无需专门集成 您就可以在与 Oracle 数据库服务器 版或更高版本连接的 Microsoft Transaction Server 中部署一个组件 但首先您必须安装 Oracle Services for Microsoft Transaction Server
结论
lishixinzhi/Article/program/Oracle/201311/18786
Oracle.DataAccess.Client 命名空间是 ODP.NET 的一部分,它包含许多类,其中有OracleConnection、OracleCommand 和 OracleTransaction。示例程序用到了这些类。 VB.NET使用ORACLR第 1 步创建一个 OracleConnection 对象连接到 Oracle 数据库,然后打开该连接。
在C# 中:OracleConnection myOracleConnection =new OracleConnection( "User Id=store;Password=store;Data Source=ORCL" ); myOracleConnection.Open(); 在VB.NET 中:Dim myOracleConnection As New OracleConnection( _ "User Id=store;Password=store;Data Source=ORCL") myOracleConnection.Open() User Id 和 Password 属性指定了您所要连接到的模式的数据库用户和口令。Data Source 属性指定了数据库的 Oracle Net 服务名称;初始数据库的默认服务名称为 ORCL。如果您使用的不是初始数据库,或者您的服务名称不同,那么您需要在程序中修改 Data Source 属性的设置。 VB.NET使用ORACLR第 2 步创建一个 OracleTransaction 对象,然后调用 OracleConnection 对象的 BeginTransaction() 方法启动事务。 在C# 中:OracleTransaction myOracleTransaction = myOracleConnection.BeginTransaction(); In VB.NET: Dim myOracleTransaction As OracleTransaction = _ myOracleConnection.BeginTransaction() VB.NET使用ORACLR第3 步创建一个 OracleCommand 对象,用于存储 SQL 语句。 在C# 中:OracleCommand myOracleCommand = myOracleConnection.CreateCommand(); 在VB.NET 中:Dim myOracleCommand As OracleCommand = myOracleConnection.CreateCommand 因为OracleCommand 对象使用 OracleConnection 对象的 CreateCommand() 方法创建的,所以它自动使用在第 2 步中为 OracleConnection 对象设置的事务。 VB.NET使用ORACLR第 4 步将OracleCommand 对象的 CommandText 属性设为向表 product_types 中添加一行的第一条 INSERT 语句。
在C# 中:myOracleCommand.CommandText = "INSERT INTO product_types (" + " product_type_id, name" + ") VALUES (" + " 3, 'Magazine'" + ")"; 在VB.NET 中:myOracleCommand.CommandText = _ "INSERT INTO product_types (" _ " product_type_id, name" _ ") VALUES (" _ " 3, 'Magazine'" _ ")" VB.NET使用ORACLR第 5 步
使用OracleCommand 对象的 ExecuteNonQuery() 方法运行 INSERT 语句。
在C# 中:myOracleCommand.ExecuteNonQuery(); 在VB.NET 中:myOracleCommand.ExecuteNonQuery(); VB.NET使用ORACLR第 6 和第 7 步将OracleCommand 对象的 CommandText 属性设为向表 Products 中添加一行的第二条 INSERT 语句,并运行它。
在C# 中:myOracleCommand.CommandText = "INSERT INTO products (" + " product_id, product_type_id, name, description, price" + ") VALUES (" + " 5, 3, 'Oracle Magazine', 'Magazine about Oracle', 4.99" + ")"; myOracleCommand.ExecuteNonQuery(); 在VB.NET 中:myOracleCommand.CommandText = _ "INSERT INTO products (" _ " product_id, product_type_id, name, description, price" _ ") VALUES (" _ " 5, 3, 'Oracle Magazine', 'Magazine about Oracle', 4.99" _ ")" myOracleCommand.ExecuteNonQuery() VB.NET使用ORACLR第 8 步使用OracleTransaction 对象的 Commit() 方法提交数据库中的事务。
在C# 中:myOracleTransaction.Commit(); 在VB.NET 中:myOracleTransaction.Commit() 在完成 Commit() 方法之后,由 INSERT 语句添加的两行将在数据库中永久记录。 VB.NET使用ORACLR第 9 步使用Close() 方法关闭 OracleConnection 对象。在C# 中:myOracleConnection.Close(); 在VB.NET 中: myOracleConnection.Close() 编译并运行示例程序要编译 C# 示例程序,您可以使用 csc 命令运行 C# 编译器。因为程序使用 Oracle Data Access DLL,所以您应使用 /r 选项指定该 DLL 的完整路径,例如:注意:您需要用您计算机上的相应路径来替换该 DLL 的路径。此外,如果您的计算机找不到 csc 编译器,那么您可能需要运行 Microsoft sdkvars.bat 脚本来首先设置 .NET SDK 的环境变量;您可以在安装 .NET SDK 的 bin 目录中找到该脚本。 如果您遇到以下错误:Example1.cs(10,7):error CS0246:The type or namespace name 'Oracle' could not be found (are you missing a using directive or an assembly reference?) 这说明您没有在编译命令中正确指定 Oracle Data Access DLL。(有关设置的信息,请参阅 John Paul Cook 的技术文章“在 Oracle 数据库上构建 .NET 应用程序”。) 下面是用于编译 VB.NET 程序的等价命令:vbc TransExample1.vb /r:C:\oracle\product\10.1.0\ Client_1\bin\Oracle.DataAccess.dll /r:system.dll /r:system.data.dll 接下来,输入以下命令,运行示例: An exception was thrown Message = ORA-12514:TNS:listener does not currently know of service requested in connect descriptor 您将看到程序的输出。不过,如果您遇到类似以下的异常这说明 OracleConnection 对象的连接字符串中的 Data Source 的设置不正确。您应当咨询您的 DBA 或查阅 Oracle Net 文档以获得更多详细信息。 如果您使用的是 VS .NET,那么您可以遵循以下指示来编译和运行 C# 程序 TransExample1.cs:
创建一个新的 C# 控制台应用程序。FileNew Project,然后选择 Visual C# Projects,Console Application。
事务处理是在数据处理时经常遇到的问题,经常用到的方法有以下3种总结整理如下:
方法1:直接写入到sql 中
在存储过程中使用 BEGIN TRANS, COMMIT TRANS, ROLLBACK TRANS 实现
begin trans
declare @orderDetailsError int,@procuntError int
delete from [order details] where productid=42
select @orderDetailsError =@@error
delete from products where productid=42
select @procuntError=@@error
if(@orderDetailsError =0 and @procuntError=0)
COMMIT TRANS
else
ROLLBACK TRANS
优点:
所有事务逻辑包含在一个单独的调用中
拥有运行一个事务的最佳性能
独立于应用程序
限制:
事务上下文仅存在于数据库调用中
数据库代码与数据库系统有关
方法2 :使用ADO.NET 实现
使用ADO.NET 实现,使用这种方式的优点是可以在中间层来管理事务,当然你也可以选择在数据层来实现。
SqlConnection 和OleDbConnection 对象有一个 BeginTransaction 方法,它可以返回 SqlTransaction
或者OleDbTransaction 对象。而且这个对象有 Commit 和 Rollback 方法来管理事务
SqlConnection sqlConnection = new SqlConnection("workstation id=WEIXIAOPING;packet size=4096;user id=sa;initial catalog=Northwind;persist security info=False");
sqlConnection.Open();
SqlTransaction myTrans = sqlConnection.BeginTransaction();
SqlCommand sqlInsertCommand = new SqlCommand();
sqlInsertCommand.Connection = sqlConnection
sqlInsertCommand.Transaction=myTrans;
try{
sqlInsertCommand.CommandText="insert into tbTree(Context,ParentID) values('北京',1)";
sqlInsertCommand.ExecuteNonQuery();
sqlInsertCommand.CommandText="insert into tbTree(Context,ParentID) values('上海',1)";
sqlInsertCommand.ExecuteNonQuery();
myTrans.Commit();
}catch(Exception ex)
{
myTrans.Rollback();
}
finally
{
sqlConnection.Close();
}
优点:
简单性
和数据据事务差不多的快
独立于数据库,不同数据库的专有代码被隐藏了
缺点:
事务不能跨越多个数据库连接
事务执行在数据库连接层上,所以需要在事务过程中维护一个数据库连接
ADO.NET分布事务也可以跨越多个数据库,但是其中一个SQL SERVER 数据库的话,通过用SQL SERVER连接服务器连接到别的数据库,但是如果是在DB2和Orcal之间就不可以。
以上两种事务是经常用到的事务处理方法。
方法3 COM+事务(分布式事务)
.NET Framework 依靠 MTS/COM+ 服务来支持自动事务。COM+ 使用 Microsoft Distributed Transaction Coordinator (DTC) 作为事务管理器和事务协调器在分布式环境中运行事务。
这样可使 .NET 应用程序运行跨多个资源结合不同操作(例如,将定单插入 SQL Server 数据库、将消息写入 Microsoft 消息队列 (MSMQ) 队列、以及从 Oracle 数据库检索数据)
的事务。
COM+事务处理的类必须继承System.EnterpriseServices.ServicedComponent,其实web service就是继承System.EnterpriseServices.ServicedComponent,所以web service也支持
COM+事务。
定义一个COM+事务处理的类
[Transaction(TransactionOption.Required)]
public class DataAccess:System.EnterpriseServices.ServicedComponent
{
}
TransactionOption枚举类型支持5个COM+值(Disabled,NotSupported,Required,RequiresNew,Supported)
Disabled 忽略当前上下文中的任何事务。
NotSupported 使用非受控事务在上下文中创建组件。
Required 如果事务存在则共享事务,并且如有必要则创建新事务。
RequiresNew 使用新事务创建组件,而与当前上下文的状态无关。
Supported 如果事务存在,则共享该事务。
一般来说COM+中的组件需要Required 或Supported。当组件用于记录或查帐时RequiresNew 很有用,因为组件应该与活动中其他事务处理的提交或回滚隔离开来。
派生类可以重载基类的任意属性。如DataAccess选用Required,派生类仍然可以重载并指定RequiresNew或其他值。
COM+事务有手动处理和自动处理,自动处理就是在所需要自动处理的方法前加上[AutoComplete],根据方法的正常或抛出异常决定提交或回滚。
手动处理就是调用ContextUtil类中EnableCommit,SetComplete,SetAbort方法。
public string testTransaction()
{
try
{
ContextUtil.EnableCommit();
InsertARecord1();
InsertARecord2();
ContextUtil.SetComplete();
return "succeed!";
}
catch(Exception ex)
{
ContextUtil.SetAbort();
return "failed!";
}
}
public void InsertARecord1()
{
string strconn="workstation id=WEIXIAOPING;packet size=4096;user id=sa;initial catalog=Northwind;persist security info=False";
SqlConnection conn=new SqlConnection(strconn);
conn.Open();
SqlCommand command=new SqlCommand("insert into tbTree(Context,ParentID) values('北京',1)",conn);
command.ExecuteNonQuery();
conn.Close();
}
public void InsertARecord2()
{
string strconn="workstation id=WEIXIAOPING;packet size=4096;user id=sa;initial catalog=Northwind;persist security info=False";
SqlConnection conn=new SqlConnection(strconn);
conn.Open();
SqlCommand command=new SqlCommand("insert into tbTree(Context,ParentID) values('上海',1)",conn);
command.ExecuteNonQuery();
conn.Close();
}
在需要事务跨 MSMQ 和其他可识别事务的资源(例如,SQL Server 数据库)运行的系统中,只能使用 DTC 或 COM+ 事务,除此之外没有其他选择。DTC 协调参与分布式事务的所有资源管理器, 也管理与事务相关的操作。
这种做法的缺点是,由于存在 DTC 和 COM 互操作性开销,导致性能降低。
COM+事务处理的类必须强命名。