MySQL高级

一、MySQL存储过程和函数

1.存储过程和函数的概念
  • 存储过程和函数是 事先经过编译并存储在数据库中的一段 SQL 语句的集合
2.存储过程和函数的好处
  • 存储过程和函数可以重复使用,减轻开发人员的工作量。类似于java中方法可以多次调用
  • 减少网络流量,存储过程和函数位于服务器上,调用的时候只需要传递名称和参数即可
  • 减少数据在数据库和应用服务器之间的传输,可以提高数据处理的效率
  • 将一些业务逻辑在数据库层面来实现,可以减少代码层面的业务处理
3.存储过程和函数的区别
  • 函数必须有返回值
  • 存储过程没有返回值
4.创建存储过程
  • 小知识
/*该关键字用来声明sql语句的分隔符,告诉MySQL该段命令已经结束!sql语句默认的分隔符是分号,但是有的时候我们需要一条功能sql语句中包含分号,但是并不作为结束标识。这个时候就可以使用DELIMITER来指定分隔符了!
*/
-- 标准语法
DELIMITER 分隔符
  • 数据准备
-- 创建db8数据库
CREATE DATABASE db8;-- 使用db8数据库
USE db8;-- 创建学生表
CREATE TABLE student(id INT PRIMARY KEY AUTO_INCREMENT,	-- 学生idNAME VARCHAR(20),					-- 学生姓名age INT,							-- 学生年龄gender VARCHAR(5),					-- 学生性别score INT                           -- 学生成绩
);
-- 添加数据
INSERT INTO student VALUES (NULL,'张三',23,'男',95),(NULL,'李四',24,'男',98),
(NULL,'王五',25,'女',100),(NULL,'赵六',26,'女',90);-- 按照性别进行分组,查询每组学生的总成绩。按照总成绩的升序排序
SELECT gender,SUM(score) getSum FROM student GROUP BY gender ORDER BY getSum ASC;
  • 创建存储过程语法
-- 修改分隔符为$
DELIMITER $-- 标准语法
CREATE PROCEDURE 存储过程名称(参数...)
BEGINsql语句;
END$-- 修改分隔符为分号
DELIMITER ;
  • 创建存储过程
-- 修改分隔符为$
DELIMITER $-- 创建存储过程,封装分组查询学生总成绩的sql语句
CREATE PROCEDURE stu_group()
BEGINSELECT gender,SUM(score) getSum FROM student GROUP BY gender ORDER BY getSum ASC;
END$-- 修改分隔符为分号
DELIMITER ;
5.调用存储过程
  • 调用存储过程语法
-- 标准语法
CALL 存储过程名称(实际参数);-- 调用stu_group存储过程
CALL stu_group();
6.查看存储过程
  • 查看存储过程语法
-- 查询数据库中所有的存储过程 标准语法
SELECT * FROM mysql.proc WHERE db='数据库名称';
7.删除存储过程
  • 删除存储过程语法
-- 标准语法
DROP PROCEDURE [IF EXISTS] 存储过程名称;-- 删除stu_group存储过程
DROP PROCEDURE stu_group;
8.存储过程语法
8.1存储过程语法介绍
  • 存储过程是可以进行编程的。意味着可以使用变量、表达式、条件控制语句、循环语句等,来完成比较复杂的功能!
8.2变量的使用
  • 定义变量
-- 标准语法
DECLARE 变量名 数据类型 [DEFAULT 默认值];
-- 注意: DECLARE定义的是局部变量,只能用在BEGIN END范围之内-- 定义一个int类型变量、并赋默认值为10
DELIMITER $CREATE PROCEDURE pro_test1()
BEGINDECLARE num INT DEFAULT 10;   -- 定义变量SELECT num;                   -- 查询变量
END$DELIMITER ;-- 调用pro_test1存储过程
CALL pro_test1();
  • 变量的赋值1
-- 标准语法
SET 变量名 = 变量值;-- 定义字符串类型变量,并赋值
DELIMITER $CREATE PROCEDURE pro_test2()
BEGINDECLARE NAME VARCHAR(10);   -- 定义变量SET NAME = '存储过程';       -- 为变量赋值SELECT NAME;                -- 查询变量
END$DELIMITER ;-- 调用pro_test2存储过程
CALL pro_test2();
  • 变量的赋值2
-- 标准语法
SELECT 列名 INTO 变量名 FROM 表名 [WHERE 条件];-- 定义两个int变量,用于存储男女同学的总分数
DELIMITER $CREATE PROCEDURE pro_test3()
BEGINDECLARE men,women INT;  -- 定义变量SELECT SUM(score) INTO men FROM student WHERE gender='男';    -- 计算男同学总分数赋值给menSELECT SUM(score) INTO women FROM student WHERE gender='女';  -- 计算女同学总分数赋值给womenSELECT men,women;           -- 查询变量
END$DELIMITER ;-- 调用pro_test3存储过程
CALL pro_test3();
8.3if语句的使用
  • 标准语法
-- 标准语法
IF 判断条件1 THEN 执行的sql语句1;
[ELSEIF 判断条件2 THEN 执行的sql语句2;]
...
[ELSE 执行的sql语句n;]
END IF;
  • 案例演示
/*定义一个int变量,用于存储班级总成绩定义一个varchar变量,用于存储分数描述根据总成绩判断:380分及以上    学习优秀320 ~ 380     学习不错320以下       学习一般
*/
DELIMITER $CREATE PROCEDURE pro_test4()
BEGIN-- 定义总分数变量DECLARE total INT;-- 定义分数描述变量DECLARE description VARCHAR(10);-- 为总分数变量赋值SELECT SUM(score) INTO total FROM student;-- 判断总分数IF total >= 380 THEN SET description = '学习优秀';ELSEIF total >= 320 AND total < 380 THEN SET description = '学习不错';ELSE SET description = '学习一般';END IF;-- 查询总成绩和描述信息SELECT total,description;
END$DELIMITER ;-- 调用pro_test4存储过程
CALL pro_test4();
8.4参数的传递
  • 参数传递的语法
DELIMITER $-- 标准语法
CREATE PROCEDURE 存储过程名称([IN|OUT|INOUT] 参数名 数据类型)
BEGIN执行的sql语句;
END$
/*IN:代表输入参数,需要由调用者传递实际数据。默认的OUT:代表输出参数,该参数可以作为返回值INOUT:代表既可以作为输入参数,也可以作为输出参数
*/
DELIMITER ;
  • 输入参数

    • 标准语法
    DELIMITER $-- 标准语法
    CREATE PROCEDURE 存储过程名称(IN 参数名 数据类型)
    BEGIN执行的sql语句;
    END$DELIMITER ;
    
    • 案例演示
    /*输入总成绩变量,代表学生总成绩定义一个varchar变量,用于存储分数描述根据总成绩判断:380分及以上  学习优秀320 ~ 380    学习不错320以下      学习一般
    */
    DELIMITER $CREATE PROCEDURE pro_test5(IN total INT)
    BEGIN-- 定义分数描述变量DECLARE description VARCHAR(10);-- 判断总分数IF total >= 380 THEN SET description = '学习优秀';ELSEIF total >= 320 AND total < 380 THEN SET description = '学习不错';ELSE SET description = '学习一般';END IF;-- 查询总成绩和描述信息SELECT total,description;
    END$DELIMITER ;-- 调用pro_test5存储过程
    CALL pro_test5(390);
    CALL pro_test5((SELECT SUM(score) FROM student));
    
  • 输出参数

    • 标准语法
    DELIMITER $-- 标准语法
    CREATE PROCEDURE 存储过程名称(OUT 参数名 数据类型)
    BEGIN执行的sql语句;
    END$DELIMITER ;
    
    • 案例演示
    /*输入总成绩变量,代表学生总成绩输出分数描述变量,代表学生总成绩的描述根据总成绩判断:380分及以上  学习优秀320 ~ 380    学习不错320以下      学习一般
    */
    DELIMITER $CREATE PROCEDURE pro_test6(IN total INT,OUT description VARCHAR(10))
    BEGIN-- 判断总分数IF total >= 380 THEN SET description = '学习优秀';ELSEIF total >= 320 AND total < 380 THEN SET description = '学习不错';ELSE SET description = '学习一般';END IF;
    END$DELIMITER ;-- 调用pro_test6存储过程
    CALL pro_test6(310,@description);-- 查询总成绩描述
    SELECT @description;
    
    • 小知识
    @变量名:  这种变量要在变量名称前面加上“@”符号,叫做用户会话变量,代表整个会话过程他都是有作用的,这个类似于全局变量一样。@@变量名: 这种在变量前加上 "@@" 符号, 叫做系统变量 
    
8.5case语句的使用
  • 标准语法1
-- 标准语法
CASE 表达式
WHEN 值1 THEN 执行sql语句1;
[WHEN 值2 THEN 执行sql语句2;]
...
[ELSE 执行sql语句n;]
END CASE;
  • 标准语法2
-- 标准语法
CASE
WHEN 判断条件1 THEN 执行sql语句1;
[WHEN 判断条件2 THEN 执行sql语句2;]
...
[ELSE 执行sql语句n;]
END CASE;
  • 案例演示
/*输入总成绩变量,代表学生总成绩定义一个varchar变量,用于存储分数描述根据总成绩判断:380分及以上  学习优秀320 ~ 380    学习不错320以下      学习一般
*/
DELIMITER $CREATE PROCEDURE pro_test7(IN total INT)
BEGIN-- 定义变量DECLARE description VARCHAR(10);-- 使用case判断CASEWHEN total >= 380 THENSET description = '学习优秀';WHEN total >= 320 AND total < 380 THENSET description = '学习不错';ELSE SET description = '学习一般';END CASE;-- 查询分数描述信息SELECT description;
END$DELIMITER ;-- 调用pro_test7存储过程
CALL pro_test7(390);
CALL pro_test7((SELECT SUM(score) FROM student));
8.6while循环
  • 标准语法
-- 标准语法
初始化语句;
WHILE 条件判断语句 DO循环体语句;条件控制语句;
END WHILE;
  • 案例演示
/*计算1~100之间的偶数和
*/
DELIMITER $CREATE PROCEDURE pro_test8()
BEGIN-- 定义求和变量DECLARE result INT DEFAULT 0;-- 定义初始化变量DECLARE num INT DEFAULT 1;-- while循环WHILE num <= 100 DO-- 偶数判断IF num%2=0 THENSET result = result + num; -- 累加END IF;-- 让num+1SET num = num + 1;         END WHILE;-- 查询求和结果SELECT result;
END$DELIMITER ;-- 调用pro_test8存储过程
CALL pro_test8();
8.7repeat循环
  • 标准语法
-- 标准语法
初始化语句;
REPEAT循环体语句;条件控制语句;UNTIL 条件判断语句
END REPEAT;-- 注意:repeat循环是条件满足则停止。while循环是条件满足则执行
  • 案例演示
/*计算1~10之间的和
*/
DELIMITER $CREATE PROCEDURE pro_test9()
BEGIN-- 定义求和变量DECLARE result INT DEFAULT 0;-- 定义初始化变量DECLARE num INT DEFAULT 1;-- repeat循环REPEAT-- 累加SET result = result + num;-- 让num+1SET num = num + 1;-- 停止循环UNTIL num>10END REPEAT;-- 查询求和结果SELECT result;
END$DELIMITER ;-- 调用pro_test9存储过程
CALL pro_test9();
8.8loop循环
  • 标准语法
-- 标准语法
初始化语句;
[循环名称:] LOOP条件判断语句[LEAVE 循环名称;]循环体语句;条件控制语句;
END LOOP 循环名称;-- 注意:loop可以实现简单的循环,但是退出循环需要使用其他的语句来定义。我们可以使用leave语句完成!
--      如果不加退出循环的语句,那么就变成了死循环。
  • 案例演示
/*计算1~10之间的和
*/
DELIMITER $CREATE PROCEDURE pro_test10()
BEGIN-- 定义求和变量DECLARE result INT DEFAULT 0;-- 定义初始化变量DECLARE num INT DEFAULT 1;-- loop循环l:LOOP-- 条件成立,停止循环IF num > 10 THENLEAVE l;END IF;-- 累加SET result = result + num;-- 让num+1SET num = num + 1;END LOOP l;-- 查询求和结果SELECT result;
END$DELIMITER ;-- 调用pro_test10存储过程
CALL pro_test10();
8.9游标
  • 游标的概念

    • 游标可以遍历返回的多行结果,每次拿到一整行数据
    • 在存储过程和函数中可以使用游标对结果集进行循环的处理
    • 简单来说游标就类似于集合的迭代器遍历
    • MySQL中的游标只能用在存储过程和函数中
  • 游标的语法

    • 创建游标
    -- 标准语法
    DECLARE 游标名称 CURSOR FOR 查询sql语句;
    
    • 打开游标
    -- 标准语法
    OPEN 游标名称;
    
    • 使用游标获取数据
    -- 标准语法
    FETCH 游标名称 INTO 变量名1,变量名2,...;
    
    • 关闭游标
    -- 标准语法
    CLOSE 游标名称;
    
  • 游标的基本使用

-- 创建stu_score表
CREATE TABLE stu_score(id INT PRIMARY KEY AUTO_INCREMENT,score INT
);/*将student表中所有的成绩保存到stu_score表中
*/
DELIMITER $CREATE PROCEDURE pro_test11()
BEGIN-- 定义成绩变量DECLARE s_score INT;-- 创建游标,查询所有学生成绩数据DECLARE stu_result CURSOR FOR SELECT score FROM student;-- 开启游标OPEN stu_result;-- 使用游标,遍历结果,拿到第1行数据FETCH stu_result INTO s_score;-- 将数据保存到stu_score表中INSERT INTO stu_score VALUES (NULL,s_score);-- 使用游标,遍历结果,拿到第2行数据FETCH stu_result INTO s_score;-- 将数据保存到stu_score表中INSERT INTO stu_score VALUES (NULL,s_score);-- 使用游标,遍历结果,拿到第3行数据FETCH stu_result INTO s_score;-- 将数据保存到stu_score表中INSERT INTO stu_score VALUES (NULL,s_score);-- 使用游标,遍历结果,拿到第4行数据FETCH stu_result INTO s_score;-- 将数据保存到stu_score表中INSERT INTO stu_score VALUES (NULL,s_score);-- 关闭游标CLOSE stu_result;
END$DELIMITER ;-- 调用pro_test11存储过程
CALL pro_test11();-- 查询stu_score表
SELECT * FROM stu_score;-- ===========================================================
/*出现的问题:student表中一共有4条数据,我们在游标遍历了4次,没有问题!但是在游标中多遍历几次呢?就会出现问题
*/
DELIMITER $CREATE PROCEDURE pro_test11()
BEGIN-- 定义成绩变量DECLARE s_score INT;-- 创建游标,查询所有学生成绩数据DECLARE stu_result CURSOR FOR SELECT score FROM student;-- 开启游标OPEN stu_result;-- 使用游标,遍历结果,拿到第1行数据FETCH stu_result INTO s_score;-- 将数据保存到stu_score表中INSERT INTO stu_score VALUES (NULL,s_score);-- 使用游标,遍历结果,拿到第2行数据FETCH stu_result INTO s_score;-- 将数据保存到stu_score表中INSERT INTO stu_score VALUES (NULL,s_score);-- 使用游标,遍历结果,拿到第3行数据FETCH stu_result INTO s_score;-- 将数据保存到stu_score表中INSERT INTO stu_score VALUES (NULL,s_score);-- 使用游标,遍历结果,拿到第4行数据FETCH stu_result INTO s_score;-- 将数据保存到stu_score表中INSERT INTO stu_score VALUES (NULL,s_score);-- 使用游标,遍历结果,拿到第5行数据FETCH stu_result INTO s_score;-- 将数据保存到stu_score表中INSERT INTO stu_score VALUES (NULL,s_score);-- 关闭游标CLOSE stu_result;
END$DELIMITER ;-- 调用pro_test11存储过程
CALL pro_test11();-- 查询stu_score表,虽然数据正确,但是在执行存储过程时会报错
SELECT * FROM stu_score;
  • 游标的优化使用(配合循环使用)
/*当游标结束后,会触发游标结束事件。我们可以通过这一特性来完成循环操作加标记思想:1.定义一个变量,默认值为0(意味着有数据)2.当游标结束后,将变量值改为1(意味着没有数据了)
*/
-- 1.定义一个变量,默认值为0(意味着有数据)
DECLARE flag INT DEFAULT 0;
-- 2.当游标结束后,将变量值改为1(意味着没有数据了)
DECLARE EXIT HANDLER FOR NOT FOUND SET flag = 1;
/*将student表中所有的成绩保存到stu_score表中
*/
DELIMITER $CREATE PROCEDURE pro_test12()
BEGIN-- 定义成绩变量DECLARE s_score INT;-- 定义标记变量DECLARE flag INT DEFAULT 0;-- 创建游标,查询所有学生成绩数据DECLARE stu_result CURSOR FOR SELECT score FROM student;-- 游标结束后,将标记变量改为1DECLARE EXIT HANDLER FOR NOT FOUND SET flag = 1;-- 开启游标OPEN stu_result;-- 循环使用游标REPEAT-- 使用游标,遍历结果,拿到数据FETCH stu_result INTO s_score;-- 将数据保存到stu_score表中INSERT INTO stu_score VALUES (NULL,s_score);UNTIL flag=1END REPEAT;-- 关闭游标CLOSE stu_result;
END$DELIMITER ;-- 调用pro_test12存储过程
CALL pro_test12();-- 查询stu_score表
SELECT * FROM stu_score;
9.存储过程的总结
  • 存储过程是 事先经过编译并存储在数据库中的一段 SQL 语句的集合。可以在数据库层面做一些业务处理
  • 说白了存储过程其实就是将sql语句封装为方法,然后可以调用方法执行sql语句而已
  • 存储过程的好处
    • 安全
    • 高效
    • 复用性强
10.存储函数
  • 存储函数和存储过程是非常相似的。存储函数可以做的事情,存储过程也可以做到!

  • 存储函数有返回值,存储过程没有返回值(参数的out其实也相当于是返回数据了)

  • 标准语法

    • 创建存储函数
    DELIMITER $-- 标准语法
    CREATE FUNCTION 函数名称([参数 数据类型])
    RETURNS 返回值类型
    BEGIN执行的sql语句;RETURN 结果;
    END$DELIMITER ;
    
    • 调用存储函数
    -- 标准语法
    SELECT 函数名称(实际参数);
    
    • 删除存储函数
    -- 标准语法
    DROP FUNCTION 函数名称;
    
  • 案例演示

/*定义存储函数,获取学生表中成绩大于95分的学生数量
*/
DELIMITER $CREATE FUNCTION fun_test1()
RETURNS INT
BEGIN-- 定义统计变量DECLARE result INT;-- 查询成绩大于95分的学生数量,给统计变量赋值SELECT COUNT(*) INTO result FROM student WHERE score > 95;-- 返回统计结果RETURN result;
END$DELIMITER ;-- 调用fun_test1存储函数
SELECT fun_test1();

二、MySQL触发器

1.触发器的概念
  • 触发器是与表有关的数据库对象,可以在 insert/update/delete 之前或之后,触发并执行触发器中定义的SQL语句。触发器的这种特性可以协助应用在数据库端确保数据的完整性 、日志记录 、数据校验等操作 。
  • 使用别名 NEW 和 OLD 来引用触发器中发生变化的记录内容,这与其他的数据库是相似的。现在触发器还只支持行级触发,不支持语句级触发。
触发器类型OLD的含义NEW的含义
INSERT 型触发器无 (因为插入前状态无数据)NEW 表示将要或者已经新增的数据
UPDATE 型触发器OLD 表示修改之前的数据NEW 表示将要或已经修改后的数据
DELETE 型触发器OLD 表示将要或者已经删除的数据无 (因为删除后状态无数据)
2.创建触发器
  • 标准语法
DELIMITER $CREATE TRIGGER 触发器名称
BEFORE|AFTER INSERT|UPDATE|DELETE
ON 表名
[FOR EACH ROW]  -- 行级触发器
BEGIN触发器要执行的功能;
END$DELIMITER ;
  • 触发器演示。通过触发器记录账户表的数据变更日志。包含:增加、修改、删除

    • 创建账户表
    -- 创建db9数据库
    CREATE DATABASE db9;-- 使用db9数据库
    USE db9;-- 创建账户表account
    CREATE TABLE account(id INT PRIMARY KEY AUTO_INCREMENT,	-- 账户idNAME VARCHAR(20),					-- 姓名money DOUBLE						-- 余额
    );
    -- 添加数据
    INSERT INTO account VALUES (NULL,'张三',1000),(NULL,'李四',2000);
    
    • 创建日志表
    -- 创建日志表account_log
    CREATE TABLE account_log(id INT PRIMARY KEY AUTO_INCREMENT,	-- 日志idoperation VARCHAR(20),				-- 操作类型 (insert update delete)operation_time DATETIME,			-- 操作时间operation_id INT,					-- 操作表的idoperation_params VARCHAR(200)       -- 操作参数
    );
    
    • 创建INSERT触发器
    -- 创建INSERT触发器
    DELIMITER $CREATE TRIGGER account_insert
    AFTER INSERT
    ON account
    FOR EACH ROW
    BEGININSERT INTO account_log VALUES (NULL,'INSERT',NOW(),new.id,CONCAT('插入后{id=',new.id,',name=',new.name,',money=',new.money,'}'));
    END$DELIMITER ;-- 向account表添加记录
    INSERT INTO account VALUES (NULL,'王五',3000);-- 查询account表
    SELECT * FROM account;-- 查询日志表
    SELECT * FROM account_log;
    
    • 创建UPDATE触发器
    -- 创建UPDATE触发器
    DELIMITER $CREATE TRIGGER account_update
    AFTER UPDATE
    ON account
    FOR EACH ROW
    BEGININSERT INTO account_log VALUES (NULL,'UPDATE',NOW(),new.id,CONCAT('修改前{id=',old.id,',name=',old.name,',money=',old.money,'}','修改后{id=',new.id,',name=',new.name,',money=',new.money,'}'));
    END$DELIMITER ;-- 修改account表
    UPDATE account SET money=3500 WHERE id=3;-- 查询account表
    SELECT * FROM account;-- 查询日志表
    SELECT * FROM account_log;
    
    • 创建DELETE触发器
    -- 创建DELETE触发器
    DELIMITER $CREATE TRIGGER account_delete
    AFTER DELETE
    ON account
    FOR EACH ROW
    BEGININSERT INTO account_log VALUES (NULL,'DELETE',NOW(),old.id,CONCAT('删除前{id=',old.id,',name=',old.name,',money=',old.money,'}'));
    END$DELIMITER ;-- 删除account表数据
    DELETE FROM account WHERE id=3;-- 查询account表
    SELECT * FROM account;-- 查询日志表
    SELECT * FROM account_log;
    
3.查看触发器
-- 标准语法
SHOW TRIGGERS;-- 查看触发器
SHOW TRIGGERS;
4.删除触发器
-- 标准语法
DROP TRIGGER 触发器名称;-- 删除DELETE触发器
DROP TRIGGER account_delete;
5.触发器的总结
  • 触发器是与表有关的数据库对象
  • 可以在 insert/update/delete 之前或之后,触发并执行触发器中定义的SQL语句
  • 触发器的这种特性可以协助应用在数据库端确保数据的完整性 、日志记录 、数据校验等操作
  • 使用别名 NEW 和 OLD 来引用触发器中发生变化的记录内容

三、MySQL事务

1.事务的概念
  • 一条或多条 SQL 语句组成一个执行单元,其特点是这个单元要么同时成功要么同时失败,单元中的每条 SQL 语句都相互依赖,形成一个整体,如果某条 SQL 语句执行失败或者出现错误,那么整个单元就会回滚,撤回到事务最初的状态,如果单元中所有的 SQL 语句都执行成功,则事务就顺利执行。
2.事务的数据准备
-- 创建db10数据库
CREATE DATABASE db10;-- 使用db10数据库
USE db10;-- 创建账户表
CREATE TABLE account(id INT PRIMARY KEY AUTO_INCREMENT,	-- 账户idNAME VARCHAR(20),			-- 账户名称money DOUBLE				-- 账户余额
);
-- 添加数据
INSERT INTO account VALUES (NULL,'张三',1000),(NULL,'李四',1000);
3.未管理事务演示
-- 张三给李四转账500元
-- 1.张三账户-500
UPDATE account SET money=money-500 WHERE NAME='张三';
-- 2.李四账户+500
出错了...
UPDATE account SET money=money+500 WHERE NAME='李四';-- 该场景下,这两条sql语句要么同时成功,要么同时失败。就需要被事务所管理!
4.管理事务演示
  • 操作事务的三个步骤
    1. 开启事务:记录回滚点,并通知服务器,将要执行一组操作,要么同时成功、要么同时失败
    2. 执行sql语句:执行具体的一条或多条sql语句
    3. 结束事务(提交|回滚)
      • 提交:没出现问题,数据进行更新
      • 回滚:出现问题,数据恢复到开启事务时的状态
  • 开启事务
-- 标准语法
START TRANSACTION;
  • 回滚事务
-- 标准语法
ROLLBACK;
  • 提交事务
-- 标准语法
COMMIT;
  • 管理事务演示
-- 开启事务
START TRANSACTION;-- 张三给李四转账500元
-- 1.张三账户-500
UPDATE account SET money=money-500 WHERE NAME='张三';
-- 2.李四账户+500
-- 出错了...
UPDATE account SET money=money+500 WHERE NAME='李四';-- 回滚事务(出现问题)
ROLLBACK;-- 提交事务(没出现问题)
COMMIT;
5.事务的提交方式
  • 提交方式

    • 自动提交(MySQL默认为自动提交)
    • 手动提交
  • 修改提交方式

    • 查看提交方式
    -- 标准语法
    SELECT @@AUTOCOMMIT;  -- 1代表自动提交    0代表手动提交
    
    • 修改提交方式
    -- 标准语法
    SET @@AUTOCOMMIT=数字;-- 修改为手动提交
    SET @@AUTOCOMMIT=0;-- 查看提交方式
    SELECT @@AUTOCOMMIT;
    
6.事务的四大特征(ACID)
  • 原子性(atomicity)
    • 原子性是指事务包含的所有操作要么全部成功,要么全部失败回滚,因此事务的操作如果成功就必须要完全应用到数据库,如果操作失败则不能对数据库有任何影响
  • 一致性(consistency)
    • 一致性是指事务必须使数据库从一个一致性状态变换到另一个一致性状态,也就是说一个事务执行之前和执行之后都必须处于一致性状态
    • 拿转账来说,假设张三和李四两者的钱加起来一共是2000,那么不管A和B之间如何转账,转几次账,事务结束后两个用户的钱相加起来应该还得是2000,这就是事务的一致性
  • 隔离性(isolcation)
    • 隔离性是当多个用户并发访问数据库时,比如操作同一张表时,数据库为每一个用户开启的事务,不能被其他事务的操作所干扰,多个并发事务之间要相互隔离
  • 持久性(durability)
    • 持久性是指一个事务一旦被提交了,那么对数据库中的数据的改变就是永久性的,即便是在数据库系统遇到故障的情况下也不会丢失提交事务的操作
7.事务的隔离级别
  • 隔离级别的概念
    • 多个客户端操作时 ,各个客户端的事务之间应该是隔离的,相互独立的 , 不受影响的。
    • 而如果多个事务操作同一批数据时,则需要设置不同的隔离级别 , 否则就会产生问题 。
    • 我们先来了解一下四种隔离级别的名称 , 再来看看可能出现的问题
  • 四种隔离级别
1读未提交read uncommitted
2读已提交read committed
3可重复读repeatable read
4串行化serializable
  • 可能引发的问题
问题现象
脏读是指在一个事务处理过程中读取了另一个未提交的事务中的数据 , 导致两次查询结果不一致
不可重复读是指在一个事务处理过程中读取了另一个事务中修改并已提交的数据, 导致两次查询结果不一致
幻读select 某记录是否存在,不存在,准备插入此记录,但执行 insert 时发现此记录已存在,无法插入。或不存在执行delete删除,却发现删除成功
  • 查询数据库隔离级别
-- 标准语法
SELECT @@TX_ISOLATION;
  • 修改数据库隔离级别
-- 标准语法
SET GLOBAL TRANSACTION ISOLATION LEVEL 级别字符串;-- 修改数据库隔离级别为read uncommitted
SET GLOBAL TRANSACTION ISOLATION LEVEL read uncommitted;-- 查看隔离级别
SELECT @@TX_ISOLATION;   -- 修改后需要断开连接重新开
8.事务隔离级别演示
  • 脏读的问题

    • 窗口1
    -- 查询账户表
    select * from account;-- 设置隔离级别为read uncommitted
    set global transaction isolation level read uncommitted;-- 开启事务
    start transaction;-- 转账
    update account set money = money - 500 where id = 1;
    update account set money = money + 500 where id = 2;-- 窗口2查询转账结果 ,出现脏读(查询到其他事务未提交的数据)-- 窗口2查看转账结果后,执行回滚
    rollback;
    
    • 窗口2
    -- 查询隔离级别
    select @@tx_isolation;-- 开启事务
    start transaction;-- 查询账户表
    select * from account;
    
  • 解决脏读的问题和演示不可重复读的问题

    • 窗口1
    -- 设置隔离级别为read committed
    set global transaction isolation level read committed;-- 开启事务
    start transaction;-- 转账
    update account set money = money - 500 where id = 1;
    update account set money = money + 500 where id = 2;-- 窗口2查看转账结果,并没有发生变化(脏读问题被解决了)-- 执行提交事务。
    commit;-- 窗口2查看转账结果,数据发生了变化(出现了不可重复读的问题,读取到其他事务已提交的数据)
    
    • 窗口2
    -- 查询隔离级别
    select @@tx_isolation;-- 开启事务
    start transaction;-- 查询账户表
    select * from account;
    
  • 解决不可重复读的问题

    • 窗口1
    -- 设置隔离级别为repeatable read
    set global transaction isolation level repeatable read;-- 开启事务
    start transaction;-- 转账
    update account set money = money - 500 where id = 1;
    update account set money = money + 500 where id = 2;-- 窗口2查看转账结果,并没有发生变化-- 执行提交事务
    commit;-- 这个时候窗口2只要还在上次事务中,看到的结果都是相同的。只有窗口2结束事务,才能看到变化(不可重复读的问题被解决)
    
    • 窗口2
    -- 查询隔离级别
    select @@tx_isolation;-- 开启事务
    start transaction;-- 查询账户表
    select * from account;-- 提交事务
    commit;-- 查询账户表
    select * from account;
    
  • 幻读的问题和解决

    • 窗口1
    -- 设置隔离级别为repeatable read
    set global transaction isolation level repeatable read;-- 开启事务
    start transaction;-- 添加一条记录
    INSERT INTO account VALUES (3,'王五',1500);-- 查询账户表,本窗口可以查看到id为3的结果
    SELECT * FROM account;-- 提交事务
    COMMIT;
    
    • 窗口2
    -- 查询隔离级别
    select @@tx_isolation;-- 开启事务
    start transaction;-- 查询账户表,查询不到新添加的id为3的记录
    select * from account;-- 添加id为3的一条数据,发现添加失败。出现了幻读
    INSERT INTO account VALUES (3,'测试',200);-- 提交事务
    COMMIT;-- 查询账户表,查询到了新添加的id为3的记录
    select * from account;
    
    • 解决幻读的问题
    /*窗口1
    */
    -- 设置隔离级别为serializable
    set global transaction isolation level serializable;-- 开启事务
    start transaction;-- 添加一条记录
    INSERT INTO account VALUES (4,'赵六',1600);-- 查询账户表,本窗口可以查看到id为4的结果
    SELECT * FROM account;-- 提交事务
    COMMIT;/*窗口2
    */
    -- 查询隔离级别
    select @@tx_isolation;-- 开启事务
    start transaction;-- 查询账户表,发现查询语句无法执行,数据表被锁住!只有窗口1提交事务后,才可以继续操作
    select * from account;-- 添加id为4的一条数据,发现已经存在了,就不会再添加了!幻读的问题被解决
    INSERT INTO account VALUES (4,'测试',200);-- 提交事务
    COMMIT;
    
9.隔离级别总结
隔离级别名称出现脏读出现不可重复读出现幻读数据库默认隔离级别
1read uncommitted读未提交
2read committed读已提交Oracle / SQL Server
3repeatable read可重复读MySQL
4**serializable **串行化

注意:隔离级别从小到大安全性越来越高,但是效率越来越低 , 所以不建议使用READ UNCOMMITTED 和 SERIALIZABLE 隔离级别.

10.事务的总结
  • 一条或多条 SQL 语句组成一个执行单元,其特点是这个单元要么同时成功要么同时失败。例如转账操作
  • 开启事务:start transaction;
  • 回滚事务:rollback;
  • 提交事务:commit;
  • 事务四大特征
    • 原子性
    • 持久性
    • 隔离性
    • 一致性
  • 事务的隔离级别
    • read uncommitted(读未提交)
    • read committed (读已提交)
    • repeatable read (可重复读)
    • serializable (串行化)

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/611788.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

【Verilog】期末复习——设计带异步清零且高电平有效的4位循环移位寄存器

系列文章 数值&#xff08;整数&#xff0c;实数&#xff0c;字符串&#xff09;与数据类型&#xff08;wire、reg、mem、parameter&#xff09; 运算符 数据流建模 行为级建模 结构化建模 组合电路的设计和时序电路的设计 有限状态机的定义和分类 期末复习——数字逻辑电路分…

虚幻UE 材质-纹理 1

本篇笔记主要讲两个纹理内的内容&#xff1a;渲染目标和媒体纹理 媒体纹理可以参考之前的笔记&#xff1a;虚幻UE 媒体播放器-视频转成材质-播放视频 所以本篇主要讲两个组件&#xff1a;场景捕获2D、场景捕获立方体 两个纹理&#xff1a;渲染目标、立方体渲染目标 三个功能&am…

jmeter分布式测试

场景&#xff1a;需求要求使用用大量的客户访问时&#xff0c;可以使用分布式来完成 分布式实现原理&#xff1a; 材料&#xff1a;一台控制机器&#xff0c;若干台代理机也叫执行机 运行时&#xff0c;控制机将脚本发送到代理机上-->代理机拿到就开始执行&#xff0c;不会…

论文阅读 BERT GPT - transformer在NLP领域的延伸

文章目录 不会写的很详细&#xff0c;只是为了帮助我理解在CV领域transformer的拓展1 摘要1.1 BERT - 核心1.2 GPT - 核心 2 模型架构2.1 概览 3 区别3.1 finetune和prompt 3.2 transformer及训练总结 不会写的很详细&#xff0c;只是为了帮助我理解在CV领域transformer的拓展 …

1.10 力扣回溯中等题

93. 复原 IP 地址 代码随想录 (programmercarl.com) 有效 IP 地址 正好由四个整数&#xff08;每个整数位于 0 到 255 之间组成&#xff0c;且不能含有前导 0&#xff09;&#xff0c;整数之间用 . 分隔。 例如&#xff1a;"0.1.2.201" 和 "192.168.1.1"…

Python exec 命令在函数内执行无效,已解决

看了很多文章&#xff0c;有很多介绍的很详细。但一直都不能正确使用&#xff0c;总是出现这样那样的问题。但学到了很多名词和描述。 继续和AI对话过程中&#xff0c;找到了解决方案。这里只针对个人问题做一个记录。 npz_data是一个字典&#xff0c; 方案2原因&#xff1a;由…

Java8新特性之函数式接口

JDK1.8 对函数式接口的描述 /*** An informative annotation type used to indicate that an interface* type declaration is intended to be a <i>functional interface</i> as* defined by the Java Language Specification.** Conceptually, a functional int…

面试专题一:js的数组

前言 想做最全的js数组方法总结。涵盖面试及日常使用。 这里写目录标题 前言如何判断数组修改数组元素的方法检测数组元素的相关方法一些跟数组相关且传参为回调函数的方法其他方法 总结 如何判断数组 不可以用typeOf方法。该方法只能用来检验最基本的数据类型&#xff0c;&…

构建安全可靠的系统:第十六章到第二十章

第四部分&#xff1a;维护系统 原文&#xff1a;Part IV. Maintaining Systems 译者&#xff1a;飞龙 协议&#xff1a;CC BY-NC-SA 4.0 准备应对不舒适情况的组织有更好的机会处理关键事件。 尽管不可能为可能扰乱您组织的每种情况制定计划&#xff0c;但作为综合灾难规划策略…

接口数据使用了 RSA 加密和签名?一篇文章带你了解

接口数据使用了RSA加密和签名&#xff1f;一篇文章带你搞定&#xff01; 1、前言 很多童鞋在工作中&#xff0c;会遇到一些接口使用RSA加密和签名来处理的请求参数&#xff0c;那么遇到这个问题的时候&#xff0c;第一时间当然是找开发要加解密的方法&#xff0c;但是开发给加…

并发编程之JUC并发工具类下

目录 CyclicBarrier&#xff08;回环栅栏或循环屏障&#xff09; 特点 常用方法 CyclicBarrier应用场景 CyclicBarrier与CountDownLatch区别 Exchanger 特点 常用方法 Exchanger的应用场景 Phaser&#xff08;阶段协同器&#xff09; 特点 常用方法 Phaser的应用场…

1991-2022年A股上市公司股价崩盘风险指标数据

1991-2022年A股上市公司股价崩盘风险指标数据 1、时间&#xff1a;1991-2022年 2、来源&#xff1a;整理自csmar 3、指标&#xff1a;证券代码、交易年度、NCSKEW(分市场等权平均法)、NCSKEW(分市场流通市值平均法)、NCSKEW(分市场总市值平均法)&#xff1b; NCSKEW(综合市…

MySQL中的临键锁:深入理解与案例解析

一、引言 在数据库中&#xff0c;锁是一种非常重要的机制&#xff0c;用于管理并发操作&#xff0c;确保数据的一致性和完整性。MySQL支持多种类型的锁&#xff0c;其中临键锁&#xff08;Next-Key Locking&#xff09;是一种非常重要的锁策略&#xff0c;它结合了行锁和间隙锁…

【Spring 篇】JdbcTemplate:轻松驾驭数据库的魔法工具

欢迎来到数据库的奇妙世界&#xff0c;在这里&#xff0c;我们将一同揭开Spring框架中JdbcTemplate的神秘面纱。JdbcTemplate是Spring提供的一个简化数据库操作的工具&#xff0c;它为我们提供了一种轻松驾驭数据库的魔法。本篇博客将详细解释JdbcTemplate的基本使用&#xff0…

我的 AI 成长星球,邀请你加入

大家好啊&#xff0c;我是董董灿。 2023年终总结时我这个小白坚持写作一整年&#xff0c;赚了多少&#xff1f;提到了一点&#xff0c;2024希望自己创建一个免费星球。 其实一直就想弄一个高质量的 AI 知识交流平台&#xff0c;方便大家一起交流和学习&#xff0c;同时提高对 …

调整Hive查询临时内存大小的方法

文章目录 前言设置Hive查询的临时内存大小1、Hive 执行引擎内存参数2. Tez 引擎内存参数3. MapReduce 引擎内存参数 查询默认内存大小 总结 前言 在Hive中&#xff0c;调整临时内存大小是优化查询性能的关键一步。通过合理配置相关参数&#xff0c;可以使查询在处理大数据集时…

我的年度总结(大一程序员的自述)

呀哈喽&#xff0c;我是结衣。 我也来参加这个年度总结的话题咯&#xff0c;喜欢的话可以点个赞哦。 作为一个大一新生&#xff0c;我从1级的编程小白到了现在的2级编程小白。在7月份之前我可以说是完全不了解编程的一位新人&#xff0c;对应电脑的了解也就只会打游戏看电视和浏…

外贸企业为何要选择Yandex推广?

Yandex作为俄罗斯最大的搜索引擎&#xff0c;对于外贸企业的推广具有不可忽视的重要意义。随着全球市场的不断扩大和互联网的普及&#xff0c;越来越多的外贸企业开始将目光投向俄罗斯市场。而Yandex作为俄罗斯本土的搜索引擎巨头&#xff0c;拥有庞大的用户群体和广泛的市场覆…

Qt QCheckBox复选按钮控件

文章目录 1 属性和方法1.1 文本1.2 三态1.3 自动排他1.4 信号和槽 2 实例2.1 布局2.2 代码实现 Qt中的复选按钮类是QCheckBox它和单选按钮很相似&#xff0c;单选按钮常用在“多选一”的场景&#xff0c;而复选按钮常用在"多选多"的场景比如喜欢的水果选项中&#xf…

暴雨信息发布算力网络应用平台打造零感知算网服务新模式

为进一步优化算力网络应用服务能力和降低算力网络使用难度&#xff0c;暴雨信息突破基于算力网络的实例跨域协同与迁移、基于测试评估的应用度量和解构等技术&#xff0c;研发并推出算力网络应用平台。该系统通过提供一种即开即用、按需付费的零感知算网应用服务&#xff0c;使…