
on时,如果有错误发生,在批处理语句结束后,系统会自动回滚所有的sql *** 作。当set xact_abort
off时,如果有错误发生,在批处理语句结束后,系统会执行所有没有发生错误的语句,发生错误的语句将不会被执行。
在存储过程中使用事务时,如果存在try…catch语句块,那么当捕获到错误时,需要在catch语句块中手动进行Rollback *** 作,否则系统会给客户端传递一条错误信息。如果在存储过程开始处将set
xact_abort
on,那么当有错误发生时,系统会将当前事务置为不可提交状态,即会将xact_state()置为-1,此时只可以对事务进行Rollback *** 作,不可进行提交(commit) *** 作,那么我们在catch语句块中就可以根据xact_state()的值来判断是否有事务处于不可提交状态,如果有则可以进行rollback *** 作了。如果在存储过程开始处将set
xact_abort
off,那么当有错误发生时,系统不会讲xact_state()置为-1,那么我们在catch块中就不可以根据该函数值来判断是否需要进行
rollback了,但是我们可以根据@@Trancount全局变量来判断,如果在catch块中判断出@@Trancount数值大于0,代表还有未提交的事务,既然进入catch语句块了,那么还存在未提交的事务,该事务应该是需要rollback的,但是这种方法在某些情况下可能判断的不准确。推荐的方法还是将set
xact_abort on,然后在catch中判断xact_state()的值来判断是否需要Rollback *** 作。
下面我们来看看两个例子:
一.使用Set xact_abort on
代码
Create proc myProcedure
As
begin
set xact_abort on
begin try
begin tran
insert into TestStu values('Terry','boy',23)
insert into TestStu values('Mary','girl',21)
commit tran
end try
begin catch
--在此可以使用xact_state()来判断是否有不可提交的事务,不可提交的事务
--表示在事务内部发生错误了。Xact_state()有三种值:-1.事务不可提交;
--1.事务可提交;0.表示没有事务,此时commit或者rollback会报错。
if xact_state()=-1
rollback tran
end catch
end
二.使用Set xact_abort off
代码
Create proc myProcedure
As
begin
set xact_abort off
begin try
begin tran
insert into TestStu values('Terry','boy',23)
insert into TestStu values('Mary','girl',21)
commit tran
end try
begin catch
--在此不可以使用xact_state来判断是否有不可提交的事务
--只可以使用@@Trancount来判断是否有还未提交的事务,未提交的事务未必
--就是不可提交的事务,所以使用@@TranCount>0后就RollBack是不准确的
if @@TranCount>0
rollback tran
end catch
end
另外,对于@@Trancount需要说明的是,begin tran 语句将 @@Trancount加 1。Rollback tran将
@@Trancount递减到 0,但 Rollback tran savepoint_name 除外,它不影响 @@Trancount。Commit tran 或 Commit work 将 @@Trancount 递减 1。
从Mysql 5.5 开始为我们提供了SIGNAL函数来实现这个功能。[sql] view plain copy
CREATE TRIGGER `tg_order_create` AFTER INSERT ON `tp_order` FOR EACH ROW BEGIN
DECLARE msg varchar(200)
/*冻结金额*/
IF 2=NEW.condition THEN
UPDATE `tp_user` SET `frozen_amount`=`frozen_amount`+NEW.amount WHERE `id`=NEW.uid AND `amount`-`frozen_amount` >NEW.amount
/*如果余额不足,产生一个错误*/
IF ROW_COUNT() <>1 THEN
set msg = "用户余额不足以完成支付."
SIGNAL SQLSTATE 'HY000' SET MESSAGE_TEXT = msg
END IF
/*扣除金额*/
ELSEIF 3=NEW.condition THEN
UPDATE `tp_user` SET `amount`=`amount`-NEW.amount WHERE `id`=NEW.uid AND `amount`-`frozen_amount` >NEW.amount
/*如果余额不足,产生一个错误*/
IF ROW_COUNT() <>1 THEN
set msg = "用户余额不足以完成支付."
SIGNAL SQLSTATE 'HY000' SET MESSAGE_TEXT = msg
END IF
END IF
END
这里这条触发器的功能是库存 *** 作,当库存足够的时候 减少库存,否则 抛出一个异常并报告商品库存不足:
[sql] view plain copy
CREATE TRIGGER `TG_order_detail_dec_stock` BEFORE INSERT ON `tp_order_detail` FOR EACH ROW BEGIN
DECLARE msg VARCHAR(200)
UPDATE `tp_stock` SET `num`=`num`-NEW.num WHERE `goods_id`=NEW.goods_id AND `mid`=NEW.mid AND `num`>=NEW.num
IF ROW_COUNT() <>1 THEN
SELECT CONCAT(`name`, ' 库存不足.') INTO msg FROM `tp_goods` WHERE `id`=NEW.goods_id
SIGNAL SQLSTATE 'HY000' SET MESSAGE_TEXT = msg
END IF
END
在PHP端的处理(注:使用ThinkPHP框架):
[php] view plain copy
//前面省略若干行....
try {
if (false === ($order_pk = $tbl_order->add($order))) {
$tbl->rollback()
echo json_encode(array('success' =>-1, 'message' =>"创建订单失败!."), JSON_UNESCAPED_UNICODE)
return
}
}catch (\PDOException $e){
$errInfo=$e->errorInfo[2]
$tbl->rollback()
echo json_encode(array('success' =>-1, 'message' =>"创建订单失败!,{$errInfo}"), JSON_UNESCAPED_UNICODE)
return
}
//后面省略若干行....
直接使用try...catch....结构。比如:try
{
DB::query("SELECT count(*) FROM pre_111 WHERE fid = $fid"
}
catch(exception $ex)
{
echo($ex->getMessage())
}
欢迎分享,转载请注明来源:内存溢出
微信扫一扫
支付宝扫一扫
评论列表(0条)