mysql存储过程之异常处理篇

mysql存储过程也提供了对异常处理的功能：通过定义HANDLER来完成异常声明的实现

语法如下：

DECLARE handler_type HANDLER FOR condition_value[,...] sp_statement handler_type: CONTINUE | EXIT condition_value: SQLSTATE [VALUE] sqlstate_value | condition_name | SQLWARNING | NOT FOUND | SQLEXCEPTION | mysql_error_code

Handlers类型:

1, EXIT: 发生错误时退出当前代码块（可能是子代码块或者main代码块）
2, CONTINUE: 发送错误时继续执行后续代码

condition_value：

condition_value支持标准的SQLSTATE定义；

SQLWARNING是对所有以01开头的SQLSTATE代码的速记

NOT FOUND是对所有以02开头的SQLSTATE代码的速记

SQLEXCEPTION是对所有没有被SQLWARNING或NOT FOUND捕获的SQLSTATE代码的速记

除了SQLSTATE值，MySQL错误代码也被支持

但是对于mysql而言，优先级如下：
MySQL Error code > SQLSTATE code > 命名条件

使用SQLSTATE还是MySQL Error Code？

1，SALSTATE是标准，貌似会更portable，但是实际上MySQL、DB2、Oracle等等的存储程序语法大相径庭，所以portable的优势不存在 
2，MySQL error code与SQLSTATE并不是一一对应的，比如很多MySQL error code都映射到同一SQLSTATE code(HY000)

当MySQL客户端碰到错误时，它会报告MySQL error code和相关的SQLSATE code:

mysql > CALL nosuch_sp();
ERROR 1305 (42000): PROCEDURE sqltune.nosuch_sp does not exist

具体的sqlsdate和mysql error code的对应可以在http://dev.mysql.com/doc/的MySQL reference manual的附录B找到完整的最新的error codes

condition_name：命名条件

MySQL error code或者SQLSTATE code的可读性太差，所以引入了命名条件:

语法：

Java代码  

1. DECLARE condition_name CONDITION FOR condition_value
2. condition_value:
3. SQLSTATE [VALUE] sqlstate_value
4. | mysql_error_code

使用:

Java代码  

1. # original
2. DECLARE CONTINUE HANDLER FOR 1216 MySQL_statements;
3. # changed
4. DECLARE foreign_key_error CONDITION FOR 1216;
5. DECLARE CONTINUE HANDLER FOR foreign_key_error MySQL_statements;

用condition_name为错误代码起了个别名。

示例1：Duplicate entry Handler

Sql代码  

1. CREATE PROCEDURE sp_add_location
2. (in_location    VARCHAR(30),
3. in_address1    VARCHAR(30),
4. in_address2    VARCHAR(30),
5. zipcode        VARCHAR(10),
6. OUT out_status VARCHAR(30))
7. BEGIN
8. DECLARE CONTINUE HANDLER
9. FOR 1062
10. SET out_status=‘Duplicate Entry‘;
11. SET out_status=‘OK‘;
12. INSERT INTO locations
13. (location,address1,address2,zipcode)
14. VALUES
15. (in_location,in_address1,in_address2,zipcode);
16. END;

示例2： Last Row Handler

Sql代码  

1. CREATE PROCEDURE sp_not_found()
2. READS SQL DATA
3. BEGIN
4. DECLARE l_last_row INT DEFAULT 0;
5. DECLARE l_dept_id INT:
6. DECLARE c_dept CURSOR FOR
7. SELECT department_id FROM departments;
8. DECLARE CONTINUE HANDLER FOR NOT FOUND SET l_last_row=1;
9. OPEN c_dept;
10. dept_cursor: LOOP
11. FETCH c_dept INTO l_dept_id;
12. IF (l_last_row=1) THEN
13. LEAVE dept_cursor;
14. END IF;
15. END LOOP dept_cursor;
16. CLOSE c_dept;
17. END;

综合示例：

Sql代码  

1. CREATE PROCEDURE sp_add_department
2. (p_department_name     VARCHAR(30),
3. p_manager_surname     VARCHAR(30),
4. p_manager_firstname   VARCHAR(30),
5. p_location            VARCHAR(30),
6. OUT p_sqlcode         INT,
7. OUT p_status_message  VARCHAR(100))
8. BEGIN
9. /* START Declare Conditions */
10. DECLARE duplicate_key CONDITION FOR 1062;
11. DECLARE foreign_key_violated CONDITION FOR 1216;
12. /* END Declare COnditions */
13. /* START Declare variables and cursors */
14. DECLARE l_manager_id INT;
15. DECLARE csr_mgr_id CURSOR FOR
16. SELECT employee_id FROM employees
17. WHERE surname=UPPER(p_manager_surname)
18. AND firstname=UPPER(p_manager_firstname);
19. /* END Declare variables and cursors */
20. /* START Declare Exception Handlers */
21. DECLARE CONTINUE HANDLER FOR duplicate_key
22. BEGIN
23. SET p_sqlcode=1052;
24. SET p_status_message=‘Duplicate key error‘;
25. END;
26. DECLARE CONTINUE HANDLER FOR foreign_key_violated
27. BEGIN
28. SET p_sqlcode=1216;
29. SET p_status_message=‘Foreign key violated‘;
30. END;
31. DECLARE CONTINUE HANDLER FOR NOT FOUND
32. BEGIN
33. SET p_sqlcode=1329;
34. SET p_status_message=‘No record found‘;
35. END;
36. /* END Declare Exception Handlers */
37. /* START Execution */
38. SET p_sqlcode=0;
39. OPEN csr_mgr_id;
40. FETCH csr_mgr_id INTO l_manager_id;
41. IF p_sqlcode<>0 THEN     /* Failed to get manager id */
42. SET p_status_message=CONCAT(p_status_message,‘ when fetching manager id‘);
43. ELSE                     /* Got manager id, we can try and insert */
44. INSERT INTO departments (department_name, manager_id, location)
45. VALUES(UPPER(p_department_name), l_manager_id, UPPER(p_location));
46. IF p_sqlcode<>0 THEN /* Failed to insert new department */
47. SET p_status_message=CONCAT(p_status_message, ‘ when inserting new department‘);
48. END IF;
49. END IF;
50. CLOSE csr_mgr_id;
51. /* END Execution */
52. END
53. 原文：http://wwty.iteye.com/blog/698239