SQL見るだけクエリ#82 PHPPDOを使用してトランザクションを利用し、複数のデータベースへの接続

記入日：2023-03-31　編集日：2023-03-31

PHP PDOを使用してトランザクションを利用し、複数のデータベースへの接続

PDOを使用してトランザクションを利用し、複数のデータベースへの接続

以下がコードの例です。

// データベース接続情報
$db1_host = 'localhost';
$db1_name = 'database1';
$db1_user = 'user1';
$db1_pass = 'pass1';

$db2_host = 'localhost';
$db2_name = 'database2';
$db2_user = 'user2';
$db2_pass = 'pass2';

try {
    // データベース1への接続
    $db1 = new PDO("mysql:host=$db1_host;dbname=$db1_name", $db1_user, $db1_pass);
    $db1->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);

    // データベース2への接続
    $db2 = new PDO("mysql:host=$db2_host;dbname=$db2_name", $db2_user, $db2_pass);
    $db2->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);

    // トランザクション開始
    $db1->beginTransaction();
    $db2->beginTransaction();

    // データベース1の処理
    $stmt1 = $db1->prepare("INSERT INTO table1 (col1, col2) VALUES (?, ?)");
    $stmt1->execute(array('value1', 'value2'));

    // データベース2の処理
    $stmt2 = $db2->prepare("UPDATE table2 SET col1 = ? WHERE col2 = ?");
    $stmt2->execute(array('new_value', 'target_value'));

    // トランザクションのコミット
    $db1->commit();
    $db2->commit();

} catch(PDOException $e) {
    // トランザクションのロールバック
    $db1->rollBack();
    $db2->rollBack();

    // エラーメッセージの表示
    echo "Error: " . $e->getMessage();
}

// データベース接続の切断
$db1 = null;
$db2 = null;

このコードでは、まずPDOを使用してデータベース1とデータベース2に接続します。それぞれのデータベースに対してトランザクションを開始し、それぞれの処理を行います。最後に、トランザクションをコミットしてデータベース接続を切断します。トランザクション中にエラーが発生した場合は、トランザクションをロールバックし、エラーメッセージを表示します。