在MySQL的实际业务开发中，事务能够将多个数据库操作绑定为一个原子性的执行单元，要么全部执行成功，要么全部失败回滚，避免出现部分操作生效导致的数据不一致问题。当事务执行过程中出现SQL错误、约束冲突等异常情况时，需要通过合理的异常处理机制触发回滚操作，而try-catch结构与rollback机制的配合是实现这一需求的核心方案。
MySQL事务与回滚的基础概念
MySQL的事务遵循ACID特性，其中原子性要求事务中的所有操作要么全部完成，要么全部不完成。当事务执行过程中出现异常时，就需要调用rollback语句将事务中已经执行的操作全部撤销，恢复到事务开始前的状态。
默认情况下，MySQL的autocommit参数是开启的，每条SQL语句都会自动提交为一个独立的事务。如果要使用多语句事务，需要先关闭autocommit，或者显式使用START TRANSACTION开启事务。
不同场景下的异常回滚实现
存储过程中的try-catch与rollback
MySQL的存储过程支持DECLARE HANDLER语法来捕获异常，相当于其他语言中的try-catch机制，结合rollback可以实现异常回滚。以下是一个转账业务的示例：
DELIMITER //
CREATE PROCEDURE transfer_funds(
IN from_account INT,
IN to_account INT,
IN amount DECIMAL(10,2)
)
BEGIN
-- 声明异常处理器，捕获所有SQLEXCEPTION
DECLARE EXIT HANDLER FOR SQLEXCEPTION
BEGIN
-- 出现异常时回滚事务
ROLLBACK;
-- 抛出自定义错误信息
RESIGNAL SET MESSAGE_TEXT = '转账操作异常，事务已回滚';
END;
-- 开启事务
START TRANSACTION;
-- 扣除转出账户金额
UPDATE account SET balance = balance - amount WHERE id = from_account;
-- 检查转出账户余额是否充足
IF (SELECT balance FROM account WHERE id = from_account) < 0 THEN
-- 余额不足时主动抛出异常触发回滚
SIGNAL SQLSTATE '45000' SET MESSAGE_TEXT = '转出账户余额不足';
END IF;
-- 增加转入账户金额
UPDATE account SET balance = balance + amount WHERE id = to_account;
-- 所有操作正常则提交事务
COMMIT;
END //
DELIMITER ;
上述存储过程中，DECLARE EXIT HANDLER FOR SQLEXCEPTION相当于try-catch的异常捕获部分，当SQL执行出现异常时，会进入处理器执行ROLLBACK操作。同时也可以通过SIGNAL语句主动抛出异常，触发回滚逻辑。
应用程序中的try-catch与rollback
在实际开发中，更多是在应用程序层面通过try-catch捕获异常，然后调用rollback回滚事务。以下是Java语言使用JDBC连接MySQL的示例：
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.SQLException;
public class MySQLTransactionDemo {
private static final String URL = "jdbc:mysql://127.0.0.1:3306/test_db?useSSL=false";
private static final String USER = "root";
private static final String PASSWORD = "123456";
public static void main(String[] args) {
Connection conn = null;
PreparedStatement ps1 = null;
PreparedStatement ps2 = null;
try {
// 获取数据库连接
conn = DriverManager.getConnection(URL, USER, PASSWORD);
// 关闭自动提交，开启事务
conn.setAutoCommit(false);
// 执行第一个更新操作
String sql1 = "UPDATE account SET balance = balance - 100 WHERE id = 1";
ps1 = conn.prepareStatement(sql1);
ps1.executeUpdate();
// 模拟异常场景，比如这里主动抛出一个运行时异常
// int error = 1 / 0;
// 执行第二个更新操作
String sql2 = "UPDATE account SET balance = balance + 100 WHERE id = 2";
ps2 = conn.prepareStatement(sql2);
ps2.executeUpdate();
// 所有操作正常，提交事务
conn.commit();
System.out.println("事务提交成功");
} catch (Exception e) {
// 捕获异常，回滚事务
try {
if (conn != null) {
conn.rollback();
System.out.println("事务回滚成功，异常信息：" + e.getMessage());
}
} catch (SQLException rollbackEx) {
rollbackEx.printStackTrace();
}
} finally {
// 关闭资源
try {
if (ps1 != null) ps1.close();
if (ps2 != null) ps2.close();
if (conn != null) {
conn.setAutoCommit(true);
conn.close();
}
} catch (SQLException closeEx) {
closeEx.printStackTrace();
}
}
}
}
上述Java代码中，通过try块包裹所有事务操作，catch块捕获执行过程中的所有异常，在catch块中调用conn.rollback()实现事务回滚。需要注意的是，回滚前要确保连接对象不为空，且回滚操作本身也可能抛出SQL异常，需要做二次异常处理。
异常回滚的注意事项
- 事务回滚只对未提交的操作有效，一旦事务提交，就无法再回滚。
- 部分存储引擎不支持事务，比如MyISAM，使用回滚机制前需要确认表的存储引擎是InnoDB。
- 在存储过程中，除了SQLEXCEPTION，还可以针对特定的SQLSTATE或者错误码定义处理器，实现更细粒度的异常处理。
- 应用程序中捕获异常后，除了回滚事务，还需要根据业务需求记录异常日志或者返回友好的错误提示给调用方。
常见问题解答
事务中部分SQL成功部分失败会回滚吗
如果开启了事务且没有提交，当其中一条SQL执行失败时，只要触发了rollback机制，所有已经执行的SQL操作都会被回滚，不会出现部分生效的情况。
主动抛出异常能触发回滚吗
在存储过程中通过SIGNAL语句主动抛出的异常会被DECLARE HANDLER捕获，进而触发rollback操作。在应用程序中主动抛出的异常如果没有被捕获，事务不会自动回滚，需要显式调用rollback方法。
| 场景 | 异常捕获方式 | 回滚触发方式 |
|---|---|---|
| MySQL存储过程 | DECLARE HANDLER FOR SQLEXCEPTION | 在处理器中执行ROLLBACK语句 |
| Java应用层 | try-catch捕获Exception | 在catch块中调用Connection.rollback() |
| Python应用层 | try-except捕获pymysql.Error | 在except块中调用conn.rollback() |