当前位置：首页 > ds >正文

MySQL——事务

ds 2025/7/19 4:48:06

一、什么是事务？

事务（Transaction） 是数据库操作的最小逻辑单元，它由一组不可分割的SQL操作组成。事务的核心目标是确保多个操作要么全部成功，要么全部失败，从而维护数据的完整性。例如，银行转账场景中，张三给李四转账1000元，必须同时完成“张三账户减1000”和“李四账户加1000”两个操作，否则就会导致数据不一致。

二、事务的四大特性（ACID）

特性	说明	示例
原子性	事务中的操作要么全部成功，要么全部回滚	转账时，张三扣款失败则李四加款也回滚
一致性	事务执行前后数据库状态保持一致	转账前后，张三和李四的总金额保持不变
隔离性	并发事务之间互不干扰	A事务转账时，B事务查询到的余额不受未提交的转账影响
持久性	事务提交后，数据永久保存到数据库	转账成功后即使系统宕机，数据也不会丢失

三、事务操作：手动控制与自动提交

1. 默认行为：自动提交

MySQL默认开启自动提交（autocommit=1），每条SQL语句独立为一个事务，执行后立即提交。

-- 查看当前提交模式
SELECT @@autocommit;  -- 返回1表示自动提交

2. 手动控制事务

通过以下命令显式控制事务流程：

-- 开启事务
START TRANSACTION;-- 执行操作（如转账）
UPDATE account SET money = money - 1000 WHERE name = '张三';
UPDATE account SET money = money + 1000 WHERE name = '李四';-- 提交事务（持久化更改）
COMMIT;-- 回滚事务（撤销所有操作）
ROLLBACK;

四、事务中的错误处理

1. 使用`SIGNAL`抛出异常

在存储过程中，可通过SIGNAL主动触发错误并回滚：

DELIMITER $$
CREATE PROCEDURE transfer()
BEGINDECLARE EXIT HANDLER FOR SQLEXCEPTION ROLLBACK; -- 异常时回滚START TRANSACTION;-- 检查余额IF (SELECT money FROM account WHERE name='张三') < 1000 THENSIGNAL SQLSTATE '45000' SET MESSAGE_TEXT = '余额不足';END IF;-- 执行转账UPDATE account SET money = money - 1000 WHERE name = '张三';UPDATE account SET money = money + 1000 WHERE name = '李四';COMMIT;
END $$
DELIMITER ;

2. 使用`ROW_COUNT()`验证操作

通过检查受影响行数判断操作是否成功：

START TRANSACTION;
-- 扣款操作
UPDATE account SET money = money - 1000 WHERE name = '张三' AND money >= 1000;
IF ROW_COUNT() = 0 THENROLLBACK;
ELSECOMMIT;
END IF;

五、存储过程与触发器中的事务

1. 存储过程的事务控制

存储过程可显式管理事务，适合复杂业务逻辑：

DELIMITER $$
CREATE PROCEDURE transfer_funds(IN from_id INT, IN to_id INT, IN amount DECIMAL)
BEGINDECLARE EXIT HANDLER FOR SQLEXCEPTION ROLLBACK;START TRANSACTION;-- 扣款UPDATE account SET money = money - amount WHERE id = from_id;-- 加款UPDATE account SET money = money + amount WHERE id = to_id;COMMIT;
END $$
DELIMITER ;

2. 触发器与事务的关系

触发器不能显式控制事务，但错误会触发外层事务回滚。
示例：禁止账户余额为负

CREATE TRIGGER check_balance
BEFORE UPDATE ON account
FOR EACH ROW
BEGINIF NEW.money < 0 THENSIGNAL SQLSTATE '45000' SET MESSAGE_TEXT = '余额不能为负';END IF;
END;

六、实战案例：转账事务的完整实现

1. 数据准备

CREATE TABLE account (id INT PRIMARY KEY AUTO_INCREMENT,name VARCHAR(20),money DECIMAL(10,2)
);
INSERT INTO account (name, money) VALUES ('张三', 2000), ('李四', 2000);

2. 实现转账逻辑

DELIMITER $$
CREATE PROCEDURE secure_transfer(IN from_name VARCHAR(20),IN to_name VARCHAR(20),IN amount DECIMAL(10,2)
)
BEGINDECLARE EXIT HANDLER FOR SQLEXCEPTION ROLLBACK;START TRANSACTION;-- 检查余额IF (SELECT money FROM account WHERE name = from_name) < amount THENSIGNAL SQLSTATE '45000' SET MESSAGE_TEXT = '余额不足';END IF;-- 执行转账UPDATE account SET money = money - amount WHERE name = from_name;UPDATE account SET money = money + amount WHERE name = to_name;COMMIT;
END $$
DELIMITER ;-- 调用示例
CALL secure_transfer('张三', '李四', 1000);