Source for file Transaction.php

Documentation is available at Transaction.php

  1. <?php
  2. /**
  3.  * Teeple2 - PHP5 Web Application Framework inspired by Seasar2
  4.  *
  5.  * PHP versions 5
  6.  *
  7.  * LICENSE: This source file is subject to version 3.0 of the PHP license
  8.  * that is available through the world-wide-web at the following URI:
  9.  * http://www.php.net/license/3_0.txt.  If you did not receive a copy of
  10.  * the PHP License and are unable to obtain it through the web, please
  11.  * send a note to license@php.net so we can mail you a copy immediately.
  12.  *
  13.  * @package     teeple
  14.  * @author      Mitsutaka Sato <miztaka@gmail.com>
  15.  * @license     http://www.php.net/license/3_0.txt  PHP License 3.0
  16.  */
  17.  
  18. /**
  19.  * Transactionクラスです。
  20.  * 
  21.  * @package teeple
  22.  */
  23. class Teeple_Transaction {
  24.  
  25.     /**
  26.      * @var Teeple_DataSource 
  27.      */
  28.     private $dataSource;
  29.     public function setComponent_Teeple_DataSource($c) {
  30.         $this->dataSource = $c;
  31.     }
  32.     
  33.     /**
  34.      * コネクションを格納する配列です。
  35.      */
  36.     private $connection = array();
  37.  
  38.     private $isstart = false;
  39.     private $isclose = false;
  40.     
  41.     /**
  42.      * @var Logger 
  43.      */
  44.     private $log;
  45.     
  46.     /**
  47.      * コンストラクタ
  48.      *
  49.      */
  50.     public function __construct() {
  51.         $this->log = LoggerManager::getLogger(get_class($this));
  52.     }
  53.     
  54.     /**
  55.      * トランザクションを開始します。
  56.      *
  57.      */
  58.     public function start() {
  59.         if ($this->isclose == true) {
  60.             $this->log->error('トランザクションを開始しようとしましたが既に終了しています。');
  61.             throw new Teeple_Exception('トランザクションを開始しようとしましたが既に終了しています。');
  62.         }
  63.         if ($this->isstart == true) {
  64.             $this->log->info("トランザクションを開始しようとしましたが既に開始されています。");
  65.             return;
  66.         }
  67.         $this->log->info("トランザクションを開始します。");
  68.         foreach($this->connection as $name => $conn) {
  69.             $conn->beginTransaction();
  70.         }
  71.         $this->isstart = true;
  72.     }
  73.     
  74.     /**
  75.      * トランザクションをコミットします。
  76.      *
  77.      */
  78.     public function commit() {
  79.         if ($this->isclose == true) {
  80.             $this->log->info('トランザクションをコミットしようとしましたが既に終了しています。');
  81.             throw new Teeple_Exception('トランザクションをコミットしようとしましたが既に終了しています。');
  82.         }
  83.         if ($this->isstart == false) {
  84.             $this->log->info("トランザクションをコミットしようとしましたがまだ開始されていません。");
  85.             return;
  86.         }
  87.         $this->log->info("トランザクションをコミットします。");
  88.         foreach($this->connection as $name => $conn) {
  89.             $conn->commit();
  90.         }
  91.         $this->isclose = true;
  92.         $this->log->info("トランザクションをコミットしました。");        
  93.         return;
  94.     }
  95.     
  96.     /**
  97.      * トランザクションをロールバックします。
  98.      *
  99.      */
  100.     public function rollback() {
  101.         if ($this->isclose == true) {
  102.             $this->log->error('トランザクションをロールバックしようとしましたが既に終了しています。');
  103.             throw new Teeple_Exception('トランザクションをロールバックしようとしましたが既に終了しています。');
  104.         }
  105.         if ($this->isstart == false) {
  106.             $this->log->info("トランザクションをロールバックしようとしましたがまだ開始されていません。");
  107.             return;
  108.         }
  109.         $this->log->info("トランザクションをロールバックします。");
  110.         foreach($this->connection as $name => $conn) {
  111.             $conn->rollback();
  112.         }
  113.         $this->isclose = true;
  114.         $this->log->info("トランザクションをロールバックしました。");
  115.         return;
  116.     }
  117.     
  118.     /**
  119.      * Entityを取得するマジックメソッドです。
  120.      *
  121.      * @param string $name 
  122.      * @return Teeple_ActiveRecord 
  123.      */
  124.     public function __get($name) {
  125.         $this->log->debug("エンティティ $name を取得します。");
  126.         if (preg_match('/^Entity_/', $name)) {
  127.             $ref = new ReflectionClass($name);
  128.             $ds = $ref->getStaticPropertyValue('_DATASOURCE');
  129.             if ($ds == "") {
  130.                 $ds = DEFAULT_DATASOURCE;
  131.             }
  132.             $this->log->debug("データソース: {$ds}");
  133.             if (isset($this->connection[$ds])) {
  134.                 $conn = $this->connection[$ds];
  135.             } else {
  136.                 $conn = $this->dataSource->getConnection($ds);
  137.                 $this->connection[$ds] = $conn;
  138.                 if ($this->isstart) {
  139.                     $conn->beginTransaction();
  140.                 }
  141.             }
  142.             return new $name($conn->getDB());
  143.         }
  144.         return NULL;
  145.     }
  146.     
  147.     public function isStarted() {
  148.         return $this->isstart;
  149.     }
  150.     
  151.     public function isClosed() {
  152.         return $this->isclose;
  153.     }
  154.     
  155. }
  156.  
  157. ?>
Documentation generated on Mon, 26 Apr 2010 09:00:01 +0900 by phpDocumentor 1.4.3