質問編集履歴

修正

2020/06/29 02:35

投稿

yakan

スコア19

title CHANGED Viewed

File without changes

body CHANGED Viewed

@@ -36,20 +36,14 @@
     try {
 		// wp_fruits1 を保存
-		$table = 'wp_fruits1';
-		$data  = $fruits_datas['fruits1'];
-		$format = ['%s'];
-		$fruits1 = $wpdb->insert( $table, $data, $format );
+		$fruits1 = $wpdb->insert( 'wp_fruits1', $fruits_datas['fruits1'], ['%s'] );
 		if( ! $fruits1 ){
 			throw new Exception("fruits1 の INSERT でエラー");
 		}else{
 			$fruits1_id = $wpdb->insert_id;
 			// wp_fruits2 を保存
-			$table = 'wp_fruits2';
-			$data  = $fruits_datas['fruits2'];
-			$format = ['%s'];
-			$fruits2 = $wpdb->insert( $table, $data, $format );
+			$fruits2 = $wpdb->insert( 'wp_fruits2', $fruits_datas['fruits2'], ['%s'] );
 			if( ! $fruits2 ){
 				throw new Exception("fruits2 の INSERT でエラー");
 			}else{
@@ -89,20 +83,14 @@
 	try {
 		// wp_vegetables1 を保存
-		$table = 'wp_vegetables1';
-		$data  = $vegetable_datas['vegetables1'];
-		$format = ['%s'];
-		$vegetables1 = $wpdb->insert( $table, $data, $format );
+		$vegetables1 = $wpdb->insert( 'wp_vegetables1', $vegetable_datas['vegetables1'], ['%s'] );
 		if( ! $vegetables1 ){
 			throw new Exception("vegetables1 の INSERT でエラー");
 		}else{
 			$vegetables1_id = $wpdb->insert_id;
 			// wp_vegetables2 を保存
-			$table = 'wp_vegetables2';
-			$data  = $vegetable_datas['vegetables2'];
-			$format = ['%s'];
-			$vegetables2 = $wpdb->insert( $table, $data, $format );
+			$vegetables2 = $wpdb->insert( 'wp_vegetables2', $vegetable_datas['wp_vegetables2'], ['%s'] );
 			if( ! $vegetables2 ){
 				throw new Exception("vegetables2 の INSERT でエラー");
 			}else{

コード誤字訂正

2020/06/29 02:35

投稿

yakan

スコア19

title CHANGED Viewed

File without changes

body CHANGED Viewed

@@ -8,9 +8,9 @@
 親関数`my_insert_wp_fruits`の中で、子関数`my_insert_wp_vegetables`が実行されます。
 （それぞれ独自に実行するケースがあるため独立させています。）
-さて以下1行目の`$val`は、子関数の最後に更新される`wp_vegetables2`テーブルを更新する値ですが、ここを`CREATE`で設定した`VARCHAR(3)`以上の文字にしてエラーを起こしてみました。
+さて以下5行目の`$val`は、子関数の最後に更新される`wp_vegetables2`テーブルを更新する値ですが、ここを`CREATE`で設定した`VARCHAR(3)`以上の文字にしてエラーを起こしてみました。
-しかし`ROLLBACK`が効くのは子関数で`LOCK TABLES`をかけた`wp_vegetables1`と`wp_vegetables2`だけでした。
+しかし`ROLLBACK`が効くのは子関数で`LOCK TABLES`をかけた`wp_vegetables1`と`wp_vegetables2`だけで、`wp_fruits1`と`wp_fruits2`はINSERTが成功してしまうのです。
 これを親関数の`LOCK TABLES`にまでさかのぼって、`wp_fruits1`と`wp_fruits2`も含めて`ROLLBACK`させられませんでしょうか？
@@ -55,6 +55,7 @@
 			}else{
 				$fruits2_id = $wpdb->insert_id;
+				// 以下の子関数でエラーが出たとき、親関数を ROLLBACK させたい
 				$vegetable_ids = my_insert_wp_vegetables($vegetable_datas);
 				if( isset($vegetable_ids['error']) ){
 					throw new Exception("my_insert_wp_vegetables でエラー");
@@ -62,19 +63,19 @@
 			}
 		}
-        // 問題なければ
+		// 問題なければ
 		$result = ['fruits1_id'=>$fruits1_id,'fruits2_id'=>$fruits2_id];
 		$result = array_merge( $result, $vegetable_ids );
 		$wpdb->query('COMMIT');
-    } catch (Exception $e) {
+	} catch (Exception $e) {
 		$wpdb->query('ROLLBACK');
-        $result = $e->getMessage();
+		$result['error'] = $e->getMessage();
-    } finally {
+	} finally {
-        $wpdb->query('UNLOCK TABLES');
+		$wpdb->query('UNLOCK TABLES');
-    }
+	}
-    return $result;
+	return $result;
 }
 // 子関数 ( wp_vegetables1 と wp_vegetables2 を INSERT )
@@ -84,8 +85,8 @@
 	$sql = "LOCK TABLES wp_vegetables1 WRITE, wp_vegetables2 WRITE";
 	$wpdb->query($sql);
-    $result = null;
+	$result = null;
-    try {
+	try {
 		// wp_vegetables1 を保存
 		$table = 'wp_vegetables1';
@@ -113,14 +114,14 @@
 		$result = ['vegetables1_id'=>$vegetables1_id,'vegetables2_id'=>$vegetables2_id];
 		$wpdb->query('COMMIT');
-    } catch (Exception $e) {
+	} catch (Exception $e) {
 		$wpdb->query('ROLLBACK');
-        $result = $e->getMessage();
+		$result['error'] = $e->getMessage();
-    } finally {
+	} finally {
-        $wpdb->query('UNLOCK TABLES');
+		$wpdb->query('UNLOCK TABLES');
-    }
+	}
-    return $result;
+	return $result;
 }
 // ４つのテーブル作成

加筆

2020/06/29 02:33

投稿

yakan

スコア19

title CHANGED Viewed

File without changes

body CHANGED Viewed

@@ -19,14 +19,14 @@
 create_tables();
 // 実行
-$val = 'val'; // ここを VARCHAR(3) 以上の文字にしてエラーを起こしても、wp_fruits1 と wp_fruits2 は `ROLLBACK`が効かない
+$val = 'val'; // ここを VARCHAR(3) 以上の文字にしてエラーを起こしても、wp_fruits1 と wp_fruits2 は ROLLBACK が効かない
 $fruits_datas = [ 'fruits1'=>['col'=>'val'], 'fruits2'=>['col'=>'val'] ];
 $vegetable_datas = [ 'vegetables1'=>['col'=>'val'], 'vegetables2'=>['col'=>$val] ];
 $result = my_insert_wp_fruits($fruits_datas,$vegetable_datas);
 var_dump( $result );
-// wp_fruits1 と wp_fruits2 を INSERT
+// 親関数 ( wp_fruits1 と wp_fruits2 を INSERT )
-function my_insert_wp_fruits($fruits_datas,$vegetable_datas){
+function my_insert_wp_fruits($fruits_datas,$vegetable_datas=[]){
 	global $wpdb;
 	$wpdb->query('SET autocommit=0');
 	$sql = "LOCK TABLES wp_fruits1 WRITE, wp_fruits2 WRITE";
@@ -77,7 +77,7 @@
     return $result;
 }
-// wp_vegetables1 と wp_vegetables2 を INSERT
+// 子関数 ( wp_vegetables1 と wp_vegetables2 を INSERT )
 function my_insert_wp_vegetables($vegetable_datas){
 	global $wpdb;
 	$wpdb->query('SET autocommit=0');
@@ -139,4 +139,26 @@
 	}
 }
+```
+###試したこと
+自分なりの解決策としては、親関数の方で、「もし子関数を更新するならLOCK TABLESを追加」というコードを下記のように加える方法ですが…
+こういった方法よりも、親関数にさかのぼって`ROLLBACK`させたいと思っています。
+ご指導宜しくお願い申し上げます。
+```php
+function my_insert_wp_fruits($fruits_datas,$vegetable_datas=[]){
+	global $wpdb;
+	$wpdb->query('SET autocommit=0');
+	$sql = "LOCK TABLES wp_fruits1 WRITE, wp_fruits2 WRITE";
+	// もし子関数を更新するならLOCK TABLESを追加
+	if( !empty($vegetable_datas) ){
+		$sql .= ",wp_vegetables1 WRITE, wp_vegetables2 WRITE"
+	}
+	$wpdb->query($sql);
+	// 以下同じ
+}
 ```