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

Copy
1<?php
2
3/**
4 * SQLite3データベースに新しい「users」テーブルを作成します。
5 * テーブルが既に存在する場合は何もしません。
6 *
7 * @param string $dbPath 接続するSQLite3データベースファイルのパス。
8 * @return bool テーブル作成操作が成功した場合はtrue、それ以外はfalseを返します。
9 */
10function createUsersTable(string $dbPath): bool
11{
12    $db = null; // データベース接続オブジェクトの初期化
13
14    try {
15        // データベースに接続します。
16        // ファイルが存在しない場合は新規作成され、読み書き可能なモードで開かれます。
17        $db = new SQLite3($dbPath, SQLITE3_OPEN_READWRITE | SQLITE3_OPEN_CREATE);
18
19        // テーブル作成のためのSQL文を定義します。
20        // 「IF NOT EXISTS」を使用することで、テーブルが既に存在してもエラーになりません。
21        $createTableSql = '
22            CREATE TABLE IF NOT EXISTS users (
23                id INTEGER PRIMARY KEY AUTOINCREMENT,
24                name TEXT NOT NULL,
25                email TEXT UNIQUE NOT NULL
26            )
27        ';
28
29        // 定数 `CREATE_TABLE` はSQLite3クラスには存在しませんが、
30        // `exec()` メソッドを使用することでSQL文を実行し、テーブルを作成できます。
31        // `exec()` は結果セットを返さないSQL文（CREATE, INSERT, UPDATE, DELETEなど）に適しています。
32        $db->exec($createTableSql);
33
34        echo "データベース '$dbPath' に 'users' テーブルが正常に作成されたか、既に存在します。\n";
35        return true;
36
37    } catch (Exception $e) {
38        // データベース操作中にエラーが発生した場合、メッセージを表示します。
39        echo "エラーが発生しました: " . $e->getMessage() . "\n";
40        return false;
41    } finally {
42        // 処理の成功・失敗に関わらず、データベース接続を閉じます。
43        if ($db) {
44            $db->close();
45        }
46    }
47}
48
49// -----------------------------------------------------------
50// スクリプトの実行例
51// -----------------------------------------------------------
52
53// データベースファイルのパスを定義します。
54$databaseFile = 'my_application.sqlite';
55
56// 上記の関数を呼び出してテーブル作成を試みます。
57if (createUsersTable($databaseFile)) {
58    echo "「users」テーブルの作成処理が完了しました。\n";
59} else {
60    echo "「users」テーブルの作成処理中に問題が発生しました。\n";
61}
62
63?>

このPHPサンプルコードは、SQLite3拡張機能を使用してデータベースに新しいテーブルを作成する方法をシステムエンジニアを目指す初心者に示しています。

まず、createUsersTable 関数は、引数としてSQLite3データベースファイルのパス（$dbPath）を受け取ります。この関数は、テーブルの作成が成功した場合は true、失敗した場合は false を戻り値として返します。

関数内部では、new SQLite3() を用いて指定されたデータベースファイルに接続します。ファイルが存在しない場合は自動的に新規作成され、読み書き可能なモードで開かれます。テーブル作成の核心部分は、CREATE TABLE IF NOT EXISTS というSQL文です。これにより、もし同じ名前のテーブルが既に存在していてもエラーにならず、安全にテーブル作成を試みることができます。

テーブルの実際の作成は、SQLite3 オブジェクトの exec() メソッドにこのSQL文を渡して実行することで行われます。リファレンス情報に記載されている SQLite3::CREATE_TABLE という定数についてですが、このサンプルコードでは直接使用されていません。代わりに、SQL文を直接記述し、exec() メソッドを使って実行するアプローチが取られています。 処理の安全性のため、try-catch-finally ブロックが使われており、エラー発生時のメッセージ表示や、成功・失敗に関わらずデータベース接続を確実に閉じる（$db->close()）仕組みが組み込まれています。

このコードは、PHPでSQLiteデータベースの基本的なテーブル操作を学ぶ上で重要な基礎となります。

Copy
1<?php
2
3declare(strict_types=1);
4
5/**
6 * MySQLの結果セットからSQLiteテーブルを作成し、データを移行する関数。
7 *
8 * この関数は、MySQLから指定されたテーブルのデータを読み込み、そのスキーマ情報に基づいて
9 * SQLiteデータベース内に新しいテーブルを作成し、MySQLのデータをSQLiteに挿入します。
10 * 参照情報に記載の `SQLite3::CREATE_TABLE` 定数は、標準のPHP拡張には存在しませんが、
11 * ここでは「テーブル作成」というその定数が意図するであろう操作を `CREATE TABLE` SQL文の実行により実現します。
12 *
13 * @param string $mysqlHost MySQLホスト名
14 * @param string $mysqlUser MySQLユーザー名
15 * @param string $mysqlPass MySQLパスワード
16 * @param string $mysqlDb MySQLデータベース名
17 * @param string $mysqlTable MySQLの元のテーブル名
18 * @param string $sqliteDbFile SQLiteデータベースファイル名 (存在しない場合は新規作成)
19 * @param string $sqliteTableName SQLiteに作成するテーブル名
20 * @return bool 成功した場合は true、失敗した場合は false
21 */
22function createSqliteTableFromMysqlResult(
23    string $mysqlHost,
24    string $mysqlUser,
25    string $mysqlPass,
26    string $mysqlDb,
27    string $mysqlTable,
28    string $sqliteDbFile,
29    string $sqliteTableName
30): bool {
31    // 1. MySQLデータベースに接続
32    $mysqli = new mysqli($mysqlHost, $mysqlUser, $mysqlPass, $mysqlDb);
33    if ($mysqli->connect_errno) {
34        error_log("MySQL 接続エラー: " . $mysqli->connect_error);
35        return false;
36    }
37
38    // 2. MySQLからテーブルのスキーマとデータを取得
39    // まずスキーマ情報を得るために全てのカラムを選択します。
40    $result = $mysqli->query("SELECT * FROM `" . $mysqli->real_escape_string($mysqlTable) . "`");
41    if (!$result) {
42        error_log("MySQL クエリエラー: " . $mysqli->error);
43        $mysqli->close();
44        return false;
45    }
46
47    // 3. SQLiteデータベースに接続（または新規作成）
48    // SQLite3::OPEN_READWRITE | SQLite3::OPEN_CREATE は、読み書きモードで開き、
49    // ファイルが存在しない場合は作成することを意味します。
50    $sqlite = new SQLite3($sqliteDbFile, SQLite3::OPEN_READWRITE | SQLite3::OPEN_CREATE);
51
52    // 4. MySQLの結果セットからCREATE TABLE文を生成
53    $columns = [];        // SQLiteのCREATE TABLE文用のカラム定義 (例: `id` INTEGER, `name` TEXT)
54    $columnNames = [];    // INSERT文用のカラム名リスト (例: `id`, `name`)
55    $paramPlaceholders = []; // INSERT文用のプレースホルダリスト (例: ?, ?)
56
57    // MySQLi_result::fetch_fields() で各カラムのメタデータ（名前、型など）を取得
58    while ($field = $result->fetch_field()) {
59        $columnName = $field->name;
60        $columnNames[] = "`" . $columnName . "`";
61        $paramPlaceholders[] = "?"; // プリペアドステートメント用のプレースホルダ
62
63        // MySQLの型をSQLiteの型にマップ (初心者向けに主要な型のみ対応し簡略化)
64        $sqliteType = 'TEXT'; // デフォルトはTEXT
65        switch ($field->type) {
66            case MYSQLI_TYPE_TINY:
67            case MYSQLI_TYPE_SHORT:
68            case MYSQLI_TYPE_LONG:
69            case MYSQLI_TYPE_INT24:
70            case MYSQLI_TYPE_LONGLONG:
71                $sqliteType = 'INTEGER'; // 整数型
72                break;
73            case MYSQLI_TYPE_DECIMAL:
74            case MYSQLI_TYPE_FLOAT:
75            case MYSQLI_TYPE_DOUBLE:
76                $sqliteType = 'REAL'; // 浮動小数点数型
77                break;
78            case MYSQLI_TYPE_DATE:
79            case MYSQLI_TYPE_DATETIME:
80            case MYSQLI_TYPE_TIMESTAMP:
81            case MYSQLI_TYPE_STRING:
82            case MYSQLI_TYPE_VAR_STRING:
83            case MYSQLI_TYPE_TINY_BLOB:
84            case MYSQLI_TYPE_MEDIUM_BLOB:
85            case MYSQLI_TYPE_LONG_BLOB:
86            case MYSQLI_TYPE_BLOB:
87                $sqliteType = 'TEXT'; // 文字列またはバイナリデータ (SQLiteは柔軟)
88                break;
89        }
90        $columns[] = "`" . $columnName . "` " . $sqliteType;
91    }
92
93    // CREATE TABLE SQL文の構築
94    $createTableSql = "CREATE TABLE IF NOT EXISTS `" . $sqlite->escapeString($sqliteTableName) . "` ("
95        . implode(", ", $columns) . ");";
96
97    // 5. SQLiteでテーブルを作成
98    // このステップが、`SQLite3::CREATE_TABLE` 定数の意図する操作です。
99    $createResult = $sqlite->exec($createTableSql);
100    if (!$createResult) {
101        error_log("SQLite テーブル作成エラー: " . $sqlite->lastErrorMsg());
102        $result->free();
103        $mysqli->close();
104        $sqlite->close();
105        return false;
106    }
107
108    // 6. MySQLから取得したデータをSQLiteに挿入
109    if (count($columnNames) > 0) {
110        $insertSql = "INSERT INTO `" . $sqlite->escapeString($sqliteTableName) . "` ("
111            . implode(", ", $columnNames) . ") VALUES (" . implode(", ", $paramPlaceholders) . ");";
112
113        $sqlite->exec('BEGIN;'); // 複数行挿入のパフォーマンス向上のためトランザクションを開始
114        $stmt = $sqlite->prepare($insertSql); // プリペアドステートメントでSQLインジェクションを防止
115
116        if (!$stmt) {
117            error_log("SQLite プリペアドステートメント作成エラー: " . $sqlite->lastErrorMsg());
118            $sqlite->exec('ROLLBACK;'); // エラー時はトランザクションをロールバック
119            $result->free();
120            $mysqli->close();
121            $sqlite->close();
122            return false;
123        }
124
125        // MySQLの結果セットから1行ずつデータをフェッチし、SQLiteに挿入
126        while ($row = $result->fetch_assoc()) {
127            $bindIndex = 1;
128            foreach ($row as $key => $value) {
129                // SQLite3::bindValue は1から始まるインデックスを使用
130                // 全ての値をテキストとしてバインド (SQLiteは柔軟な型扱いのため問題ないことが多い)
131                $stmt->bindValue($bindIndex++, $value, SQLITE3_TEXT);
132            }
133            $executeResult = $stmt->execute();
134            if (!$executeResult) {
135                error_log("SQLite データ挿入エラー: " . $sqlite->lastErrorMsg());
136                $sqlite->exec('ROLLBACK;'); // エラー時はロールバック
137                $stmt->close();
138                $result->free();
139                $mysqli->close();
140                $sqlite->close();
141                return false;
142            }
143        }
144        $sqlite->exec('COMMIT;'); // トランザクションをコミット
145        $stmt->close();
146    }
147
148    // 7. リソースの解放
149    $result->free();
150    $mysqli->close();
151    $sqlite->close();
152
153    return true;
154}
155
156// --------------------------------------------------------------------------------
157// 使用例: MySQLからテストデータを取得し、SQLiteに移行する
158// (この部分は、上記関数を単体で動作させるためのデモンストレーションです)
159// --------------------------------------------------------------------------------
160
161// MySQL接続情報 (ご自身の環境に合わせて変更してください)
162$mysqlHost = 'localhost';
163$mysqlUser = 'root';
164$mysqlPass = ''; // ここにMySQLのパスワードを設定してください
165$mysqlDb = 'test_migration_db';
166$mysqlTable = 'users_source';
167
168// SQLiteファイルとテーブル名
169$sqliteDbFile = 'migrated_data.sqlite';
170$sqliteTableName = 'users_target';
171
172// テスト用MySQLデータベースとテーブルの準備 (既に存在する場合はスキップまたは再作成)
173try {
174    // MySQLに接続してテストデータを作成
175    $testMysqli = new mysqli($mysqlHost, $mysqlUser, $mysqlPass);
176    if ($testMysqli->connect_errno) {
177        throw new Exception("MySQLテスト接続エラー: " . $testMysqli->connect_error);
178    }
179    $testMysqli->query("CREATE DATABASE IF NOT EXISTS `" . $mysqlDb . "`");
180    $testMysqli->select_db($mysqlDb); // 作成したデータベースを選択
181
182    // テストテーブルを毎回クリーンアップし、再作成
183    $testMysqli->query("DROP TABLE IF EXISTS `" . $mysqlTable . "`");
184    $testMysqli->query("CREATE TABLE `" . $mysqlTable . "` (
185        id INT AUTO_INCREMENT PRIMARY KEY,
186        name VARCHAR(255) NOT NULL,
187        email VARCHAR(255) UNIQUE,
188        age INT,
189        created_at DATETIME DEFAULT CURRENT_TIMESTAMP
190    );");
191    $testMysqli->query("INSERT INTO `" . $mysqlTable . "` (name, email, age) VALUES
192        ('Alice Smith', 'alice@example.com', 30),
193        ('Bob Johnson', 'bob@example.com', 24),
194        ('Charlie Brown', 'charlie@example.com', 35);");
195    $testMysqli->close();
196    echo "MySQLテストデータが正常に準備されました。\n";
197} catch (Exception $e) {
198    echo "MySQLテストデータの準備中にエラーが発生しました: " . $e->getMessage() . "\n";
199    echo "MySQLの接続情報や権限を確認してください。\n";
200    exit(1); // 準備に失敗した場合は終了
201}
202
203// SQLiteデータベースファイルが既に存在する場合は削除 (テスト実行ごとにクリーンな状態にするため)
204if (file_exists($sqliteDbFile)) {
205    unlink($sqliteDbFile);
206    echo "既存のSQLiteファイル '{$sqliteDbFile}' を削除しました。\n";
207}
208
209echo "MySQLテーブル '{$mysqlDb}.{$mysqlTable}' からSQLiteテーブル '{$sqliteDbFile}.{$sqliteTableName}' へのデータ移行を開始します...\n";
210
211// データ移行関数の実行
212if (createSqliteTableFromMysqlResult(
213    $mysqlHost,
214    $mysqlUser,
215    $mysqlPass,
216    $mysqlDb,
217    $mysqlTable,
218    $sqliteDbFile,
219    $sqliteTableName
220)) {
221    echo "データ移行が成功しました！ SQLiteデータベースファイル: {$sqliteDbFile}\n";
222    echo "作成されたSQLiteテーブル: {$sqliteTableName}\n";
223
224    // 移行結果の確認 (オプション)
225    try {
226        $sqliteCheck = new SQLite3($sqliteDbFile, SQLite3::OPEN_READONLY);
227        $checkResult = $sqliteCheck->query("SELECT * FROM `" . $sqliteCheck->escapeString($sqliteTableName) . "`");
228        if ($checkResult) {
229            echo "\n--- 移行されたデータの確認 ---\n";
230            while ($row = $checkResult->fetchArray(SQLITE3_ASSOC)) {
231                print_r($row);
232            }
233            echo "------------------------------\n";
234            $checkResult->finalize(); // 結果セットを解放
235        } else {
236            echo "SQLiteデータの確認中にエラー: " . $sqliteCheck->lastErrorMsg() . "\n";
237        }
238        $sqliteCheck->close();
239    } catch (Exception $e) {
240        echo "SQLiteデータの確認中に例外が発生しました: " . $e->getMessage() . "\n";
241    }
242
243} else {
244    echo "データ移行に失敗しました。上記のエラーメッセージを確認してください。\n";
245}

このPHPコードは、MySQLデータベースから既存のテーブルの構造とデータを読み込み、それをSQLiteデータベースに新しいテーブルとして作成し、データ移行を行うための関数です。

参照情報で言及されているSQLite3::CREATE_TABLE定数はPHPの標準拡張には存在しませんが、この関数ではCREATE TABLEというSQL文を動的に生成・実行することで、その定数が意図する「テーブル作成」の操作を実現しています。

具体的には、まずMySQLに接続して指定されたテーブルのスキーマ（カラム名やデータ型）を取得します。次に、その情報をもとにSQLiteデータベースに接続し、適切な型の新しいテーブルを作成します。そして、MySQLから取得したデータを一行ずつSQLiteの新しいテーブルに安全に挿入します。この際、複数のデータ挿入を効率的に行うためトランザクション処理を利用し、また悪意のある入力を防ぐためプリペアドステートメントを使用しています。

引数には、MySQLの接続情報としてホスト名、ユーザー名、パスワード、データベース名、元のテーブル名を指定します。さらに、SQLiteのデータベースファイル名と、新しく作成するテーブル名も必要です。この関数は、処理が成功した場合は真（true）を、何らかのエラーが発生した場合は偽（false）を戻り値として返します。