java实现mysql事务回滚

基础概念

事务是数据库操作的基本单位，它确保一组数据库操作要么全部成功，要么全部失败。如果事务中的任何一条SQL语句执行失败，那么整个事务将被回滚到事务开始之前的状态。

优势

数据一致性：确保数据库在多个操作中保持一致状态。
数据完整性：防止因部分操作失败导致的数据不完整。
并发控制：通过事务隔离级别，减少并发操作带来的问题。

类型

MySQL支持以下几种事务隔离级别：

READ UNCOMMITTED
READ COMMITTED
REPEATABLE READ（MySQL默认）
SERIALIZABLE

应用场景

事务通常用于以下场景：

银行转账：确保从一个账户扣除金额和向另一个账户增加金额的操作是原子的。
订单处理：确保订单创建、库存更新和支付处理等操作要么全部成功，要么全部失败。

实现MySQL事务回滚的Java代码示例

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.SQLException;

public class TransactionExample {
    public static void main(String[] args) {
        String url = "jdbc:mysql://localhost:3306/mydatabase";
        String user = "username";
        String password = "password";

        Connection conn = null;
        PreparedStatement pstmt1 = null;
        PreparedStatement pstmt2 = null;

        try {
            // 1. 获取数据库连接
            conn = DriverManager.getConnection(url, user, password);

            // 2. 关闭自动提交，开启事务
            conn.setAutoCommit(false);

            // 3. 执行第一个SQL语句
            String sql1 = "UPDATE accounts SET balance = balance - 100 WHERE id = 1";
            pstmt1 = conn.prepareStatement(sql1);
            pstmt1.executeUpdate();

            // 4. 执行第二个SQL语句
            String sql2 = "UPDATE accounts SET balance = balance + 100 WHERE id = 2";
            pstmt2 = conn.prepareStatement(sql2);
            pstmt2.executeUpdate();

            // 5. 提交事务
            conn.commit();
            System.out.println("Transaction committed successfully.");

        } catch (SQLException e) {
            // 6. 发生异常，回滚事务
            if (conn != null) {
                try {
                    conn.rollback();
                    System.out.println("Transaction rolled back due to an error: " + e.getMessage());
                } catch (SQLException ex) {
                    ex.printStackTrace();
                }
            }
        } finally {
            // 7. 关闭资源
            try {
                if (pstmt1 != null) pstmt1.close();
                if (pstmt2 != null) pstmt2.close();
                if (conn != null) conn.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
    }
}

参考链接

常见问题及解决方法

事务未回滚：
- 原因：可能是由于没有正确捕获异常或者没有调用rollback方法。
- 解决方法：确保在catch块中调用conn.rollback()方法，并且捕获所有可能的异常。

事务隔离级别设置不当：
- 原因：不同的隔离级别可能导致不同的并发问题，如脏读、不可重复读和幻读。
- 解决方法：根据应用需求选择合适的隔离级别，例如使用conn.setTransactionIsolation(Connection.TRANSACTION_REPEATABLE_READ)。
资源未正确关闭：
- 原因：未正确关闭数据库连接和语句对象可能导致资源泄漏。
- 解决方法：在finally块中关闭所有资源，或者使用try-with-resources语句。