事务处理是由以一个单一的逻辑单位完成的一系列操作,它可以由一系列的SQL语句、SELECT、INSERT、UPDATE、DELETE组成,如果在该单位包含的操作执行完毕后没有发生错误,那么它对数据库所作的改变就是永久的了。如果一旦有错误发生,它就不会对数据库作任何修改或改变。
要定义一个事务,需要使用Begin tran命令,在这一命令之后的任何语句都将被认为是事务的一部分。命令Commit用来完成事务,并使事务对数据库所作的修改成为永久的。Rollback命令用来取消一个事务,并还原事务对数据库所作的修改。
下面是一个事务的例子:
[SQL SERVER7.0 or SQL SERVER2000]
BEGIN TRAN
INSERT INTO PRODUCT(PRODUCTID, PRODUCTNAME) VALUES("0001", "KEYBOARD")
UPDATE PRODUCT SET PRICE=12 WHERE PRODUCTID= "0002"
IF (@ERROR>0)
ROLLBACK
ELSE
什么是异常处理?
开发一种错误消息处理机制、并向用户提供有用的、清楚、有意义的信息也是编程人员的任务之一,异常处理就是能够提供这一服务的一种机制。一旦事务失败,服务器就会向系统发出一个用于帮助用户发现并修复邦联的数据库错误信息。我们可以异常处理功能来获取这种异常信息,并修复出现的故障。异常处理功能的用法如下所示:
[c#]
| try
{ //数据库操作命令 } catch (Exception e) { ?//如果有异常发生,这部分语句将被执行 } finally { ?//无论是否有异常发生,这部分语句都会得到执行 } |
1、在一个存储过程中编写事务语句,并使用下面的控制发现是否有错误发生,返回相应的值,互联网应用程序会根据返回的值显示正确的和容易理解的错误信息。下面是一个事务的例子:
| [Store Procedure]
CREATE PROCEDURE PRODUCT_SAVE( AS DECLARE (@USERID CHAR(5), @LOCATION VARCHAR(50), ) BEGIN TRAN UPDATE ADDRESS SET LOCATION=@LOCATION WHERE USERID=@USERID IF (@@ERROR>0) BEGIN @RETURNS=-1 /* Fail to Update */ ROLLBACK END ELSE @RETURNS=0 /* Succeed to update */ COMMIT RETURN @RETURNS [Web Application in C#] int values; DBClass dbc=new DBClass(); // 使用new命令生成一个数据库类 values=dbc.updatedb("0001", "23 Rain Street"); //And call its function member to update record if (values==0) Lable_message.text= "Update successfully"; else Lable_message.text= "Sorry, can not update this record, please contact your DBA." |
2、在.NET框架中,我们可以使用SqlTransaction类定义一个事务。此后,我们就可以使用commit或rollback函数控制事务。当然了,我们也可以使用.NET框架提供的异常处理功能获取系统异常。下面是一个有关的例子:
| [Web Applicaion in C#]
SqlConnection myConnection = new SqlConnection("Data Source=localhost;Initial Catalog=Northwind;Integrated Security=SSPI;"); myConnection.Open(); SqlTransaction myTrans = myConnection.BeginTransaction(); //使用New新生成一个事务 SqlCommand myCommand = new SqlCommand(); myCommand.Transaction = myTrans; try { myCommand.CommandText = "Update Address set location='23 rain street' where userid='0001'"; myCommand.ExecuteNonQuery(); myTrans.Commit(); Console.WriteLine("Record is udated."); } catch(Exception e) { myTrans.Rollback(); Console.WriteLine(e.ToString()); Console.WriteLine("Sorry, Record can not be updated."); } finally { myConnection.Close(); } |
本文引用的地址为http://webservices.ctocio.com.cn/wsnettec/375/8106375.shtml