如何Mysql触发器中抛出一个异常

从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())

}

确实不行，这是MYSQL的存储过程十分不完善的地方 我也找了很久，后来想了了个巧妙的方法 IF @i>30 THEN -- 在这里抛出异常和取消 insert *** 作 SELECT E001 INTO M_ERRMSGend if 1. MYSQL没有抛出异常的语句,MYSQL已经承认此语句为SIGNAL,目前还没封装. 2. 所以目前能做的是, 要在抛出异常的地方,插入一个错误语句 3. 这个错误语句只能是运行期错误语句,否则编译无法通过 4. 用SELELCT E001 INTO M_ERRMSG, 其中E001可以随便定义为一个不存在字段或函数, 因为这个错误是运行期错误,编译是可以通过的. 后面的INTO M_ERRMSG实际上没有什么用处, 因为SELECT 后面必须加INTO一个变量,否则编译也是不可以通过。

---