zoukankan      html  css  js  c++  java
  • 视图,触发器,事务

    视图

      一个SQL查询语句的结果是一张虚拟表,将这种虚拟表保存下来,它就变成了一个视图。

      我我们之所以使用视图,是因为当你频繁需要用到多张表的连表结果的时候,你就可以事先生成好视图,之后直接调用即可,避免了反复写连表操作的sql语句。

      视图只有表结构,视图中的数据还是来源于原来的表,不要改动视图表中的数据,因为会影响到其它表中的数据 一般情况下不会频繁的使用视图来写业务逻辑。

      固定语句

        create view 跟视图的名字 as 后面跟虚拟表的名字(就是SQL语句拿到的表)

    触发器

      到达某个条件自动触发,当你在对数据进行增 删 改的情况下会自动触发触发器的运行,类似一个警报系统,就是你一旦做了某个操作,我就立马执行什么东西。

    触发器分为六种情况: 增前; 增后; 改前; 改后; 删前; 删后。
      固定语法结构:
      create trigger 触发器的名字 after/before insert/update/delete on 表名 for each row   
      begin
      sql语句
      end                                            # ror each row  是实时在监测的意思,只要有一条数据被增了,改了或者删了就立马触发

    增前

      create trigger tri_before/after_insert/update/delete_t1 after/before insert/update/delete on t1 for each row
      begin
      sql语句
      end
      可以修改MySQL默认的结束符(;)
      delimiter $$    #  只对当前窗口有效
      create trigger tri_before_insert_user before insert on user for each row
      begin
      select * from user
      end $$
      delimiter ;

    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
    );
    
    #  补充:NEW对象指代的就是当前记录
    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 ;
    
    
    
    
    delimiter $$  # 只对当前窗口有效
    create trigger tri_after_insert_user after insert on user for each row
    begin
        insert into user(name,password) values('咻咻咻','123');
    end $$
    delimiter ;
    
    
    drop trigger tri_before_insert_user;

    事务:

    事务包含一大堆sql语句,这些sql要么同时成功,要么一个也别想成功

      事务四大特性:ACID
        A:原子性
        C:一致性
        I:隔离性
        D:持久性

          原子性(atomicity)。一个事务是一个不可分割的工作单位,事务中包括的诸操作要么都做,要么都不做。
          一致性(consistency)。事务必须是使数据库从一个一致性状态变到另一个一致性状态。一致性与原子性是密切相关的。
          隔离性(isolation)。一个事务的执行不能被其他事务干扰。即一个事务内部的操作及使用的数据对并发的其他事务是隔离的,并发执行的各个事务之间不能互相干扰。
          持久性(durability)。持久性也称永久性(permanence),指一个事务一旦提交,它对数据库中数据的改变就应该是永久性的。接下来的其他操作或故障不应该对其有任何影响

    如何开启事务
      start transaction
    事务回滚
      rollback
    永久性更改
      commit

    存储过程

      就类似于python中的自定义函数,内部封装了操作数据库的sql语句,后续想要实现相应的操作 只需要调用存储过程即可。

      create procedure pi() 储存过程的意思  后面跟参数   pi相当于函数名  括号内放形参

    # 语法结果
            delimiter $$
            create procedure p1()
            begin
                select * from user;
            end $$
            delimiter ;
    
     #   带参数的
            delimiter $$
            create procedure p1(
                in m int,  # 不能被返回出去
                in n int,
                out res int,  # 可以被返回
                inout xxx int,  # 既可以进又可以出
            )
            begin
                select * from user;
            end $$
            delimiter ;
    
    
    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 ;
    
    set @res = 10   # 设置一个变量与值的绑定关系
    
    # 调用存储过程 将变量@res传入
    
    # 之后通过,select @res 查看存储过程执行完成后的返回结果,存储过程在哪个库下面定义 就只能在哪个库下面使用

    pymysql调用存储过程:

    import pymysql
    
    conn = pymysql.connect(
        host = '127.0.0.1',
        port = 3306,
        user = 'root',
        password = '123',
        database = 'day38',
        charset = 'utf8',
        autocommit = True
    )
    cursor = conn.cursor(pymysql.cursors.DictCursor)
    # call p1()  mysql中调用
    # callproc()  pymysql中调用
    cursor.callproc('p1',(1,5,10))
    # 内部自动用变量名存储了对应的值
    print(cursor.fetchall())
    
    """
    @_p1_0=1
    @_p1_1=5
    @_p1_2=10
    @_存储过程名_索引值
    """
    cursor.execute('select @_p1_0')
    print(cursor.fetchall())
    cursor.execute('select @_p1_1')
    print(cursor.fetchall())
    cursor.execute('select @_p1_2')
    print(cursor.fetchall())

    存储过程与事务联合使用

    delimiter //
    create PROCEDURE p5(           #  创建一个存储器p5是名字
        OUT p_return_code tinyint    #   括号内是形参  OUT是能够被返回回来的
    )
    BEGIN               #  规定代码块儿
    
        DECLARE exit handler for sqlexception
        BEGIN
            -- ERROR     #   标识报错
            set p_return_code = 1;          #   如果出现报错了把返回值改成1
            rollback;
        END;
    
    
      DECLARE exit handler for sqlwarning   # 警告
      BEGIN
          -- WARNING
          set p_return_code = 2;   # 改成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 ; 

    函数:

    注意与存储过程的区别,mysql内置的函数只能在sql语句中使用

    博客:<http://www.cnblogs.com/linhaifeng/articles/7495918.html#_label2>

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

    流程控制

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

    索引与慢查询优化

    知识回顾:数据都是存在硬盘上的,那查询数据不可避免的需要进行IO操作

    *索引在MySQL中也叫做“键”,是存储引擎用于快速找到记录的一种数据结构。*

    * primary key
    * unique key
    * index key

    注意foreign key不是用来加速查询用的,不在我们研究范围之内,上面三种key前两种除了有加速查询的效果之外还有额外的约束条件(primary key:非空且唯一,unique key:唯一),而index key没有任何约束功能只会帮你加速查询

    索引就是一种数据结构,类似于书的目录。意味着以后再查数据应该先找目录再找数据,而不是用翻页的方式查询数据

    **本质都是:通过不断地缩小想要获取数据的范围来筛选出最终想要的结果,同时把随机的事件变成顺序的事件,也就是说,有了这种索引机制,我们可以总是用同一种查找方式来锁定数据。**

    **索引的影响:**

    * 在表中有大量数据的前提下,创建索引速度会很慢
    * 在索引创建完毕后,对表的查询性能会大幅度提升,但是写的性能会降低

     b+树

    博客网址:  <https://images2017.cnblogs.com/blog/1036857/201709/1036857-20170912011123500-158121126.png>

    只有叶子结点存放真实数据,根和树枝节点存的仅仅是虚拟数据

    查询次数由树的层级决定,层级越低次数越少

    一个磁盘块儿的大小是一定的,那也就意味着能存的数据量是一定的。如何保证树的层级最低呢?一个磁盘块儿存放占用空间比较小的数据项

    思考我们应该给我们一张表里面的什么字段字段建立索引能够降低树的层级高度>>> 主键id字段

    **聚集索引(primary key)**

    聚集索引其实指的就是表的主键,innodb引擎规定一张表中必须要有主键。先来回顾一下存储引擎。

    myisam在建表的时候对应到硬盘有几个文件(三个)?

    innodb在建表的时候对应到硬盘有几个文件(两个)?frm文件只存放表结构,不可能放索引,也就意味着innodb的索引跟数据都放在idb表数据文件中。

    **特点:**叶子结点放的一条条完整的记录

    辅助索引(unique,index)

    辅助索引:查询数据的时候不可能都是用id作为筛选条件,也可能会用name,password等字段信息,那么这个时候就无法利用到聚集索引的加速查询效果。就需要给其他字段建立索引,这些索引就叫辅助索引

    **特点:**叶子结点存放的是辅助索引字段对应的那条记录的主键的值(比如:按照name字段创建索引,那么叶子节点存放的是:{name对应的值:name所在的那条记录的主键值})

    select name from user where name='jason';

    上述语句叫覆盖索引:只在辅助索引的叶子节点中就已经找到了所有我们想要的数据

    select age from user where name='jason';

    上述语句叫非覆盖索引,虽然查询的时候命中了索引字段name,但是要查的是age字段,所以还需要利用主键才去查找

     测试索引

    **准备**

    ```mysql
    #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. 查看存储过程
    show create procedure auto_insert1G

    #4. 调用存储过程
    call auto_insert1();
    ```

    ``` mysql 
    # 表没有任何索引的情况下
    select * from s1 where id=30000;
    # 避免打印带来的时间损耗
    select count(id) from s1 where id = 30000;
    select count(id) from s1 where id = 1;

    # 给id做一个主键
    alter table s1 add primary key(id); # 速度很慢

    select count(id) from s1 where id = 1; # 速度相较于未建索引之前两者差着数量级
    select count(id) from s1 where name = 'jason' # 速度仍然很慢


    """
    范围问题
    """
    # 并不是加了索引,以后查询的时候按照这个字段速度就一定快
    select count(id) from s1 where id > 1; # 速度相较于id = 1慢了很多
    select count(id) from s1 where id >1 and id < 3;
    select count(id) from s1 where id > 1 and id < 10000;
    select count(id) from s1 where id != 3;

    alter table s1 drop primary key; # 删除主键 单独再来研究name字段
    select count(id) from s1 where name = 'jason'; # 又慢了

    create index idx_name on s1(name); # 给s1表的name字段创建索引
    select count(id) from s1 where name = 'jason' # 仍然很慢!!!
    """
    再来看b+树的原理,数据需要区分度比较高,而我们这张表全是jason,根本无法区分
    那这个树其实就建成了“一根棍子”
    """
    select count(id) from s1 where name = 'xxx';
    # 这个会很快,我就是一根棍,第一个不匹配直接不需要再往下走了
    select count(id) from s1 where name like 'xxx';
    select count(id) from s1 where name like 'xxx%';
    select count(id) from s1 where name like '%xxx'; # 慢 最左匹配特性

    # 区分度低的字段不能建索引
    drop index idx_name on s1;

    # 给id字段建普通的索引
    create index idx_id on s1(id);
    select count(id) from s1 where id = 3; # 快了
    select count(id) from s1 where id*12 = 3; # 慢了 索引的字段一定不要参与计算

    drop index idx_id on s1;
    select count(id) from s1 where name='jason' and gender = 'male' and id = 3 and email = 'xxx';
    # 针对上面这种连续多个and的操作,mysql会从左到右先找区分度比较高的索引字段,先将整体范围降下来再去比较其他条件
    create index idx_name on s1(name);
    select count(id) from s1 where name='jason' and gender = 'male' and id = 3 and email = 'xxx'; # 并没有加速

    drop index idx_name on s1;
    # 给name,gender这种区分度不高的字段加上索引并不难加快查询速度

    create index idx_id on s1(id);
    select count(id) from s1 where name='jason' and gender = 'male' and id = 3 and email = 'xxx'; # 快了 先通过id已经讲数据快速锁定成了一条了
    select count(id) from s1 where name='jason' and gender = 'male' and id > 3 and email = 'xxx'; # 慢了 基于id查出来的数据仍然很多,然后还要去比较其他字段

    drop index idx_id on s1

    create index idx_email on s1(email);
    select count(id) from s1 where name='jason' and gender = 'male' and id > 3 and email = 'xxx'; # 快 通过email字段一剑封喉
    ```

     联合索引

    ```mysql
    select count(id) from s1 where name='jason' and gender = 'male' and id > 3 and email = 'xxx';
    # 如果上述四个字段区分度都很高,那给谁建都能加速查询
    # 给email加然而不用email字段
    select count(id) from s1 where name='jason' and gender = 'male' and id > 3;
    # 给name加然而不用name字段
    select count(id) from s1 where gender = 'male' and id > 3;
    # 给gender加然而不用gender字段
    select count(id) from s1 where id > 3;

    # 带来的问题是所有的字段都建了索引然而都没有用到,还需要花费四次建立的时间
    create index idx_all on s1(email,name,gender,id); # 最左匹配原则,区分度高的往左放
    select count(id) from s1 where name='jason' and gender = 'male' and id > 3 and email = 'xxx'; # 速度变快
    ```

    总结:上面这些操作,你感兴趣可以敲一敲,不感兴趣你就可以不用敲了,权当看个乐呵。理论掌握了就行了

    慢查询日志

    设定一个时间检测所有超出改时间的sql语句,然后针对性的进行优化!

  • 相关阅读:
    [APIO 2009] Atm
    Codeforces518 D. Ilya and Escalator
    [POJ2096] Collecting bugs
    [ZOJ3329] One Person Game
    [LightOJ1038] Race to 1 Again
    「NOI2003」逃学的小孩
    [HAOI2006] 旅行
    ☆ [POJ2411] Mondriaan's Dream 「状压DP」
    「POJ3311」Hie with the Pie
    「乘法逆元」 学习笔记
  • 原文地址:https://www.cnblogs.com/sweet-i/p/11402603.html
Copyright © 2011-2022 走看看