您的位置:首页 > 数据库

SQL 存储过程入门(事务)

2014-02-11 16:11 381 查看
本篇我们来讲一下事务处理技术。为什么要使用事务呢,事务有什么用呢,举个例子。假设我们现在有个业务,当做成功某件事情的时候要向2张表中插入数据,A表,B表,我们插入的顺序是先插入A,再插入B表,如果都顺利插入成功了,当然没有问题,如果任意一张表插入失败了,而另一张表插入成功了,插入成功的表就是垃圾数据了。我们要判断,任意一张表插入失败都回滚,就是都不插入,这就是事务的基本使用。一,sql事务定义所谓事务是用户定义的一个数据库操作序列,是一个不可分割的工作单位。他包含的所有数据库操作命令作为一个整体一起向系提交或撤消,这些操作要么全做,要么全不做,例如在关系数据库中,一个事务可以是一条sql语句,或者是一组sql语句或者是整个程序。二,sql事务语句开始事务:BEGINTRANSACTION
提交事务:COMMITTRANSACTION
回滚事务:ROLLBACKTRANSACTION事务通常是以begintransaction开始的,以commit或rollback结束,commit表示提交,既提交事务的所有操作。具体的说就是将事务中所有对数据库的更新写到磁盘上的物理数据中去,事务正常结束。Rollback表示回滚,在事务运行的过程中发生了某种故障,事务不能继续执行,系统将事务中对数据库的所有已完成的操作全部取消,回滚到事务开始时的状态。这里的操作指对数据库的更新操作。三,事务的特性(ACIDPropertites)原子性(Atomicity):事务是数据库的逻辑工作单位,事务中包括的诸操作要么都做,要么都不做。一致性(Consistency):事物完成时,数据必须是一致的,也就是说,和事物开始之前,数据存储中的数据处于一致状态。保证数据的无损隔离性(Isolation):一个事务的执行不能被其他事务干扰。并发执行的各个事务之间不能互相干扰。持续性(Durability):指一个事务一旦提交,它对数据库中数据的改变时永久性的。四,存储过程使用事务这里做好准备工作,建立一张表,插入一条数据。
--新建表
createtableuserinfo
(IDintidentity(1,1),
UserNamevarchar(20)primarykey,
UserPwdvarchar(20),
RegisterTimedatetime
)
--初始化插入一条记录
insertintouserinfo(username,userpwd,RegisterTime)
values('admin','admin',getdate())

select*fromuserinfo

-------------------

IDuserNameUserPwdRegisterTime

1adminadmin2013-04-1310:30:36.387
从表结构看出,UserName是主键,是唯一值,现在要插入两条数据
CreateProcedureMyProcedure
AS
Begin
SetNOCOUNTON;
SetXACT_ABORTon;--这句话非常重要

BeginTran--开始事务

insertintouserinfo(username,userpwd,RegisterTime)values('admin','admin',getdate())
insertintouserinfo(username,userpwd,RegisterTime)values('jack','jack',getdate())

CommitTran--提交事务
End
执行
execMyProcedure

/*
消息2627,级别14,状态1,过程MyProcedure,第9行
违反了PRIMARYKEY约束'PK__userinfo__C9F284577F60ED59'。不能在对象'dbo.userinfo'中插入重复键。

*/
--查看数据库

------------------------------------------------
12adminadmin2013-04-1310:41:22.457
上面说了SetXACT_ABORTon;这句话非常重要,为什么呢?我们来设置为off的时候来看效果
CreateProcedureMyProcedure
AS
Begin
SetNOCOUNTON;
SetXACT_ABORToff;--这句话非常重要

BeginTran--开始事务

insertintouserinfo(username,userpwd,RegisterTime)values('admin','admin',getdate())
insertintouserinfo(username,userpwd,RegisterTime)values('jack','jack',getdate())

CommitTran--提交事务
End
执行并查看结果
execMyProcedure

/*
消息2627,级别14,状态1,过程MyProcedure,第9行
违反了PRIMARYKEY约束'PK__userinfo__C9F284577F60ED59'。不能在对象'dbo.userinfo'中插入重复键。
语句已终止。

*/

--查看结果
select*fromuserinfo
-------------------------------------------
12adminadmin2013-04-1310:41:22.457
15jackjack2013-04-1310:44:05.203
这里我们将XACT_ABORT设置为off,事务中执行已经出现错误了,但是还是将“jack”这条记录插入进去了。这就违反了事务的一致性原则了。所以我们要将XACT_ABORT设置为ON的原因。看看下面说明:1、使用存储过程执行事物,需要开启XACT_ABORT参数(默认值为Off),将该参数设置为On,表示当执行事务时,如果出错,会将transcation设置为uncommittable状态,那么在语句块批处理结束后将回滚所有操作;如果该参数设置为Off,表示当执行事务时,如果出错,出错的语句将不会执行,其他正确的操作继续执行。2、当SETNOCOUNT为ON时,不返回计数(计数表示受Transact-SQL语句影响的行数,例如在Sqlserver查询分析器中执行一个delete操作后,下方窗口会提示(3)RowsAffected)。当SETNOCOUNT为OFF时,返回计数,我们应该在存储过程的头部加上SETNOCOUNTON这样的话,在退出存储过程的时候加上SETNOCOUNTOFF这样的话,以达到优化存储过程的目的。
五,存储过程中事务和try…catch联合使用

如果我们在存储过程事务中出现了错误,我们不想显示错误,我们想动态处理这些错误信息,比如出错了,我们回滚,我们设置某个属性的值,这里就会用到try,catch了
还是从例子出发
CreateProcedureMyProcedure
AS
Begin
SetNOCOUNTON;
SetXACT_ABORTON;--这句话非常重要
begintry
BeginTran--开始事务

insertintouserinfo(username,userpwd,RegisterTime)values('admin','admin',getdate())
insertintouserinfo(username,userpwd,RegisterTime)values('jack','jack',getdate())

CommitTran--提交事务
endtry
begincatch
--在此可以使用xact_state()来判断是否有不可提交的事务,不可提交的事务

--表示在事务内部发生错误了。Xact_state()有三种值:-1.事务不可提交;

--1.事务可提交;0.表示没有事务,此时commit或者rollback会报错。

ifxact_state()=-1
rollbacktran;
endcatch

SetXACT_ABORTOFF;

End
当我们执行的时候不会再出现刚才的那种错误了,
execMyProcedure

--------------
命令已成功完成。--没有出现那种错误

select*fromuserinfo

--------------------------------------------------
22adminadmin2013-04-1310:55:50.653
可以看到,事务回滚了,没有插入数据了。
如果我们想看到错误信息呢,再来看个例子
CreateProcedureMyProcedure
AS
Begin
SetNOCOUNTON;
SetXACT_ABORTON;--这句话非常重要
begintry
BeginTran--开始事务

insertintouserinfo(username,userpwd,RegisterTime)values('admin','admin',getdate())
insertintouserinfo(username,userpwd,RegisterTime)values('jack','jack',getdate())

CommitTran--提交事务
endtry
begincatch
--在此可以使用xact_state()来判断是否有不可提交的事务,不可提交的事务

--表示在事务内部发生错误了。Xact_state()有三种值:-1.事务不可提交;

--1.事务可提交;0.表示没有事务,此时commit或者rollback会报错。

ifxact_state()=-1
begin
rollbacktran;
SELECTERROR_NUMBER()ASErrorNumber,
ERROR_MESSAGE()ASErrorMessage;
end
endcatch

End
执行
execMyProcedure

--------------------------------
ErrorNumberErrorMessage
2627违反了PRIMARYKEY约束'PK__userinfo__C9F284577F60ED59'。不能在对象'dbo.userinfo'中插入重复键。
说明:1、捕获错误的函数有很多,如下:ERROR_NUMBER()返回错误号。    ERROR_SEVERITY()返回严重性。    ERROR_STATE()返回错误状态号。    ERROR_PROCEDURE()返回出现错误的存储过程或触发器的名称。    ERROR_LINE()返回导致错误的例程中的行号。    ERROR_MESSAGE()返回错误消息的完整文本。该文本可包括任何可替换参数所提供的值,如长度、对象名或时间。

在存储过程中使用事务时,如果存在try…catch语句块,那么当捕获到错误时,需要在catch语句块中手动进行Rollback操作,否则系统会给客户端传递一条错误信息。如果在存储过程开始处将setxact_aborton,那么当有错误发生时,系统会将当前事务置为不可提交状态,即会将xact_state()置为-1,此时只可以对事务进行Rollback操作,不可进行提交(commit)操作,那么我们在catch语句块中就可以根据xact_state()的值来判断是否有事务处于不可提交状态,如果有则可以进行rollback操作了。如果在存储过程开始处将setxact_abortoff,那么当有错误发生时,系统不会讲xact_state()置为-1,那么我们在catch块中就不可以根据该函数值来判断是否需要进行rollback了,但是我们可以根据@@Trancount全局变量来判断,如果在catch块中判断出@@Trancount数值大于0,代表还有未提交的事务,既然进入catch语句块了,那么还存在未提交的事务,该事务应该是需要rollback的,但是这种方法在某些情况下可能判断的不准确。推荐的方法还是将setxact_aborton,然后在catch中判断xact_state()的值来判断是否需要Rollback操作。下面再来看个例子,在实践中不断熟悉。这个例子就是,如果插入重复的数据给出提示信息并返回
--判断要创建的存储过程名是否存在
ifExists(SelectnameFromsysobjectsWherename='P_InsertUser'Andtype='P')
--删除存储过程
DropProceduredbo.P_InsertUser
Go
USE[StoreTest]
GOcreateProcedure[dbo].[P_InsertUser]
@UserNamevarchar(100),
@UserPwdvarchar(100)
AS
Begin
SetNOCOUNTON;
SetXACT_ABORTON;--这句话非常重要Begintry
if(isnull(@UserName,'')='')
  begin
print'UserNameisempty';
    return;
end
declare@iCountint;
set@iCount=0;
select@iCount=Count(1)fromuserinfowith(nolock)whereusername=@UserName;
if(@iCount>0)
begin
print'thecurrentnamealreadyexist';
return
end
BeginTran--开始事务,事务中不能有return语句
--insert
insertintouserinfo(
username
,userpwd
,RegisterTime
)
values(
@UserName,
@UserPwd,
getdate()
)CommitTran--提交事务
endtry
begincatch
--在此可以使用xact_state()来判断是否有不可提交的事务,不可提交的事务
--表示在事务内部发生错误了。Xact_state()有三种值:-1.事务不可提交;
--1.事务可提交;0.表示没有事务,此时commit或者rollback会报错。
ifxact_state()=-1
begin
rollbacktran;--事务回滚
SELECTERROR_NUMBER()ASErrorNumber,
ERROR_MESSAGE()ASErrorMessage;
end
endcatch
SetXACT_ABORToff;
End--调用存储过程
exec[P_InsertUser]'','admin'select*fromuserinfoGO
事务的东西很多,这里希望能起到抛砖引玉的效果。
内容来自用户分享和网络整理,不保证内容的准确性,如有侵权内容,可联系管理员处理 点击这里给我发消息
标签: