CakePHPのコントローラ内にtry/catchを仕込み、トランザクションの一連の処理を実装します。データベースを絡めた処理の場合に、その整合性を保つ為に、エラーが出たら処理前の状態に戻して終了させたい場合があります。そんな時に必要なのは、トランザクションという仕組みです。また、それを実現する為に基本的には、エラーが発生し例外が投げられた際にそれをキャッチし独自の処理を実装する必要があります。

CakePHP3のトランザクションとtry/catchと例外処理と。

データベースを絡めた処理の場合に、その整合性を保つ為に、エラーが出たら処理前の状態に戻して終了させたい場合があります。そんな時に必要なのは、トランザクションという仕組みです。
また、それを実現する為に基本的には、エラーが発生し例外が投げられた際にそれをキャッチし独自の処理を実装する必要があります。
今回は CakePHP のコントローラ内に try/catch を仕込み、トランザクションの一連の処理を実装します。
<h2 id="contents">Contents</h2>
<ol>
<li><a href="#%E9%96%8B%E7%99%BA%E7%92%B0%E5%A2%83">開発環境</a></li>
<li><a href="#trycatch-%E3%81%AE%E5%9F%BA%E6%9C%AC%E5%BD%A2">try/catch の基本形</a></li>
<li><a href="#%E3%83%88%E3%83%A9%E3%83%B3%E3%82%B6%E3%82%AF%E3%82%B7%E3%83%A7%E3%83%B3%E3%81%AE%E5%9F%BA%E6%9C%AC%E5%BD%A2">トランザクションの基本形</a></li>
<li><a href="#%E4%BE%8B%E5%A4%96%E5%87%A6%E7%90%86">例外処理</a></li>
</ol>
<h2 id="開発環境">開発環境</h2>
今回の開発環境は以下の通りです。
<ul>
<li>MySQL 5.7</li>
<li>PHP 7.2</li>
<li>CakePHP 3.6</li>
</ul>
<h2 id="trycatch-の基本形">try/catch の基本形</h2>
まずは try/catch の基本形から。コントローラに対して以下のように記述します。
<pre><code class="hljs language-php">&#x3C;?php

namespace App\Controller;

use App\Controller\AppController;

class SamplesController extends AppController
{
 public function index()
 {

 try {

 // ここに通常の処理を書く

 } catch(\Exception $e) {
 // ここに例外が発生した際の処理を書く
 }

 }
}
</code></pre>
通常の処理を記述し、それらが実行していく中で例外が発生すると、try 内の処理を break し、catch の方に処理が移ります。
これに関しては CakePHP とか PHP フレームワークとかは関係なく、PHP 全体で共通の書式なります。
<h2 id="トランザクションの基本形">トランザクションの基本形</h2>
トランザクションの基本形を以下に示します。
<pre><code class="hljs language-php">&#x3C;?php

namespace App\Controller;

use App\Controller\AppController;
use Cake\Datasource\ConnectionManager;

class SamplesController extends AppController
{
 public function index()
 {
 $connection = ConnectionManager::get('default');
 // トランザクション開始
 $connection->begin();
 try {

 // 何らかの処理
 $this->hoge();

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

 } catch(\Exception $e) {
 // 例外に対する処理

 // ロールバック
 $connection->rollback();
 }
 }
}
</code></pre>
トランザクションを使うには ConnectionManager が必要なので use しています。
そしてインスタンスを渡す際に get('default') を行っていますが、この「default 」というのが、cakephp/config/app.php で設定されている Datasources プロパティの default 部分になります。つまり、この deafult部分で設定されたデータベースに対してトランザクションを行う。という事になります。
その他はよくある形です。トランザクションを開始し、例外が発生しなければコミット、例外が発生すればロールバックを行います。
<h2 id="例外処理">例外処理</h2>
ここからはおまけです。例外を catch したら try から抜けて例外処理部分に移行するわけですが、引数で渡される変数 $e に関しては、以下のメソッドがあります。
<pre><code class="hljs language-php">$e->getCode(); // HTTP ステータスコード
$e->getMessage(); // エラーメッセージ
$e->getFile(); // 例外が発生したファイル（クラス）のフルパス
$e->getLine(); // 例外が投げられた行
$e->getPrevious(); // 前の例外を返す
$e->getTraceAsString(); // エラーの詳細
$e->getTrace(); // エラーの詳細を配列に格納したもの
</code></pre>
場合によりますが、例外が発生した際に上記メソッドで取得できる情報は以下のようなものになります。
<pre><code class="hljs language-php">Array
(
 [getCode] => 501
 [getMessage] => エラーが発生しました
 [getFile] => /var/www/html/cakephp/src/Controller/SamplesController.php
 [getLine] => 203
 [getPrevious] => 
 [getTrace] => Array (
 // 長いので省略
 )
 [getTraceAsString] => // 長いので省略
)
</code></pre>
ではこのベースのソースコードにメソッドを追加して例外を発生させてみます。
<pre><code class="hljs language-php">&#x3C;?php

namespace App\Controller;

use App\Controller\AppController;
use Cake\Datasource\ConnectionManager;

use Cake\Network\Exception\NotImplementedException;

class SamplesController extends AppController
{
 public function index()
 {
 $connection = ConnectionManager::get('default');
 // トランザクション開始
 $connection->begin();
 try {

 // 何らかの処理
 $this->hoge();

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

 } catch(\Exception $e) {
 // 例外に対する処理
 print_r($e);

 // ロールバック
 $connection->rollback();

 }
 }

 public function hoge()
 {
 throw new NotImplementedException(__('例外が発生しました'));
 }
}
</code></pre>
単純に hoge() メソッドを作成し、その中で例外を投げています。
上記の場合、501 エラーを返すために例外クラスである NotImplementedException クラスを use して例外を投げています。
HTTP ステータスコードによってクラスが存在しているので、詳しくは cookbook を参照して適宜使ってください。 
<a href="https://book.cakephp.org/3.0/ja/development/errors.html#id6" rel="noopener noreferrer" target="_blank">https://book.cakephp.org/3.0/ja/development/errors.html#id6</a>
<h2 id="まとめ">まとめ</h2>
作業は以上になります。データの整合性を保つ必要のあるデータベース処理にはトランザクションは大事なので是非試してみてください。
また、PHP では全ての動きに対して例外が投げられるわけではありません。 CakePHP などの PHP フレームワークでは、エラー等が発生した際に例外を投げそれをキャッチして通知したりロギングしたりしてくれますが、投げられない例外はそもそもキャッチされないので、exec() などは独自に例外を throw する処理を書きましょう。

Author