トランザクション処理

 トランザクション処理を行うにはPDOクラスのメソッドを使います。トランザクション処理は次の手順で行います。

  1. PDOオブジェクトを生成して、データベースに接続する
  2. PDOオブジェクトのbeginTransactionメソッドでトランザクションを開始する
  3. SQLコマンドを実行する
  4. 確定(commit)するか、取り消し(rollBack)をする
  5. データベースを切断する

■ rollBackメソッドで取り消す

クラス名 PDO
メソッド名 rollBack
概要 トランザクションをロールバックする
パラメーターリスト
パラメター名 説明
void -
返り値
bool 成功した場合はTRUE、失敗した場合はFALSEを返す
rollBackメソッドの仕様

○ ファイル

 「ExecInsertTest.php」ファイルをコピーして、次のPHPファイルをプロジェクトに追加してください。

ファイルの種類 PHPファイル
ファイル名 ExecTransactionTest.php

サンプルダウンロード

○ プログラム

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

ExecTransactionTest.php

  1. <html lang="ja">
  2.  <meta charset="utf-8">
  3.  <head>
  4.   <title>INSERT文実行</title>
  5.  </head>
  6.  <body>
  7. <?php
  8. //検証用のフラグ
  9. $errorflag = true; //true:エラー発生 false:正常
  10. try{
  11.  //データベースに接続する
  12.  $pdo = new PDO('mysql:host=' . $host . ';dbname=' . $dbname .';charset=utf8;',
  13.   $username,
  14.   $password);
  15.  //トランザクションを開始する
  16.  $pdo -> beginTransaction();
  17.  //SQL文を実行する
  18.  $result = $pdo -> query('SELECT * FROM users;');
  19.  //データを取得する
  20.  print('追加前*****');
  21.  while($row = $result -> fetchObject('User')){
  22.   var_dump($row);
  23.  }
  24.  //データを追加する
  25.  $ret = $pdo -> exec('INSERT INTO users VALUES("004", "tanaka", "tpass", "田中");');
  26.  //検証用のフラグをもとに確定か取り消しをする
  27.  if($errorflag){ //エラーとする場合
  28.   $pdo -> rollBack();
  29.  }else{ //正常とする場合
  30.   $pdo -> commit();
  31.  }
  32.  //追加後のデータを取得する
  33.  $result = $pdo -> query('SELECT * FROM users;');
  34.  //データを取得する
  35.  print('<hr>追加後*****');
  36.  while($row = $result -> fetchObject('User')){
  37.   var_dump($row);
  38.  }
  39. }catch(PDOException $e){

○ 実行結果

実行結果
実行結果

○ 解説

 19行目の「$errorflag」変数は、今回のサンプルでデータベースを使った処理が正常に進んだ場合(false)と、処理の途中で異常が見つかった場合(true)をシミュレートするための変数です。今回のファイルでは「true」がセットされているので、エラーが起きたと仮定して処理をさせます。

 43~47行目では、$errorflag変数の内容に応じて呼び出すメソッドを切り替えます。今回のファイルはエラーの状態を表しているので、44行目の「rollBack」メソッドが実行されます。そのため、55行目の追加後のデータの一覧を確認すると、データが追加されていないことを確認できます。

■ commitメソッドで確定する

クラス名 PDO
メソッド名 commit
概要 トランザクションをコミットする
パラメーターリスト
パラメター名 説明
void -
返り値
bool 成功した場合はTRUE、失敗した場合はFALSEを返す
commitメソッドの仕様

○ ファイル

 「ExecTransactionTest.php」ファイルをコピーして、次のPHPファイルをプロジェクトに追加してください。

ファイルの種類 PHPファイル
ファイル名 ExecTransactionTest2.php

サンプルダウンロード

○ プログラム

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

ExecTransactionTest2.php

  1. <?php
  2. //検証用のフラグ
  3. $errorflag = false; //true:エラー発生 false:正常
  4. try{

○ 実行結果

実行結果
実行結果

○ 解説

 19行目の「$errorflag」変数を「false」にセットしました。今回のファイルでは正常に処理が進んだと仮定して処理をさせます。

 43~47行目の処理では46行目の「commit」メソッドが実行されます。そのため、55行目の追加後のデータの一覧を確認すると、データが追加されていることを確認できます。

前へ   次へ