Java – MYSQLを使ったデータベースのトランザクション処理

<dependency>
    <groupId>mysql</groupId>
    <artifactId>mysql-connector-java</artifactId>
    <version>8.0.30</version> <!-- 最新のバージョンを確認してください -->
</dependency>

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.SQLException;
public class App {
    public static void main(String[] args) {
        // データベース接続情報
        String url = "jdbc:mysql://localhost:3306/your_database"; // データベース名を指定
        String user = "your_username"; // ユーザー名を指定
        String password = "your_password"; // パスワードを指定
        Connection connection = null;
        try {
            // データベース接続の確立
            connection = DriverManager.getConnection(url, user, password);
            
            // 自動コミットを無効にする
            connection.setAutoCommit(false);
            // SQL文の準備
            String sql1 = "INSERT INTO accounts (name, balance) VALUES (?, ?)";
            String sql2 = "UPDATE accounts SET balance = balance - ? WHERE name = ?";
            try (PreparedStatement pstmt1 = connection.prepareStatement(sql1);
                 PreparedStatement pstmt2 = connection.prepareStatement(sql2)) {
                
                // トランザクション内の操作
                pstmt1.setString(1, "Alice");
                pstmt1.setDouble(2, 1000.0);
                pstmt1.executeUpdate();
                pstmt2.setDouble(1, 200.0);
                pstmt2.setString(2, "Bob");
                pstmt2.executeUpdate();
                // コミット
                connection.commit();
                System.out.println("トランザクションが成功しました。");
            } catch (SQLException e) {
                // エラーが発生した場合はロールバック
                connection.rollback();
                System.out.println("トランザクションが失敗しました。ロールバックしました。");
                e.printStackTrace();
            }
        } catch (SQLException e) {
            e.printStackTrace();
        } finally {
            // 接続を閉じる
            if (connection != null) {
                try {
                    connection.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }
        }
    }
}

トランザクションが成功しました。

トランザクションが失敗しました。ロールバックしました。

CREATE TABLE accounts (
    id INT AUTO_INCREMENT PRIMARY KEY,
    name VARCHAR(50) NOT NULL,
    balance DECIMAL(10, 2) NOT NULL
);
INSERT INTO accounts (name, balance) VALUES ('Alice', 1000.00);
INSERT INTO accounts (name, balance) VALUES ('Bob', 500.00);

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.SQLException;
public class App {
    public static void main(String[] args) {
        // データベース接続情報
        String url = "jdbc:mysql://localhost:3306/your_database"; // データベース名を指定
        String user = "your_username"; // ユーザー名を指定
        String password = "your_password"; // パスワードを指定
        Connection connection = null;
        try {
            // データベース接続の確立
            connection = DriverManager.getConnection(url, user, password);
            
            // 自動コミットを無効にする
            connection.setAutoCommit(false);
            // SQL文の準備
            String sqlWithdraw = "UPDATE accounts SET balance = balance - ? WHERE name = ?";
            String sqlDeposit = "UPDATE accounts SET balance = balance + ? WHERE name = ?";
            try (PreparedStatement pstmtWithdraw = connection.prepareStatement(sqlWithdraw);
                 PreparedStatement pstmtDeposit = connection.prepareStatement(sqlDeposit)) {
                
                // 送金処理
                double amount = 200.00; // 送金額
                String sender = "Alice"; // 送金元
                String receiver = "Bob"; // 送金先
                // 送金元からの引き落とし
                pstmtWithdraw.setDouble(1, amount);
                pstmtWithdraw.setString(2, sender);
                pstmtWithdraw.executeUpdate();
                // 送金先への加算
                pstmtDeposit.setDouble(1, amount);
                pstmtDeposit.setString(2, receiver);
                pstmtDeposit.executeUpdate();
                // コミット
                connection.commit();
                System.out.println("送金処理が成功しました。");
            } catch (SQLException e) {
                // エラーが発生した場合はロールバック
                connection.rollback();
                System.out.println("送金処理が失敗しました。ロールバックしました。");
                e.printStackTrace();
            }
        } catch (SQLException e) {
            e.printStackTrace();
        } finally {
            // 接続を閉じる
            if (connection != null) {
                try {
                    connection.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }
        }
    }
}

送金処理が成功しました。

送金処理が失敗しました。ロールバックしました。