四十二、视图、触发器、事务、储存过程、函数、流程控制和索引等知识的应用

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

    删除视图：drop view teacher2course

标准语法
        create trigger 触发器名字 after insert on 表名 for each row
        begin
            sql语句
        end

    ①增
        增加数据之前
        create trigger tri_before_insert_t1 before insert on t1 for each row
        begin
            sql语句
        end

        增加数据之后
        create trigger tri_after_insert_t1 after insert on t1 for each row
        begin
            sql语句
        end

    ②删
        删除数据之前
        create trigger tri_before_delete_t1 before delete on t1 for each row
        begin
            sql语句
        end

        删除数据之后
        create trigger tri_after_delete_t1 after delete on t1 for each row
        begin
            sql语句
        end

    ③改
        修改数据之前
        create trigger tri_before_update_t1 before update on t1 for each row
        begin
            sql语句
        end

        修改数据之后
        create trigger tri_after_update_t1 after update on t1 for each row
        begin
            sql语句
        end

 举例：
        创建表格：
        create table cmd(
            id int primary key auto_increment,
            user char(32),
            prvi 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 $$   # 将mysql默认的结束符由;改为$$
        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,prvi,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‘);

        查看触发器：
        show create trigger tri_after_insert_cmd;

        删除触发器：
        drop trigger tri_after_insert_cmd;

语法
    开启事物
        start transaction
        
    创建表格   
        create table t1();
        
    插入数据
        insert into t1 values(1,2),
        insert into t1 values(1,2),
        insert into t1 values(1,2),

    回滚
        roll back
    提交
        commit

　　①创建表
    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:
        roll back
    else:
        commit

    那如何检测异常？就用到储存过程

 ①直接在mysql中调用
    set @res=10;       # res的值是用来判断存储过程是否被执行成功的依据，所以需要先定义一个变量@res存储10
    call p1(2,4,10);  # 报错
    call p1(2,4,@res);
    查看结果
    select @res;  # 执行成功，@res变量值发生了变化

    ②在python程序中调用，下一节内容
    pymysql链接mysql
    产生的游表cursor.callproc(‘p1‘,(2,4,10))  # 内部原理：@_p1_0=2,@_p1_1=4,@_p1_2=10;
    cursor.excute(‘select @_p1_2‘)
    print(cursor.fetchall())

语法：
        delimiter $$
        create procedure p1()
        begin
            select * from user;
        end $$
        delimiter ;
        调用存储过程
        call p1();


举例：
        delimiter @@
        create procedure p1(
            in m int,    # in 表示该形参接收的数据不能被返回出来
            in n int,
            out res int  # out 表示该形参接收的数据可以被返回出去
        )
        begin
            select * from teacher where tid > m and tid < n;
            set res=0;   # 返回一个值，判断储存过程是否执行
        end @@
        delimiter ;
        set @res = 10;   # 存一个变量，用来判断执行储存过程后res是否改成0，然后再调用存储过程
        调用存储过程
        call p1(1,5,@res);

import pymysql

conn = pymysql.connect(
    host=‘127.0.0.1‘,
    port=3306,
    user=‘root‘,
    password=‘3822515‘,
    database=‘day41‘,
    charset=‘utf8‘,
    autocommit=True
)

cursor = conn.cursor(pymysql.cursors.DictCursor)

cursor.callproc(‘p1‘, (1, 5, 10))  # @_p1_2 = 1  @_p1_1 = 5 @_p1_2 = 10

cursor.execute(‘select @_p1_2‘)
print(cursor.fetchall())      # [{‘@_p1_2‘: 0}]

create table blog(
    id int primary key auto_increment,
    name char(32),
    sub_time datetime
);

insert into blog(name,sub_time) values
    (‘第1篇‘,‘2015-03-01 11:31:21‘),
    (‘第2篇‘,‘2015-03-11 16:31:21‘),
    (‘第3篇‘,‘2016-07-01 10:21:31‘),
    (‘第4篇‘,‘2016-07-22 09:23:21‘),
    (‘第5篇‘,‘2016-07-23 10:11:11‘),
    (‘第6篇‘,‘2016-07-25 11:21:31‘),
    (‘第7篇‘,‘2017-03-01 15:33:21‘),
    (‘第8篇‘,‘2017-03-01 17:32:21‘),
    (‘第9篇‘,‘2017-03-01 18:31:21‘);

格式化日期取出年月，然后按日期分组
select date_format(sub_time,‘%Y-%m‘),count(id) from blog group by date_format(sub_time,‘%Y-%m‘);

1、if条件语句

delimiter $$
create procedure proc_if ()
begin
    declare i int default 0;
    if i = 1 then
        select 1;
    elseif i = 2 then
        select 2;
    else
        select 7;
    end if;
end $$
delimiter ;



2、while循环

delimiter $$
create procedure proc_while ()
begin
    declare num int ;
    set num = 0 ;
    while num < 10 do
        select
            num ;
        set num = num + 1 ;
    end while ;
end $$
delimiter ;

1. 准备表
    create table s1(
        id int,
        name varchar(20),
        gender char(6),
        email varchar(50)
    );

2、创建存储过程，实现批量插入记录
    delimiter $$
    create procedure auto_insert1()
    begin
        declare i int default 1;
        while(i<3000000)do
            insert into s1 values(i,‘jason‘,‘male‘,concat(‘jason‘,i,‘@oldboy‘));
            set i=i+1;
        end while;
    end $$
    delimiter;

3、调用存储过程
    call auto_insert1();

    查看插了多少
    select count(id) from s1;

4、查看存储过程
    show create procedure auto_insert1\G;