質問をすることでしか得られない、回答やアドバイスがある。

15分調べてもわからないことは、質問しよう!

ただいまの
回答率

88.05%

DBのテーブルの上書きでのトランザクションがうまくいきません MYSQL

解決済

回答 2

投稿

  • 評価
  • クリップ 0
  • VIEW 537

score 11

DBのテーブルの上書きでのトランザクションがうまくいきません

CSVを読み込み、DBのテーブルを上書きするものを作成しているのですが、途中でエラーがおこってもトランザクションが働かず、
$del = "DELETE FROM ".$table_name;
$dbh->query($del);
この処理のみ通ってしまいます。
どうすればうまく上書きができますか?

それとも、インサートよりも、UPDATE又はREPLACEのほうがいいですか?
(テーブルにデータがあれば上書き、なければインサート)という風にしたいです。
プライマリキーは設定していません。
idはオートインクリメント

<?php
// DB情報
$dbh       = null;
$db_admin = "sbiccicms_admin_local_auto";
$db_common = "sbiccicms_common_local_auto";
$db_front = "sbiccicms_front_local_auto";
$user      = 'root';
$pass      = '';

// URlファイルパス取得
$get_dir      = __FILE__;
$get_dir_path = dirname($get_dir);
$csv_path     = glob($get_dir_path.'/categoris/categori.csv');
$csv_color     = glob($get_dir_path.'/categoris/category_colors.csv');

$table_name = "categories";

try {
    // DB接続
    $dbh = new PDO('mysql:host=127.0.0.1; dbname='. $db_front.'; charset=utf8', $user, $pass);

    $sql = "SET AUTOCOMMIT=0" ;
    $dbh->query($sql);

    //例外処理を投げる(スロー)ようにする
    $dbh->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);

    // トランザクション開始
    $dbh->beginTransaction();

    $del = "DELETE FROM ".$table_name;
    $dbh->query($del);
    $auto_reset = "ALTER TABLE ".$table_name." auto_increment = 1;";
    $dbh->query($auto_reset);

    // color読み込み
    if (($handle_color = fopen($csv_color[0], "r")) !== FALSE) {
        // ファイルポインタ有効時
        $color = [];
        while ($handle_color && !feof($handle_color)) {
            $input_color = fgetcsv($handle_color);
            if (!$input_color) {
                continue;
            }

            // エンコード
            if ($input_color[1]==="") {
                    continue;
                }
                $input_color[1] = mb_convert_encoding($input_color[1], 'UTF-8', 'SJIS-win');
            $color[] = $input_color[1];
        }
    }
    fclose($handle_color);

    // CSVファイルインサート準備
    $insert = "INSERT INTO ".$table_name." (site_id, parent_id, name, pass, sort, level, color, user_id, created) VALUES (:site_id, :parent_id, :name, :pass, :sort, :level, :color, :user_id, cast(now() as datetime))";
    $insert_start = $dbh->prepare($insert);
    if (!$insert_start) {
        throw new Exception('インサート準備失敗');
    }


    // CSVファイルインサート
    if (($handle = fopen($csv_path[0], "r")) !== FALSE) {
        // ファイルポインタ有効時
        $title_skip = 0;
        $co = 1;
        while ($handle && !feof($handle)) {
            $input_csv = fgetcsv($handle);
            if ($title_skip < 2) {
                $title_skip++;
                continue;
            }
            if (!$input_csv) {
                continue;
            }

            // エンコード
            $count_input_csv = count($input_csv);
            for ($i=1;$i<$count_input_csv;$i++) {
                if ($input_csv[$i]==="") {
                    continue;
                }
                $input_csv[$i] = mb_convert_encoding($input_csv[$i], 'UTF-8', 'SJIS-win');
            }

            // 実行
            $synonyms_check = $insert_start->execute([':site_id' => $input_csv[1], ':parent_id' => $co, ':name' => $input_csv[3], ':pass' => $input_csv[4], ':sort' => $input_csv[5], ':level' => $input_csv[6], ':color' => $color[$co], ':user_id' => $input_csv[8]]);
            if (!$synonyms_check) {
                throw new Exception('インサート失敗');
            }
            $co++;
        }
    }

    // 接続終了
    fclose($handle);
    $insert_start = null;

    //  エラー  //
    $insert_users_check = $dbh>query($insert_site_configs);

    // コミット
    $dbh->commit();

} catch (PDOException $e) {
    // ロールバック
    $dbh->rollBack();
    echo 'DB接続エラー:' . $e->getMessage();
    die();
} catch (Throwable $e) {
    echo "ロールバック";
    // ロールバック
    $dbh->rollBack();
    echo '失敗:' . $e->getMessage();
    die();
}

$dbh = null;

?>
  • 気になる質問をクリップする

    クリップした質問は、後からいつでもマイページで確認できます。

    またクリップした質問に回答があった際、通知やメールを受け取ることができます。

    クリップを取り消します

  • 良い質問の評価を上げる

    以下のような質問は評価を上げましょう

    • 質問内容が明確
    • 自分も答えを知りたい
    • 質問者以外のユーザにも役立つ

    評価が高い質問は、TOPページの「注目」タブのフィードに表示されやすくなります。

    質問の評価を上げたことを取り消します

  • 評価を下げられる数の上限に達しました

    評価を下げることができません

    • 1日5回まで評価を下げられます
    • 1日に1ユーザに対して2回まで評価を下げられます

    質問の評価を下げる

    teratailでは下記のような質問を「具体的に困っていることがない質問」、「サイトポリシーに違反する質問」と定義し、推奨していません。

    • プログラミングに関係のない質問
    • やってほしいことだけを記載した丸投げの質問
    • 問題・課題が含まれていない質問
    • 意図的に内容が抹消された質問
    • 過去に投稿した質問と同じ内容の質問
    • 広告と受け取られるような投稿

    評価が下がると、TOPページの「アクティブ」「注目」タブのフィードに表示されにくくなります。

    質問の評価を下げたことを取り消します

    この機能は開放されていません

    評価を下げる条件を満たしてません

    評価を下げる理由を選択してください

    詳細な説明はこちら

    上記に当てはまらず、質問内容が明確になっていない質問には「情報の追加・修正依頼」機能からコメントをしてください。

    質問の評価を下げる機能の利用条件

    この機能を利用するためには、以下の事項を行う必要があります。

質問への追記・修正、ベストアンサー選択の依頼

  • m.ts10806

    2020/05/11 17:50

    回答依頼いただきましたが、既についた回答で進めることは可能かと思います。

    キャンセル

回答 2

+1

まずはデバッグとして
$dbh->commit();
の箇所を
$dbh->rollback();
にして、元に戻るかどうかチェックするところからです

投稿

  • 回答の評価を上げる

    以下のような回答は評価を上げましょう

    • 正しい回答
    • わかりやすい回答
    • ためになる回答

    評価が高い回答ほどページの上位に表示されます。

  • 回答の評価を下げる

    下記のような回答は推奨されていません。

    • 間違っている回答
    • 質問の回答になっていない投稿
    • スパムや攻撃的な表現を用いた投稿

    評価を下げる際はその理由を明確に伝え、適切な回答に修正してもらいましょう。

  • 2020/05/11 16:00

    行ったところやはり
    $del = "DELETE FROM ".$table_name;
    $dbh->query($del);
    のみ通ってしまいますね。
    DELETEはトランザクションに対応してないのでしょうか

    キャンセル

  • 2020/05/11 16:10

    いえ、DELETEは大丈夫なはずです。
    categoriesテーブルの詳細な情報を提示ください

    キャンセル

  • 2020/05/11 16:12

    CREATE TABLE `categories` (
    `id` bigint(20) NOT NULL COMMENT 'カテゴリID',
    `site_id` bigint(20) NOT NULL COMMENT 'サイトID',
    `parent_id` bigint(20) DEFAULT NULL COMMENT '親カテゴリID',
    `name` varchar(100) DEFAULT NULL COMMENT 'カテゴリ名',
    `pass` varchar(50) DEFAULT NULL COMMENT '実ディレクトリ名',
    `sort` int(11) NOT NULL COMMENT 'ソート番号',
    `level` tinyint(4) DEFAULT NULL COMMENT 'カテゴリ階層(大:1 中:2)',
    `color` varchar(50) DEFAULT NULL COMMENT 'カテゴリカラー',
    `user_id` bigint(20) NOT NULL COMMENT '更新者',
    `created` datetime DEFAULT NULL COMMENT '作成日付',
    `modified` datetime DEFAULT NULL COMMENT '更新日付',
    `deleted` datetime DEFAULT NULL COMMENT '削除日付'
    ) ENGINE=InnoDB DEFAULT CHARSET=utf8;

    ALTER TABLE `categories`
    ADD PRIMARY KEY (`id`),
    ADD KEY `parent_id` (`parent_id`),
    ADD KEY `level` (`level`);

    ALTER TABLE `categories`
    MODIFY `id` bigint(20) NOT NULL AUTO_INCREMENT COMMENT 'カテゴリID', AUTO_INCREMENT=24;
    COMMIT;

    キャンセル

checkベストアンサー

0

MySQLでは、ALTER TABLEは強制的にトランザクション外となり、それ以前に行われていたトランザクションもすべてコミットしてしまいます(8.0のマニュアル)。

投稿

  • 回答の評価を上げる

    以下のような回答は評価を上げましょう

    • 正しい回答
    • わかりやすい回答
    • ためになる回答

    評価が高い回答ほどページの上位に表示されます。

  • 回答の評価を下げる

    下記のような回答は推奨されていません。

    • 間違っている回答
    • 質問の回答になっていない投稿
    • スパムや攻撃的な表現を用いた投稿

    評価を下げる際はその理由を明確に伝え、適切な回答に修正してもらいましょう。

  • 2020/05/11 16:24

    ALTER TABLE文を削除しても
    $del = "TRUNCATE TABLE ".$table_name;
    $dbh->query($del);
    のみ通ってしまいますね

    キャンセル

  • 2020/05/11 16:29

    TRUNCATE TABLEも同様に、トランザクションに含められない命令です。

    キャンセル

  • 2020/05/11 16:35

    なるほど、、、では上書きをトランザクションで行うにはどの構文がふさわしいでしょうか?
    (テーブルにデータがない場合も含め)

    キャンセル

  • 2020/05/11 22:02

    そもそもトランザクション制御の目的は何ですか?
    オートナンバーをリセットしているようですけど、オートナンバーもトランザクション制御はされませんよ。

    キャンセル

15分調べてもわからないことは、teratailで質問しよう!

  • ただいまの回答率 88.05%
  • 質問をまとめることで、思考を整理して素早く解決
  • テンプレート機能で、簡単に質問をまとめられる

同じタグがついた質問を見る