【PHP8.x】SAVEPOINT定数の使い方

Copy
1<?php
2
3// SQLite3 データベースを操作するクラス
4class SQLiteSavepointExample
5{
6    private $db;
7
8    // データベース接続
9    public function __construct(string $dbPath)
10    {
11        try {
12            $this->db = new SQLite3($dbPath);
13        } catch (Exception $e) {
14            die("データベース接続エラー: " . $e->getMessage());
15        }
16    }
17
18    // セーブポイントを使用したトランザクション処理
19    public function executeTransactionWithSavepoint(): void
20    {
21        $this->db->exec('BEGIN;'); // トランザクション開始
22
23        try {
24            // セーブポイントを作成
25            $this->db->exec('SAVEPOINT my_savepoint;');
26
27            // 最初の操作
28            $this->db->exec("INSERT INTO users (name, age) VALUES ('Alice', 30);");
29
30            // エラーが発生する可能性のある操作
31            // 例: 存在しないカラムにデータを挿入する
32            try {
33                 $this->db->exec("INSERT INTO users (invalid_column, age) VALUES ('Bob', 25);");
34            } catch (Exception $e) {
35                echo "エラーが発生しました: " . $e->getMessage() . "\n";
36
37                // セーブポイントまでロールバック
38                $this->db->exec('ROLLBACK TO SAVEPOINT my_savepoint;');
39                echo "セーブポイントまでロールバックしました。\n";
40            }
41
42            // 別の操作
43            $this->db->exec("INSERT INTO users (name, age) VALUES ('Charlie', 40);");
44
45            // トランザクションをコミット
46            $this->db->exec('RELEASE SAVEPOINT my_savepoint;');
47            $this->db->exec('COMMIT;');
48            echo "トランザクションをコミットしました。\n";
49
50        } catch (Exception $e) {
51            // ロールバック
52            $this->db->exec('ROLLBACK;');
53            echo "トランザクションをロールバックしました: " . $e->getMessage() . "\n";
54        }
55    }
56
57    // データベースクローズ
58    public function __destruct()
59    {
60        if ($this->db) {
61            $this->db->close();
62        }
63    }
64}
65
66// データベースファイルのパス
67$dbPath = 'my_database.db';
68
69// データベースが存在しない場合は作成し、テーブルを作成する
70if (!file_exists($dbPath)) {
71    $db = new SQLite3($dbPath);
72    $db->exec('CREATE TABLE users (id INTEGER PRIMARY KEY AUTOINCREMENT, name TEXT, age INTEGER);');
73    $db->close();
74}
75
76// SQLiteSavepointExample のインスタンスを作成し、トランザクションを実行
77$example = new SQLiteSavepointExample($dbPath);
78$example->executeTransactionWithSavepoint();
79
80?>

このサンプルコードは、PHPのSQLite3拡張を用いて、セーブポイントを利用したトランザクション処理を行う方法を示しています。SQLite3::SAVEPOINT定数は、セーブポイントを作成し、トランザクション内の一部の操作を部分的にロールバックするために使用されます。

まず、SQLite3クラスを利用してデータベースに接続します。beginTransaction()でトランザクションを開始後、exec('SAVEPOINT my_savepoint;')でセーブポイントを作成します。

トランザクション内で複数のデータベース操作を実行し、もし途中でエラーが発生した場合、ROLLBACK TO SAVEPOINT my_savepoint; を実行することで、直前のセーブポイントまでロールバックできます。これにより、トランザクション全体をロールバックするのではなく、エラーが発生した操作とその後の操作のみをキャンセルできます。

エラーが発生しなければ、RELEASE SAVEPOINT my_savepoint;でセーブポイントを解放し、COMMIT;でトランザクションをコミットします。もしトランザクション全体でエラーが発生した場合は、ROLLBACK;を実行してトランザクション全体をロールバックします。

この例では、存在しないカラムへのINSERTを試みることで意図的にエラーを発生させ、セーブポイントまでのロールバックを体験できます。セーブポイントを使うことで、複雑なトランザクション処理において、より柔軟なエラーハンドリングが可能になります。SQLite3::SAVEPOINT自体は定数であり、直接コードで使用されることはありませんが、SAVEPOINTコマンドを通じて間接的に利用されます。引数はなく、戻り値もありません。

Copy
1<?php
2
3/**
4 * SQLite3 SAVEPOINT の使用例
5 *
6 * SAVEPOINT を使用して、トランザクションの一部をロールバックできるようにします。
7 */
8try {
9    $db = new SQLite3('database.sqlite');
10
11    // トランザクションを開始
12    $db->exec('BEGIN');
13
14    // セーブポイントを設定
15    $db->exec('SAVEPOINT my_savepoint');
16
17    // 処理1: データの挿入
18    $db->exec("INSERT INTO users (name, email) VALUES ('John Doe', 'john.doe@example.com')");
19
20    // エラーが発生した場合をシミュレート
21    $error_occurred = false; // 例: 何らかの条件でエラーが発生するかどうかを判断
22
23    if ($error_occurred) {
24        // セーブポイントまでロールバック
25        $db->exec('ROLLBACK TO SAVEPOINT my_savepoint');
26        echo "ロールバックしました。\n";
27    } else {
28        // 処理2: 別のデータの挿入
29        $db->exec("INSERT INTO users (name, email) VALUES ('Jane Doe', 'jane.doe@example.com')");
30
31        // トランザクションをコミット
32        $db->exec('RELEASE SAVEPOINT my_savepoint'); // セーブポイントを解放
33        $db->exec('COMMIT');
34        echo "コミットしました。\n";
35    }
36
37} catch (Exception $e) {
38    // エラーが発生した場合、トランザクション全体をロールバック
39    $db->exec('ROLLBACK');
40    echo "トランザクションをロールバックしました: " . $e->getMessage() . "\n";
41} finally {
42    if (isset($db)) {
43        $db->close();
44    }
45}
46
47?>

このサンプルコードは、PHPのSQLite3拡張におけるSAVEPOINT定数の使用例を示しています。SAVEPOINTは、データベース操作におけるトランザクション処理の一部を、エラー発生時にロールバックするために使用されます。

まず、SQLite3データベースに接続し、トランザクションを開始します。SAVEPOINT my_savepointを実行することで、my_savepointという名前のセーブポイントを設定します。これは、トランザクションの中間地点を記録するようなものです。

次に、データの挿入など、一連のデータベース操作を行います。ここでは、usersテーブルへのデータ挿入を例としています。もし、これらの操作の途中でエラーが発生した場合（ここでは$error_occurred変数がtrueの場合を想定）、ROLLBACK TO SAVEPOINT my_savepointを実行することで、セーブポイントmy_savepointまでロールバックできます。これにより、セーブポイント以降の変更が取り消され、データベースはセーブポイントを設定した時点の状態に戻ります。

エラーが発生しなかった場合は、後続の処理（ここでは別のデータの挿入）を行い、RELEASE SAVEPOINT my_savepointでセーブポイントを解放し、COMMITを実行してトランザクションを確定します。RELEASE SAVEPOINTはセーブポイントが不要になった時点で実行します。

try-catchブロックを使用することで、例外が発生した場合にトランザクション全体をロールバックし、エラーメッセージを表示することができます。finallyブロックでは、データベース接続をクローズします。

この例では、SAVEPOINTを使用することで、トランザクションをより細かく制御し、エラー発生時の影響範囲を限定的にすることができます。