自動コミット設定とロールバックの使い方

package dbsample;

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:oracle:thin:@localhost:1521:dbName";
        String user = "yourUsername"; // データベースのユーザー名
        String password = "yourPassword"; // データベースのパスワード

        // データベース接続とSQL実行のためのオブジェクト
        Connection conn = null;
        PreparedStatement insertStmt = null;
        PreparedStatement updateStmt = null;

        try {
            // データベースに接続
            conn = DriverManager.getConnection(url, user, password);

            // 自動コミットを無効にして、手動でコミット/ロールバックできるように設定
            conn.setAutoCommit(false);

            // INSERT文の準備
            String insertSql = "INSERT INTO STOCK_TABLE (ID, ITEM_NO, COUNT, UPDATE_TIME) " +
                               "VALUES (?, ?, ?, SYSDATE)";
            insertStmt = conn.prepareStatement(insertSql);
            insertStmt.setInt(1, 101);           // ID（ユニークな値を設定）
            insertStmt.setInt(2, 5);             // ITEM_NO
            insertStmt.setInt(3, 20);            // COUNT

            // UPDATE文の準備
            String updateSql = "UPDATE STOCK_TABLE SET COUNT = COUNT + ? WHERE ITEM_NO = ?";
            updateStmt = conn.prepareStatement(updateSql);
            updateStmt.setInt(1, 5);             // COUNTを増加
            updateStmt.setInt(2, 5);             // 対象のITEM_NO

            // SQL操作を実行
            insertStmt.executeUpdate(); // INSERT操作
            updateStmt.executeUpdate(); // UPDATE操作

            // すべての操作が成功した場合のみコミット
            conn.commit();
            System.out.println("トランザクションが正常にコミットされました。");

        } catch (SQLException e) {
            // エラーが発生した場合はロールバック
            try {
                if (conn != null) {
                    conn.rollback();
                    System.out.println("エラーが発生したため、ロールバックが実行されました。");
                }
            } catch (SQLException rollbackEx) {
                rollbackEx.printStackTrace();
            }
            e.printStackTrace();
        } finally {
            // リソースの解放
            try {
                if (insertStmt != null) insertStmt.close();
                if (updateStmt != null) updateStmt.close();
                if (conn != null) {
                    conn.setAutoCommit(true); // 自動コミットを元に戻す
                    conn.close();
                }
            } catch (SQLException closeEx) {
                closeEx.printStackTrace();
            }
        }
    }
}

// 自動コミットを無効にする
conn.setAutoCommit(false);

// 自動コミットを有効にする（デフォルトの設定）
conn.setAutoCommit(true);

try {
    conn.setAutoCommit(false); // 自動コミットを無効にする

    // 複数のSQL操作
    stmt1.executeUpdate(); // INSERT
    stmt2.executeUpdate(); // UPDATE

    conn.commit(); // すべての操作が成功したらコミット（確定）

} catch (SQLException e) {
    conn.rollback(); // エラーが発生したらロールバック
    e.printStackTrace();
} finally {
    conn.setAutoCommit(true); // 最後に自動コミットを有効に戻す
}

try {
    conn.setAutoCommit(false);

    stmt1.executeUpdate(); // INSERT
    conn.commit(); // ここで一旦コミットすることでstmt1の結果は確定

    stmt2.executeUpdate(); // UPDATE
    stmt3.executeUpdate(); // DELETE

    conn.commit(); // stmt2とstmt3が成功した場合のみ、再度コミット

} catch (SQLException e) {
    conn.rollback(); // 最後のコミット以降の操作をロールバック
    e.printStackTrace();
}