sqliteテーブルの自動生成

Question

前提・実現したいこと

こちらに掲載している、[https://gray-code.com/php/make-the-board-vol23/]「ひとこと掲示版」でページを新設するたびにdbを新しくしたいのですが、dbがconnect_errnoになってしまいます。

発生している問題・エラーメッセージ

エラーメッセージは特にありません。ここの部分のテーブルが読み込めていないみたい？作れてはいました。

			//IF NOT EXISTS オプション を指定することで存在しない場合のみ、テーブル作成を行うこともできます。
              $arr[]=chr(mt_rand(97, 122)).chr(mt_rand(97, 122)).chr(mt_rand(97, 122));
               $arr[]=mt_rand(1,10000);
                $arr[]=chr(mt_rand(97, 122)).chr(mt_rand(97, 122)).chr(mt_rand(97, 122));
                $arr[]=mt_rand(1,10000);
               $table_name=implode($arr);
           $sql="CREATE TABLE IF NOT EXISTS $table_name(
 view_name INTEGER PRIMARY KEY,
  message TEXT,
  post_date INTEGER,
  created_datetime TIMESTAMP DEFAULT (datetime(CURRENT_TIMESTAMP,'localtime'))
)";
			// データを登録するSQL作成
			$sql = "INSERT INTO $table_name (view_name, message, post_date) VALUES ( '$clean[view_name]', '$clean[message]', '$now_date')";



	$sql = "SELECT view_name,message,post_date FROM $table_name ORDER BY post_date DESC";
	$res = $db->query($sql);
	

該当のソースコード

<?php
session_start();

// メッセージを保存するファイルのパス設定
define( 'FILENAME', './message.txt');

// タイムゾーン設定
date_default_timezone_set('Asia/Tokyo');

// 変数の初期化
$now_date = null;
$data = null;
$file_handle = null;
$split_data = null;
$message = array();
$message_array = array();
$success_message = null;
$error_message = array();
$clean = array();

// トランザクション開始
$db->exec('begin');

try {
if( !empty($_POST['btn_submit']) ) {
	
	// 表示名の入力チェック
	if( empty($_POST['view_name']) ) {
		$error_message[] = '表示名を入力してください。';
	} else {
		$clean['view_name'] = htmlspecialchars( $_POST['view_name'], ENT_QUOTES);
	}
	
	// メッセージの入力チェック
	if( empty($_POST['message']) ) {
		$error_message[] = 'ひと言メッセージを入力してください。';
	} else {
		$clean['message'] = htmlspecialchars( $_POST['message'], ENT_QUOTES);
		$clean['message'] = preg_replace( '/\r\n|\n|\r/', '<br>', $clean['message']);
	
		
		// セッションに表示名を保存
		$_SESSION['view_name'] = $clean['view_name'];
		}

	if( empty($error_message) ) {

		/*
		if( $file_handle = fopen( FILENAME, "a") ) {
	
		    // 書き込み日時を取得
			$now_date = date("Y-m-d H:i:s");
		
			// 書き込むデータを作成
			$data = "'".$clean['view_name']."','".$clean['message']."','".$now_date."'\n";
		
			// 書き込み
			fwrite( $file_handle, $data);
		
			// ファイルを閉じる
			fclose( $file_handle);
	
			$success_message = 'メッセージを書き込みました。';
		}
		*/
		
		// データベースに接続
		$db = new SQLite3("test.db");
		
		// 接続エラーの確認
		if( $db->connect_errno ) {
			$error_message[] = '書き込みに失敗しました。';} 
            else {

			/*// 文字コード設定
			$db->set_charset('utf8');
			*/
			// 書き込み日時を取得
			$now_date = date("Y-m-d H:i:s");
			//IF NOT EXISTS オプション を指定することで存在しない場合のみ、テーブル作成を行うこともできます。
              $arr[]=chr(mt_rand(97, 122)).chr(mt_rand(97, 122)).chr(mt_rand(97, 122));
               $arr[]=mt_rand(1,10000);
                $arr[]=chr(mt_rand(97, 122)).chr(mt_rand(97, 122)).chr(mt_rand(97, 122));
                $arr[]=mt_rand(1,10000);
               $table_name=implode($arr);
           $sql="CREATE TABLE IF NOT EXISTS $table_name(
 view_name INTEGER PRIMARY KEY,
  message TEXT,
  post_date INTEGER,
  created_datetime TIMESTAMP DEFAULT (datetime(CURRENT_TIMESTAMP,'localtime'))
)";
			// データを登録するSQL作成
			$sql = "INSERT INTO $table_name (view_name, message, post_date) VALUES ( '$clean[view_name]', '$clean[message]', '$now_date')";

			// データを登録
			$res = $db->query($sql);
		
			if( $res ) {
				$success_message = 'メッセージを書き込みました。';
			} else {
				$error_message[] = '書き込みに失敗しました。';
			}
		
			// データベースの接続を閉じる
			$db->close();
		}/*
header('Location: ./');*/
	}
}
/*
if( $file_handle = fopen( FILENAME,'r') ) {
    while( $data = fgets($file_handle) ){

		$split_data = preg_split( '/\'/', $data);

		$message = array(
			'view_name' => $split_data[1],
			'message' => $split_data[3],
			'post_date' => $split_data[5]
		);
		array_unshift( $message_array, $message);
	}
    
    // ファイルを閉じる
    fclose( $file_handle);
}*/

// データベースに接続
$db = new SQLite3("test.db");

// 接続エラーの確認
if( $db->connect_errno ) {
	$error_message[] = 'データの読み込みに失敗しました。';
} else {

	$sql = "SELECT view_name,message,post_date FROM $table_name ORDER BY post_date DESC";
	$res = $db->query($sql);
	
	/*if( $res ) {
		$message_array = $res->fetch_all(MYSQLI_ASSOC);
	}
	if( $res ) {
		$message_array = $res->fetchArray(SQLITE3_ASSOC);
	}
	
	$message_array = sqlite3fetchAll($res);

function sqlite3fetchAll($res)
{
$result = [];
while ($row = $res->fetchArray()) $result[] = $row;
return $result;
} while( $row = $res->fetchArray() ) {
    
    echo '<ul>'.'<li>'.$row[0].'</li>'.'<li>'.$row[1].'</li>'
	.'<li>'.$row[2].'</li>'.'<li>'.$row[3].'</li>'.'</ul>';}
	*/
	$message_array = [];
while ($row = $res->fetchArray(SQLITE3_ASSOC)) 
$message_array[] = $row;

$db->close();	

// コミット
	$db->exec('commit');

} catch(Exception $e) {

	// ロールバック
	$db->exec('rollback');

	// エラーメッセージの取得
	$error = $e->getTraceAsString();
	return;
}
?>

<h1>ひと言掲示板</h1>
<?php if( empty($_POST['btn_submit']) && !empty($_SESSION['success_message']) ): ?>
	<p class="success_message"><?php echo $_SESSION['success_message']; ?></p>
	<?php unset($_SESSION['success_message']); ?><?php endif; ?>
<?php if( !empty($error_message) ): ?>
    <ul class="error_message">
		<?php foreach( $error_message as $value ): ?>
            <li>・<?php echo $value; ?></li>
		<?php endforeach; ?>
    </ul>
<?php endif; ?>
<form method="post">
	<div>
		<label for="view_name">表示名</label>
		<input id="view_name" type="text" name="view_name" value="<?php if( !empty($_SESSION['view_name']) ){ echo $_SESSION['view_name']; } ?>">
	</div>
	<div>
		<label for="message">ひと言メッセージ</label>
		<textarea id="message" name="message"></textarea>
	</div>
	<input type="submit" name="btn_submit" value="書き込む">
</form>
<hr>
<section>
<?php if( !empty($message_array) ){ ?>
<?php foreach( $message_array as $value ){ ?>
<article>
    <div class="info">
        <h2><?php echo $value['view_name']; ?></h2>
        <time><?php echo date('Y年m月d日 H:i', strtotime($value['post_date'])); ?></time>
    </div>
    <p><?php echo $value['message']; ?></p>
</article>
<?php } ?>
<?php } ?>
</section>

Comments

[m.ts10806]

そもそもエラーを捕捉する仕組みになってないのでPHP以外のエラーは出ません。エラーハンドリングを入れてください。

[退会済みユーザー]

すみません。
よくわからなかったので教えてください。
dbの例外処理って意味でしょうか？

[m.ts10806]

はい。

Answer 1

yokuwakarimasenndesita