存储过程
MySQL存储过程简介
我们前面所学习的MySQL语句都是针对一个表或几个表的单条 SQL 语句,但是在数据库的实际操作中,并非所有操作都那么简单,经常会有一个完整的操作需要多条SQL语句处理多个表才能完成。例如,为了确认学生能否毕业,需要同时查询学生档案表、成绩表和综合表,此时就需要使用多条 SQL 语句来针对几个数据表完成这个处理要求。存储过程可以有效地完成这个数据库操作。
存储过程是数据库存储的一个重要的功能,但是 MySQL 在 5.0 以前并不支持存储过程,这使得 MySQL 在应用上大打折扣。好在 MySQL 5.0 终于开始已经支持存储过程,这样即可以大大提高数据库的处理速度,同时也可以提高数据库编程的灵活性。
存储过程是一组为了完成特定功能的 SQL 语句集合。使用存储过程的目的是将常用或复杂的工作预先用 SQL语句写好并用一个指定名称存储起来,这个过程经编译和优化后存储在数据库服务器中,因此称为存储过程。当以后需要数据库提供与已定义好的存储过程的功能相同的服务时,只需调用“CALL存储过程名字”即可自动完成。
常用操作数据库的 SQL 语句在执行的时候需要先编译,然后执行。存储过程则采用另一种方式来执行 SQL 语句。
一个存储过程是一个可编程的函数,它在数据库中创建并保存,一般由 SQL 语句和一些特殊的控制结构组成。当希望在不同的应用程序或平台上执行相同的特定功能时,存储过程尤为合适。
存储过程通常有如下优点:
1.封装性 存储过程被创建后,可以在程序中被多次调用,而不必重新编写该存储过程的 SQL 语句,并且数据库专业人员可以随时对存储过程进行修改,而不会影响到调用它的应用程序源代码。
2.可增强 SQL 语句的功能和灵活性 存储过程可以用流程控制语句编写,有很强的灵活性,可以完成复杂的判断和较复杂的运算。
3.可减少网络流量 由于存储过程是在服务器端运行的,且执行速度快,因此当客户计算机上调用该存储过程时,网络中传送的只是该调用语句,从而可降低网络负载。
4.高性能 存储过程执行一次后,产生的二进制代码就驻留在缓冲区,在以后的调用中,只需要从缓冲区中执行二进制代码即可,从而提高了系统的效率和性能。
5.提高数据库的安全性和数据的完整性 使用存储过程可以完成所有数据库操作,并且可以通过编程的方式控制数据库信息访问的权限。
MySQL创建存储过程(CREATE PROCEDURE)
MySQL 存储过程是一些 SQL 语句的集合,比如有的时候我们可能需要一大串的 SQL 语句,或者说在编写 SQL语句的过程中还需要设置一些变量的值,这个时候我们就完全有必要编写一个存储过程。下面我们来介绍一下如何创建一个存储过程。 基本语法 可以使用 CREATE PROCEDURE 语句创建存储过程。
语法格式如下:
CREATE PROCEDURE <过程名> ( [过程参数[,…] ] ) <过程体> [过程参数[,…] ] 格式 [ IN | OUT | INOUT ] <参数名> <类型>
语法说明如下:
1.过程名 存储过程的名称,默认在当前数据库中创建。若需要在特定数据库中创建存储过程,则要在名称前面加上数据库的名称,即 db_name.sp_name。需要注意的是,名称应当尽量避免选取与 MySQL 内置函数相同的名称,否则会发生错误。
2.过程参数 存储过程的参数列表。其中,<参数名>为参数名,<类型>为参数的类型(可以是任何有效的MySQL 数据类型)。当有多个参数时,参数列表中彼此间用逗号分隔。存储过程可以没有参数(此时存储过程的名称后仍需加上一对括号),也可以有 1 个或多个参数。
MySQL 存储过程支持三种类型的参数,即输入参数、输出参数和输入/输出参数,分别用 IN、OUT 和 INOUT三个关键字标识。其中,输入参数可以传递给一个存储过程,输出参数用于存储过程需要返回一个操作结果的情形,而输入/输出参数既可以充当输入参数也可以充当输出参数。需要注意的是,参数的取名不要与数据表的列名相同,否则尽管不会返回出错信息,但是存储过程的 SQL 语句会将参数名看作列名,从而引发不可预知的结果。
3.过程体 存储过程的主体部分,也称为存储过程体,包含在过程调用的时候必须执行的 SQL 语句。这个部分以关键字 BEGIN 开始,以关键字 END 结束。若存储过程体中只有一条 SQL 语句,则可以省略 BEGINEND 标志。在存储过程的创建中,经常会用到一个十分重要的 MySQL 命令,即 DELIMITER 命令,特别是对于通过命令行的方式来操作 MySQL 数据库的使用者,更是要学会使用该命令。
在 MySQL 中,服务器处理 SQL 语句默认是以分号作为语句结束标志的。然而,在创建存储过程时,存储过程体可能包含有多条 SQL 语句,这些 SQL 语句如果仍以分号作为语句结束符,那么 MySQL 服务器在处理时会以遇到的第一条 SQL 语句结尾处的分号作为整个程序的结束符,而不再去处理存储过程体中后面的 SQL 语句,这样显然不行。为解决这个问题,通常可使用 DELIMITER 命令将结束命令修改为其他字符。
语法格式如下:
delimiter $$
语法说明如下: $$ 是用户定义的结束符,通常这个符号可以是一些特殊的符号,如两个“?”或两个“¥”等。 当使用 DELIMITER 命令时,应该避免使用反斜杠“\”字符,因为它是 MySQL 的转义字符。
在 MySQL 命令行客户端输入如下SQL语句。
mysql > DELIMITER ??
成功执行这条 SQL 语句后,任何命令、语句或程序的结束标志就换为两个问号“??”了。
若希望换回默认的分号“;”作为结束标志,则在 MySQL 命令行客户端输入下列语句即可:
mysql > DELIMITER ;
注意:DELIMITER 和分号“;”之间一定要有一个空格。在创建存储过程时,必须具有 CREATE ROUTINE 权限。可以使用 SHOW PROCEDURE STATUS 命令查看数据库中存在哪些存储过程,若要查看某个存储过程的具体信息,则可以使用 SHOW CREATE PROCEDURE <存储过程名>。
创建不带参数的存储过程 【实例 1】创建名称为 ShowStuScore 的存储过程,存储过程的作用是从学生成绩信息表中查询学生的成绩信息,输入的 SQL 语句和执行过程如下所示.
mysql> DELIMITER //
mysql> CREATE PROCEDURE ShowStuScore()
-> BEGIN
-> SELECT * FROM tb_students_score;
-> END //
Query OK, 0 rows affected (0.09 sec)
创建存储过程 ShowStuScore 后,通过 CALL 语句调用该存储过程的 SQL 语句和执行结果如下所示。
mysql> DELIMITER ;
mysql> CALL ShowStuScore();
+--------------+---------------+
| student_name | student_score |
+--------------+---------------+
| Dany | 90 |
| Green | 99 |
| Henry | 95 |
| Jane | 98 |
| Jim | 88 |
| John | 94 |
| Lily | 100 |
| Susan | 96 |
| Thomas | 93 |
| Tom | 89 |
+--------------+---------------+
10 rows in set (0.00 sec)
Query OK, 0 rows affected (0.02 sec)
创建带参数的存储过程 【实例 2】创建名称为 GetScoreByStu 的存储过程,输入参数是学生姓名。存储过程的作用是通过输入的学生姓名从学生成绩信息表中查询指定学生的成绩信息,输入的 SQL 语句和执行过程如下所示。
mysql> DELIMITER //
mysql> CREATE PROCEDURE GetScoreByStu
-> (IN name VARCHAR(30))
-> BEGIN
-> SELECT student_score FROM tb_students_score
-> WHERE student_name=name;
-> END //
Query OK, 0 rows affected (0.01 sec)
创建存储过程 GetScoreByStu 后,通过 CALL 语句调用该存储过程的 SQL 语句和执行结果如下所示。
mysql> DELIMITER ;
mysql> CALL GetScoreByStu('Green');
+---------------+
| student_score |
+---------------+
| 99 |
+---------------+
1 row in set (0.03 sec)
Query OK, 0 rows affected (0.03 sec)
MySQL修改存储过程(ALTER PROCEDURE)
在实际开发过程中,业务需求修改的情况时有发生,这样,不可避免的需要修改 MySQL 中存储过程的特征 。基本语法 可以使用 ALTER PROCEDURE 语句修改存储过程的某些特征。
语法格式如下:
ALTER PROCEDURE <过程名> [ <特征> … ]
提示:这个语法用于修改存储过程的某些特征,如要修改存储过程的内容,可以先删除该存储过程,再重新创建。
修改存储过程的内容和名称 修改存储过程的内容可以通过删除原存储过程,再以相同的命名创建新的存储过程。
修改存储过程的名称可以通过删除原存储过程,再以不同的命名创建新的存储过程。
MySQL删除存储过程(DROP PROCEDURE)
当 MySQL 数据库中存在废弃的存储过程是,我们需要将它从数据库中删除。 基本语法 存储过程被创建后,保存在数据库服务器上,直至被删除。可以使用 DROP PROCEDURE 语句删除数据库中已创建的存储过程。
语法格式如下:
DROP { PROCEDURE | FUNCTION } [ IF EXISTS ] <过程名>
语法说明如下:
1.过程名 指定要删除的存储过程的名称。
2.IF EXISTS 指定这个关键字,用于防止因删除不存在的存储过程而引发的错误。 注意:存储过程名称后面没有参数列表,也没有括号,在删除之前,必须确认该存储过程没有任何依赖关系,否则会导致其他与之关联的存储过程无法运行。
删除存储过程 删除存储过程 GetScoreByStu,查看存储过程的运行结果如下所示。
mysql> DROP PROCEDURE GetScoreByStu;
Query OK, 0 rows affected (0.00 sec)
mysql> CALL GetScoreByStu('Green');
ERROR 1305 (42000): PROCEDURE test_db.GetScoreByStu does not exist
存储过程例子
基础语法
CREATE
PROCEDURE sp_name ([ IN | OUT | INOUT ])
[characteristic ...] routine_body
CREATE
[DEFINER = user]
FUNCTION sp_name ([func_parameter[,...]])
RETURNS type
[characteristic ...] routine_body
proc_parameter:
[ IN | OUT | INOUT ] param_name type
func_parameter:
param_name type
1.利用存储过程向表中插入数据
mysql> delimiter $$
mysql> create procedure test1()
-> begin
-> create table test (id int,name varchar(30));
-> insert into test values (1,'wang');
-> insert into test values (2,'zhao');
-> insert into test values (3,'liu');
-> end $$
Query OK, 0 rows affected (0.06 sec)
mysql> delimiter ;
mysql> call test1();
Query OK, 1 row affected (0.08 sec)
mysql> select * from test;
+------+------+
| id | name |
+------+------+
| 1 | wang |
| 2 | zhao |
| 3 | liu |
+------+------+
3 rows in set (0.00 sec)
2.利用存储过程查看表中数据
mysql> delimiter ##
mysql> create procedure test2()
-> begin
-> select * from test;
-> end ##
Query OK, 0 rows affected (0.00 sec)
mysql> delimiter ;
mysql> call test2();
+------+------+
| id | name |
+------+------+
| 1 | wang |
| 2 | zhao |
| 3 | liu |
+------+------+
3 rows in set (0.01 sec)
Query OK, 0 rows affected (0.01 sec)
3.利用带参数的存储过程进行表中数据查看
mysql> delimiter ##
mysql> create procedure test3(in a int)
-> begin
-> select * from test where id=a;
-> end ##
Query OK, 0 rows affected (0.03 sec)
mysql> delimiter ;
mysql> call test3(1);
+------+------+
| id | name |
+------+------+
| 1 | wang |
+------+------+
1 row in set (0.00 sec)
Query OK, 0 rows affected (0.00 sec)
mysql> call test3(2);
+------+------+
| id | name |
+------+------+
| 2 | zhao |
+------+------+
1 row in set (0.00 sec)
Query OK, 0 rows affected (0.00 sec)
mysql> call test3(3);
+------+------+
| id | name |
+------+------+
| 3 | liu |
+------+------+
1 row in set (0.01 sec)
Query OK, 0 rows affected (0.01 sec)
4.利用存储过程把参数传出来
out (输出)
mysql> delimiter ##
mysql> create procedure test5(out a int)
-> begin
-> select a;
-> set a=100;
-> select a;
-> end ##
Query OK, 0 rows affected (0.01 sec)
mysql> delimiter ;
mysql> call test5(@a);
+------+
| a |
+------+
| NULL |
+------+
1 row in set (0.01 sec)
+------+
| a |
+------+
| 100 |
+------+
1 row in set (0.01 sec)
Query OK, 0 rows affected (0.01 sec)
in(输入)
mysql> delimiter ##
mysql> create procedure test6(in a int)
-> begin
-> select a;
-> set a=100;
-> select a;
-> end ##
Query OK, 0 rows affected (0.00 sec)
mysql> delimiter ;
mysql> call test6(@a);
+------+
| a |
+------+
| 100 |
+------+
1 row in set (0.01 sec)
+------+
| a |
+------+
| 100 |
+------+
1 row in set (0.01 sec)
Query OK, 0 rows affected (0.01 sec)
inout (两者都有)
mysql> delimiter ##
mysql> create procedure test7(inout a int)
-> begin
-> select a;
-> set a=100;
-> select a;
-> end ##
Query OK, 0 rows affected (0.00 sec)
mysql> delimiter ;
mysql> call test7(@a);
+------+
| a |
+------+
| 100 |
+------+
1 row in set (0.00 sec)
+------+
| a |
+------+
| 100 |
+------+
1 row in set (0.00 sec)
Query OK, 0 rows affected (0.00 sec)
5.利用存储过程创建表并插入数据
mysql> delimiter @@
mysql> create procedure test8()
-> begin
-> create table student(id int,name varchar(20),sex int,scores float);
-> insert into student values (1,'zhs',1,90.5);
-> insert into student values (2,'lis',1,85.5);
-> insert into student values (3,'wangw',0,78.5);
-> insert into student values (4,'liul',0,66.5);
-> insert into student values (5,'zhaos',1,50.5);
-> insert into student values (6,'test',0,30.5);
-> select * from student;
-> end @@
Query OK, 0 rows affected (0.00 sec)
mysql> delimiter ;
mysql> call test8();
+------+-------+------+--------+
| id | name | sex | scores |
+------+-------+------+--------+
| 1 | zhs | 1 | 90.5 |
| 2 | lis | 1 | 85.5 |
| 3 | wangw | 0 | 78.5 |
| 4 | liul | 0 | 66.5 |
| 5 | zhaos | 1 | 50.5 |
| 6 | test | 0 | 30.5 |
+------+-------+------+--------+
6 rows in set (0.06 sec)
Query OK, 0 rows affected (0.06 sec)
6.利用if条件语句对数据表进行条件筛选
mysql> delimiter @@
mysql> create procedure test9(in t char)
-> begin
-> if t="男" then
-> select * from student where sex=1;
-> else
-> select * from student where sex=0;
-> end if;
-> end @@
Query OK, 0 rows affected (0.00 sec)
mysql> delimiter ;
mysql> call test9('男');
+------+-------+------+--------+
| id | name | sex | scores |
+------+-------+------+--------+
| 1 | zhs | 1 | 90.5 |
| 2 | lis | 1 | 85.5 |
| 5 | zhaos | 1 | 50.5 |
+------+-------+------+--------+
3 rows in set (0.01 sec)
Query OK, 0 rows affected (0.01 sec)
7.使用case语句对数据表进行筛选
输入1显示大于90分的学生
输入2显示80~90的学生
输入3显示60~80的学生
输入4显示小于60的学生
输入其他显示所有
mysql> delimiter @@
mysql> create procedure test10(in t int)
-> begin
-> case t
-> when 1 then
-> select * from student where scores>90;
-> when 2 then
-> select * from student where scores>80 and scores<=90;
-> when 3 then
-> select * from student where scores>60 and scores<=80;
-> when 4 then
-> select * from student where scores<60;
-> else
-> select * from student;
-> end case;
-> end @@
Query OK, 0 rows affected (0.01 sec)
mysql> delimiter ;
mysql> call test10(1);
+------+------+------+--------+
| id | name | sex | scores |
+------+------+------+--------+
| 1 | zhs | 1 | 90.5 |
+------+------+------+--------+
1 row in set (0.00 sec)
Query OK, 0 rows affected (0.00 sec)
mysql> call test10(2);
+------+------+------+--------+
| id | name | sex | scores |
+------+------+------+--------+
| 2 | lis | 1 | 85.5 |
+------+------+------+--------+
1 row in set (0.00 sec)
Query OK, 0 rows affected (0.00 sec)
mysql> call test10(3);
+------+-------+------+--------+
| id | name | sex | scores |
+------+-------+------+--------+
| 3 | wangw | 0 | 78.5 |
| 4 | liul | 0 | 66.5 |
+------+-------+------+--------+
2 rows in set (0.00 sec)
Query OK, 0 rows affected (0.00 sec)
mysql> call test10(4);
+------+-------+------+--------+
| id | name | sex | scores |
+------+-------+------+--------+
| 5 | zhaos | 1 | 50.5 |
| 6 | test | 0 | 30.5 |
+------+-------+------+--------+
2 rows in set (0.00 sec)
Query OK, 0 rows affected (0.00 sec)
mysql> call test10(5);
+------+-------+------+--------+
| id | name | sex | scores |
+------+-------+------+--------+
| 1 | zhs | 1 | 90.5 |
| 2 | lis | 1 | 85.5 |
| 3 | wangw | 0 | 78.5 |
| 4 | liul | 0 | 66.5 |
| 5 | zhaos | 1 | 50.5 |
| 6 | test | 0 | 30.5 |
+------+-------+------+--------+
6 rows in set (0.01 sec)
Query OK, 0 rows affected (0.01 sec)
8.使用存储过程通过while语句进行1到100的求和
mysql> delimiter @@
mysql> create procedure test11()
-> begin
-> declare i int;
-> declare summary int;
-> set i=1;
-> set summary=0;
-> while i<=100 do
-> set summary=summary+i;
-> set i=i+1;
-> end while ;
-> select summary;
-> end @@
Query OK, 0 rows affected (0.00 sec)
mysql> delimiter ;
mysql> call test11();
+---------+
| summary |
+---------+
| 5050 |
+---------+
1 row in set (0.00 sec)
Query OK, 0 rows affected (0.00 sec)
9.使用存储过程通过while语句和if语句进行1到a之间的偶数求和
mysql> delimiter @@
mysql> create procedure test12(in a int)
-> begin
-> declare i int;
-> declare summary int;
-> set i=1;
-> set summary=0;
-> while i<=a do
-> if i%2=0 then
-> set summary=summary+i;
-> end if;
-> set i=i+1;
-> end while ;
-> select summary;
-> end @@
Query OK, 0 rows affected (0.00 sec)
mysql> delimiter ;
mysql> call test13(12);
+---------+
| summary |
+---------+
| 42 |
+---------+
1 row in set (0.00 sec)
Query OK, 0 rows affected (0.00 sec)
mysql> call test16(50);
+---------+
| summary |
+---------+
| 650 |
+---------+
1 row in set (0.01 sec)
Query OK, 0 rows affected (0.01 sec)
mysql> call test16(20);
+---------+
| summary |
+---------+
| 110 |
+---------+
1 row in set (0.00 sec)
Query OK, 0 rows affected (0.00 sec)
10.使用存储过程实现向数据表中插入大量数据
mysql> delimiter @@
mysql> create procedure test13()
-> begin
-> declare a int;
-> set a=0;
-> while a<100 do
-> insert into student values(a,"a",1,100);
-> set a=a+1;
-> end while ;
-> end @@
Query OK, 0 rows affected (0.00 sec)
mysql> delimiter ;
mysql> call test13();
Query OK, 1 row affected (0.08 sec)
mysql> select * from student;
+------+-------+------+--------+
| id | name | sex | scores |
+------+-------+------+--------+
| 1 | zhs | 1 | 90.5 |
| 2 | lis | 1 | 85.5 |
| 3 | wangw | 0 | 78.5 |
| 4 | liul | 0 | 66.5 |
| 5 | zhaos | 1 | 50.5 |
| 6 | test | 0 | 30.5 |
| 0 | a | 1 | 100 |
| 1 | a | 1 | 100 |
| 2 | a | 1 | 100 |
| 3 | a | 1 | 100 |
| 4 | a | 1 | 100 |
| 5 | a | 1 | 100 |
| 6 | a | 1 | 100 |
| 7 | a | 1 | 100 |
| 8 | a | 1 | 100 |
| 9 | a | 1 | 100 |
| 10 | a | 1 | 100 |
| 11 | a | 1 | 100 |
| 12 | a | 1 | 100 |
| 13 | a | 1 | 100 |
| 14 | a | 1 | 100 |
| 15 | a | 1 | 100 |
| 16 | a | 1 | 100 |
| 17 | a | 1 | 100 |
| 18 | a | 1 | 100 |
| 19 | a | 1 | 100 |
| 20 | a | 1 | 100 |
| 21 | a | 1 | 100 |
| 22 | a | 1 | 100 |
| 23 | a | 1 | 100 |
| 24 | a | 1 | 100 |
| 25 | a | 1 | 100 |
| 26 | a | 1 | 100 |
| 27 | a | 1 | 100 |
| 28 | a | 1 | 100 |
| 29 | a | 1 | 100 |
| 30 | a | 1 | 100 |
| 31 | a | 1 | 100 |
| 32 | a | 1 | 100 |
| 33 | a | 1 | 100 |
| 34 | a | 1 | 100 |
| 35 | a | 1 | 100 |
| 36 | a | 1 | 100 |
| 37 | a | 1 | 100 |
| 38 | a | 1 | 100 |
| 39 | a | 1 | 100 |
| 40 | a | 1 | 100 |
| 41 | a | 1 | 100 |
| 42 | a | 1 | 100 |
| 43 | a | 1 | 100 |
| 44 | a | 1 | 100 |
| 45 | a | 1 | 100 |
| 46 | a | 1 | 100 |
| 47 | a | 1 | 100 |
| 48 | a | 1 | 100 |
| 49 | a | 1 | 100 |
| 50 | a | 1 | 100 |
| 51 | a | 1 | 100 |
| 52 | a | 1 | 100 |
| 53 | a | 1 | 100 |
| 54 | a | 1 | 100 |
| 55 | a | 1 | 100 |
| 56 | a | 1 | 100 |
| 57 | a | 1 | 100 |
| 58 | a | 1 | 100 |
| 59 | a | 1 | 100 |
| 60 | a | 1 | 100 |
| 61 | a | 1 | 100 |
| 62 | a | 1 | 100 |
| 63 | a | 1 | 100 |
| 64 | a | 1 | 100 |
| 65 | a | 1 | 100 |
| 66 | a | 1 | 100 |
| 67 | a | 1 | 100 |
| 68 | a | 1 | 100 |
| 69 | a | 1 | 100 |
| 70 | a | 1 | 100 |
| 71 | a | 1 | 100 |
| 72 | a | 1 | 100 |
| 73 | a | 1 | 100 |
| 74 | a | 1 | 100 |
| 75 | a | 1 | 100 |
| 76 | a | 1 | 100 |
| 77 | a | 1 | 100 |
| 78 | a | 1 | 100 |
| 79 | a | 1 | 100 |
| 80 | a | 1 | 100 |
| 81 | a | 1 | 100 |
| 82 | a | 1 | 100 |
| 83 | a | 1 | 100 |
| 84 | a | 1 | 100 |
| 85 | a | 1 | 100 |
| 86 | a | 1 | 100 |
| 87 | a | 1 | 100 |
| 88 | a | 1 | 100 |
| 89 | a | 1 | 100 |
| 90 | a | 1 | 100 |
| 91 | a | 1 | 100 |
| 92 | a | 1 | 100 |
| 93 | a | 1 | 100 |
| 94 | a | 1 | 100 |
| 95 | a | 1 | 100 |
| 96 | a | 1 | 100 |
| 97 | a | 1 | 100 |
| 98 | a | 1 | 100 |
| 99 | a | 1 | 100 |
+------+-------+------+--------+
106 rows in set (0.00 sec)