理解MySQL变量和条件

一、概述 

 变量在存储过程中会经常被使用，变量的使用方法是一个重要的知识点，特别是在定义条件这块比较重要。

 mysql版本：5.6

二、变量定义和赋值 

#创建数据库
drop database if exists dpro;
create database dpro
character set utf8
;

use dpro;

#创建部门表
drop table if exists employee;
create table employee
(id int not null primary key comment '主键',
 name varchar(20) not null comment '人名',
 depid int not null comment '部门id'
);

insert into employee(id,name,depid) values(1,'陈',100),(2,'王',101),(3,'张',101),(4,'李',102),(5,'郭',103);

declare定义变量

在存储过程和函数中通过declare定义变量在begin...end中，且在语句之前。并且可以通过重复定义多个变量

注意：declare定义的变量名不能带符号，mysql在这点做的确实不够直观，往往变量名会被错成参数或者字段名。

declare var_name[,...] type [default value]
例如：

drop procedure if exists pro_employee;
delimiter $$
create procedure pro_employee(in pdepid varchar(20),out pcount int )
reads sql data
sql security invoker
begin
declare pname varchar(20) default '陈';
select count(id) into pcount from employee where depid=pdepid;

end$$
delimiter ;

set变量赋值

set除了可以给已经定义好的变量赋值外，还可以指定赋值并定义新变量，且set定义的变量名可以带符号，set语句的位置也是在begin ....end之间的语句之前。

1.变量赋值

set var_name = expr [, var_name = expr] ...
drop procedure if exists pro_employee;
delimiter $$
create procedure pro_employee(in pdepid varchar(20),out pcount int )
reads sql data
sql security invoker
begin
declare pname varchar(20) default '陈';
set pname='王';
select count(id) into pcount from employee where depid=pdepid and name=pname;

end$$
delimiter ;

call pro_employee(101,@pcount);
 select @pcount;

 

2.通过赋值定义变量

drop procedure if exists pro_employee;
delimiter $$
create procedure pro_employee(in pdepid varchar(20),out pcount int )
reads sql data
sql security invoker
begin
declare pname varchar(20) default '陈';
set pname='王';
set @id=1;
select count(id) into pcount from employee where depid=pdepid and name=pname;
select @id;

end$$
delimiter ;

call pro_employee(101,@pcount);

select ... into语句赋值

 通过select into语句可以将值赋予变量，也可以之间将该值赋值存储过程的out参数,上面的存储过程select into就是之间将值赋予out参数。

drop procedure if exists pro_employee;
delimiter $$
create procedure pro_employee(in pdepid varchar(20),out pcount int )
reads sql data
sql security invoker
begin
declare pname varchar(20) default '陈';
declare pid int;
select count(id) into pid from employee where depid=pdepid and name=pname;
select pid;

end$$
delimiter ;

call pro_employee(101,@pcount);

这个存储过程就是select into将值赋予变量；

 

表中并没有depid=101 and name='陈'的记录。

三、条件 

条件的作用一般用在对指定条件的处理，比如我们遇到主键重复报错后该怎样处理。

定义条件

 定义条件就是事先定义某种错误状态或者sql状态的名称，然后就可以引用该条件名称开做条件处理，定义条件一般用的比较少，一般会直接放在条件处理里面。

declare condition_name condition for condition_value
 
condition_value:
  sqlstate [value] sqlstate_value
 | mysql_error_code

1.没有定义条件：

drop procedure if exists pro_employee_insert;
delimiter $$
create procedure pro_employee_insert()
modifies sql data
sql security invoker
begin
set @id=1;
insert into employee(id,name,depid) values(1,'陈',100);
set @id=2;
insert into employee(id,name,depid) values(6,'陈',100);
set @id=3;

end$$
delimiter ;

#执行存储过程
call pro_employee_insert();

#查询变量值
select @id,@x;

报主键重复的错误，其中1062是主键重复的错误代码，23000是sql错误状态

2.定义处理条件

drop procedure if exists pro_employee_insert;
delimiter $$
create procedure pro_employee_insert()
modifies sql data
sql security invoker
begin
#定义条件名称，
declare reprimary condition for 1062;
#引用前面定义的条件名称并做赋值处理
declare exit handler for reprimary set @x=1;
set @id=1;
insert into employee(id,name,depid) values(1,'陈',100);
set @id=2;
insert into employee(id,name,depid) values(6,'陈',100);
set @id=3;

end$$
delimiter ;

call pro_employee_insert();

select @id,@x;

在执行存储过程的步骤中并没有报错，但是由于我定义的是exit，所以在遇到报错sql就终止往下执行了。

接下来看看continue的不同

drop procedure if exists pro_employee_insert;
delimiter $$
create procedure pro_employee_insert()
modifies sql data
sql security invoker
begin
#定义条件名称，
declare reprimary condition for sqlstate '23000';
#引用前面定义的条件名称并做赋值处理
declare continue handler for reprimary set @x=1;
set @id=1;
insert into employee(id,name,depid) values(1,'陈',100);
set @id=2;
insert into employee(id,name,depid) values(6,'陈',100);
set @id=3;

end$$
delimiter ;

call pro_employee_insert();

select @id,@x;

其中红色标示的是和上面不同的地方，这里定义条件使用的是sql状态，也是主键重复的状态；并且这里使用的是continue就是遇到错误继续往下执行。

 条件处理

条件处理就是之间定义语句的错误的处理，省去了前面定义条件名称的步骤。

declare handler_type handler for condition_value[,...] sp_statement
 
handler_type:
  continue| exit| undo
 
condition_value:
  sqlstate [value] sqlstate_value
 | condition_name
 | sqlwarning
 | not found
 | sqlexception
 | mysql_error_code

handler_type：遇到错误是继续往下执行还是终止，目前undo还没用到。

continue:继续往下执行

exit：终止执行

condition_values:错误状态

sqlstate [value] sqlstate_value：就是前面讲到的sql错误状态，例如主键重复状态sqlstate '23000'

condition_name：上面讲到的定义条件名称；

sqlwarning：是对所有以01开头的sqlstate代码的速记，例如：declare continue handler for sqlwarning。

not found:是对所有以02开头的sqlstate代码的速记。

sqlexception:是对所有没有被sqlwarning或not found捕获的sqlstate代码的速记。

mysql_error_code:是错误代码，例如主键重复的错误代码是1062，declare continue handler for 1062

 语句：

drop procedure if exists pro_employee_insert;
delimiter $$
create procedure pro_employee_insert()
modifies sql data
sql security invoker
begin

#引用前面定义的条件名称并做赋值处理
declare continue handler for sqlexception set @x=2;
#开始事务必须在declare之后
start transaction ;
set @id=1;
insert into employee(id,name,depid) values(7,'陈',100);
set @id=2;
insert into employee(id,name,depid) values(6,'陈',100);
set @id=3;

if @x=2 then
 rollback;
else
 commit;
end if; 

end$$
delimiter ;

#执行存储过程
call pro_employee_insert();
#查询
select @id,@x;

通过select @id,@x可以知道存储过程已经执行到了最后，但是因为存储过程后面有做回滚操作整个语句进行了回滚，所以id=7的符合条件的记录也被回滚了。

总结 

变量的使用不仅仅只有这些，在光标中条件也是一个很好的功能，刚才测试的是continue如果使用exit的话语句执行完“set @id=2;”就不往下执行了，后面的if也不被执行整个语句不会被回滚，但是使用contine当出现错误后还是会往下执行如果后面的语句还有很多的话整个回滚的过程将会很长，在这里可以利用循环，当出现错误立刻退出循环执行后面的if回滚操作，在下一篇讲循环语句会写到，欢迎关注。