python 之数据库（视图、触发器、事务、存储过程）

10.13 视图

1、什么是视图视图就是通过查询得到一张虚拟表，然后保存下来，下次用的直接使用即可

2、为什么要用视图如果要频繁使用一张虚拟表，可以不用重复查询

3、如何使用视图

视图记录的增、删、改和表方法相同，但改变视图记录，原始表也跟着改，所以不要修改视图记录，只用于查看

create view teacher2course as                                #创建视图

select * from teacher inner join course on teacher.tid = course.teacher_id;



alter view teacher2course as                                 #修改视图名

select * from teacher inner join course on teacher.tid = course.teacher_id;



drop view teacher2course;                                    #删除视图

强调： 1、在硬盘中，视图只有表结构文件，没有表数据文件 2、视图通常用于查询，尽量不要修改视图中的数据

10.14 触发器

触发器：在满足对某张表数据的增、删、改的情况下，自动触发的功能称之为触发器触发器专门针对我们对某一张表数据增insert、删delete、改update的行为，这类行为一旦执行就会触发触发器的执行，即自动运行另外一段sql代码

创建触发器语法：

# 针对插入(insert)

create trigger tri_after_insert_t1 after insert on 表名 for each row

begin

    sql代码...

end



create trigger tri_before_insert_t2 before insert on 表名 for each row

begin

    sql代码...

end



# 针对删除(delete)

create trigger tri_after_delete_t1 after delete on 表名 for each row

begin

    sql代码...

end



create trigger tri_before_delete_t2 before delete on 表名 for each row

begin

    sql代码...

end



# 针对修改(update)

create trigger tri_after_update_t1 after update on 表名 for each row

begin

    sql代码...

end



create trigger tri_before_update_t2 before update on 表名 for each row

begin

    sql代码...

end

举例：

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') );

CREATE TABLE errlog (

    id INT PRIMARY KEY auto_increment,

    err_cmd CHAR (64),

    err_time datetime);

delimiter $$

create trigger tri_after_insert_cmd after insert on cmd for each row

begin

    if NEW.success = 'no' then      #等值判断只有一个等号

        insert into errlog(err_cmd,err_time) values(NEW.cmd,NEW.sub_time);

    end if;

end $$

delimiter ;



insert into cmd (USER,priv,cmd,sub_time,success) values

    ('egon','','ls -l /etc',NOW(),'yes'),

    ('egon','','cat /etc/passwd',NOW(),'no'),

    ('egon','','useradd xxx',NOW(),'no'),

    ('egon','','ps aux',NOW(),'yes');



mysql> select * from errlog;        #查询错误日志，发现有两条

+----+-----------------+---------------------+

| id | err_cmd         | err_time            |

+----+-----------------+---------------------+

|  1 | cat /etc/passwd | 2017-09-14 22:18:48 |

|  2 | useradd xxx     | 2017-09-14 22:18:48 |

+----+-----------------+---------------------+

删除触发器：

drop trigger tri_after_insert_cmd;

10.15 事务

什么是事务：开启一个事务可以包含一些sql语句，这些sql语句要么同时成功，要么都不成功，称之为事务的原子性作用：事务用于将某些操作的多个SQL作为原子性操作，一旦有某一个出现错误，即可回滚到原来的状态，从而保证数据库数据完整性。

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;                                      #无异常，提交结果，提交后回滚无效

10.16 存储过程

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

存储过程的优点：1、用于替代程序写的SQL语句，实现程序与sql解耦 2、基于网络传输，传别名的数据量小，而直接传sql数据量大

存储过程的缺点：程序员扩展功能不方便

10.161 创建与执行存储过程

创建简单存储过程(无参):

delimiter $$

create procedure p1()

BEGIN

    select * from blog;

    insert into blog(name,sub_time) values("xxx",now());

END $$

delimiter ;



#在mysql中调用

call p1()



#在python中基于pymysql调用

cursor.callproc('p1')

print(cursor.fetchall())

创建存储过程(有参）:

delimiter $$

create procedure p2(

    in m int,                           #只可传入

    in n int,

    out res int)                        #只可返回   # inout 既可以传入又可以当作返回值

begin

    select tname from teacher where tid > m and tid < n;

    set res=1;                          #执行成功res返回0

end $$

delimiter ;



#在mysql中调用

set @res=0;

call p2(3,2,@res)

select @res;                            #0代表假（执行失败），1代表真（执行成功）



#在python中基于pymysql调用

cursor.callproc('p2',(2,3,0))            #0相当于set @res=0

print(cursor.fetchall())                #查询select的查询结果



cursor.execute('select @_p2_2;')         #@_p2_2代表第三个参数，即返回值

print(cursor.fetchall())

将事务封装入存储过程：

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;

        DELETE from tb1; #执行失败

        insert into blog(name,sub_time) values('yyy',now());

    COMMIT;



    -- SUCCESS

    set p_return_code = 0; #0代表执行成功



END //

delimiter ;



#在mysql中调用存储过程

set @res=123;

call p5(@res);

select @res;



#在python中基于pymysql调用存储过程

cursor.callproc('p5',(123,))

print(cursor.fetchall()) #查询select的查询结果



cursor.execute('select @_p5_0;')

print(cursor.fetchall())

10.162 删除存储过程

drop procedure proc_name;

回到顶部

巴特西

python 之数据库（视图、触发器、事务、存储过程）

10.13 视图

10.14 触发器

10.15 事务

10.16 存储过程

10.161 创建与执行存储过程

10.162 删除存储过程

最新文章

热门文章

巴特西

python 之 数据库（视图、触发器、事务、存储过程）

10.13 视图

10.14 触发器

10.15 事务

10.16 存储过程

10.161 创建与执行存储过程

10.162 删除存储过程

最新文章

热门文章

python 之数据库（视图、触发器、事务、存储过程）