【PHP】CakePHP4.X系で複数のモデルを同一トランザクションで処理したかった。

こんにちは。
もう少しわかりやすくしてほしい。
只野です。

はい。最近なんとなくCakePHPに触れている私です。しっかりと学習すれば強力なフレームワークなんでしょうが、私が思った感想は、DB系の処理がすげー触りにくい。です。

多分SQLとか直接DBへ命令する事を意識させないようにしているのでしょうが、SQLやDBの仕組みをある程度理解している身からするとここまでフレームワークで制御しちゃうの？とか思いました。

なぜこのような事を思ったかと言いますと、複数のテーブルへ登録または更新処理をしようとした時に私は1トランザクションでDB操作を実行し、何かしらエラーが発生したら全てロールバック（なかったことに）する処理を組もうとしたのですが、CakePHPのフレームワークで利用できる「Model」層と言われるDB操作系の処理が普通に使うとトランザクションを「Model」単位で発行していたのです。

「Model」層を完全に無視してDB処理を実装することもできましたが、「Model」層を完全に無視するとCakePHPを使う理由が薄れていくなと思い使う方向で考えました。

そんでまずこんな処理を書いてみますがこれは失敗例です。

1use Cake\Datasource\ConnectionManager;
2use Cake\Core\Exception\Exception;
3 
4public function sample() {
5    //モデルロード
6    $this->loadModel('table1');
7    $this->loadModel('table2');
8    //DB接続コネクション取得
9    $connection = ConnectionManager::get('default');
10    //トランザクション開始
11    $connection->begin();
12 
13    try {
14        $table1 = $this->table1->newEmptyEntity();
15        //値設定とか
16        $this->table1->save($table1);
17 
18        $table2 = $this->table2->newEmptyEntity();
19        //値設定とか
20        $this->table2->save($table2 );
21         
22        //コミット
23        $connection->commit();
24    } catch ( Exception $ex ) {
25        //例外処理（ロールバック）
26        $connection->rollback();
27    }
28}

上記のような形で処理を組み「table1」でDB処理成功後、「table2」の処理で何かした例外エラーが発生したとします。ここでは当然「table1」も例外処理に含まれているロールバックにより「table1」のDB操作内容が取消されていなければなりません。
ですが上記コードではロールバックされません。Web検索するとCakePHPの4.X以前のバージョンであれば上記内容でロールバックされます。との記事を多数見かけましたが、4.Xから仕様が変わったのか普通にコミットされています。

上記コード何が問題になるのか詳しく調べたところ、まずCakePHPのsaveメソッドはDB操作処理が正常終了の場合、デフォルトで「commit」するという事。余計なお世話です。

次にDBコネクションが何もしなければ「Model」単位で発行するという事。DBコネクションがどこかで一つだけ使うようにフレームワークで制御してくれと思います。「Model」が別であれば別々のコネクションが利用されています。上記例の場合、「table1」、「table2」は別々のコネクションが発行されています。

上記2点の問題を解消すれば1トランザクションでDB処理を全て解決できます。フレームワークのソースコードを直接見た結果、複数のモデルを利用する場合に同一トランザクションで処理するには、下記実装が一応解決策になります。

1use Cake\Datasource\ConnectionManager;
2use Cake\Core\Exception\Exception;
3 
4public function sample() {
5    //モデルロード
6    $this->loadModel('table1');
7    $this->loadModel('table2');
8    //DB接続コネクション取得
9    $connection = ConnectionManager::get('default');
10    //トランザクション開始
11    $connection->begin();
12    //Modelへ利用するコネクションを設定
13    $this->table1->setConnection($connection);
14    $this->table2->setConnection($connection);
15 
16    try {
17        $table1 = $this->table1->newEmptyEntity();
18        //値設定とか
19        //オートコミット解除
20        $this->table1->save($table1, ['atomic' => false]);
21 
22        $table2 = $this->table2->newEmptyEntity();
23        //値設定とか
24        //オートコミット解除
25        $this->table2->save($table2 ['atomic' => false]);
26         
27        //コミット
28        $connection->commit();
29    } catch ( Exception $ex ) {
30        //例外処理（ロールバック）
31        $connection->rollback();
32    }
33}