トランザクション処理

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

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

　トランザクション処理を行うにはConnectionクラスとCommandクラスを使います。トランザクション処理は次の手順で行います。

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

○　プロジェクト

　プロジェクトを作成して確認してみましょう。

プロジェクト名 TransactionTest

サンプルダウンロード

○　作成の準備

　StatementTestプロジェクトをコピーして作成してください。

○　プログラム

　mainメソッドを次のように記述してください。

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

○　実行結果

登録するユーザー情報を入力してください。 ID：5
ユーザー名：itou
パスワード：ipass
氏名：伊藤
変更のあった件数：1
1)確定 2)取消し(デフォルト)：2
取り消しました。

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

登録するユーザー情報を入力してください。 ID：5
ユーザー名：itou
パスワード：ipass
氏名：伊藤
変更のあった件数：1
1)確定 2)取消し(デフォルト)：1
確定しました。

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

○　解説

　30行目で自動コミット機能をオフにしています。これにより、SQL文を実行するとトランザクションモードで実行され、すぐには確定されなくなります。

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

前へ   次へ