mysql-视图-触发器-事务-存储过程-流程控制

文章目录

• 一、视图
• 二、触发器
• 三、事务
• 四、存储过程
• 五、流程控制

一、视图

'''
数据：
create table dep(
id int primary key auto_increment,
name varchar(16),
work varchar(16)
);
create table emp(
id int primary key auto_increment,
name varchar(16),
salary float,
dep_id int
);
insert into dep values(1, '市场部', '销售'), (2, '教学部', '授课'), (3, '管理部', '开车');
insert into emp(name, salary, dep_id) values('egon', 3.0, 2),('yanghuhu', 2.0, 2),('sanjiang', 10.0, 1),('owen', 88888.0, 2),('liujie', 8.0, 1),('yingjie', 1.2, 0);
'''

select * from emp left join dep on emp.dep_id = dep.id
union
select * from emp right join dep on emp.dep_id = dep.id;

# 全连接形成一张新表，现有查询是基于全连接这张新表，如何来操作
# 解决：将新表其别名full_table，将需求转换为 select 需求字段 from full_table 条件
create view temp(emp_id,emp_name,salary,dep_id,dep_id2,dep_name,work) as
select * from emp left join dep on emp.dep_id = dep.id
union
select * from emp right join dep on emp.dep_id = dep.id;

what: 视图是由一张表或多张表的查询结果构成的一张虚拟表
why: 将复杂常用的查询结果保留下来重复使用 | 将一张大表拆分成多张小表

语法：
create [or replace] view 视图名[(查询字段别名们)] as 查询语句
create view new_emp as (select * from emp);

1.查询字段别名们要与查询语句的查询字段对应

2.create or replace: 操作视图没有则创建，有则替换
create or replace view new_emp(id,姓名,工资) as (select id,name,salary from emp where dep_id = 2);

3.视图中字段的操作：不允许alter操作字段
alter table new_emp rename new_emp1; # 报错
alter view new_emp modify id tinyint; # 报错

4.视图中记录的操作：等价于普通表，完成增删改查
update new_emp set 姓名='san' where id = 3;
delete from new_emp where id = 3;
nsert into new_emp(id, 姓名, 工资) values (10, "Bob", 10000); #操作的是实体表，虚拟表要重新创建才能拿到最新数据

5.视图的删除：
drop view 视图名：

二、触发器

'''
what：在表发生数据更新时，会自动触发的功能称之为触发器
why：当一个表在发生数据更新时，需要去完成一些操作，可以为具体数据更新的方式添加触发器

语法：
delimiter //
create trigger 触发器名 before|after insert|update|delete on 表名 for each row
begin
需要触发执行的sql代码们
end //
delimiter ;

# 触发器名: t1_before_insert_tri

注：delimiter是用来修改sql的语句结束标识符

删除触发器：drop trigger 触发器名;
'''

# cmd表
create table cmd (
id int primary key auto_increment,
user char(32),
priv char(10),
cmd char (64),
sub_time datetime, # 提交时间
success enum ('yes', 'no') # 0代表执行失败
);

# 错误日志表
create table errlog (
id int primary key auto_increment,
err_cmd char(64),
err_time datetime
);

# 创建触发器
delimiter //
create trigger trigger1 after insert on cmd for each row
begin
# new就是cmd当前插入的那条记录(对象)
if new.success = "no" then
insert into errlog values(null, new.cmd, new.sub_time);
end if;
end //
delimiter ;

# 往表cmd中插入记录，触发触发器，根据IF的条件决定是否插入错误日志
insert into cmd(user, priv, cmd, sub_time, success) values
('egon', '0765', 'ls -l /etc', now(), 'yes'),
('jerry', '0852', 'cat /etc/passwd', now(), 'no'),
('kevin', '0867', 'useradd xxx', now(), 'no'),
('owen', '0912', 'ps aux', now(), 'yes');

# 查看cmd数据信息
select * from cmd;

# 查看错误日志表中的记录是否有自动插入
select * from errlog;

三、事务

'''
what：事务是逻辑上的一组操作，要么都成功，要么都失败
why：很多时候一个数据操作，不是一个sql语句就完成的，可能有很多个sql语句，如果部分sql执行成功而部分sql执行失败将导致数据错乱
eg：转账 => 转入转出均成功，才能认为操作成功

事务的使用：
start transaction： --开启事物,在这条语句之后的sql将处在同一事务，并不会立即修改数据库
commit：--提交事务，让这个事物中的sql立即执行数据的操作
rollback：--回滚事务，取消这个事物，这个事物不会对数据库中的数据产生任何影响

事务的四大特性：
1.原子性：事务是一组不可分割的单位，要么同时成功，要么同时不成功
2.一致性：事物前后的数据完整性应该保持一致(数据库的完整性：如果数据库在某一时间点下，所有的数据都符合所有的约束，则称数据库为完整性的状态)
3.隔离性：事物的隔离性是指多个用户并发访问数据时，一个用户的事物不能被其它用户的事务所干扰，多个并发事务之间数据要相互隔离
4.持久性：持久性是指一个事物一旦被提交，它对数据的改变就是永久性的，接下来即使数据库发生故障也不应该对其有任何影响

事务的用户隔离级别：
数据库使用者可以控制数据库工作在哪个级别下，就可与防止不同的隔离性问题
read uncommitted --不做任何隔离，可能脏读，幻读
read committed --可以防止脏读，不能防止不可重复读，和幻读
Repeatable read --可以防止脏读，不可重复读，不能防止幻读
Serializable --数据库运行在串行化实现，所有问题都没有，就是性能低

修改隔离级别：
select @@tx_isolation;--查询当前级别
set[session|global] transaction isolation level ....;修改级别
实例：
set global transaction isolation level Repeatable read;
注：修改后重新连接服务器生效
'''

#准备数据
create table account(
id int primary key auto_increment,
name varchar(20),
money double
);
insert into account values
(1,'owen',10000),
(2,'egon',1000),
(3,'jerry',1000),
(4,'kevin',1000);

#egon向owen借1000块钱，未使用事务
update account set money = money - 1000 where id = 1;
update account set moneys = money + 1000 where id = 2; # money打错了导致执行失败

#在python中使用事务处理
import pymysql
from pymysql.err import InternalError
conn = pymysql.connect(host='192.168.32.100', port=3306, user='root', password='123456', db='db2', charset='utf8')
cursor = conn.cursor(pymysql.cursors.DictCursor)
sql = 'update account set money = money - 1000 where id = 1'
sql2 = 'update account set moneys = money + 1000 where id = 2' # money打错了导致执行失败
try:
cursor.execute(sql)
cursor.execute(sql2)
conn.commit()
except InternalError:
print("转账失败")
conn.rollback()

四、存储过程

'''
what：用于完成指定功能的sql语句块，类似于Python中的函数
why：将能指定功能的sql语句块建立成存储过程，不仅将sql语句逻辑化了，更是功能化了，那我们要完成相同的事，只需要重复使用建立的存储过程，不就需要再重复书写sql语句了
# 总结: 存储过程可以让sql语句具有复用性，从而提高开发效率

语法：
delimiter //
create procedure 存储过程名(
输入输出类型1 参数名1 参数类型1(宽度),
... ,
输入输出类型n 参数名n 参数类型n(宽度)
)
begin
sql语句块
end //
delimiter ;
注：
1.输入输出类型：in | out | inout
2.call存储过程名(实参们)来调用存储过程

案例：
set @res = null; # 定义空值变量，用来接收存储过程的执行结果
delimiter //
create procedure user_info(in b int, in l int, out res char(20))
begin
select * from emp limit b, l;
set res = 'success';
end //
delimiter ;
call user_info(2, 3, @res); # 调用存储过程，传入相应的实参
select @res; # 查看存储过程的执行结果

变量的使用：
1.赋值变量：set @变量名 = 变量值
2.使用变量：@变量名 | select @变量名
3.删除变量：set @变量名 = null

三种开发方式：
1. 业务逻辑 + 存储过程：高执行与开发效率，低耦合 | 不易移植，人员成本高
2. 业务逻辑 + 原生sql：人员成本低 | 开发难度大
3. 业务逻辑 + ORM：高开发效率，对象化操作数据库，可移植 | 性能消耗加大，多表联查、复杂条件会复制化ORM

存储过程的操作：
1.查看
select routine_name, routine_type from information_schema.routines where routine_schema='数据库名';

eg: select routine_name, routine_type from information_schema.routines where routine_schema='db2';

2.删除
drop procedure [if exists] 数据库名.存储过程名
'''
delimiter //
create procedure send_money( out p_return_code char(20) )
begin
# 异常处理
declare exit handler for sqlexception
begin
# error
set p_return_code = '错误异常';
rollback;
end;
# exit也可以换成continue，表示发送异常时继续执行
declare exit handler for sqlwarning
begin
# warning
set p_return_code = '警告异常';
rollback;
end;

start transaction;
update account set money = money - 1000 where id = 1;
update account set money = moneys + 1000 where id = 2; # moneys字段导致异常
commit;

# success
set p_return_code = '转账成功'; # 代表执行成功
end //
delimiter ;

# 在mysql中调用存储过程
set @res=null;
call send_money(@res);
select @res;

五、流程控制

• if语句的使用

第一种 if:
"""
if 条件 then
语句;
end if;
"""
第二种 if elseif
"""
if 条件  then
语句1;
elseif 条件 then
语句2;
else 语句3;
end if;
"""

案例：编写过程，实现输入一个整数type范围1-2 输出type=1 or type=2 or type=other;

delimiter //
create procedure showType(in type int,out result char(20))
begin
if type = 1 then
set result = "type = 1";
elseif type = 2 then
set result = "type = 2";
else
set result = "type = other";
end if;
end //
delimiter ;

set @res=null;
call showType(100, @res);
select @res;

• CASE语句

大体意思与Swtich一样的，你给我一个值，我对它进行选择，然后执行匹配上的语句

delimiter //
create procedure caseTest(in type int)
begin
CASE type
when 1  then select "type = 1";
when 2  then select "type = 2";
else select "type = other";
end case;
end //
delimiter ;
call caseTest(1);

• 定义变量

declare 变量名 类型 default 值;
例如：declare i int default 0;

• WHILE循环

循环输出10次hello mysql

delimiter //
create procedure showHello()
begin
declare i int default 0;
while  i < 10 do
select "hello mysql";
set i  = i + 1;
end while;
end //
delimiter ;
call showHello();

• LOOP循环

没有条件，需要自己定义结束语句

输出10次hello mysql

delimiter //
create procedure showloop()
begin
declare i int default 0;
aloop: LOOP
select "hello loop";
set i = i + 1;
if i > 9 then leave aloop;
end if;
end LOOP aloop;
end //
delimiter ;
call showloop();

• REPEAT循环

#类似do while
#输出10次hello repeat
delimiter //
create procedure showRepeat()
begin
declare i int default 0;
repeat
select "hello repeat";
set i = i + 1;
until i > 9
end repeat;
end //
delimiter ;
call showRepeat();

#输出0-100之间的奇数
delimiter //
create procedure showjishu()
begin
declare i int default 0;
aloop: loop
set i = i + 1;
if i >= 101 then leave aloop; end if;
if i % 2 = 0 then iterate aloop; end if;
select i;
end loop aloop;
end //
delimiter ;
call showjishu();