[Cake]CakePHPで意識の低いトランザクション commit rollback

2017/03/08

cakeで複数のテーブルにまたがったトランザクション管理をしたい。

ただ、個人的にcakephpを使うとき、あまり規約に従って作ってなくて、db操作もmodel->query()を使いまくっている。

そのときにcommitとかrollbackとか、どうすれば出来るべなと確認。

やり方

基本的にはやっぱりquery()でbeginとかcommitとか発行すればOK。

#Modelにメソッドを用意

   /**
    * transaction begin
    */
    public function begin_transaction(){
        $sql = "BEGIN; ";
        $this->query($sql);
    }


    /**
    * commit
    */
    public function commit(){
        $sql = "COMMIT";
        $this->query($sql);

    }

    /**
    * rollback
    */
    public function rollback(){
        $sql = "ROLLBACK;";
        $this->query($sql);
    }

/**

* transaction begin

public function begin_transaction(){

$sql = "BEGIN; ";

$this->query($sql);

}

/**

* commit

public function commit(){

$sql = "COMMIT";

$this->query($sql);

}

/**

* rollback

public function rollback(){

$sql = "ROLLBACK;";

$this->query($sql);

}

#Controller

$this->Campaign->begin_transaction();

// 異なるテーブルの登録処理(modelでqueryでがっつり発行)
$res = [];
$res[] = $this->Campaign->save_table1($data);
$res[] = $this->Campaign->save_table2($data);

if(in_array(false,  $res)){
    $this->Campaign->rollback();
    //$this->redirect('error');
}else{
    $this->Campaign->commit();
}

$this->Campaign->begin_transaction();

// 異なるテーブルの登録処理(modelでqueryでがっつり発行)

$res = [];

$res[] = $this->Campaign->save_table1($data);

$res[] = $this->Campaign->save_table2($data);

if(in_array(false, $res)){

$this->Campaign->rollback();

//$this->redirect('error');

}else{

$this->Campaign->commit();

}

ちなみに、cakeでもExceptionは普通のtry catchでOK。

＃例外があったらfalse

＃cake内での try catch 例
try{
    $this->query($sql, $param) ;
    return true;

}catch (Exception $e){
    return false;
}

＃cake内での try catch 例

try{

$this->query($sql, $param) ;

return true;

}catch (Exception $e){

return false;

}

#例外があったら、そのまま例外を投げる。

こっちだと、上でtry-catchで拾えてcommit,rollbackの制御が出来る。

try{
    $this->query($sql, $param) ;
    return true;

}catch (Exception $e){
    throw $e;　//例外をそのまま投げる。
}

try{

$this->query($sql, $param) ;

return true;

}catch (Exception $e){

throw $e;　//例外をそのまま投げる。

}

またトランザクション中にハンドリングしていない例外が発生しても、コミットはされない。よかた。

- cake, php

PREV: [js] chart.jsのグラフをwkhtmltopdfでpdfに保存する
NEXT: [AWS]基本事項メモ

: [PHP][PDO]prepareでのバインド方法整理

データをstmtに渡す部分をちょくちょく待ちがえて混乱するのでメモ参考:htt …

: WordPressで作ったページと同じデザインで、好きなコンテンツを好きな場所に作りたい

下記のわがままをかなえるため、調査そもそも、wordpressでブログを作った …

: CentOSをインストールしたときにいつも最初にやること(apache mysql phpのインストール)

SElinuxの無効化 iptableの無効化 apacheのインストール・自動 …

: 【Cake】一般用テーブルと、管理用テーブルを分ける場合のログイン（Auth）の使い方・整理

まず1つサービス・ログイン機能これは ①Userテーブル、UserModel、 …

[php]期間指定で月一覧、日付一覧のデータ取得

#日付けで取得(yyyy-mm-dd)
function get_period_date (){

    $startDate = date('Y-m-d', strtotime('2018-01-06'));
    $endDate = date('Y-m-d', strtotime("2018-01-09"));
    $diff = (strtotime($endDate) - strtotime($startDate)) / ( 60 * 60 * 24);
    for($i = 0; $i <= $diff; $i++) {
        $period[] = date('Y-m-d', strtotime($startDate . '+' . $i . 'days'));
    }
    return $period;
}


#月(yyyy-mm)で取得
function get_period_month(){
    $startDate = date('Y-m-d', strtotime('2017-01-06'));
    $endDate = date('Y-m-d', strtotime("2018-01-09"));
    $diff = (strtotime($endDate) - strtotime($startDate)) / ( 60 * 60 * 24 * 30);
    for($i = 0; $i <= $diff; $i++) {
        $period[] = date('Y-m', strtotime($startDate . '+' . $i . 'month'));
    }
    return $period;

}