1、视图
视图是一个虚拟表（非真实存在），其本质是【根据SQL语句获取动态的数据集，并为其命名】，用户使用时只需使用【名称】便可获取结果集，能够将该结果集当作表来使用。html
使用视图咱们能够把查询过程当中的临时表摘出来，用视图去实现，这样之后再想操做该临时表的数据时就无需重写复杂的sql了，直接去视图中查找便可，但视图有明显地效率问题，而且视图是存放在数据库中的，若是咱们程序中使用的sql过度依赖数据库中的视图，即强耦合，那就意味着扩展sql极为不便，所以并不推荐使用python
-- 1.视图是一个虚拟表(非正式存在)，其本质是其本质是
-- 【根据SQL语句获取动态的数据集，并为其命名】，
-- 用户使用时只需使用【名称】便可获取结果集，
-- 能够将该结果集当作表来使用。
-- 2.
-- 有了视图之后你是否是以为写sql语句就很简单了，可是你尽可能不要这样作
-- 由于mysql是DBA管着呢，那么你告诉DBA建一堆视图，你写程序的时候是方便了，
-- 可是你要是修改呢，那么你就得修改视图了，你就得找到DBA修改你的视图了，
-- 那么这样联系别人会很麻烦的。说不定人家还很忙呢。仍是推荐本身去写sql语句。
-- #注意：
-- 若是是一个单表的就能够修改或者删除或者插入
-- 若是是几个表关联的时候是不能够修改或者删除或者插入的(这点也是不肯定的，有的能够改，有的不能够改)
准备表mysql
======================== 建立部门表 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.建立视图sql
建立视图语法数据库
CREATE VIEW 视图名称 AS SQL语句网络
create view teacher_view as select tid from teacher where tname='李平老师';ide
#连表 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 视图名称
2、触发器
使用触发器能够定制用户对表进行【增、删、改】操做时先后的行为，注意：没有查询oop
-- 触发器：某种程序触发了工具的运行
-- 触发器不能主动调用，只有触发了某种行为才会调用触发器的执行
-- 插入一条记录就触发一次
-- 仍是建议不要用触发器，由于这是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');
3、事务
-- 事务用于将某些操做的多个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 // 2 create PROCEDURE p6( 3 OUT p_return_code tinyint 4 ) 5 BEGIN 6 DECLARE exit handler for sqlexception 7 BEGIN 8 -- ERROR 9 set p_return_code = 1; 10 rollback; 11 END; 12 DECLARE exit handler for sqlwarning 13 BEGIN 14 -- WARNING 15 set p_return_code = 2; 16 rollback; 17 END; 18 START TRANSACTION; 19 update user set balance = 100 where name = '海燕'; 20 update user set balance = 210 where name = '哪吒'; 21 update user11 set balance = 290 where name = '小哈'; 22 COMMIT; 23 -- SUCCESS 24 set p_return_code = 0; #0表明执行成功 25 END // 26 delimiter ;
1 ============捕捉异常+事务============== 2 delimiter // 3 create PROCEDURE p6( 4 OUT p_return_code tinyint 5 ) 6 BEGIN 7 DECLARE exit handler for sqlexception 8 BEGIN 9 -- ERROR 10 set p_return_code = 1; 11 rollback; 12 END; 13 DECLARE exit handler for sqlwarning 14 BEGIN 15 -- WARNING 16 set p_return_code = 2; 17 rollback; 18 END; 19 START TRANSACTION; 20 insert into test(username,dep_id) values('egon',1); 21 DELETE from tb1111111; #若是执行失败，就不会执行commit了 22 COMMIT; 23 -- SUCCESS 24 set p_return_code = 0; #0表明执行成功 25 END // 26 delimiter ; 27 #调用 28 set @res = 111 #至关于定义一个全局变量 29 call p6(@res) 30 select * from test; 31 select @res
其实也就至关于python中的try.....except
1 #用python模拟 2 try: 3 START TRANSACTION; 4 DELETE from tb1; #执行失败 5 insert into blog(name,sub_time) values('yyy',now()); 6 COMMIT; 7 set p_return_code = 0; #0表明执行成功 8 except sqlexception: 9 set p_return_code = 1; 10 rollback; 11 except sqlwaring: 12 set p_return_code = 2; 13 rollback;
4、存储过程
存储过程包含了一系列可执行的sql语句，存储过程存放于MySQL中，经过调用它的名字能够执行其内部的一堆sql
-- 存储过程的优势：
-- 1.程序与数据实现解耦
-- 2.减小网络传输的数据量
-- 可是看似很完美，仍是不推荐你使用
1 ===========建立无参的存储过程=============== 2 delimiter // 3 create procedure p1() 4 begin 5 select * from test; 6 insert into test(username,dep_id) VALUES('egon',1); 7 end // 8 delimiter ; 9 10 #调用存储过程 11 #在mysql中调用 12 call p1(); 13 #在python程序中调用 14 cursor.callproc('p1')
对于存储过程，能够接收参数，其参数有三类：
#in 仅用于传入参数用
#out 仅用于返回值用
#inout 既能够传入又能够看成返回值
1 ==========建立有参的存储过程(in)=============== 2 delimiter // 3 create procedure p2( 4 in m int, #从外部传进来的值 5 in n int 6 ) 7 begin 8 insert into test(username,dep_id) VALUES ('haha',2),('xixi',3),('sasa',1),('yanyan',2); 9 select * from test where id between m and n; 10 end // 11 delimiter ; 12 13 #调用存储过程 14 call p2(3,7); #在mysql中执行 15 #在python程序中调用 16 cursor.callproc('p2',arg(3,7))
1 ===========建立有参的存储过程(out)=============== 2 delimiter // 3 create procedure p3( 4 in m int, #从外部传进来的值 5 in n int, 6 out res int 7 ) 8 begin 9 select * from test where id between m and n; 10 set res = 1;#若是不设置，则res返回null 11 end // 12 delimiter ; 13 14 #调用存储过程 15 set @res = 11111; 16 call p3(3,7,@res); 17 select @res; #在mysql中执行 18 19 #在python中 20 res=cursor.callproc('p3',args=(3,7,123)) #@_p3_0=3,@_p3_1=7,@_p3_2=123 21 print(cursor.fetchall()) #只是拿到存储过程当中select的查询结果 22 cursor.execute('select @_p3_0,@_p3_1,@_p3_2') 23 print(cursor.fetchall()) #能够拿到的是返回值
1 =============建立有参存储过程之inout的使用========== 2 delimiter // 3 create procedure p4( 4 inout m int 5 ) 6 begin 7 select * from test where id > m; 8 set m=1; 9 end // 10 delimiter ; 11 12 #在mysql中 13 set @x=2; 14 call p4(@x); 15 select @x; 16 17 =========================== 18 delimiter // 19 create procedure p5( 20 inout m int 21 ) 22 begin 23 select * from test11111 where id > m; 24 set m=1; 25 end // 26 delimiter ; 27 28 #在mysql中 29 set @x=2; 30 call p5(@x); 31 select @x; #这时因为不存在那个表就会报错，查看的结果就成2了。
-- 无参数 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：存储过程 程序：调用存储过程 #方式二： 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;
5、函数
MySQL中提供了许多内置函数，例如：
1 CHAR_LENGTH(str) 2 返回值为字符串str 的长度，长度的单位为字符。一个多字节字符算做一个单字符。 3 对于一个包含五个二字节字符集, LENGTH()返回值为 10, 而CHAR_LENGTH()的返回值为5。 4 5 CONCAT(str1,str2,...) 6 字符串拼接 7 若有任何一个参数为NULL ，则返回值为 NULL。 8 CONCAT_WS(separator,str1,str2,...) 9 字符串拼接（自定义链接符） 10 CONCAT_WS()不会忽略任何空字符串。 (然而会忽略全部的 NULL）。 11 12 CONV(N,from_base,to_base) 13 进制转换 14 例如： 15 SELECT CONV('a',16,2); 表示将 a 由16进制转换为2进制字符串表示 16 17 FORMAT(X,D) 18 将数字X 的格式写为'#,###,###.##',以四舍五入的方式保留小数点后 D 位， 并将结果以字符串的形式返回。若 D 为 0, 则返回结果不带有小数点，或不含小数部分。 19 例如： 20 SELECT FORMAT(12332.1,4); 结果为： '12,332.1000' 21 INSERT(str,pos,len,newstr) 22 在str的指定位置插入字符串 23 pos：要替换位置其实位置 24 len：替换的长度 25 newstr：新字符串 26 特别的： 27 若是pos超过原字符串长度，则返回原字符串 28 若是len超过原字符串长度，则由新字符串彻底替换 29 INSTR(str,substr) 30 返回字符串 str 中子字符串的第一个出现位置。 31 32 LEFT(str,len) 33 返回字符串str 从开始的len位置的子序列字符。 34 35 LOWER(str) 36 变小写 37 38 UPPER(str) 39 变大写 40 41 LTRIM(str) 42 返回字符串 str ，其引导空格字符被删除。 43 RTRIM(str) 44 返回字符串 str ，结尾空格字符被删去。 45 SUBSTRING(str,pos,len) 46 获取字符串子序列 47 48 LOCATE(substr,str,pos) 49 获取子序列索引位置 50 51 REPEAT(str,count) 52 返回一个由重复的字符串str 组成的字符串，字符串str的数目等于count 。 53 若 count <= 0,则返回一个空字符串。 54 若str 或 count 为 NULL，则返回 NULL 。 55 REPLACE(str,from_str,to_str) 56 返回字符串str 以及全部被字符串to_str替代的字符串from_str 。 57 REVERSE(str) 58 返回字符串 str ，顺序和字符顺序相反。 59 RIGHT(str,len) 60 从字符串str 开始，返回从后边开始len个字符组成的子序列 61 62 SPACE(N) 63 返回一个由N空格组成的字符串。 64 65 SUBSTRING(str,pos) , SUBSTRING(str FROM pos) SUBSTRING(str,pos,len) , SUBSTRING(str FROM pos FOR len) 66 不带有len 参数的格式从字符串str返回一个子字符串，起始于位置 pos。带有len参数的格式从字符串str返回一个长度同len字符相同的子字符串，起始于位置 pos。 使用 FROM的格式为标准 SQL 语法。也可能对pos使用一个负值。倘若这样，则子字符串的位置起始于字符串结尾的pos 字符，而不是字符串的开头位置。在如下格式的函数中能够对pos 使用一个负值。 67 68 mysql> SELECT SUBSTRING('Quadratically',5); 69 -> 'ratically' 70 71 mysql> SELECT SUBSTRING('foobarbar' FROM 4); 72 -> 'barbar' 73 74 mysql> SELECT SUBSTRING('Quadratically',5,6); 75 -> 'ratica' 76 77 mysql> SELECT SUBSTRING('Sakila', -3); 78 -> 'ila' 79 80 mysql> SELECT SUBSTRING('Sakila', -5, 3); 81 -> 'aki' 82 83 mysql> SELECT SUBSTRING('Sakila' FROM -4 FOR 2); 84 -> 'ki' 85 86 TRIM([{BOTH | LEADING | TRAILING} [remstr] FROM] str) TRIM(remstr FROM] str) 87 返回字符串 str ， 其中全部remstr 前缀和/或后缀都已被删除。若分类符BOTH、LEADIN或TRAILING中没有一个是给定的,则假设为BOTH 。 remstr 为可选项，在未指定状况下，可删除空格。 88 89 mysql> SELECT TRIM(' bar '); 90 -> 'bar' 91 92 mysql> SELECT TRIM(LEADING 'x' FROM 'xxxbarxxx'); 93 -> 'barxxx' 94 95 mysql> SELECT TRIM(BOTH 'x' FROM 'xxxbarxxx'); 96 -> 'bar' 97 98 mysql> SELECT TRIM(TRAILING 'xyz' FROM 'barxxyz'); 99 -> 'barx' 100 101 部份内置函数
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;
1 #1 基本使用 2 mysql> SELECT DATE_FORMAT('2009-10-04 22:23:00', '%W %M %Y'); 3 -> 'Sunday October 2009' 4 mysql> SELECT DATE_FORMAT('2007-10-04 22:23:00', '%H:%i:%s'); 5 -> '22:23:00' 6 mysql> SELECT DATE_FORMAT('1900-10-04 22:23:00', 7 -> '%D %y %a %d %m %b %j'); 8 -> '4th 00 Thu 04 10 Oct 277' 9 mysql> SELECT DATE_FORMAT('1997-10-04 22:23:00', 10 -> '%H %k %I %r %T %S %w'); 11 -> '22 22 10 10:23:00 PM 22:23:00 00 6' 12 mysql> SELECT DATE_FORMAT('1999-01-01', '%X %V'); 13 -> '1998 52' 14 mysql> SELECT DATE_FORMAT('2006-06-00', '%d'); 15 -> '00' 16 17 18 #2 准备表和记录 19 CREATE TABLE blog ( 20 id INT PRIMARY KEY auto_increment, 21 NAME CHAR (32), 22 sub_time datetime 23 ); 24 25 INSERT INTO blog (NAME, sub_time) 26 VALUES 27 ('第1篇','2015-03-01 11:31:21'), 28 ('第2篇','2015-03-11 16:31:21'), 29 ('第3篇','2016-07-01 10:21:31'), 30 ('第4篇','2016-07-22 09:23:21'), 31 ('第5篇','2016-07-23 10:11:11'), 32 ('第6篇','2016-07-25 11:21:31'), 33 ('第7篇','2017-03-01 15:33:21'), 34 ('第8篇','2017-03-01 17:32:21'), 35 ('第9篇','2017-03-01 18:31:21'); 36 37 #3. 提取sub_time字段的值，按照格式后的结果即"年月"来分组 38 SELECT DATE_FORMAT(sub_time,'%Y-%m'),COUNT(1) FROM blog GROUP BY DATE_FORMAT(sub_time,'%Y-%m'); 39 40 #结果 41 +-------------------------------+----------+ 42 | DATE_FORMAT(sub_time,'%Y-%m') | COUNT(1) | 43 +-------------------------------+----------+ 44 | 2015-03 | 2 | 45 | 2016-07 | 4 | 46 | 2017-03 | 3 | 47 +-------------------------------+----------+ 48 rows in set (0.00 sec)
6、流程控制
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.循环语句
1 delimiter // 2 CREATE PROCEDURE proc_while () 3 BEGIN 4 5 DECLARE num INT ; 6 SET num = 0 ; 7 WHILE num < 10 DO 8 SELECT 9 num ; 10 SET num = num + 1 ; 11 END WHILE ; 12 13 END // 14 delimiter ;
1 delimiter // 2 CREATE PROCEDURE proc_repeat () 3 BEGIN 4 5 DECLARE i INT ; 6 SET i = 0 ; 7 repeat 8 select i; 9 set i = i + 1; 10 until i >= 5 11 end repeat; 12 13 END // 14 delimiter ;
1 BEGIN 2 3 declare i int default 0; 4 loop_label: loop 5 6 set i=i+1; 7 if i<8 then 8 iterate loop_label; 9 end if; 10 if i>=10 then 11 leave loop_label; 12 end if; 13 select i; 14 end loop loop_label; 15 16 END