database - ZF2 - 複数のテーブルを更新するデータベース トランザクション

Question

ZF2 db トランザクションを使用して複数のテーブルを更新したいと考えています。通常、私は単一のテーブルに対して次のような方法でトランザクションを行います:

 $connection = null;
 try {
        $connection = $this->tableGateway->getAdapter()->getDriver()->getConnection();
        $connection->beginTransaction();
        $this->tableGateway->insert($data);
        $connection->commit();
     }
  catch (Exception $e) {
       if ($connection instanceof \Zend\Db\Adapter\Driver\ConnectionInterface) {
          $connection->rollback();
       }
  }

今、1 つのトランザクション内で 2 つのテーブルを更新したいと考えています。ZF1 では、table2 クラスのインスタンスを作成し、同じトランザクション内で適切なメソッドを呼び出すことでこれを行いました。しかし、モデル内で別のモデルクラスを呼び出す方法がわからないので、ZF1のようにはできません。これは、tbl_invoice に新しい行を追加したり、新しい請求書 (請求書) を入力するときに請求書の t​​bl_runno テーブルの実行番号を更新するなどの単純なタスクに必要です。

Answer 1

コントローラーで次のことができます。

$db = $this->getServiceLocator()->get('Zend\Db\Adapter\Adapter');
$con = $db->getDriver()->getConnection();
$con->beginTransaction();
try {
    //get tables and do sth
    $con->commit();
} catch (Exception $e) {
    $con->rollback();
}

Answer 2

DataMapper 設計パターンを使用します。パターン TableGateway は、データを単一のテーブルに射影する役割を果たします。

• http://akrabat.com/development/objects-in-the-model-layer
• http://akrabat.com/php/objects-in-the-model-layer-part-2
• http://www.slideshare.net/aaronsaray/midwest-php-2013

• https://leanpub.com/zendframework2-en 次のようなものを使用できます。

  namespace ScContent\Mapper;
  
  use Zend\Db\Sql\Sql;
  use Zend\Db\Sql\Select;
  use Zend\Db\Sql\SqlInterface;
  use Zend\Db\Sql\PreparableSqlInterface;
  
  use Zend\Db\Adapter\AdapterInterface;
  use Zend\Db\Adapter\Driver\ResultInterface;
  
  use Zend\Stdlib\Hydrator\ClassMethods;
  use Zend\StdLib\Hydrator\HydratorInterface;
  
  abstract class AbstractDbMapper
  {
      /**
       * @var string
       */
      const JoinInner = Select::JOIN_INNER;
  
      /**
       * @var string
       */
      const JoinLeft = Select::JOIN_LEFT;
  
      /**
       * @var string
       */
      const JoinRight = Select::JOIN_RIGHT;
  
      /**
       * @var Zend\Db\Adapter\AdapterInterface
       */
      protected $_adapter;
  
      /**
       * @var Zend\Db\Sql\SqlInterface
       */
      protected $_sql;
  
      /**
       * @var Zend\Stdlib\HydratorInterface
       */
      protected $_hydrator;
  
      /**
       * @var array
       */
      protected $_tables = array();
  
      /**
       * @param Zend\Db\Adapter\AdapterInterface $adapter
       */
      public function setAdapter(AdapterInterface $adapter)
      {
          $this->_adapter = $adapter;
      }
  
      /**
       * @return Zend\Db\Adapter\AdapterInterface
       */
      public function getAdapter()
      {
          if(!$this->_adapter instanceof AdapterInterface) {
              throw new Exception('Adapter is not installed.');
          }
          return $this->_adapter;
      }
  
      /**
       * @param Zend\Db\Sql\SqlInterface $sql
       */
      public function setSql(SqlInterface $sql)
      {
          $this->_sql = $sql;
      }
  
      /**
       * @return Zend\Db\Sql\SqlInterface
       */
      public function getSql()
      {
          if(!$this->_sql instanceof SqlInterface) {
              $this->_sql = new Sql($this->getAdapter());
          }
          return $this->_sql;
      }
  
      /**
       * @param Zend\Stdlib\HydratorInterface $hydrator
       */
      public function setHydrator(HydratorInterface $hydrator)
      {
          $this->_hydrator = $hydrator;
      }
  
      /**
       * @return Zend\Stdlib\HydratorInterface
       */
      public function getHydrator()
      {
          if(!$this->_hydrator instanceof HydratorInterface) {
              $this->_hydrator = new ClassMethods();
          }
          return $this->_hydrator;
      }
  
      /**
       * @param string $alias
       * @param string $name
       */
      public function setTable($alias, $name)
      {
          $this->_tables[$alias] = $name;
      }
  
      /**
       * @param string $alias
       * @throws Exception
       * @return string
       */
      public function getTable($alias)
      {
          if(!array_key_exists($alias, $this->_tables)) {
              throw new Exception(sprintf("Unknown table alias '%s'.", $alias));
          }
          return $this->_tables[$alias];
      }
  
      /**
       * @return int|null|false
       */
      protected function lastInsertId()
      {
          return $this->adapter->getDriver()->getConnection()->getLastGeneratedValue();
      }
  
      /**
       * @param void
       * @return void
       */
      protected function beginTransaction()
      {
          $this->getAdapter()->getDriver()->getConnection()->beginTransaction();
      }
  
      /**
       * @param void
       * @return void
       */
      protected function commit()
      {
          $this->getAdapter()->getDriver()->getConnection()->commit();
      }
  
      /**
       * @return bool
       */
      protected function inTransaction()
      {
          return $this->getAdapter()->getDriver()
              ->getConnection()->getResource()->inTransaction();
      }
  
      /**
       * @param void
       * @return void
       */
      protected function rollBack()
      {
          $this->getAdapter()->getDriver()->getConnection()->rollBack();
      }
  
      /**
       * @param Zend\Db\Sql\PreparableSqlInterface $sqlObject
       * @return Zend\Db\Adapter\ResultInterface
       */
      protected function execute(PreparableSqlInterface $sqlObject)
      {
          return $this->getSql()->prepareStatementForSqlObject($sqlObject)->execute();
      }
  
      /**
       * @param Zend\Db\Adapter\ResultInterface $source
       * @return array
       */
      protected function toArray(ResultInterface $source)
      {
          $result = array();
          foreach($source as $item) {
              $result[] = $item;
          }
          return $result;
      }
  
      /**
       *
       */
      protected function toString(SqlInterface $sqlObject)
      {
          return $this->getSql()->getSqlStringForSqlObject($sqlObject);
      }
  }
  

  使用例:

  <?php  
  
  
  namespace ScContent\Mapper;
  
  use Zend\Db\Adapter\AdapterInterface;
  
  class ContentMapper extends AbstractDbMapper
  {
      /**
       * @var string
       */
      const ContentTableAlias = 'contentalias';
  
      /**
       * @var string
       */
      const UsersTableAlias = 'usersalias';
  
      /**
       * @param AdapterInterface $adapter
       */
      public function __construct(AdapterInterface $adapter) {
          $this->setAdapter($adapter);
      }
  
      /**
       * @var array
       */
      protected $_tables = array(
          self::ContentTableAlias => 'sc_content',
          self::UsersTableAlias   => 'sc_users'
      );
  
      /**
       * @param integer $id
       * @return null | array
       */
      public function findById($id)
      {
          $select = $this->getSql()->select()
              ->from(array('content' => $this->getTable(self::ContentTableAlias)))
              ->join(
                  array('users' => $this->getTable(self::UsersTableAlias)),
                  'content.author = users.user_id',
                  array('username'),
                  self::JoinInner
              )
              ->where(array('`content`.`id` = ?' => $id));
          return $this->execute($select)->current();
      }
  }