【PHP8.x】Pdo\Sqlite::OPEN_CREATE定数の使い方

Copy
1<?php
2
3/**
4 * SQLiteデータベースファイルを開く、または存在しない場合は作成します。
5 *
6 * Pdo\Sqlite::OPEN_CREATE は、ファイルが存在しない場合にデータベースを
7 * 作成する意図を持つ定数として参照されています。
8 * PHP 8の標準のPDO_SQLite拡張では、データベースファイルのDSNパスを
9 * 指定するだけで、ファイルが存在しない場合は自動的に作成されます。
10 * この関数は、その自動作成挙動を利用してデータベースに接続します。
11 *
12 * @param string $dbFilePath 作成または開くデータベースファイルのパス。
13 * @return PDO 接続されたPDOインスタンス。
14 * @throws PDOException データベース接続に失敗した場合。
15 */
16function createOrOpenSqliteDatabase(string $dbFilePath): PDO
17{
18    // SQLiteデータベースのDSN (Data Source Name) を構築します。
19    // 'sqlite:' の後にファイルパスを指定すると、そのファイルに接続します。
20    // もしファイルが存在しない場合、PDO_SQLiteは自動的に新しいファイルを作成します。
21    // この挙動は、Pdo\Sqlite::OPEN_CREATE 定数によって示される意図に相当します。
22    $dsn = 'sqlite:' . $dbFilePath;
23
24    try {
25        // PDOインスタンスを作成し、データベースに接続します。
26        // 接続オプションとして、エラーモードを例外に設定し、エラーハンドリングを容易にします。
27        $pdo = new PDO($dsn, null, null, [
28            PDO::ATTR_ERRMODE => PDO::ERRMODE_EXCEPTION,
29        ]);
30
31        // データベース接続が成功した後、サンプルとしてテーブルを作成します。
32        // テーブルが既に存在する場合は何もしません (IF NOT EXISTS)。
33        $pdo->exec("CREATE TABLE IF NOT EXISTS messages (
34            id INTEGER PRIMARY KEY AUTOINCREMENT,
35            text TEXT NOT NULL,
36            created_at DATETIME DEFAULT CURRENT_TIMESTAMP
37        )");
38
39        return $pdo;
40
41    } catch (PDOException $e) {
42        // データベース接続または作成に失敗した場合、例外をスローします。
43        // 初心者にも分かりやすいように、具体的なエラーメッセージを含めます。
44        throw new PDOException("Failed to connect or create SQLite database: " . $e->getMessage(), (int)$e->getCode(), $e);
45    }
46}
47
48// --- サンプル実行 ---
49$databaseName = 'my_messages.db'; // 作成または開くデータベースファイル名
50
51try {
52    // データベースに接続（または新規作成）します。
53    $pdo = createOrOpenSqliteDatabase($databaseName);
54    echo "データベース '{$databaseName}' に接続しました。\n";
55
56    // メッセージを挿入する例
57    $stmt = $pdo->prepare("INSERT INTO messages (text) VALUES (?)");
58    $stmt->execute(['Hello, world!']);
59    $stmt->execute(['This is a test message.']);
60    echo "メッセージを挿入しました。\n";
61
62    // メッセージを取得して表示する例
63    $stmt = $pdo->query("SELECT id, text, created_at FROM messages ORDER BY created_at DESC");
64    $messages = $stmt->fetchAll(PDO::FETCH_ASSOC);
65
66    echo "--- データベース内のメッセージ ---\n";
67    foreach ($messages as $message) {
68        echo "ID: {$message['id']}, Text: '{$message['text']}', Created At: {$message['created_at']}\n";
69    }
70    echo "----------------------------------\n";
71
72    // 接続を閉じる (PDOオブジェクトがスコープ外に出ると自動的に閉じられますが、明示的にnullを設定することも可能)
73    $pdo = null;
74
75} catch (PDOException $e) {
76    // エラーが発生した場合、メッセージを出力します。
77    error_log("Unhandled PDO Exception: " . $e->getMessage());
78    echo "エラーが発生しました: " . $e->getMessage() . "\n";
79}

このPHPサンプルコードは、SQLiteデータベースファイルを開く、または存在しない場合に新規作成する方法を初心者向けに示しています。Pdo\Sqlite::OPEN_CREATE定数は、データベースファイルが存在しない場合に新しく作成するという意図を示すものですが、PHP 8のPDO_SQLite拡張では、データベース接続時に'sqlite:ファイルパス'形式のDSN（データソース名）を指定するだけで、ファイルが存在しなければ自動的に作成される挙動を利用しています。

createOrOpenSqliteDatabase関数は、引数として作成または開くデータベースファイルのパス（$dbFilePath、文字列）を受け取ります。この関数は、指定されたパスにSQLiteデータベースへ接続し、もしファイルが存在しなければ新しいデータベースファイルを生成します。接続が成功した場合、データベース操作に利用するPDOインスタンスを戻り値として返します。データベース接続や作成に失敗した場合はPDOExceptionがスローされます。

コード内では、エラー発生時に例外を投げるように設定し、messagesテーブルの作成、データの挿入、取得といった基本的なデータベース操作の例も含まれており、データベースの準備から基本的なCRUD操作までの一連の流れを理解できます。