#準備表
#學生表
create table student(sid int primary key auto_increment,
sname varchar(5),
teacher_id int,
foreign key (teacher_id) references teacher(tid)
on update cascade
on delete cascade);
#插入數據
insert into student(sname,teacher_id) values('劉一',1),('陳二',2),
('張三',3),('李四',4),
('王五',1),('趙六',2),
('孫七',3),('周八',4),
('吳九',1),('鄭十',2);
#查看數據
mysql> select * from student;
+-----+-------+------------+
| sid | sname | teacher_id |
+-----+-------+------------+
| 1 | 劉一 | 1 |
| 2 | 陳二 | 2 |
| 3 | 張三 | 3 |
| 4 | 李四 | 4 |
| 5 | 王五 | 1 |
| 6 | 趙六 | 2 |
| 7 | 孫七 | 3 |
| 8 | 周八 | 4 |
| 9 | 吳九 | 1 |
| 10 | 鄭十 | 2 |
+-----+-------+------------+
10 rows in set (0.00 sec)
#教師表
create table teacher(tid int primary key auto_increment,
tname varchar(10));
#插入數據
insert into teacher(tname)values('愛根'),('艾利克斯'),('元灝'),('舞沛氣');
#查看數據
mysql> select * from teacher;
+-----+----------+
| tid | tname |
+-----+----------+
| 1 | 愛根 |
| 2 | 艾利克斯 |
| 3 | 元灝 |
| 4 | 舞沛氣 |
+-----+----------+
4 rows in set (0.00 sec)
#測試
#查詢屬於egon老師的學生
select sname from student where teacher_id in (select tid from teacher where tname = '愛根');
+-------+
| sname |
+-------+
| 劉一 |
| 王五 |
| 吳九 |
+-------+
3 rows in set (0.00 sec)
使用觸發器能夠定製用戶對錶進行【增、刪、改】操做時先後的行爲,注意:沒有查詢
#建立觸發器的語法
CREATE
TRIGGER trigger_name
trigger_time trigger_event
ON tbl_name FOR EACH ROW
trigger_body
trigger_time: { BEFORE | AFTER }
trigger_event: { INSERT | UPDATE | DELETE }
#第一步:準備表
create table cmd_log_tesk(
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_task(
id int primary key auto_increment,
cname char(64),
stime datetime
);
#第二步:建立觸發器
delimiter //
CREATE
TRIGGER tri_after_insert_cmd_log_tesk
after insert
ON cmd_log_tesk FOR EACH ROW
BEGIN
if new.is_success = 'no' then
insert into err_log_task(cname,stime) values(new.cmd_name,new.sub_time);
end if;
END //
delimiter ;
#測試
insert into cmd_log_tesk(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');
Query OK, 4 rows affected (0.35 sec)
Records: 4 Duplicates: 0 Warnings: 0
查看插入的數據
mysql> select * from cmd_log_tesk;
+----+----------------------------+---------------------+-----------+------------+
| id | cmd_name | sub_time | user_name | is_success |
+----+----------------------------+---------------------+-----------+------------+
| 1 | ls -l /etc | grep *.conf | 2017-09-18 19:02:03 | root | no |
| 2 | ps aux |grep mysqld | 2017-09-18 19:02:03 | root | yes |
| 3 | cat /etc/passwd |grep root | 2017-09-18 19:02:03 | root | yes |
| 4 | netstat -tunalp |grep 3306 | 2017-09-18 19:02:03 | egon | no |
+----+----------------------------+---------------------+-----------+------------+
4 rows in set (0.00 sec)
查看錯誤日誌
mysql> select * from err_log_task;
+----+----------------------------+---------------------+
| id | cname | stime |
+----+----------------------------+---------------------+
| 1 | ls -l /etc | grep *.conf | 2017-09-18 19:02:03 |
| 2 | netstat -tunalp |grep 3306 | 2017-09-18 19:02:03 |
+----+----------------------------+---------------------+
2 rows in set (0.00 sec)
#事務用於將某些操做的多個SQL做爲原子性操做,一旦有某一個出現錯誤,便可回滾到原來的狀態,從而保證數據庫數據完整性。
#測試數據
create table user(id int primary key auto_increment,
name varchar(10),
balance int);
insert into user (name, balance) values ('陳陽',1000),
('潘斌',1000),('劉武',1000);
#原子操做
start transaction;
update user set balance = 900 where name = '劉武';#轉帳100
update user set balance = 1010 where name = '潘斌';#中間手續費10
update user set balance = 1090 where name = '陳陽';#收帳90
commit;
mysql> select * from user;
+----+------+---------+
| id | name | balance |
+----+------+---------+
| 1 | 陳陽 | 1090 |
| 2 | 潘斌 | 1010 |
| 3 | 劉武 | 900 |
+----+------+---------+
3 rows in set (0.00 sec)
#出現異常,回滾到初始狀態
start transaction;
update user set balance=900 where name='劉武'; #買支付100元
update user set balance=1010 where name='潘斌'; #中介拿走10元
uppdate user set balance=1090 where name='城陽'; #賣家拿到90元,出現異常沒有拿到
rollback;
commit;
mysql> select * from user;
+----+------+---------+
| id | name | balance |
+----+------+---------+
| 1 | 陳陽 | 1090 |
| 2 | 潘斌 | 1010 |
| 3 | 劉武 | 900 |
+----+------+---------+
3 rows in set (0.00 sec)
#存儲過程包含了一系列可執行的sql語句,存儲過程存放於MySQL中,經過調用它的名字能夠執行其內部的一堆sql
#使用存儲過程的優勢:
#1. 用於替代程序寫的SQL語句,實現程序與sql解耦
#2. 基於網絡傳輸,傳別名的數據量小,而直接傳sql數據量大
#使用存儲過程的缺點:
#1. 執行效率低
#2. 程序員擴展功能不方便
#建立測試數據;
create table task(id int primary key auto_increment,
name varchar(10),
age int(5));
insert into task(name,age) values('張三',18),
('李四',18),
('趙武',19),
('王六',11);
mysql> select * from task;
+----+------+------+
| id | name | age |
+----+------+------+
| 1 | 張三 | 18 |
| 2 | 李四 | 18 |
| 3 | 趙武 | 19 |
| 4 | 王六 | 11 |
+----+------+------+
4 rows in set (0.00 sec)
*********************************建立存儲過程*****************************
#1.建立簡單存儲過程(無參)
delimiter //
create procedure h1()
begin
select * from task;
insert into task(name,age) values('xxx',18);
end //
delimiter ;
在mysql中調用
call h1();
mysql> call h1();
+----+------+------+
| id | name | age |
+----+------+------+
| 1 | 張三 | 18 |
| 2 | 李四 | 18 |
| 3 | 趙武 | 19 |
| 4 | 王六 | 11 |
+----+------+------+
4 rows in set (0.00 sec)
Query OK, 1 row affected (0.05 sec)
#在Python中基於pymysql調用
代碼:
import pymysql
conn = pymysql.connect(host='localhost',
user = 'root',
password = '',
database = 'day48',
charset = 'utf8')
cursor = conn.cursor(cursor=pymysql.cursors.DictCursor)
res = cursor.callproc('h1')
conn.commit()
print(cursor.fetchall())
cursor.close()
conn.close()
輸出結果:
[{'id': 1, 'name': '張三', 'age': 18},
{'id': 2, 'name': '李四', 'age': 18},
{'id': 3, 'name': '趙武', 'age': 19},
{'id': 4, 'name': '王六', 'age': 11},
{'id': 5, 'name': 'xxx', 'age': 18}]
#2.建立簡單存儲過程(有參)
對於存儲過程,能夠接受參數,其中參數有三類:
(1)
.in 僅用於傳入參數
delimiter //
create procedure h2(
in n1 int,
in n2 int
)
begin
select * from task where id between n1 and n2;
end //
delimiter;
# 在mysql中調用
mysql> call h2(1,3);
+----+------+------+
| id | name | age |
+----+------+------+
| 1 | 張三 | 18 |
| 2 | 李四 | 18 |
| 3 | 趙武 | 19 |
+----+------+------+
3 rows in set (0.00 sec)
Query OK, 0 rows affected (0.00 sec)
#在Python中基於pymysql調用
cursor = conn.cursor(cursor=pymysql.cursors.DictCursor)
res = cursor.callproc('h2',args = (1,4))
********************************************************************
(2)out 僅用於返回值用
delimiter //
create procedure h3(
in n3 int,
out res1 int
)
BEGIN
select * from task where id > n3;
set res1 = 1;
END //
delimiter ;
#在mysql中調用
set @res1=0; #0表明假(執行失敗),1表明真(執行成功)
call p3(3,@res1);
mysql> call h3(3,@res1);
+----+------+------+
| id | name | age |
+----+------+------+
| 4 | 王六 | 11 |
| 5 | xxx | 18 |
| 6 | xxx | 18 |
+----+------+------+
3 rows in set (0.00 sec)
Query OK, 0 rows affected (0.01 sec)
select @res1;
mysql> select @res1;
+-------+
| @res1 |
+-------+
| 1 |
+-------+
1 row in set (0.00 sec)
#在python中基於pymysql調用
res = cursor.callproc('h3',args = (1,4)) #0至關於set @res=0
print(cursor.fetchall()) #查詢select的查詢結果
執行結果:
[{'id': 2, 'name': '李四', 'age': 18},
{'id': 3, 'name': '趙武', 'age': 19},
{'id': 4, 'name': '王六', 'age': 11},
{'id': 5, 'name': 'xxx', 'age': 18},
{'id': 6, 'name': 'xxx', 'age': 18}]
cursor.execute('select @_h3_0,@_h3_1;') #@p3_0表明第一個參數,@p3_1表明第二個參數,即返回值
print(cursor.fetchall())
執行結果
[{'@_h3_0': 1, '@_h3_1': 1}]
********************************************************************
(3)inout 既能夠傳入又能夠當作返回值
delimiter //
create procedure h4(
inout h4 int
)
BEGIN
select * from task where id > h4;
set h4 = 1;
END //
delimiter ;
#在mysql中調用
mysql> set @x=3;
Query OK, 0 rows affected (0.00 sec)
mysql> call h4(@x);
+----+------+------+
| id | name | age |
+----+------+------+
| 4 | 王六 | 11 |
| 5 | xxx | 18 |
| 6 | xxx | 18 |
+----+------+------+
3 rows in set (0.00 sec)
Query OK, 0 rows affected (0.01 sec)
mysql> select @x;
+------+
| @x |
+------+
| 1 |
+------+
1 row in set (0.00 sec)
#在python中基於pymysql調用
cursor.callproc('h4',(3,))
print(cursor.fetchall()) #查詢select的查詢結果
執行結果:
[{'id': 3, 'name': '趙武', 'age': 19},
{'id': 4, 'name': '王六', 'age': 11},
{'id': 5, 'name': 'xxx', 'age': 18},
{'id': 6, 'name': 'xxx', 'age': 18}]
cursor.execute('select @_p4_0;')
print(cursor.fetchall())
執行結果
[{'@_h4_0': 1}]
###############################執行存儲過程##################################
#在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)
#在Python基於pymysql執行存儲過程
import pymysql
conn = pymysql.connect(host='localhost',
user = 'root',
password = '',
database = 'day48',
charset = 'utf8')
cursor = conn.cursor(cursor=pymysql.cursors.DictCursor)
# res = cursor.callproc('h2',args = (1,4))#基於有參的
# res = cursor.callproc('h')#基於無參數的
res = cursor.callproc('h4',args = (2,))#基於inout
res1 = cursor.execute('select @_h4_0;')
conn.commit()
print(cursor.fetchall())
cursor.close()
conn.close()
###############################刪除存儲過程##################################
drop procedure 存儲過程名
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 基本使用
************************************************************************************
mysql> SELECT DATE_FORMAT('2009-10-04 22:23:00', '%W %M %Y');
+------------------------------------------------+
| DATE_FORMAT('2009-10-04 22:23:00', '%W %M %Y') |
+------------------------------------------------+
| Sunday October 2009 |
+------------------------------------------------+
1 row in set (0.02 sec)
************************************************************************************
mysql> SELECT DATE_FORMAT('2007-10-04 22:23:00', '%H:%i:%s');
+------------------------------------------------+
| DATE_FORMAT('2007-10-04 22:23:00', '%H:%i:%s') |
+------------------------------------------------+
| 22:23:00 |
+------------------------------------------------+
1 row in set (0.00 sec)
************************************************************************************
mysql> SELECT DATE_FORMAT('1900-10-04 22:23:00','%D %y %a %d %m %b %j');
+-----------------------------------------------------------+
| DATE_FORMAT('1900-10-04 22:23:00','%D %y %a %d %m %b %j') |
+-----------------------------------------------------------+
| 4th 00 Thu 04 10 Oct 277 |
+-----------------------------------------------------------+
1 row in set (0.00 sec)
************************************************************************************
mysql> SELECT DATE_FORMAT('1997-10-04 22:23:00','%H %k %I %r %T %S %w');
+-----------------------------------------------------------+
| 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 |
+-----------------------------------------------------------+
1 row in set (0.00 sec)
************************************************************************************
mysql> SELECT DATE_FORMAT('1999-01-01', '%X %V');
+------------------------------------+
| DATE_FORMAT('1999-01-01', '%X %V') |
+------------------------------------+
| 1998 52 |
+------------------------------------+
1 row in set (0.00 sec)
************************************************************************************
mysql> SELECT DATE_FORMAT('2006-06-00', '%d');
+---------------------------------+
| DATE_FORMAT('2006-06-00', '%d') |
+---------------------------------+
| 00 |
+---------------------------------+
1 row in set (0.00 sec)
************************************************************************************
#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)
須要掌握函數:date_format