トランザクション処理

トランザクションは、データベースに対する複数の更新を一つの処理として扱う単位です。もし複数の更新処理のうち、一つでも失敗したら更新前の状態に戻し、すべての更新処理が成功したら確定することができます。

Javaプログラムからデータベースを操作するときに、既定の設定では自動的確定するようになっているので、トランザクション処理をする場合はその機能をオフにする必要があります。その後、データベースに対する処理を行ない、成功したらコミット(確定)、失敗したらロールバック(取り消し)の指定をします。

トランザクション処理を行うにはConnectionオブジェクトを使います。トランザクション処理は次の手順で行います。

1． データベースに接続する
2． ConnectionオブジェクトのsetAutoCommitメソッドで自動コミット機能をオフにする
3． SQLコマンドを実行する
4． 確定(Commit)するか、取り消し(Rollback)をする
5． データベースを切断する

○　ファイル

StatementTest.javaファイルをコピーして、次のファイルを作成してください。

ファイル名 TransactionTest.java

サンプルダウンロード

○　プログラム

次のようにプログラムを入力してください。

TransactionTest.java

  1. import java.io.BufferedReader;
  2. import java.io.InputStreamReader;
  3. import java.sql.Connection;
  4. import java.sql.DriverManager;
  5. import java.sql.Statement;
  7. public class TransactionTest{
  8.     public static void main(String[] args){
  9.         try{
  10.             //JDBCドライバークラスを指定する
  11.             String drivername = "com.mysql.cj.jdbc.Driver";
  13.             //データベースを指定する
  14.             String url = "jdbc:mysql://localhost:3306/books? characterEncoding=utf8";
  16.             //ユーザー名を指定する
  17.             String username = "root";
  19.             //パスワードを指定する
  20.             String password = "";
  22.             //指定したドライバークラスを読み込む
  23.             Class.forName(drivername);
  25.             //データベースに接続する
  26.             Connection con = DriverManager.getConnection(url, username, password);
  28.             //自動コミットをオフにする
  29.             con.setAutoCommit(false);
  31.             //追加する情報を入力する
  32.             BufferedReader br = new BufferedReader(new InputStreamReader(System.in));
  33.             System.out.println("登録するユーザー情報を入力してください。");
  34.             System.out.print("ID：");
  35.             int id = Integer.parseInt(br.readLine());
  36.             System.out.print("ユーザー名：");
  37.             String uname = br.readLine();
  38.             System.out.print("パスワード：");
  39.             String passwd = br.readLine();
  40.             System.out.print("氏名：");
  41.             String name = br.readLine();
  43.             //入力した情報をもとにSQL文を作成する
  44.             String sql = "INSERT INTO Users VALUES(" + id + ", '" + uname + "', '" + passwd + "', '" + name + "')";
  46.             //Statementオブジェクトを取得する
  47.             Statement st = con.createStatement();
  49.             //SQL文を実行する
  50.             int ret = st.executeUpdate(sql);
  52.             //変更のあった行数を表示する
  53.             System.out.println("変更のあった件数：" + ret);
  55.             //確定か取り消しを入力する
  56.             System.out.print("1)確定 2)取り消し(デフォルト)：");
  57.             String input = br.readLine();
  59.             switch(input){
  60.                 case "1":
  61.                     //確定
  62.                     con.commit();
  63.                     System.out.println("確定しました。");
  64.                     break;
  65.                 default:
  66.                     con.rollback();
  67.                     System.out.println("取り消しました。");
  68.                     break;
  69.             }
  71.             //データベースを切断する
  72.             st.close();
  73.             con.close();
  74.         }catch(Exception e){
  75.             //例外の状態を出力する
  76.             e.printStackTrace();
  77.         }
  78.     }
  79. }

○　コンパイルと実行

C:¥work>javac　TransactionTest.java
C:¥work>java　-cp　mysql-connector-java-8.0.22.jar;.　TransactionTest
登録するユーザー情報を入力してください。
ID：5
ユーザー名：itou
パスワード：ipass
氏名：伊藤
変更のあった件数：1
1)確定 2)取り消し(デフォルト)：2
取り消しました。

C:¥work>

usersテーブルに追加されていない
usersテーブルに追加されていない

○　実行

C:¥work>java　-cp　mysql-connector-java-8.0.22.jar;.　TransactionTest
登録するユーザー情報を入力してください。
ID：5
ユーザー名：itou
パスワード：ipass
氏名：伊藤
変更のあった件数：1
1)確定 2)取り消し(デフォルト)：1
確定しました。

C:¥work>

usersテーブルに追加された
usersテーブルに追加された

○　解説

29行目で、setAutoCommitメソッドの引数に「false」を指定することで、自動コミット機能をオフにしています。これにより、SQL文を実行するとトランザクションモードで実行され、すぐには確定されなくなります。

59行目から、確定するか、取り消すかの処理が行われます。もし確定する場合は62行目にあるように、Connectionオブジェクトのcommitメソッドを呼び出して確定します。これによりデータベース上の変更が確定され、データベースに反映されます。取り消す場合は66行目にあるようにConnectionオブジェクトのrollbackメソッドを呼び出して取り消します。これによりデータベース上の変更が破棄され、SQL文実行前の状態に戻ります。

今回は、SQL文実行後に確定するか、取り消すかの選択により、commitメソッド、rollbackメソッドを呼び出しましたが、ほかにも、複数のデータベース更新処理をtryブロックに記述し、その中で例外がスローされた場合に、その時点までのデータベース処理を取り消すために、catchブロックに取消処理を書くことができます。

前へ   次へ