当前位置:Gxlcms > 数据库问题 > 43 MySQL视图、触发器、事务、存储过程、函数

43 MySQL视图、触发器、事务、存储过程、函数

时间:2021-07-01 10:21:17 帮助过:19人阅读

  1、什么是视图

    通过查询得到一张虚拟表,然后保存下来,下次直接使用即可

  2、为什么要用视图

    如需频繁使用一张虚拟表,可以不用重复查询

  3、如何用视图

注意:

  1)在硬盘中,视图只有表结构文件,没有表数据文件
  2)视图通常是用于查询,尽量不要修改视图中的数据

create view teacher2course as
select * from teacher inner join course on teacher.tid = course.teacher_id;

-- 删除视图
drop view teacher2course;
技术图片
不会!视图是mysql的功能:
如果项目里面大量的使用到了视图,那意味着后期想要扩张某个功能的时候这个功能恰巧又需要对视图进行修改,意味着你需要先在mysql这边将视图先修改一下,然后再去应用程序中修改对应的sql语句,这就涉及到跨部门沟通的问题......
-- 通常不会使用视图,而是通过重新修改sql语句来扩展功能
思考:开发过程中会不会去使用视图?

触发器

  在满足对某张表数据的增、删、改的情况下,自动触发的功能称之为触发器

 

  1)为何要用触发器

    触发器专门针对我们对某一张表数据增insert、删delete、改update的行为,这类行为一旦执行
?    就会触发触发器的执行,即自动运行另外一段sql代码

 

  2)创建触发器语法

关键字:trigger

触发位置:before | after

触发操作:insert | update | delete

设置MySQL结束符:delimiter

-- 针对插入
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

 

  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),
    (egon,0755,cat /etc/passwd,NOW(),no),
    (egon,0755,useradd xxx,NOW(),no),
    (egon,0755,ps aux,NOW(),yes);


-- 查询errlog表记录
select * from errlog;
-- 删除触发器
drop trigger tri_after_insert_cmd;

 

事务

  开启包含一些sql语句的事务,这些sql语句要么同时成功, 要么一个都别想成功

  1)事务的作用

保证了对数据操作的数据安全性

案例:用交行的卡操作建行ATM机给工商的账户转钱

  2)事务的属性:ACID特性

Ⅰ)原子性 atomicity

  事务是一个不可分割的工作单位,包括的诸操作要么都做,要么都不做。

Ⅱ)一致性 consistency

  事务必须是使数据库从一个一致性状态变到另一个一致性状态。一致性与原子性是密切相关的。

Ⅲ)隔离性 isolation

  一个事务的执行不能被其他事务干扰。

  即一个事务内部的操作及使用的数据对并发的其他事务是隔离的,并发执行的各个事务之间不能互相干扰。

Ⅳ)持久性 durability

  也称永久性 permanence ,指一个事务一旦提交,它对数据库中数据的改变就应该是永久性的。

  接下来的其他操作或故障不应该对其有任何影响。

 

  3)事务的使用

create table user(
id int primary key auto_increment,
name char(32),
balance int
);

insert into user(name,balance)
values
(wsb,1000),
(egon,1000),
(ysb,1000);

-- 修改数据之前先开启事务操作
start transaction;

-- 修改操作
update user set balance=900 where name=wsb; #买支付100元
update user set balance=1010 where name=egon; #中介拿走10元
update user set balance=1090 where name=ysb; #卖家拿到90元

-- 回滚到上一个状态
rollback;

-- 开启事务之后,只要没有执行commit操作,数据其实都没有真正刷新到硬盘
commit;

"""开启事务检测操作是否完整,不完整主动回滚到上一个状态,如果完整就应该执行commit操作"""

-- 站在python代码的角度,应该实现的伪代码逻辑,
try:
    update user set balance=900 where name=wsb; #买支付100元
    update user set balance=1010 where name=egon; #中介拿走10元
    update user set balance=1090 where name=ysb; #卖家拿到90元
except 异常:
    rollback;
else:
    commit;

-- 那如何检测异常?

 

存储过程

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

  1、创建存储过程

delimiter $$
create procedure p1(
    in m int,  # in表示这个参数必须只能是传入不能被返回出去
    in n int,  
    out res int  # out表示这个参数可以被返回出去,还有一个inout表示即可以传入也可以被返回出去
)
begin
    select tname from teacher where tid > m and tid < n;
    set res=0;
end $$
delimiter ;

-- 小知识点补充,当一张表的字段特别多记录也很多的情况下,终端下显示出来会出现显示错乱的问题 \G:逐条显示
select * from mysql.user\G;

 

  2、如何用存储过程

    大前提:存储过程在哪个库下面创建的只能在对应的库下面才能使用!!!

-- 1、直接在mysql中调用
set @res=10  # res的值是用来判断存储过程是否被执行成功的依据,所以需要先定义一个变量@res存储10
call p1(2,4,10);  # 报错
call p1(2,4,@res);  

# 查看结果
select @res;  # 执行成功,@res变量值发生了变化

-- 2、在python程序中调用
pymysql链接mysql
产生的游表cursor.callproc(p1,(2,4,10))  # 内部原理:@_p1_0=2,@_p1_1=4,@_p1_2=10;
cursor.excute(select @_p1_2;)


-- 3、存储过程与事务使用举例(了解)
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 ;

  3、三种开发模型

人气教程排行