【PHP8.x】resetメソッドの使い方

Copy
1<?php
2
3// SQLite3データベースを操作するクラス
4class DatabaseHandler {
5    private $db;
6
7    // コンストラクタ：データベースに接続
8    public function __construct($dbPath) {
9        try {
10            $this->db = new SQLite3($dbPath);
11        } catch (Exception $e) {
12            die("データベース接続エラー: " . $e->getMessage());
13        }
14    }
15
16    // プリペアドステートメントを実行し、結果を処理する関数
17    public function executeStatement($sql, $params = []) {
18        $stmt = $this->db->prepare($sql);
19
20        // パラメータをバインド
21        foreach ($params as $key => $value) {
22            $stmt->bindValue($key, $value);
23        }
24
25        $result = $stmt->execute();
26
27        // ステートメントをリセット
28        $stmt->reset();
29
30        return $result;
31    }
32
33    // デストラクタ：データベース接続を閉じる
34    public function __destruct() {
35        if ($this->db) {
36            $this->db->close();
37        }
38    }
39}
40
41// データベースファイルのパス
42$dbPath = 'test.db';
43
44// DatabaseHandlerのインスタンスを作成
45$dbHandler = new DatabaseHandler($dbPath);
46
47// テーブルを作成するSQL
48$createTableSQL = 'CREATE TABLE IF NOT EXISTS users (id INTEGER PRIMARY KEY, name TEXT, age INTEGER)';
49$dbHandler->executeStatement($createTableSQL);
50
51// データを挿入するSQL
52$insertSQL = 'INSERT INTO users (name, age) VALUES (:name, :age)';
53$insertParams = [':name' => 'John Doe', ':age' => 30];
54$dbHandler->executeStatement($insertSQL, $insertParams);
55
56$insertParams = [':name' => 'Jane Smith', ':age' => 25];
57$dbHandler->executeStatement($insertSQL, $insertParams);
58
59// データを更新するSQL
60$updateSQL = 'UPDATE users SET age = :age WHERE name = :name';
61$updateParams = [':name' => 'John Doe', ':age' => 31];
62$dbHandler->executeStatement($updateSQL, $updateParams);
63
64// データを削除するSQL
65$deleteSQL = 'DELETE FROM users WHERE name = :name';
66$deleteParams = [':name' => 'Jane Smith'];
67$dbHandler->executeStatement($deleteSQL, $deleteParams);
68
69// データを取得するSQL
70$selectSQL = 'SELECT * FROM users';
71$result = $dbHandler->executeStatement($selectSQL);
72
73// 結果を処理
74if ($result) {
75    while ($row = $result->fetchArray(SQLITE3_ASSOC)) {
76        echo "ID: " . $row['id'] . ", Name: " . $row['name'] . ", Age: " . $row['age'] . PHP_EOL;
77    }
78} else {
79    echo "データの取得に失敗しました。" . PHP_EOL;
80}
81
82?>

このサンプルコードは、PHPのSQLite3拡張を用いてデータベース操作を行う例です。DatabaseHandlerクラスは、データベースへの接続、プリペアドステートメントの実行、および接続のクローズをカプセル化します。

executeStatement関数では、SQL文とパラメータを受け取り、プリペアドステートメントを作成して実行します。重要な点として、$stmt->reset()が呼び出されています。これは、SQLite3Stmtクラスのresetメソッドを使用しており、ステートメントを初期状態に戻します。

resetメソッドは引数を取らず、成功した場合はtrueを返します。このメソッドを呼び出すことで、同じステートメントを異なるパラメータで再利用できます。サンプルコードでは、データの挿入、更新、削除などの操作を繰り返し行う際に、プリペアドステートメントをリセットして再利用しています。これにより、データベースへの負荷を軽減し、効率的な処理を実現できます。

データベース接続はコンストラクタで確立され、デストラクタで閉じられます。サンプルでは、test.dbというSQLite3データベースファイルを使用しており、usersテーブルの作成、データの挿入、更新、削除、そして取得といった一連の操作を行っています。取得したデータは、fetchArray(SQLITE3_ASSOC)メソッドを用いて連想配列として取り出し、画面に表示しています。このコードは、データベース操作の基本的な流れと、resetメソッドの役割を示す良い例です。

Copy
1<?php
2
3// SQLite3データベースを扱うサンプル
4$db = new SQLite3(':memory:');
5
6// テーブルを作成
7$db->exec('CREATE TABLE items (id INTEGER PRIMARY KEY, name TEXT)');
8
9// プリペアドステートメントを作成
10$stmt = $db->prepare('INSERT INTO items (name) VALUES (:name)');
11
12// 値をバインドして実行
13$stmt->bindValue(':name', 'Item 1', SQLITE3_TEXT);
14$stmt->execute();
15
16$stmt->bindValue(':name', 'Item 2', SQLITE3_TEXT);
17$stmt->execute();
18
19// ステートメントをリセットして再利用
20$stmt->reset();
21
22$stmt->bindValue(':name', 'Item 3', SQLITE3_TEXT);
23$stmt->execute();
24
25// 結果を確認
26$result = $db->query('SELECT * FROM items');
27while ($row = $result->fetchArray()) {
28    echo "ID: " . $row['id'] . ", Name: " . $row['name'] . PHP_EOL;
29}
30
31// プリペアドステートメントを閉じる
32$stmt->close();
33
34// データベースを閉じる
35$db->close();
36
37?>

このPHPのサンプルコードは、SQLite3データベースを操作し、プリペアドステートメントのresetメソッドの働きを示すものです。

まず、SQLite3データベースをメモリ上に作成し、itemsテーブルを作成します。次に、$db->prepare()でINSERT文のプリペアドステートメントを作成し、$stmt変数に格納します。プリペアドステートメントは、SQL文をあらかじめコンパイルしておくことで、繰り返し実行する際のパフォーマンスを向上させます。

$stmt->bindValue()メソッドでプレースホルダ:nameに値をバインドし、$stmt->execute()でSQL文を実行します。ここでは、Item 1とItem 2をテーブルに挿入しています。

ここで$stmt->reset()が登場します。resetメソッドは、プリペアドステートメントの状態をリセットし、バインドされたパラメータをクリアします。これにより、同じステートメントを別の値で再利用できるようになります。このサンプルでは、resetメソッドを呼び出した後、改めてItem 3をバインドして挿入しています。resetメソッドは引数を取らず、常にtrueを返します。

最後に、SELECT文でitemsテーブルの内容を取得し、結果を表示します。$stmt->close()と$db->close()で、プリペアドステートメントとデータベース接続をそれぞれ閉じます。

この例から、resetメソッドを使うことで、プリペアドステートメントを効率的に再利用し、データベース操作を簡略化できることがわかります。