トランザクションおよび自動コミット

さあ、PDO を使用してデータベースに接続することができました。クエリを発行する前に、PDO がトランザクションをどのように扱うのかを理解しなければなりません。トランザクションについてよくわからない方のために説明すると、これは以下の 4 つの機能、つまり原子性 - Atomicity、一貫性 - Consistency、独立性 - Isolation および永続性 - Durability (ACID) を提供するものです。一般的な言葉で言うと、トランザクション内で実行された作業はたとえ段階的に行われたものであってもデータベースに安全に反映されることが保証されています。トランザクションのコミット時に他の接続の干渉を受けることはありません。また、トランザクション内での作業は (まだコミットされていなければ) いつでも自動的に取り消すことができます。これにより、スクリプト内でのエラー処理がより楽になります。

トランザクションの一般的な実装は、変更内容を一時的に「蓄えて」おき、それを一気に適用するようになっています。この実装には、更新処理の性能を劇的に向上させるという効果もあります。つまり、トランザクションによってあなたの書くスクリプトはより高速になり、また、より堅牢になるということです (これらの恩恵をうけるためには、トランザクションを正しく使用する必要があります)。

残念ながら、すべてのデータベースがトランザクションをサポートしているというわけではありません。そのため、PDO で最初に接続をオープンした際には、いわゆる「自動コミット」モードで動作します。自動コミットモードとは、もしデータベースがトランザクションをサポートしていたら個々のクエリが暗黙的なトランザクションのもとで実行され、サポートしていなかったらトランザクションを使用せずに実行されることを意味します。トランザクションを使用する場合は、 PDO::beginTransaction() メソッドを使用してトランザクションを初期化する必要があります。使用しているドライバがトランザクションをサポートしていない場合は PDOException がスローされます (これは深刻な状態であるため、エラー処理の設定にかかわらず常にスローされます)。初期化した後でトランザクションを終了させるには、トランザクション内でのコードが成功したか否かに応じて PDO::commit() あるいは PDO::rollBack() を使用します。

警告

PDO は、トランザクション機能をドライバレベルでしかチェックしません。実行時に何らかの条件でトランザクションが使えない場合でも、データベースサーバがトランザクション開始要求を受け付けた場合には PDO::beginTransaction() は TRUE を返します。エラーとはなりません。

たとえば、MySQL データベースの MyISAM テーブルでトランザクションを使おうとした場合にこの現象が発生します。

スクリプトが終了したり接続が閉じられようとした際に、もし処理が完了していないトランザクションがあれば PDO が自動的にロールバックします。これは、スクリプトが予期せぬ状態で終了した場合にデータの不整合が発生するのを避けるための安全装置です。もし明示的にコミットしていなければ、おそらく何かおかしなことが起こったのだろうと推測されます。そのため、データを守るためにロールバックが行われるのです。

警告

自動的にロールバックが行われるのは、トランザクションを PDO::beginTransaction() で開始した場合のみです。トランザクションを開始するクエリを手動で発行した場合、 PDO はそれを知ることができません。そのため、何か問題が発生してもロールバックすることはできないのです。

例6 トランザクション内で一括処理を行う

以下の例では、新しい従業員のデータを作成しているものとします。この従業員には ID 番号 23 を割り当てます。この人物についての基礎データを入力するだけでなく、その給与についても登録する必要があります。以下では単純に 2 つの別々の更新を行っていますが、それらは PDO::beginTransaction() および PDO::commit() のコールで囲まれています。これにより、変更が完了するまでは他からは一切変更内容が見えないことが保証されます。もし何か問題が発生すれば、 catch ブロック内でトランザクション開始以降のすべての変更がロールバックされます。そしてエラーメッセージを表示します。


<?php
try {
  $dbh = new PDO('odbc:SAMPLE', 'db2inst1', 'ibmdb2', 
      array(PDO::ATTR_PERSISTENT => true));
  echo "接続しました\n";
} catch (Exception $e) {
  die("接続できません: " . $e->getMessage());
}

try {  
  $dbh->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);

  $dbh->beginTransaction();
  $dbh->exec("insert into staff (id, first, last) values (23, 'Joe', 'Bloggs')");
  $dbh->exec("insert into salarychange (id, amount, changedate) 
      values (23, 50000, NOW())");
  $dbh->commit();
  
} catch (Exception $e) {
  $dbh->rollBack();
  echo "失敗しました。" . $e->getMessage();
}
?>

トランザクション内で行える処理は、更新には限りません。たとえば何か複雑なクエリを発行してデータを抽出し、その情報をもとにデータの更新をしたり別のクエリを実行したりすることも可能です。トランザクションがアクティブな間は、作業中のデータについては他から一切変更が加えられないことが保証されます。トランザクションについての詳細は、使用するデータベースサーバのドキュメントを参照ください。