jdbc mysql事务

基础概念

JDBC（Java Database Connectivity）是Java语言中用于连接和操作数据库的标准API。MySQL是一种流行的关系型数据库管理系统。事务是数据库操作的基本单位，它确保一组数据库操作要么全部成功，要么全部失败，从而保持数据的一致性和完整性。

事务的优势

原子性：事务中的所有操作要么全部完成，要么全部不完成。
一致性：事务执行前后，数据库必须处于一致状态。
隔离性：多个事务并发执行时，彼此之间互不干扰。
持久性：一旦事务提交，其结果就是永久的，即使系统崩溃也不会丢失。

事务的类型

自动提交事务：默认情况下，每个SQL语句都是一个独立的事务，执行完毕后自动提交。
显式事务：通过BEGIN TRANSACTION、COMMIT和ROLLBACK语句显式地控制事务的开始、提交和回滚。

应用场景

事务广泛应用于需要保证数据一致性的场景，如银行转账、订单处理、库存管理等。

示例代码

以下是一个使用JDBC进行MySQL事务处理的示例代码：

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

public class JDBCTransactionExample {
    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 {
            // 连接数据库
            conn = DriverManager.getConnection(url, user, password);
            // 关闭自动提交，开启事务
            conn.setAutoCommit(false);

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

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

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