編集履歴

質問編集履歴

補足

2020/05/11 03:58

投稿

kaito2414

スコア11

test CHANGED Viewed

File without changes

test CHANGED Viewed

@@ -1,4 +1,6 @@
-トランザクション処理が失敗しても通ってしまいます
+トランザクション処理が失敗しても通ってしまいます。
+1つ目は成功、2つ目は失敗にしていますが、2が失敗しても1はそのまま実行されてしまいます。
 [参考サイト](https://gray-code.com/php/transaction-by-using-pdo/)
@@ -8,21 +10,7 @@
-テーブルを作成するコードなのですが、
-$dbh->query($table_cpppp);
-という存在しない変数名を宣言し失敗するようにしているのですが、
-ロールバック失敗と表示されるもののテーブルは作成されてしまいます。
+2つ目のインサート文は引数があっていません
-トランザクション処理は簡単に言うとトランザクション内がエラーなく成功するとそのコードを実行し、途中でエラーが出たら、処理内容を破棄し、実行しないという処理ですよね？
-原因を教えていただけないでしょうか。
@@ -34,17 +22,15 @@
 $dbh       = null;
-$db_admin = "sbiccicms_admin_local2";
+$db_admin = "sbiccicms_admin_local_auto";
-$db_common = "sbiccicms_common_local2";
+$db_common = "sbiccicms_common_local_auto";
-$db_front = "sbiccicms_front_local2";
+$db_front = "sbiccicms_front_local_auto";
 $user      = 'root';
 $pass      = '';
-$table_name = "categories";
@@ -52,7 +38,7 @@
 	// DB接続
-	$dbh = new PDO('mysql:host=127.0.0.1; dbname='. $db_front.'; charset=utf8', $user, $pass);
+	$dbh = new PDO('mysql:host=127.0.0.1; dbname='. $db_admin.'; charset=utf8', $user, $pass);
@@ -68,21 +54,27 @@
-	// サブテーブル作成
-	$table_cp = 'create table test_import like '.$table_name;
+	$table_cp = 'create table test_import like site_configs';
 	$table_create = $dbh->query($table_cp);
-　　　　 // 失敗
+	$table_cp = 'create table error like site_configs';
-	$dbh->query($table_cpppp);
+	$table_create = $dbh->query($table_cp);
+	$insert_site_configs = "INSERT INTO test_import (site_url, site_name, wrt_user_id, created, modified) VALUES ('CCI', 'CCIホーム', 99, cast(now() as datetime),cast(now() as datetime))";
-	echo "コミット";
+	$insert_users_check = $dbh->query($insert_site_configs);
+	$insert_site_configs = "INSERT INTO error (site_url, site_name, wrt_user_id, created, modified) VALUES ('CCIホーム', 99, cast(now() as datetime),cast(now() as datetime))";
+	$insert_users_check = $dbh->query($insert_site_configs);
@@ -94,6 +86,16 @@
 } catch (PDOException $e) {
+	// ロールバック
+	$dbh->rollBack();
+	echo 'DB接続エラー：' . $e->getMessage();
+	die();
+} catch (Throwable $e) {
 	echo "ロールバック";
 	// ロールバック
@@ -101,6 +103,8 @@
 	$dbh->rollBack();
 	echo '失敗：' . $e->getMessage();
+	die();
 }
@@ -117,343 +121,3 @@
 ?>
 ```
-```php
-<?php
-// DB情報
-$dbh       = null;
-$db_admin = "sbiccicms_admin_local2";
-$db_common = "sbiccicms_common_local2";
-$db_front = "sbiccicms_front_local2";
-$user      = 'root';
-$pass      = '';
-$table_name = "categories";
-try {
-	// DB接続
-	$dbh = new PDO('mysql:host=127.0.0.1; dbname='. $db_front.'; charset=utf8', $user, $pass);
-	// トランザクション開始
-	$dbh->beginTransaction();
-	// 存在しないテーブルにUPDATE
-	$sql = "UPDATE categories SET age = 25 WHERE id = 4";
-	// クエリ実行
-	$res = $dbh->query($sql);
-		// サブテーブル作成
-	$table_cp = 'create table test_import like '.$table_name;
-	$table_create = $dbh->query($table_cp);
-	if (!$table_create) {
-		throw new Exception('テーブル作成失敗');
-	}
-// 強制的にロールバックする
-	$dbh->rollBack();
-} catch (PDOException $e) {
-	echo "ロールバック";
-	// ロールバック
-	$dbh->rollBack();
-	echo '失敗：' . $e->getMessage();
-}
-// DB接続終了
-$dbh = null;
-?>
-```
-### **※実現したいこと**
-以下のコードにトランザクション処理を導入し、サブテーブル作成工程をなくす。
-insertをロールバック
-```php
-<?php
-// DB情報
-$dbh       = null;
-$db_admin = "sbiccicms_admin_local2";
-$db_common = "sbiccicms_common_local2";
-$db_front = "sbiccicms_front_local2";
-$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);
-	// トランザクション処理
-	// サブテーブル作成
-	$table_cp = 'create table test_import like '.$table_name;
-	$table_create = $dbh->query($table_cp);
-	if (!$table_create) {
-		$delet_table = "DROP TABLE test_import";
-		$dbh->query($delet_table);
-		throw new Exception('テーブル作成失敗');
-	}
-	// 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 test_import (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) {
-		$delet_table = "DROP TABLE test_import";
-		$dbh->query($delet_table);
-		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) {
-				$delet_table = "DROP TABLE test_import";
-				$dbh->query($delet_table);
-				throw new Exception('インサート失敗');
-			}
-			$co++;
-		}
-	}
-	// 上書き
-	$delet_table = "DROP TABLE $table_name";
-	$dbh->query($delet_table);
-	$rename = "ALTER TABLE test_import RENAME $table_name";
-	$dbh->query($rename);
-	// 接続終了
-	fclose($handle);
-	$insert_start = null;
-	$dbh = null;
-} catch (PDOException $e) {
-	echo 'DB接続エラー：' . $e->getMessage();
-}
-?>
-```

補足

2020/05/11 03:58

投稿

kaito2414

スコア11

test CHANGED Viewed

File without changes

test CHANGED Viewed

@@ -222,6 +222,8 @@
 以下のコードにトランザクション処理を導入し、サブテーブル作成工程をなくす。
+insertをロールバック

実現したいことを追加

2020/05/11 02:56

投稿

kaito2414

スコア11

test CHANGED Viewed

File without changes

test CHANGED Viewed

@@ -213,3 +213,245 @@
 ?>
 ```
+### **※実現したいこと**
+以下のコードにトランザクション処理を導入し、サブテーブル作成工程をなくす。
+```php
+<?php
+// DB情報
+$dbh       = null;
+$db_admin = "sbiccicms_admin_local2";
+$db_common = "sbiccicms_common_local2";
+$db_front = "sbiccicms_front_local2";
+$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);
+	// トランザクション処理
+	// サブテーブル作成
+	$table_cp = 'create table test_import like '.$table_name;
+	$table_create = $dbh->query($table_cp);
+	if (!$table_create) {
+		$delet_table = "DROP TABLE test_import";
+		$dbh->query($delet_table);
+		throw new Exception('テーブル作成失敗');
+	}
+	// 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 test_import (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) {
+		$delet_table = "DROP TABLE test_import";
+		$dbh->query($delet_table);
+		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) {
+				$delet_table = "DROP TABLE test_import";
+				$dbh->query($delet_table);
+				throw new Exception('インサート失敗');
+			}
+			$co++;
+		}
+	}
+	// 上書き
+	$delet_table = "DROP TABLE $table_name";
+	$dbh->query($delet_table);
+	$rename = "ALTER TABLE test_import RENAME $table_name";
+	$dbh->query($rename);
+	// 接続終了
+	fclose($handle);
+	$insert_start = null;
+	$dbh = null;
+} catch (PDOException $e) {
+	echo 'DB接続エラー：' . $e->getMessage();
+}
+?>
+```

補足

2020/05/11 02:27

投稿

kaito2414

スコア11

test CHANGED Viewed

File without changes

test CHANGED Viewed

@@ -4,6 +4,10 @@
+環境：MYSQL
 テーブルを作成するコードなのですが、
 $dbh->query($table_cpppp);
@@ -113,3 +117,99 @@
 ?>
 ```
+```php
+<?php
+// DB情報
+$dbh       = null;
+$db_admin = "sbiccicms_admin_local2";
+$db_common = "sbiccicms_common_local2";
+$db_front = "sbiccicms_front_local2";
+$user      = 'root';
+$pass      = '';
+$table_name = "categories";
+try {
+	// DB接続
+	$dbh = new PDO('mysql:host=127.0.0.1; dbname='. $db_front.'; charset=utf8', $user, $pass);
+	// トランザクション開始
+	$dbh->beginTransaction();
+	// 存在しないテーブルにUPDATE
+	$sql = "UPDATE categories SET age = 25 WHERE id = 4";
+	// クエリ実行
+	$res = $dbh->query($sql);
+		// サブテーブル作成
+	$table_cp = 'create table test_import like '.$table_name;
+	$table_create = $dbh->query($table_cp);
+	if (!$table_create) {
+		throw new Exception('テーブル作成失敗');
+	}
+// 強制的にロールバックする
+	$dbh->rollBack();
+} catch (PDOException $e) {
+	echo "ロールバック";
+	// ロールバック
+	$dbh->rollBack();
+	echo '失敗：' . $e->getMessage();
+}
+// DB接続終了
+$dbh = null;
+?>
+```