目录
一、视图
1、什么是视图
视图就是通过查询得到一张虚拟表，然后保存下来，下次直接使用即可
2、为什么要用视图
如果要频繁使用一张虚拟表，可以不用重复查询
'''实际工作中，如果数据量比较大，表比较多的情况下，一般情况尽量不使用连表，连表会影响查询效率，不是所有情况都不让使用连表的，有些特殊场景，还真需要使用连表'''
# 能不能超过两张表以上的表连表?
可以
'''表连的越多，效率越低，查询时间会变长'''
能使用单表的最好使用单表查询，尽量连表的时候不要连太多的表
# 工作中，有些会限制
1. 不让连表
2. 不让循环查库
for id in [1,2,3,4,5]:
select * from user where id = id; # 查询5次库
3. 循环查库最大的问题也是效率问题，
select * from user where id in (1,2,3,4,5); # 只会查询一次库
# 代码上线------->review代码---------->检查代码------->代码规范
review ------>测试环境------> 测试-------->改bug----------->测试提交一个报告，上线----->有数据库---->先上数据库------>合并代码(git)---->合并命令
# 对于mysql的增 删 改 查------>最影响效率的是查询-------- 增 删 改可能影响的效率可以忽略
# 对于MySQL来说，一张表中千万条记录以下，几乎不影响应能，超过千万级别，查询性能会急剧下降
3、如何用视图
create view teacher2course as
select * from teacher inner join course on teacher.tid = course.teacher_id;
"""
创建好了之后，验证它的存在navicat验证，cmd终端验证
最后文件验证，得出下面的结论，视图只有表结构数据还是来源于之前的表
delete from teacher2course where id=1;
"""
强调
- 在硬盘中，视图只有表结构文件，没有表数据文件
- 视图通常是用于查询，尽量不要修改视图中的数据
视图尽量少用，会跟真正的表产生混淆，从而干扰操作者
drop view teacher2course;
思考:开发过程中会不会去使用视图？
不会！视图是mysql的功能，如果你的项目里面大量的使用到了视图，那意味着你后期想要扩张某个功能的时候这个功能恰巧又需要对视图进行修改，意味着你需要先在mysql这边将视图先修改一下，然后再去应用程序中修改对应的sql语句，这就涉及到跨部门沟通的问题，所以通常不会使用视图，而是通过重新修改sql语句来扩展功能
二、触发器
在满足对某张表数据的增、删、改的情况下，自动触发的功能称之为触发器
1、为何要用触发器
触发器专门针对我们对某一张表数据增insert、删delete、改update的行为，这类行为一旦执行就会触发触发器的执行，即自动运行另外一段sql代码
2、创建触发器语法
"""语法结构"""
create trigger 触发器的名字 before/after insert/update/delete on 表名 for each row
begin
sql语句
end
# 针对插入
create trigger tri_after_insert_t1 after insert on 表名 for each row
begin
sql代码...
end
create trigger tri_after_insert_t2 before insert on 表名 for each row
begin
sql代码...
end
# 针对删除
create trigger tri_after_delete_t1 after delete on 表名 for each row
begin
sql代码...
end
create trigger tri_after_delete_t2 before delete on 表名 for each row
begin
sql代码...
end
# 针对修改
create trigger tri_after_update_t1 after update on 表名 for each row
begin
sql代码...
end
create trigger tri_after_update_t2 before update on 表名 for each row
begin
sql代码...
end
1.触发器命名有一定的规律
tri_before_insert_t1
tri_after_delete_t2
tri_after_update_t2
2.临时修改SQL语句的结束符
需要注意:在书写sql代码的时候结束符是; 而整个触发器的结束也需要分号;
这就会出现语法冲突,需要我们临时修改结束符号
delimiter $$ # 将mysql默认的结束符由;换成$$
delimiter ;
该语法只在当前窗口有效
3、实际应用
# 案例
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 $$ # 将mysql默认的结束符由;换成$$
create trigger tri_after_insert_cmd after insert on cmd for each row
begin # 插入之后应用的触发器
if NEW.success = 'no' then # 新记录都会被MySQL封装成NEW对象
insert into errlog(err_cmd,err_time) values(NEW.cmd,NEW.sub_time);
end if;
end $$
delimiter ; # 结束之后记得再改回来，不然后面结束符就都是$$了
#往表cmd中插入记录，触发触发器，根据IF的条件决定是否插入错误日志
INSERT INTO cmd (
USER,
priv,
cmd,
sub_time,
success
)
VALUES
('egon','0755','ls -l /etc',NOW(),'yes'), # NOW()是查询当前时间的函数
('egon','0755','cat /etc/passwd',NOW(),'no'),
('egon','0755','useradd xxx',NOW(),'no'),
('egon','0755','ps aux',NOW(),'yes');
# 查询cmd表记录
select * from cmd;
# 查询errlog表记录
select * from errlog;
# 查看所有的触发器
show triggers;
# 删除触发器
drop trigger tri_after_insert_cmd;
'''触发器建在哪个库里面，只在这个库里面生效'''
#########################
mysql> select * from cmd;
+----+------+------+-----------------+---------------------+---------+
| id | USER | priv | cmd | sub_time | success |
+----+------+------+-----------------+---------------------+---------+
| 1 | egon | 0755 | ls -l /etc | 2023-04-10 15:20:21 | yes |
| 2 | egon | 0755 | cat /etc/passwd | 2023-04-10 15:20:21 | no |
| 3 | egon | 0755 | useradd xxx | 2023-04-10 15:20:21 | no |
| 4 | egon | 0755 | ps aux | 2023-04-10 15:20:21 | yes |
+----+------+------+-----------------+---------------------+---------+
4 rows in set (0.00 sec)
mysql> select * from errlog;
+----+-----------------+---------------------+
| id | err_cmd | err_time |
+----+-----------------+---------------------+
| 1 | cat /etc/passwd | 2023-04-10 15:20:21 |
| 2 | useradd xxx | 2023-04-10 15:20:21 |
+----+-----------------+---------------------+
2 rows in set (0.00 sec)
mysql> show triggers;
+----------------------+--------+-------+-------------------------------------------------------------------------------------------------------------------------------------+--------+---------+----------------------------------------+----------------+----------------------+----------------------+--------------------+
| Trigger | Event | Table | Statement | Timing | Created | sql_mode | Definer | character_set_client | collation_connection | Database Collation |
+----------------------+--------+-------+-------------------------------------------------------------------------------------------------------------------------------------+--------+---------+----------------------------------------+----------------+----------------------+----------------------+--------------------+
| tri_after_insert_cmd | INSERT | cmd | begin
if NEW.success = 'no' then
insert into errlog(err_cmd,err_time) values(NEW.cmd,NEW.sub_time);
end if;
end | AFTER | NULL | ONLY_FULL_GROUP_BY,STRICT_TRANS_TABLES | root@localhost | utf8 | utf8_general_ci | utf8_general_ci |
+----------------------+--------+-------+-------------------------------------------------------------------------------------------------------------------------------------+--------+---------+----------------------------------------+----------------+----------------------+----------------------+--------------------+
1 row in set (0.02 sec)
三、存储过程
1、介绍
存储过程包含了一系列可执行的sql语句，存储过程存放于MySQL中，通过调用它的名字可以执行其内部的一堆sql
使用存储过程的优点：
#1. 用于替代程序写的SQL语句，实现程序与sql解耦
#2. 基于网络传输，传别名的数据量小，而直接传sql数据量大
使用存储过程的缺点：
#1. 程序员扩展功能不方便
补充：程序与数据库结合使用的三种方式
#方式一：
MySQL：存储过程
程序：调用存储过程
#方式二：
MySQL：
程序：纯SQL语句
#方式三：
MySQL:
程序：类和对象，即ORM（本质还是纯SQL语句）
2、创建简单存储过程（无参）
DBA：数据库管理员---------->专门管理数据的人员------->数据备份------>
# 无参函数
delimiter $$
create procedure p1()
begin
select * from cmd; # 类似函数体代码
end $$
delimiter ;
# 1.在mysql中调用
call p1() # 执行了存储过程中的代码
# 2.在python中基于pymysql调用
cursor.callproc('p1')
print(cursor.fetchall())
3、创建存储过程（有参）
对于存储过程，可以接收参数，其参数有三类：
#in 仅用于传入参数用
#out 仅用于返回值用
#inout 既可以传入又可以当作返回值
# 有参函数
delimiter $$
create procedure p2(
in m int, # in表示这个参数必须只能是传入不能被返回出去
in n int,
out res int # out表示这个参数可以被返回出去
)
begin
select * from cmd where id > m and id < n;
set res=0; # 用来标志存储过程是否执行
end $$
delimiter ;
# 针对res需要先提前定义
# n、m是要被传入的，可以直接传值。但是res是要被返回的需要传个变量
set @res=10; # 定义，声明一个变量可以随意命名
select @res; # 查看
# 1.在mysql中调用
call p2(1,4,@res); # 调用
select @res; # 查看
# 2.在python中基于pymysql调用
cursor.callproc('p2',(2,4,10))
print(cursor.fetchall())
cursor.excute('select @_p2_2;')
print(cursor.fetchall())
'''存储过程一定是先定义，再调用'''
4、如何用存储过程
在MySQL中执行存储过程
# 大前提:存储过程在哪个库下面创建的只能在对应的库下面才能使用！！！
# 1、直接在mysql中调用
set @res=10 # res的值是用来判断存储过程是否被执行成功的依据，所以需要先定义一个变量@res存储10
# call p2(2,4,10); # 报错
call p2(2,4,@res);
# 查看结果
select @res; # 执行成功，@res变量值发生了变化
在python中基于pymysql执行存储过程
# 2、在python程序中调用
pymysql链接mysql
产生的游表cursor.callproc('p2',(2,4,10)) # 内部原理：@_p2_0=2,@_p2_1=4,@_p2_2=10;
cursor.excute('select @_p2_2;')
pymysql模块的具体使用
import pymysql
conn = pymysql.connect(
host='127.0.0.1',
port=3306,
user='root',
password='1113',
db='db7',
charset='utf8',
autocommit=True
)
cursor = conn.cursor(cursor=pymysql.cursors.DictCursor)
# 1.构造查询SQL语句
sql = ""
# 2.发送给服务端并执行存储过程
# 内部原理：@_p2_0=2,@_p2_1=4,@_p2_2=10;
cursor.callproc('p2', (2, 4, 10)) # ('过程名',(参数1,参数2))
print(cursor.fetchall())
# > [{'id': 3, 'USER': 'egon', 'priv': '0755', 'cmd': 'useradd xxx', 'sub_time': datetime.datetime(2023, 4, 10, 15, 20, 21), 'success': 'no'}]
# 3.执行SQL语句
cursor.execute('select @_p2_2;') # 查询@res的值
# 4.获取执行结果
res = cursor.fetchall()
print(res)
# > [{'@_p2_2': 0}]
5、查看存储与删除存储
查看存储过程具体信息
show create procedure p1;
查看所有存储过程
show procedure status;
删除存储过程
drop procedure pro1;
6、存储过程与事务使用举例(了解
delimiter //
create PROCEDURE p5(
OUT p_return_code tinyint
)
BEGIN
DECLARE exit handler for sqlexception
BEGIN
-- ERROR
set p_return_code = 1;
rollback;
END;
DECLARE exit handler for sqlwarning
BEGIN
-- WARNING
set p_return_code = 2;
rollback;
END;
START TRANSACTION;
update user set balance=900 where id =1;
update user123 set balance=1010 where id = 2;
update user set balance=1090 where id =3;
COMMIT;
-- SUCCESS
set p_return_code = 0; #0代表执行成功
END //
delimiter ;