トランザクション

<?php
// まずプログラムの最初に、$mdb2 という名前の
// MDB2 オブジェクトを作成します
require_once 'MDB2.php';

$mdb2 =& MDB2::connect('pgsql://usr:pw@localhost/dbnam');
if (PEAR::isError($mdb2)) {
    die($mdb2->getMessage());
}

// このドライバでトランザクションがサポートされているかどうかを調べます
if (!$mdb2->supports('transactions')) {
    exit();
}

// トランザクションをオープンします
$res = $mdb2->beginTransaction();

..

// トランザクション処理中かどうか、そして
// セーブポイントがサポートされているかどうかを調べます
if ($mdb2->inTransaction() && $mdb2->supports('savepoints')) {
    // セーブポイントを設定します
    $savepoint = 'MYSAVEPOINT';
    $res = $mdb2->beginTransaction($savepoint);

    ..

    // セーブポイントを開放するか、そこまでロールバックするかを判断します
    if ($error_condition) {
        $res = $mdb2->rollback($savepoint);
    } else {
        $res = $mdb2->commit($savepoint);
    }
}

..

// コミットするかロールバックするかを判断します
if ($error_condition) {
    $res = $mdb2->rollback();
} else {
    $res = $mdb2->commit();
}

?>

<?php

$mdb2->beginNestedTransaction(); # トランザクションをオープンします

$query = "INSERT INTO autoinc (id) VALUES (?)";
$stmt = $mdb2->prepare($query);

$stmt->execute(array(1));

$savepoint = $mdb2->beginNestedTransaction(); # 無視されます / セーブポイントを設定します

..

// この例では決して true にはなりません
if (false) {
    // エラーを発生させます
    $error = $mdb2->raiseError(MDB2_ERROR, null, null, 'kaboom');
    $mdb2->failNestedTransaction();
}

if(($error = $mdb2->getNestedTransactionError())) {
    die($error->getUserinfo());
}

$mdb2->completeNestedTransaction(); # 無視されます / セーブポイントを開放します

$stmt->execute(array(2));

$mdb2->completeNestedTransaction(); # コミットします

?>

<?php

$options = array('wait' => 'WAIT', 'rw' => 'READ WRITE');
$options = array('wait' => 'NO WAIT', 'rw' => 'READ ONLY');

$isolation_level = READ UNCOMMITTED # (ダーティリードを許可します)
$isolation_level = READ COMMITTED # (ダーティリードを防ぎます)
$isolation_level = REPEATABLE READ # (再読み込み不可能な読み込みを防ぎます)
$isolation_level = SERIALIZABLE # (ファントムリードを防ぎます)
$mdb2->setTransactionIsolation($isolation_level, $options);

?>