/linhaifeng/articles/7495918.html

视图

​ 试图就是一个虚拟表（非真实存在），本质就是【根据sql语句获取动态的数据集，并为其命名】，用户使用时只需要使用名称即可获取数据集，可将该数据集当作表来使用。

'''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);视图的修改：alter 等价于 create or replace, 且语法一致alter view new_emp(id,姓名,工资) as (select id,name,salary from emp where dep_id = 1);视图中字段的操作：不允许alter操作字段alter table new_emp rename new_emp1;alter view new_emp modify id tinyint;视图中记录的操作：等价于普通表，完成增删改查update new_emp set 姓名='san' where id = 3;delete from new_emp where id = 3;insert into new_emp(id, 姓名, 工资) values (10, "Bob", 10000); # 操作的是实体表, 虚拟表要重新创建才能拿到最新数据视图的删除:drop view 视图名;总结: 虚拟表作用 -- 查询'''

触发器

使用触发器可以定制用户对表进行【增删改】操作时前后的行为（不报包括查询）

'''what：在表发生数据更新时，会自动触发的功能称之为触发器why：当一个表在发生数据更新时，需要去完成一些操作，可以为具体数据更新的方式添加触发器语法：delimiter //create trigger 触发器名 before|after insert|update|delete on 表名 for each rowbegin 需要触发执行的sql代码们end //delimiter ;# 触发器名: t1_before_insert_tri注：delimiter是用来修改sql的语句结束标识符删除触发器：drop trigger 触发器名;'''

# 插入前CREATE TRIGGER tri_before_insert_tb1 BEFORE INSERT ON tb1 FOR EACH ROWBEGIN...END# 插入后CREATE TRIGGER tri_after_insert_tb1 AFTER INSERT ON tb1 FOR EACH ROWBEGIN...END# 删除前CREATE TRIGGER tri_before_delete_tb1 BEFORE DELETE ON tb1 FOR EACH ROWBEGIN...END# 删除后CREATE TRIGGER tri_after_delete_tb1 AFTER DELETE ON tb1 FOR EACH ROWBEGIN...END# 更新前CREATE TRIGGER tri_before_update_tb1 BEFORE UPDATE ON tb1 FOR EACH ROWBEGIN...END# 更新后CREATE TRIGGER tri_after_update_tb1 AFTER UPDATE ON tb1 FOR EACH ROWBEGIN...END# 删除触发器drop trigger tri_after_insert_cmd;

# 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 rowbegin# 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;

​ 触发器用户无法直接调用，而是由对表的【增删改】操作被动引发的

事务

事务用于将某些操作的多个SQL作为原子性操作，一旦有某一个出现错误，即可回滚到原来的状态，从而保证数据库数据完整性

'''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中使用事务处理from pymysql.err import InternalErrorsql = '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)mit() # 提交事务except InternalError:print("转账失败")conn.rollback()# 回滚操作

存储过程

一、简介

​ 存储过程包含了一系列可执行的sql语句，存储过程存放于mysql中，通过调用它的名字可执行其内部的一堆sql语句

​ 优点：

#1. 用于替代程序写的SQL语句，实现程序与sql解耦#2. 基于网络传输，传别名的数据量小，而直接传sql数据量大

​ 缺点：程序员扩展功能不方便

程序与数据库结合使用的三种方式

#方式一：MySQL：存储过程程序：调用存储过程#方式二：MySQL：程序：纯SQL语句#方式三：MySQL:程序：类和对象，即ORM（本质还是纯SQL语句）

二、创建简单的存储过程（无参）

delimiter //create procedure p1()BEGINselect * from blog;INSERT into blog(name,sub_time) values("xxx",now());END //delimiter ;#在mysql中调用call p1() #在python中基于pymysql调用cursor.callproc('p1') print(cursor.fetchall())

三、创建存储过程（有参）

对于存储过程，可以接收参数，其参数有三类：#in仅用于传入参数用#out 仅用于返回值用#inout既可以传入又可以当作返回值

① in：传入参数

delimiter //create procedure p2(in n1 int,in n2 int)BEGINselect * from blog where id > n1;END //delimiter ;#在mysql中调用call p2(3,2)#在python中基于pymysql调用cursor.callproc('p2',(3,2))print(cursor.fetchall())

② out：返回值

delimiter //create procedure p3(in n1 int,out res int)BEGINselect * from blog where id > n1;set res = 1;END //delimiter ;#在mysql中调用set @res=0; #0代表假（执行失败），1代表真（执行成功）call p3(3,@res);select @res;#在python中基于pymysql调用cursor.callproc('p3',(3,0)) #0相当于set @res=0print(cursor.fetchall()) #查询select的查询结果cursor.execute('select @_p3_0,@_p3_1;') #@p3_0代表第一个参数，@p3_1代表第二个参数，即返回值print(cursor.fetchall())

③ inout 可传值可返回

delimiter //create procedure p4(inout n1 int)BEGINselect * from blog where id > n1;set n1 = 1;END //delimiter ;#在mysql中调用set @x=3;call p4(@x);select @x;#在python中基于pymysql调用cursor.callproc('p4',(3,))print(cursor.fetchall()) #查询select的查询结果cursor.execute('select @_p4_0;') print(cursor.fetchall())

四、执行存储过程

① 在MySQL中执行存储过程

-- 无参数call proc_name()-- 有参数，全incall proc_name(1,2)-- 有参数，有in，out，inoutset @t1=0;set @t2=3;call proc_name(1,2,@t1,@t2)

② 在python中基于MySQL执行存储过程

#!/usr/bin/env python# -*- coding:utf-8 -*-import pymysqlconn = pymysql.connect(host='127.0.0.1', port=3306, user='root', passwd='123', db='t1')cursor = conn.cursor(cursor=pymysql.cursors.DictCursor)# 执行存储过程cursor.callproc('p1', args=(1, 22, 3, 4))# 获取执行完存储的参数cursor.execute("select @_p1_0,@_p1_1,@_p1_2,@_p1_3")result = cursor.fetchall()mit()cursor.close()conn.close()print(result)

五、删除存储过程

drop procedure proc_name;

六、小结

'''what：用于完成指定功能的sql语句块，类似于Python中的函数why：将能指定功能的sql语句块建立成存储过程，不仅将sql语句逻辑化了，更是功能化了，那我们要完成相同的事，只需要重复使用建立的存储过程，不就需要再重复书写sql语句了# 总结: 存储过程可以让sql语句具有 复用性, 从而提高开发效率语法：delimiter //create procedure 存储过程名(输入输出类型1 参数名1 参数类型1(宽度), ... ,输入输出类型n 参数名n 参数类型n(宽度))beginsql语句块end //delimiter ;注：1.输入输出类型：in | out | inout2.call 存储过程名(实参们)来调用存储过程案例：set @res = null; # 定义空值变量, 用来接收存储过程的执行结果delimiter //create procedure user_info(in b int, in l int, out res char(20))beginselect * 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;