存储过程语法

一、存储过程的变量

①变量的声明：

DECLARE var_name[,...] type [DEFAULT value]

这个语句被用来声明局部变量。要给变量提供一个默认值，需要包含一个DEFAULT子句。值可以被指定为一个表达式，不需要为一个常数。如果没有DEFAULT子句，初始值为NULL。

局部变量的作用范围在它被声明的BEGIN ... END块内。它可以被用在嵌套的块中，除了那些用相同名字声明变量的块。

②变量赋值：
A：使用SET语句：

SET var_name = expr [, var_name = expr]...

也可以用语句代替SET来为用户变量分配一个值。在这种情况下，分配符必须为:=而不能用=，因为在非SET语句中=被视为一个比较
操作符，如下所示：

mysql> SET @t1=0, @t2=0,@t3=0;
mysql> SELECT @t1:=0,@t2:=0,@t3:=0;

对于使用select语句为变量赋值的情况，若返回结果为空，即没有记录，此时变量的值为上一次变量赋值时的值，如果没有对变量赋过值，则为NULL。

B：使用SELECT....INTO语句：

SELECT col_name[,...] INTO var_name[,...]table_expr 这个SELECT语法把选定的列直接存储到变量。因此，只有单一的行可以被取回。

例：SELECT id,data INTO x,y FROM test.t1 LIMIT 1;

二、BEGIN....END复合语句：

[begin_label:] BEGIN

[statement_list]

END [end_label]

存储子程序可以使用BEGIN ... END复合语句来包含多个语句。statement_list代表一个或多个语句的列表。statement_list之内每个语句都必须用分号（；）来结尾。

复合语句可以被标记。除非begin_label存在，否则end_label不能被给出，并且如果二者都存在，他们必须是同样的。

三、流程控制：

① IF语句：

IF search_condition THEN statement_list   
[ELSEIF search_condition THEN statement_list] ...   
[ELSE statement_list]
END IF 

IF实现了一个基本的条件构造。如果search_condition求值为真，相应的SQL语句列表被执行。如果没有search_condition匹配，在ELSE子句里的语句列表被执行。statement_list可以包括一个或多个语句。

例： student表：

mysql> select * from student;
+---------------+---------------+----------------------+-----------+----+
| nickname      | password      | email                | address   | id |
+---------------+---------------+----------------------+-----------+----+
| elgin         | 12345         | dddffg@qq.com        | xinbei9-2 |  1 |
| elgin         | 12345         | dddffg@qq.com        | xinbei9-2 |  2 |
| seth          | 12345         | dddffg@qq.com        | xinbei9-2 |  3 |
| 3344          | ddff3322      | dddffg@qq.com        | xinbei9-2 |  4 |
| ddddfff       | procedure1234 | dddffg@qq.com        | xinbei9-2 |  5 |
| jdbcName      | jdbc1234      | dddffg@qq.com        | xinbei9-2 |  6 |
| testProcedure | procedure1234 | procedure123@163.com | china.js  |  7 |
| jdbcName      | jdbc1234      | jdbc1234@gmail.com   | china.js  |  9 |
+---------------+---------------+----------------------+-----------+----+
8 rows in set

使用流程控制的存储过程：

mysql> create procedure testif(sid varchar(10))
-> begin
-> if sid='01' then
-> select * from student where id=1;
-> elseif sid='02' then
-> select * from student where id=2;
-> else
-> select * from student where id=7;
-> end if;
-> end;
Query OK, 0 rows affected

调用结果：

mysql> call testif('01');
+----------+----------+---------------+-----------+----+
| nickname | password | email         | address   | id |
+----------+----------+---------------+-----------+----+
| elgin    | 12345    | dddffg@qq.com | xinbei9-2 |  1 |
+----------+----------+---------------+-----------+----+
1 row in set

Query OK, 0 rows affected

mysql> call testif('02');
+----------+----------+---------------+-----------+----+
| nickname | password | email         | address   | id |
+----------+----------+---------------+-----------+----+
| elgin    | 12345    | dddffg@qq.com | xinbei9-2 |  2 |
+----------+----------+---------------+-----------+----+
1 row in set

Query OK, 0 rows affected

mysql> call testif(null);
+---------------+---------------+----------------------+----------+----+
| nickname      | password      | email                | address  | id |
+---------------+---------------+----------------------+----------+----+
| testProcedure | procedure1234 | procedure123@163.com | china.js |  7 |
+---------------+---------------+----------------------+----------+----+
1 row in set

Query OK, 0 rows affected

② CASE 语句：

CASE case_value 
WHEN when_value THEN statement_list   
[WHEN when_value THEN statement_list] ...   
[ELSE statement_list]
END CASE
Or:
CASE 
WHEN search_condition THEN statement_list   
[WHEN search_condition THEN statement_list] ...   
[ELSE statement_list]
END CASE

依旧使用student表：

mysql> create procedure testcase(sid int)
-> begin
-> declare x int;
-> set x=sid+1;
-> case
-> when 10 then select * from student where id=5;
-> when 10 then select * from student where id=1;
-> else select * from student where id=7;
-> end case;
-> end;
Query OK, 0 rows affected

调用结果：

mysql> call testcase(9);
+----------+----------+---------------+-----------+----+
| nickname | password | email         | address   | id |
+----------+----------+---------------+-----------+----+
| elgin    | 12345    | dddffg@qq.com | xinbei9-2 |  1 |
+----------+----------+---------------+-----------+----+
1 row in set

Query OK, 0 rows affected

mysql> call testcase(10);
+----------+---------------+---------------+-----------+----+
| nickname | password      | email         | address   | id |
+----------+---------------+---------------+-----------+----+
| ddddfff  | procedure1234 | dddffg@qq.com | xinbei9-2 |  5 |
+----------+---------------+---------------+-----------+----+
1 row in set

Query OK, 0 rows affected

mysql> call testcase(6);
+---------------+---------------+----------------------+----------+----+
| nickname      | password      | email                | address  | id |
+---------------+---------------+----------------------+----------+----+
| testProcedure | procedure1234 | procedure123@163.com | china.js |  7 |
+---------------+---------------+----------------------+----------+----+
1 row in set

③ WHILE 语句：

示例：

mysql> create procedure testwhile()
-> begin
-> declare x int;
-> set x=5;
-> while x<8 do
-> insert into student(nickname,password,email,address)values('dfg',x,'dfg@gmail.com','china.js');
-> set x=x+1;
-> end while;
-> end;
Query OK, 0 rows affected

调用结果：

mysql> call testwhile();
Query OK, 1 row affected

mysql> select * from student
-> ;
+---------------+---------------+----------------------+-----------+----+
| nickname      | password      | email                | address   | id |
+---------------+---------------+----------------------+-----------+----+
| elgin         | 12345         | dddffg@qq.com        | xinbei9-2 |  1 |
| elgin         | 12345         | dddffg@qq.com        | xinbei9-2 |  2 |
| seth          | 12345         | dddffg@qq.com        | xinbei9-2 |  3 |
| 3344          | ddff3322      | dddffg@qq.com        | xinbei9-2 |  4 |
| ddddfff       | procedure1234 | dddffg@qq.com        | xinbei9-2 |  5 |
| jdbcName      | jdbc1234      | dddffg@qq.com        | xinbei9-2 |  6 |
| testProcedure | procedure1234 | procedure123@163.com | china.js  |  7 |
| jdbcName      | jdbc1234      | jdbc1234@gmail.com   | china.js  |  9 |
| dfg           | 5             | dfg@gmail.com        | china.js  | 10 |
| dfg           | 6             | dfg@gmail.com        | china.js  | 11 |
| dfg           | 7             | dfg@gmail.com        | china.js  | 12 |
+---------------+---------------+----------------------+-----------+----+
11 rows in set

可以看到插入了3条记录

④ LOOP语句：

LOOP允许某特定语句或语句群的重复执行，实现一个简单的循环构造。在循环内的语句一直重复直到循环被退出，退出通常伴随着一个LEAVE 语句。
示例：

mysql> create procedure testloop()
-> begin
-> declare x int;
-> set x=5;
-> insertloop:loop
-> insert into student(nickname,password,email,address)values('dfgloop',x,'dfg@gmail.com','china.js');
-> set x=x+1;
-> if x>=8 then
-> leave insertloop;
-> end if;
-> end loop;
-> end;
Query OK, 0 rows affected

调用结果：

mysql> call testloop();
Query OK, 1 row affected

mysql> select * from student;
+---------------+---------------+----------------------+-----------+----+
| nickname      | password      | email                | address   | id |
+---------------+---------------+----------------------+-----------+----+
| elgin         | 12345         | dddffg@qq.com        | xinbei9-2 |  1 |
| elgin         | 12345         | dddffg@qq.com        | xinbei9-2 |  2 |
| seth          | 12345         | dddffg@qq.com        | xinbei9-2 |  3 |
| 3344          | ddff3322      | dddffg@qq.com        | xinbei9-2 |  4 |
| ddddfff       | procedure1234 | dddffg@qq.com        | xinbei9-2 |  5 |
| jdbcName      | jdbc1234      | dddffg@qq.com        | xinbei9-2 |  6 |
| testProcedure | procedure1234 | procedure123@163.com | china.js  |  7 |
| jdbcName      | jdbc1234      | jdbc1234@gmail.com   | china.js  |  9 |
| dfg           | 5             | dfg@gmail.com        | china.js  | 10 |
| dfg           | 6             | dfg@gmail.com        | china.js  | 11 |
| dfg           | 7             | dfg@gmail.com        | china.js  | 12 |
| dfgloop       | 5             | dfg@gmail.com        | china.js  | 13 |
| dfgloop       | 6             | dfg@gmail.com        | china.js  | 14 |
| dfgloop       | 7             | dfg@gmail.com        | china.js  | 15 |
+---------------+---------------+----------------------+-----------+----+
14 rows in set

四、异常处理 Error Handling

声明异常处理的语法：

DECLARE 
{ EXIT | CONTINUE } HANDLER FOR 
{ error-number | { SQLSTATE error-string } | condition } SQL statement

① CONTINUE异常处理示例：

在上述student表的基础上

存储过程：

mysql> create procedure testhandler()
-> begin
-> declare CONTINUE HANDLER FOR SQLSTATE '23000' set @x2=3;
-> set @x=1;
-> insert into student(nickname,password,email,address,id)values('dfgloop','330335','dfg@gmail.com','china.js',15);
-> set @x=3;
-> end;
Query OK, 0 rows affected

调用之后结果：

mysql> call testhandler();
Query OK, 0 rows affected

mysql> select @x,@x2;
+----+-----+
| @x | @x2 |
+----+-----+
|  3 |   3 |
+----+-----+
1 row in set

执行流程分析：

第一步执行 set @x=1; 之后尝试执行insert 语句 ，发生主键冲突错误插入失败并执行错误处理语句 set @x2=3 ，之后继续执行 set @x=3 语句。

可以看出，由于是 CONTINUE异常处理，发生错误之后，执行错误处理语句，之后继续回继续执行下面的语句 （本例为 set @x=3）；

② EXIT异常处理示例：

存储过程：

mysql> create procedure testhandler1()
-> begin
-> declare EXIT HANDLER FOR SQLSTATE '23000' set @x2=3;
-> set @x=1;
-> insert into student(nickname,password,email,address,id)values('dfgloop','330335','dfg@gmail.com','china.js',15);
-> set @x=3;
-> end;
Query OK, 0 rows affected

调用之后结果：

mysql> call testhandler1();
Query OK, 0 rows affected

mysql> select @x,@x2;
+----+-----+
| @x | @x2 |
+----+-----+
|  1 |   3 |
+----+-----+
1 row in set

第一步执行 set @x=1; 之后尝试执行insert 语句 ，发生主键冲突错误插入失败并执行错误处理语句 set @x2=3 ，之后由于出错结束本次执行。

可以看出，由于是EXIT异常处理，发生错误之后，执行错误处理语句，之后退出，并不继续执行后续的语句；

五 游标

声明游标

DECLARE cursor_nameCURSOR FORselect_statement

这个语句声明一个光标。也可以在子程序中定义多个光标，但是一个块中的每一个光标必须有唯一的名字。

打开游标

OPEN cursor_name

这个语句打开先前声明的光标。

游标FETCH

FETCH cursor_nameINTO
var_name [, var_name]...

这个语句用指定的打开光标读取下一行（如果有下一行的话），

并且前进光标指针。

关闭游标CLOSE

CLOSE cursor_name

这个语句关闭先前打开的光标。

如果未被明确地关闭，光标在它被声明的复合语句的末尾被关闭。

游标的特性：

READ ONLY 只读，只能取值而不能赋值；

NOT SCROOLABLE 不可回滚，只能顺序读取；

ASENSITIVE 敏感，不能在已经打开游标的表上执行update事务；

游标使用实例：

mysql> create procedure testcur(out val int)
-> begin
-> declare a,b int;
-> declare cur1 cursor for select id from student;
-> declare continue handler for not found set b=1;
-> open cur1;
-> repeat fetch cur1 into a;
-> until b=1 end repeat;
-> close cur1;
->  set val=a;
-> end;
Query OK, 0 rows affected

调用并查看结果：

mysql> call testcur(@x);
Query OK, 0 rows affected

mysql> select @x;
+----+
| @x |
+----+
| 15 |
+----+
1 row in set

容易出现的错误：1328 - Incorrect number of FETCH variables

出现这个错误使用的存储过程语句：

mysql> create procedure testcur(out val int)
-> begin
-> declare a,b int;
-> declare cur1 cursor for select * from student;
-> declare continue handler for not found set b=1;
-> open cur1;
-> repeat fetch cur1 into a;
-> until b=1 end repeat;
-> close cur1;
->  set val=a;
-> end;
Query OK, 0 rows affected

上述定义游标的语句中 查询语句使用的时 select * ，即从student表中查询出所有记录 ，而在fetch的时候 fetch cur1 into a ，这里接收查询结果的变量只有a ，而查询结果却有5个字段，多以会出现上面的错误： Incorrect number of FETCH variables ，如果想要接收多个结果值，可以在此增加接收查询结果的变量