<?php /** * TDbTransaction class file * * @author Qiang Xue <qiang.xue@gmail.com> * @link http://www.pradosoft.com/ * @copyright Copyright © 2006 PradoSoft * @license http://www.pradosoft.com/license/ * @version $Id$ * @package System.Data */ Prado::using('System.Data.TDbDataReader'); /** * TDbTransaction class. * * TDbTransaction represents a DB transaction. * It is usually created by calling {@link TDbConnection::beginTransaction}. * * The following code is a common scenario of using transactions: * <code> * try * { * $transaction=$connection->beginTransaction(); * $connection->createCommand($sql1)->execute(); * $connection->createCommand($sql2)->execute(); * //.... other SQL executions * $transaction->commit(); * } * catch(Exception $e) * { * $transaction->rollBack(); * } * </code> * * @author Qiang Xue <qiang.xue@gmail.com> * @version $Id$ * @package System.Data * @since 3.0 */ class TDbTransaction extends TComponent { private $_connection=null; private $_active; /** * Constructor. * @param TDbConnection the connection associated with this transaction * @see TDbConnection::beginTransaction */ public function __construct(TDbConnection $connection) { $this->_connection=$connection; $this->setActive(true); } /** * Commits a transaction. * @throws TDbException if the transaction or the DB connection is not active. */ public function commit() { if($this->_active && $this->_connection->getActive()) { $this->_connection->getPdoInstance()->commit(); $this->_active=false; } else throw new TDbException('dbtransaction_transaction_inactive'); } /** * Rolls back a transaction. * @throws TDbException if the transaction or the DB connection is not active. */ public function rollback() { if($this->_active && $this->_connection->getActive()) { $this->_connection->getPdoInstance()->rollBack(); $this->_active=false; } else throw new TDbException('dbtransaction_transaction_inactive'); } /** * @return TDbConnection the DB connection for this transaction */ public function getConnection() { return $this->_connection; } /** * @return boolean whether this transaction is active */ public function getActive() { return $this->_active; } /** * @param boolean whether this transaction is active */ protected function setActive($value) { $this->_active=TPropertyValue::ensureBoolean($value); } } ?>