PHP：データベースの作成手順

<!DOCTYPE html>
<html lang = “ja”>
    <head>
        <meta charset = “UFT-8”>
        <title></title>
    </head>
    <body>
        <?php
            $dsn = "mysql:host=localhost;dbname=hogemoge;charset=utf8;";
            $user = 'root';
            $pass = '';
            try{
                //  DBへ接続
                $db = new PDO($dsn,$user,$pass);
                // エラー時に例外処理をthrowする
                $db->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
                if ($db == null){
                    print('接続に失敗しました。<br>');
                }else{
                    print('接続に成功しました。<br>');
                }

                // プリペアドステートメントを利用
                $db->setAttribute(PDO::ATTR_EMULATE_PREPARES, false);
                // トランザクション開始
                $db->beginTransaction();
                
                // SQL作成
                $sql1 = 'CREATE TABLE hoge(
                    id INT(11) AUTO_INCREMENT PRIMARY KEY,
                    name VARCHAR(10),
                    age INT(11),
                    hobby VARCHAR(10),
                )charset = utf8';

                try{
                    // SQL実行
                    $q = $db -> query($sql1);
                    $results = $q->fetchall();
                    
                    $aryInsert=[[':name'=>'hogehoge', ':age'=>10, ':hobby'=>'昼寝'],
                            [':name'=>'mogemoge', ':age'=>12, ':hobby'=>'歌'],
                           　[':name'=>'hogehoge2', ':age'=>10, ':hobby'=>'散歩'],
                            [':name'=>'hogehoge3', ':age'=>15, ':hobby'=>'映画'],
                    ];

                    // SQL作成
                    $sql = $pdo->prepare("INSERT INTO hoge(
                        name, age, hobby
                    ) VALUES (
                        :name, :age, :hobby
                    )");
                    
                    $arySql1=[];
                    // 行（レコード）の繰り返し
                    foreach($aryInsert as $key1 => $val1){
                        $arySql2 = [];
                        //列（カラム）の繰り返し
                        foreach($val1 as $key2 => $val2){
                            $arySql2[] = ':'.$key2.$key1;
                        }
                        $arySql1[] = '('.implode(',', $arySql2).')';
                    }
                    
                    $sql .= implode(',', $arySql1);

                    $sth = $pdo -> prepare($sql);
                    foreach($aryInsert as $key1 => $val1){
                        foreach($val1 as $key2 => $val2){
                            $sth -> bindValue(':'.$key2.$key1, $val2);
                        }
                    }
                }
        
            }catch (PDOException $e) {
                $db->rollBack();
                echo $e->getMessage();
                die();
                }

                    // 接続を閉じる
                    $dbh = null;
        ?>
    </body>
</html>

前提・実現したいこと

PHPからデータベース・テーブル作成をしています。
DBに接続可能・データベースも作成済みです。
テーブルが作成できても、その先に進めません。
データをインサートする際に以下のエラーメッセージが発生しました。

###　エラーメッセージ（XAMPPブラウザ表示）

接続に成功しました。
SQLSTATE[42S01]: Base table or view already exists: 1050 Table 'fruits' already exists

該当のソースコード

// SQL実行
                    $q = $db -> query($sql1);
                    $results = $q->fetchall();
                    
                    $aryInsert=[[':name'=>'plum', ':price'=>240, ':stock'=>40],
                            [':name'=>'kiwi', ':price'=>120, ':stock'=>80],
                            [':name'=>'lemon', ':price'=>180, ':stock'=>50],
                            [':name'=>'melon', ':price'=>360, ':stock'=>30],
                    ];

                    // SQL作成
                    $sql = $pdo->prepare("INSERT INTO fruits(
                        name, price, stock
                    ) VALUES (
                        :name, :price, :stock
                    )");
                    
                    $arySql1=[];
                    // 行（レコード）の繰り返し
                    foreach($aryInsert as $key1 => $val1){
                        $arySql2 = [];
                        //列（カラム）の繰り返し
                        foreach($val1 as $key2 => $val2){
                            $arySql2[] = ':'.$key2.$key1;
                        }
                        $arySql1[] = '('.implode(',', $arySql2).')';
                    }
                    
                    $sql .= implode(',', $arySql1);

                    $sth = $pdo -> prepare($sql);
                    foreach($aryInsert as $key1 => $val1){
                        foreach($val1 as $key2 => $val2){
                            $sth -> bindValue(':'.$key2.$key1, $val2);
                        }
                    }
                }

試したこと

try/catchの区切りがいまいちわかっていないため、もしかしたらそれが原因なのではないかと思います。
初心者のもので、まだまだコード不備あると思いますが、なんなりとご教示いただけますと幸いです。

補足情報（FW/ツールのバージョンなど）

vscode/xampp/DBeaverを使用

行動規範の内容に同意します

回答2件

プログラムで「CREATE TABLE」するのはやめておいたほうがよいでしょう
予め作っておいたテーブルにINSERTしたりSELECTしたりすることです

投稿2021/05/21 09:31

yambejp

総合スコア114839

作ったテーブルを削除せずまた実行したら、
そりゃそういうエラーも出ちゃいますよ。
大事なデータが入っているテーブルを明示的に棄てるとかしないと、迂闊なことはできませんし。

CREATE TABLE IF NOT EXISTS テーブル名

みたいに書けば、存在しないときは作ります、となります。

あくまで、
テーブル名が合致するものがすでに存在するかどうかのチェックであって、
書いたCREATE TABLE文と内容が同じかどうかのチェックはしていない。

テーブルの仕様が異なるもので作り直したい場合は、
素直にDELETE TABLE文を実行してからのほうがいい。

MySQL :: MySQL 5.6 リファレンスマニュアル :: 13.1.17 CREATE TABLE 構文

投稿2021/05/21 08:12

編集2021/05/21 08:14

退会済みユーザー

総合スコア0

xxx0_0xxx

2021/05/21 08:40

ご丁寧な回答ありがとうございます。テーブル自体はこのPHPで新規に作成し、そのあとの操作をするための区切り方？というものが分からないものでして・・・もう少し詳しくお教え願います＞＜

退会済みユーザー

2021/05/21 08:47

テーブルなどデータベース作成に関わるところは、稼働中にうっかりテーブルが消えてしまったりしないよう、通常はphpプログラムにCREATE TABLEやDROP TABLEなどは含めないものだと思う。別途テーブル作成しておいて準備しておくもの。 phpプログラムからは、データの追加(INSERT INTO)、更新(UPDATE)、削除(DELETE)のみ行うっていう。

退会済みユーザー

2021/05/21 08:48

ただ、質問文に掲載しているものは、その準備段階を実現するものに見える。であれば、まずDROP TABLE文を実行し、成功したらCREATE TABLE文を実行し、成功したらINSERT INTO文を実行する、という段取りでしょうか。

退会済みユーザー

2021/05/21 08:58

try～catchは、DB接続から切断まででひとつ、クエリー一つ一つの実行ごとにもさらに。この記事、読むべし。 https://qiita.com/mpyw/items/b00b72c5c95aac573b71

行動規範の内容に同意します

あなたの回答