カプセル化されたトランザクション処理

Question

PHPのDAOとDTOを使用した場合のロールバック処理に悩んでいます。
現在の構成は下記になっており、複数テーブルをまたがる依存性の高いトランザクション処理を実行した場合に、
どのようにしたら、シンプルに実装できますでしょうか？

＜現在の構成＞
・DAO、DTOはテーブルと1対1の構成で実装
・DAOのトリガーはビジネスロジック層で実装
・DBのオープンやトランザクションの実行はDAOのコンストラクタ、デコンストラクタで実装

＜DB構成＞
・aテーブル
・bテーブル
・cテーブル

＜フォルダ構成＞
プロジェクト
├DAO
│├a_dao.php
│├b_dao.php
│└c_dao.php
│
├DTO
│├a_dto.php
│├a_dto.php
│└a_dto.php
│
└LOGIC
└logic.php

やはり、ビジネスロジック層でDBコネクト及びトランザクション開始など実施したほうがよいでしょうか？
シンプルな実装方法がございましたら、ご教授くださいませ。
また、サンプルなどいただけましたら幸いでございます。

以上、よろしくお願いいたします。

Answer 1

スマホからざっくりとしたイメージで発言したので、語弊がありました。
フロントコントローラで実装するのではなく、アクションコントローラ側で実装を行います。

フロントコントローラは確かにルーティングおよびそれに関わる制御を司る役割です。
しかし、だからこそ、アクションコントローラを実行するぞ！、アクションコントローラの実行が終わったぞ！というタイミングを捕捉できるのもフロントコントローラです。

ご提示頂いたコードは、申し訳ありませんが、よく理解できませんでした。。。
(なぜDatabaseManagerを継承するようなクラスにビジネスロジック的なコードが？？)

以下、1アクセス1トランザクションの一例です。
勿論、DIや要・不要を考えたら、無駄が発生する方法論でもありますが、無条件に簡素的に実装する方法となります。
色々はしょってますが、ニュアンスでご理解頂ければと・・・。

FrontBaseContrtoller

// なんやかんやrootingして対象actionを決定
$actionClass = hoge;
$actionName = fuga;
try {
  $actionClass->actionExecuting($actionName, $params); // パラメータとかも送ればいい
  $actionClass->$actionName(); // rootingで決定されたアクセスへdispatch
  $actionClass->actionSucceed($actionName, $params); // パラメータとかも送ればいい

} catch(Exception $e) {
  $actionClass->actionFailed($actionName, $params, $e); // パラメータとかも送ればいい
}

ActionBaseController

class ActionBaseController {
  public function actionExecuting($actionName, $params) {
  }

  public function actionSucceed($actionName, $params) {
  }

  public function actionFailed($actionName, $params, $e) {
  }
}

ActionController

class ActionController extends ActionBaseController {
  public function actionExecuting($actionName, $params) {
    parent::actionExecuting($actionName, $params);
    // 設定ファイルなどから接続情報を取得し、DB接続して、Managerに登録さす
    // $db = DbManager::create("DB1");
  }

  public function actionSucceed($actionName, $params) {
    parent::actionSucceed($actionName, $params);
    // Managerが管理しているDBをすべてCommit
    // DbManager::commitAll();
  }

  public function actionFailed($actionName, $params, $e) {
    parent::actionFailed($actionName, $params, $e);
    // Managerが管理しているDBをすべてRollback
    // DbManager::rollbackAll();
}

HogeActionController

class HogeActionController extends ActionController {
  public function page1() {
    $dto = // なんやかんやしたDTO
    $dao1 = new TableDao1();
    $dao1->ins($dto);
    $dao2 = new TableDao2();
    $dao2->ins($dto);
  }
}

DbAccessor

class DbAccessor {
  private $_dbName;

  public function __construct($dbName) {
    $this->_dbName = $dbName;
  }

  public function insert($tableName, $entity) {
    // $tableNameに$entityの値をプレースホルダーなどを利用してinsert
    // $db = $DbManager::get($this->_dbName);
    // $db->execute($query);
  }

  // 似たような実装で
  public function select() { }
  public function delete() { }
  public function update() { }
  public function execute() { }
  
  // クエリの生成用にこんなメソッドがあったり
  private function _createQuery() { }
}

Dao1

class Table1Dao {
  private $_db = new DbAccessor("DB1");

  public function ins($dto) {
    // なんやかんやして、dtoからentityを生成
    //$entity = new Table1Entity();

    $this->_db->insert("Table1", $entity);
  }
}

Dao2

class Table2Dao {
  private $_db = new DbAccessor("DB1");

  public function ins($dto) {
    // なんやかんやして、dtoからentityを生成
    //$entity = new Table2Entity();

    $this->_db->insert("Table2", $entity);
  }
}

みたいな。
もうちょっと全体的に、まともに考える必要はありますが(雑すぎ)。

Comments

[otagroove]

お付き合い頂いてありがとうございます！
無事、把握することが出来ました！

少し、こちらの方も試行錯誤して実装してみたいと思います。

Answer 2

フロントコントローラーなどによってDB接続できませんか？
DAOでは、どのDBを利用してアクセスするかを決定したうえでクエリ発行となると思います。（特に複数DBを利用する場合）

1アクセス1トランザクションとし、DAOでコミット、ロールバックは一切行わない、正常終了でコミット、例外発生でロールバック、ではダメでしょうか？

Comments

[otagroove]

ご回答ありがとうございます！
知識不足もあり教えて頂きたいのですが、フロントコントローラはアクションコントローラを呼び出すためのものだと認識しております。

よって呼び出し後のアクションコントローラ内でDB接続を実装するというのがベストだという認識でよろしいでしょうか？

>1アクセス1トランザクションとし、DAOでコミット、ロールバックは一切行わない、正常終了でコミット、例外発>生でロールバック、ではダメでしょうか？

こちらも考えたのですが、再利用性を考慮するとあまりピンと来なかったため、
テーブル単位にDAOを作成しております。
ご意見を頂きたいのですが、下記の用に考えてみたのですがいかがでしょうか？
（近場に同職がいないため、よろしくお願いいたします（汗））

function execHoge ($dto) {
$dao = new dao();

try {
$dao->ins($dto);
$dao->ins2($dto);
} catch (Exception $e) {
throw $e;
}
}

function execHoge2 ($dto) {
$dao = new dao();

try {
$dao->del($dto);
$dao->del($dto);
} catch (Exception $e) {
throw $e;
}
}

class aaa extends DatabaseManager {
pricate $mysqli = null;

function __construct() {
parent::__construct();
$this->mysqli = parent::getConnect();
}

function __destruct() {
parent::getCloseDB($this->mysqli);
}

function test(dto) {
try {
execHoge(dto);
execHoge2(dto);
mysqli_commit($this->mysqli);
} catch (Exception $e) {
mysqli_rollback($this->mysqli);
}
}
}