一、視圖

視圖是一個虛擬表（非真實存在），其本質是【根據SQL語句獲取動態的數據集，並為其命名】，用戶使用時只需使用【名稱】即可獲取結果集，可以將該結果集當做表來使用。

使用視圖我們可以把查詢過程中的臨時表摘出來，用視圖去實現，這樣以後再想操作該臨時表的數據時就無需重寫復雜的sql了，直接去視圖中查找即可，但視圖有明顯地效率問題，並且視圖是存放在數據庫中的，如果我們程序中使用的sql過分依賴數據庫中的視圖，即強耦合，那就意味著擴展sql極為不便，因此並不推薦使用

-- 1.視圖是一個虛擬表(非正式存在)，其本質是其本質是
-- 【根據SQL語句獲取動態的數據集，並為其命名】，
-- 用戶使用時只需使用【名稱】即可獲取結果集，
-- 可以將該結果集當做表來使用。
-- 2.
-- 有了視圖以後你是不是覺得寫sql語句就很簡單了，但是你盡量不要這樣做
-- 因為mysql是DBA管著呢，那麽你告訴DBA建一堆視圖，你寫程序的時候是方便了，
-- 但是你要是修改呢，那麽你就得修改視圖了，你就得找到DBA修改你的視圖了，
-- 那麽這樣聯系別人會很麻煩的。說不定人家還很忙呢。還是推薦自己去寫sql語句。

-- #註意：
-- 如果是一個單表的就可以修改或者刪除或者插入
-- 如果是幾個表關聯的時候是不可以修改或者刪除或者插入的(這點也是不確定的，有的可以改，有的不可以改)

準備表

========================
創建部門表
create table dep(
id int primary key auto_increment,
name char(32)
);
創建用戶表
create table user(
id int primary key auto_increment,
name char(32),
dep_id int,
foreign key(dep_id) references dep(id)
);
插數據
insert into dep(name) values(‘外交部‘),(‘銷售‘),(‘財經部‘);
insert into user(name,dep_id) values (‘egon‘,1),
                                       (‘alex‘,2),
                                       (‘haiyan‘,3);

1.創建視圖

創建視圖語法

CREATE VIEW 視圖名稱 AS SQL語句

create view teacher_view as select tid from teacher where tname=‘李平老師‘;

#連表
select * from dep left join user on dep.id = user.dep_id;
#創建一個視圖
create view user_dep_view as select dep.id depid ,user.id uid ,user.name uname,dep.name depname from dep left join user
on dep.id = user.dep_id;
-- 這樣創建一個視圖以後就可以吧一個虛擬表保存下來,就可以查看了。
select uname from user_dep_view where depid = 3;
-- 我的電腦上不可以增刪改，只可查看。但是有的電腦上又可以增刪改，可能是跟版本有關吧
#測試
insert into user_dep_view VALUES (1,2,‘egon‘,‘人文部‘); #會報錯
DELETE from  user_dep_view where uid = 1;  #會報錯
update user_dep_view set uname = ‘海燕‘ where depid = 2; #會報錯

-- 對於單表來說是可以修改的，並且原來表的也就更改了。
-- 但是一般還是不要這樣改。視圖大多數是用來查看的

#建表
CREATE TABLE t1(
id int PRIMARY KEY auto_increment,
name CHAR(10)
);
#插入數據
insert into t1 VALUES (1,‘egon‘),
                        (2,‘daa‘),
                        (3,‘eef‘);
#創建視圖
CREATE view t1_view as select * from t1;
#測試創建視圖以後還能不能增刪改查
select * from t1_view;
update t1_view set name = ‘海燕‘ where id = 2; #可以修改(而且原來表的記錄也修改了)
INSERT into t1_view values(4,‘aaa‘); #可以插入(同上)
delete from t1_view where id=3;#同上

2.修改視圖

語法：ALTER VIEW 視圖名稱 AS SQL語句

3.刪除視圖

語法：DROP VIEW 視圖名稱

二、觸發器

使用觸發器可以定制用戶對表進行【增、刪、改】操作時前後的行為，註意：沒有查詢

-- 觸發器：某種程序觸發了工具的運行
-- 觸發器不能主動調用，只有觸發了某種行為才會調用觸發器的執行
-- 插入一條記錄就觸發一次
-- 還是建議不要用觸發器，因為這是BDA管理的，還是不如你在程序裏面直接寫比較方便

1.創建觸發器的語法

create
   trigger trigger_name
   trigger_time trigger_event
   on tbl_name for each row
   triggrr_body  #主體，就是在觸發器裏幹什麽事
trigger_time:{before | after}
trigger_event:{insert | update |detele}

準備表

-- # 2.準備表
-- #第一步：準備表
create table cmd_log(
id int primary key auto_increment,
cmd_name char(64), #命令的名字
sub_time datetime, #提交時間
user_name char(32), #是哪個用戶過來執行這個命令
is_success enum(‘yes‘,‘no‘)  #命令是否執行成功
);

create table err_log(
id int primary key auto_increment,
cname char(64), #命令的名字
stime datetime #提交時間
);

創建觸發器

-- #創建觸發器（向err_log表裏插入最新的記錄）
delimiter //
create
  trigger tri_after_inser_cmd_log
  after insert
  on cmd_log for  each row
BEGIN
  if new.is_success = ‘no‘ then
    insert into err_log(cname,stime) VALUES(new.cmd_name,new.sub_time);
  end if;  #記得加分號,mysql一加分號代表結束,那麽就得聲明一下
END //
delimiter ;  #還原的最原始的狀態


-- #創建觸發器（向err_log表裏插入最舊的記錄）
delimiter //
create
  trigger tri_after_inser_cmd_log1
  after delete
  on cmd_log for  each row
BEGIN
  if old.is_success = ‘no‘ then
    insert into err_log(cname,stime) VALUES(old.cmd_name,old.sub_time);
  end if;  #記得加分號,mysql一加分號代表結束,那麽就得聲明一下
END //
delimiter ;  #還原的最原始的狀態
DELETE from cmd_log where id=1;

-- 觸發器的兩個關鍵字：new ,old
-- new :表示新的記錄
-- old:表示舊的那條記錄
-- 什麽情況下才往裏面插記錄
--       當命令輸入錯誤的時候就把錯誤的記錄插入到err_log表中

測試

# 4.測試
insert into cmd_log(cmd_name,sub_time,user_name,is_success) values
(‘ls -l /etc | grep *.conf‘,now(),‘root‘,‘no‘), #NEW.id,NEW.cmd_name,NEW.sub_time
(‘ps aux |grep mysqld‘,now(),‘root‘,‘yes‘),
(‘cat /etc/passwd |grep root‘,now(),‘root‘,‘yes‘),
(‘netstat -tunalp |grep 3306‘,now(),‘egon‘,‘no‘);

三、事務

-- 事務用於將某些操作的多個SQL作為原子性操作，一旦有某一個出現錯誤，
-- 即可回滾到原來的狀態，從而保證數據庫數據完整性。
-- 事務也就是要麽都成功，要麽都不成功
-- 事務就是由一堆sql語句組成的

create table user(
id int primary key auto_increment,
name char(32),
balance int  #用戶余額
);

insert into user(name,balance) values(‘海燕‘,200),
                                       (‘哪咤‘,200),
                                       (‘小哈‘,200);

-- 如果都成功就執行commit，，，如果不成功就執行rollback。
start transaction #開啟事務
update user set balance = 100 where name = ‘海燕‘;
update user set balance = 210 where name = ‘哪咤‘;
update user set balance = 290 where name = ‘小哈‘;  #sql語句錯誤就會報錯了
commit; #如果所有的sql語句都沒有出現異常，應該執行commit

start transaction
update user set balance = 100 where name = ‘海燕‘;
update user set balance = 210 where name = ‘哪咤‘;
updatezzzz user set balance = 290 where name = ‘小哈‘;  #sql語句錯誤就會報錯了
rollback; #如果任意一條sql出現異常，都應該回歸到初始狀態

上面的兩種情況我們可以用異常處理捕捉一下

#捕捉異常+事務1
delimiter //
create PROCEDURE p6(
    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 = 100 where name = ‘海燕‘;
       update user set balance = 210 where name = ‘哪咤‘;
       update user11 set balance = 290 where name = ‘小哈‘;
    COMMIT;
    -- SUCCESS
    set p_return_code = 0; #0代表執行成功
END //
delimiter ;

#捕捉異常+事務2
============捕捉異常+事務==============
delimiter //
create PROCEDURE p6(
    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;
        insert into test(username,dep_id) values(‘egon‘,1);
        DELETE from tb1111111; #如果執行失敗，就不會執行commit了
    COMMIT;
    -- SUCCESS
    set p_return_code = 0; #0代表執行成功
END //
delimiter ;
#調用
set @res = 111  #相當於定義一個全局變量
call p6(@res)
select * from test;
select @res

其實也就相當於python中的try.....except

#用python模擬
try:
    START TRANSACTION;
        DELETE from tb1; #執行失敗
        insert into blog(name,sub_time) values(‘yyy‘,now());
    COMMIT;
    set p_return_code = 0; #0代表執行成功
except sqlexception:
    set p_return_code = 1;
    rollback;
except sqlwaring:
    set p_return_code = 2;
    rollback;

四、存儲過程

存儲過程包含了一系列可執行的sql語句，存儲過程存放於MySQL中，通過調用它的名字可以執行其內部的一堆sql

-- 存儲過程的優點：
--   1.程序與數據實現解耦
--   2.減少網絡傳輸的數據量
-- 但是看似很完美，還是不推薦你使用

===========創建無參的存儲過程===============
delimiter //
create procedure p1()
begin
select * from test;
insert into test(username,dep_id) VALUES(‘egon‘,1);
end //
delimiter ;

#調用存儲過程
#在mysql中調用
call p1();
#在python程序中調用
cursor.callproc(‘p1‘)

對於存儲過程，可以接收參數，其參數有三類：

　　#in 僅用於傳入參數用

　　#out 僅用於返回值用

　　 #inout 既可以傳入又可以當作返回值

==========創建有參的存儲過程(in)===============
delimiter //
create procedure p2(
    in m int, #從外部傳進來的值
    in n int
)
begin
    insert into test(username,dep_id) VALUES (‘haha‘,2),(‘xixi‘,3),(‘sasa‘,1),(‘yanyan‘,2);
    select * from test where id between m and n;
end //
delimiter ;

#調用存儲過程
call p2(3,7); #在mysql中執行
#在python程序中調用
cursor.callproc(‘p2‘,arg(3,7))

創建有參的存儲過程(in)

===========創建有參的存儲過程(out)===============
delimiter //
create procedure p3(
    in m int, #從外部傳進來的值
    in n int,
    out res int
)
begin
    select * from test where id between m and n;
    set res = 1;#如果不設置，則res返回null
end //
delimiter ;

#調用存儲過程
set @res = 11111;
call p3(3,7,@res);
select @res; #在mysql中執行

#在python中
res=cursor.callproc(‘p3‘,args=(3,7,123)) #@_p3_0=3,@_p3_1=7,@_p3_2=123
print(cursor.fetchall()) #只是拿到存儲過程中select的查詢結果
cursor.execute(‘select @_p3_0,@_p3_1,@_p3_2‘)
print(cursor.fetchall()) #可以拿到的是返回值

創建有參的存儲過程(out)

=============創建有參存儲過程之inout的使用==========
delimiter //
create procedure p4(
    inout m int
)
begin
    select * from test where id > m;
    set m=1;
end //
delimiter ;

#在mysql中
set @x=2;
call p4(@x);
select @x;

===========================
delimiter //
create procedure p5(
    inout m int
)
begin
    select * from test11111 where id > m;
    set m=1;
end //
delimiter ;

#在mysql中
set @x=2;
call p5(@x);
select @x;  #這時由於不存在那個表就會報錯，查看的結果就成2了。

創建有參存儲過程之inout的使用

# 在MySQL中執行存儲過程
-- 無參數
call proc_name()

-- 有參數，全in
call proc_name(1,2)

-- 有參數，有in，out，inout
set @t1=0;
set @t2=3;
call proc_name(1,2,@t1,@t2)

補充：程序與數據庫結合使用的三種方式

#方式一：
    MySQL：存儲過程
    程序：調用存儲過程

#方式二：
    MySQL：
    程序：純SQL語句

#方式三：
    MySQL:
    程序：類和對象，即ORM（本質還是純SQL語句）

import pymysql
conn = pymysql.connect(host = ‘localhost‘,user = ‘root‘,password=‘123456‘,database = ‘lianxi‘,charset = ‘utf8‘)
cursor = conn.cursor(pymysql.cursors.DictCursor)  #以字典的形式輸出
# rows = cursor.callproc(‘p1‘)  #1.調用存儲過程的方法 ，沒參數時
# rows = cursor.callproc(‘p2‘,args=(3,7))  #有參數時
rows = cursor.callproc(‘p3‘, args=(3,7,123))  #@_p3_0=3,@_p3_1=7 ,@_p3_2=123  #有參數時
conn.commit()  #執行
print(cursor.fetchall())
cursor.execute(‘select @_p3_0,@_p3_1,@_p3_2‘)
print(cursor.fetchall())
cursor.close()
conn.close()

刪除存儲過程

drop procedure proc_name;

五、函數

MySQL中提供了許多內置函數，例如：

# 部分內置函數
CHAR_LENGTH(str)
        返回值為字符串str 的長度，長度的單位為字符。一個多字節字符算作一個單字符。
        對於一個包含五個二字節字符集, LENGTH()返回值為 10, 而CHAR_LENGTH()的返回值為5。

    CONCAT(str1,str2,...)
        字符串拼接
        如有任何一個參數為NULL ，則返回值為 NULL。
    CONCAT_WS(separator,str1,str2,...)
        字符串拼接（自定義連接符）
        CONCAT_WS()不會忽略任何空字符串。 (然而會忽略所有的 NULL）。

    CONV(N,from_base,to_base)
        進制轉換
        例如：
            SELECT CONV(‘a‘,16,2); 表示將 a 由16進制轉換為2進制字符串表示

    FORMAT(X,D)
        將數字X 的格式寫為‘#,###,###.##‘,以四舍五入的方式保留小數點後 D 位， 並將結果以字符串的形式返回。若  D 為 0, 則返回結果不帶有小數點，或不含小數部分。
        例如：
            SELECT FORMAT(12332.1,4); 結果為： ‘12,332.1000‘
    INSERT(str,pos,len,newstr)
        在str的指定位置插入字符串
            pos：要替換位置其實位置
            len：替換的長度
            newstr：新字符串
        特別的：
            如果pos超過原字符串長度，則返回原字符串
            如果len超過原字符串長度，則由新字符串完全替換
    INSTR(str,substr)
        返回字符串 str 中子字符串的第一個出現位置。

    LEFT(str,len)
        返回字符串str 從開始的len位置的子序列字符。

    LOWER(str)
        變小寫

    UPPER(str)
        變大寫

    LTRIM(str)
        返回字符串 str ，其引導空格字符被刪除。
    RTRIM(str)
        返回字符串 str ，結尾空格字符被刪去。
    SUBSTRING(str,pos,len)
        獲取字符串子序列

    LOCATE(substr,str,pos)
        獲取子序列索引位置

    REPEAT(str,count)
        返回一個由重復的字符串str 組成的字符串，字符串str的數目等於count 。
        若 count <= 0,則返回一個空字符串。
        若str 或 count 為 NULL，則返回 NULL 。
    REPLACE(str,from_str,to_str)
        返回字符串str 以及所有被字符串to_str替代的字符串from_str 。
    REVERSE(str)
        返回字符串 str ，順序和字符順序相反。
    RIGHT(str,len)
        從字符串str 開始，返回從後邊開始len個字符組成的子序列

    SPACE(N)
        返回一個由N空格組成的字符串。

    SUBSTRING(str,pos) , SUBSTRING(str FROM pos) SUBSTRING(str,pos,len) , SUBSTRING(str FROM pos FOR len)
        不帶有len 參數的格式從字符串str返回一個子字符串，起始於位置 pos。帶有len參數的格式從字符串str返回一個長度同len字符相同的子字符串，起始於位置 pos。 使用 FROM的格式為標準 SQL 語法。也可能對pos使用一個負值。假若這樣，則子字符串的位置起始於字符串結尾的pos 字符，而不是字符串的開頭位置。在以下格式的函數中可以對pos 使用一個負值。

        mysql> SELECT SUBSTRING(‘Quadratically‘,5);
            -> ‘ratically‘

        mysql> SELECT SUBSTRING(‘foobarbar‘ FROM 4);
            -> ‘barbar‘

        mysql> SELECT SUBSTRING(‘Quadratically‘,5,6);
            -> ‘ratica‘

        mysql> SELECT SUBSTRING(‘Sakila‘, -3);
            -> ‘ila‘

        mysql> SELECT SUBSTRING(‘Sakila‘, -5, 3);
            -> ‘aki‘

        mysql> SELECT SUBSTRING(‘Sakila‘ FROM -4 FOR 2);
            -> ‘ki‘

    TRIM([{BOTH | LEADING | TRAILING} [remstr] FROM] str) TRIM(remstr FROM] str)
        返回字符串 str ， 其中所有remstr 前綴和/或後綴都已被刪除。若分類符BOTH、LEADIN或TRAILING中沒有一個是給定的,則假設為BOTH 。 remstr 為可選項，在未指定情況下，可刪除空格。

        mysql> SELECT TRIM(‘  bar   ‘);
                -> ‘bar‘

        mysql> SELECT TRIM(LEADING ‘x‘ FROM ‘xxxbarxxx‘);
                -> ‘barxxx‘

        mysql> SELECT TRIM(BOTH ‘x‘ FROM ‘xxxbarxxx‘);
                -> ‘bar‘

        mysql> SELECT TRIM(TRAILING ‘xyz‘ FROM ‘barxxyz‘);
                -> ‘barx‘

1.自定義函數

#！！！註意！！！
#函數中不要寫sql語句（否則會報錯），函數僅僅只是一個功能，是一個在sql中被應用的功能
#若要想在begin...end...中寫sql，請用存儲過程

delimiter //
create function f1(
    i1 int,
    i2 int)
returns int
BEGIN
    declare num int;  #聲明
    set num = i1 + i2;
    return(num);
END //
delimiter ;

delimiter //
create function f5(
    i int
)
returns int
begin
    declare res int default 0;
    if i = 10 then
        set res=100;
    elseif i = 20 then
        set res=200;
    elseif i = 30 then
        set res=300;
    else
        set res=400;
    end if;
    return res;
end //
delimiter ;

2.刪除函數

drop function func_name;

3.執行函數

# 獲取返回值
select UPPER(‘egon‘) into @res;
SELECT @res;

select f1(1,2) into @res;
select @res

# 在查詢中使用

 select f1(11,nid) ,name from tb2;

#DATE_FORMAT需要掌握

#1 基本使用
mysql> SELECT DATE_FORMAT(‘2009-10-04 22:23:00‘, ‘%W %M %Y‘);
-> ‘Sunday October 2009‘
mysql> SELECT DATE_FORMAT(‘2007-10-04 22:23:00‘, ‘%H:%i:%s‘);
-> ‘22:23:00‘
mysql> SELECT DATE_FORMAT(‘1900-10-04 22:23:00‘,
-> ‘%D %y %a %d %m %b %j‘);
-> ‘4th 00 Thu 04 10 Oct 277‘
mysql> SELECT DATE_FORMAT(‘1997-10-04 22:23:00‘,
-> ‘%H %k %I %r %T %S %w‘);
-> ‘22 22 10 10:23:00 PM 22:23:00 00 6‘
mysql> SELECT DATE_FORMAT(‘1999-01-01‘, ‘%X %V‘);
-> ‘1998 52‘
mysql> SELECT DATE_FORMAT(‘2006-06-00‘, ‘%d‘);
-> ‘00‘

#2 準備表和記錄
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‘);

#3. 提取sub_time字段的值，按照格式後的結果即"年月"來分組
SELECT DATE_FORMAT(sub_time,‘%Y-%m‘),COUNT(1) FROM blog GROUP BY DATE_FORMAT(sub_time,‘%Y-%m‘);

#結果
+-------------------------------+----------+
| DATE_FORMAT(sub_time,‘%Y-%m‘) | COUNT(1) |
+-------------------------------+----------+
| 2015-03 | 2 |
| 2016-07 | 4 |
| 2017-03 | 3 |
+-------------------------------+----------+
rows in set (0.00 sec)

六、流程控制

1.條件語句

舉例一

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 ;

舉例二

#函數中不要寫sql語句，它僅僅只是一個功能，是一個在sql中被應用的功能
#若要想在begin...end...中寫sql，請用存儲過程
delimiter //
create function f5(
    i int
)
returns int
begin
    declare res int default 0;
    if i = 10 then
        set res=100;
    elseif i = 20 then
        set res=200;
    elseif i = 30 then
        set res=300;
    else
        set res=400;
    end if;
    return res;
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 ;

#repeat
delimiter //
CREATE PROCEDURE proc_repeat ()
BEGIN

    DECLARE i INT ;
    SET i = 0 ;
    repeat
        select i;
        set i = i + 1;
        until i >= 5
    end repeat;

END //
delimiter ;

#loop
BEGIN
    
    declare i int default 0;
    loop_label: loop
        
        set i=i+1;
        if i<8 then
            iterate loop_label;
        end if;
        if i>=10 then
            leave loop_label;
        end if;
        select i;
    end loop loop_label;

END

MySQL數據庫學習【第十篇】（視圖、觸發器、事物）