Subversion-Projekte lars-tiefland.prado

<?php
/**
 * TCachingStatement class file.
 *
 * @author Wei Zhuo <weizhuo[at]gmail[dot]com>
 * @link http://www.pradosoft.com/
 * @copyright Copyright &copy; 2005-2008 PradoSoft
 * @license http://www.pradosoft.com/license/
 * @version $Id: TCachingStatement.php 2541 2008-10-21 15:05:13Z qiang.xue $
 * @package System.Data.SqlMap.Statements
 */

/**
 * TCacheingStatement class.
 *
 * @author Wei Zhuo <weizhuo[at]gmail[dot]com>
 * @version $Id: TCachingStatement.php 2541 2008-10-21 15:05:13Z qiang.xue $
 * @package System.Data.SqlMap.Statements
 * @since 3.1
 */
class TCachingStatement implements IMappedStatement
{
        private $_mappedStatement;

        public function __construct(TMappedStatement $statement)
        {
                $this->_mappedStatement = $statement;
        }

        public function getID()
        {
                return $this->_mappedStatement->getID();
        }

        public function getStatement()
        {
                return $this->_mappedStatement->getStatement();
        }

        public function getManager()
        {
                return $this->_mappedStatement->getManager();
        }

        public function executeQueryForMap($connection, $parameter,$keyProperty, $valueProperty=null,  $skip=-1, $max=-1,$delegate=null)
        {
                $sql = $this->createCommand($connection, $parameter, $skip, $max);
                $key = $this->getCacheKey(array(clone($sql), $keyProperty, $valueProperty,$skip, $max));
                $map = $this->getStatement()->getCache()->get($key);
                if(is_null($map))
                {
                        $map = $this->_mappedStatement->runQueryForMap(
                                $connection, $parameter, $sql, $keyProperty, $valueProperty,  $delegate);
                        $this->getStatement()->getCache()->set($key, $map);
                }
                return $map;
        }

        public function executeUpdate($connection, $parameter)
        {
                return $this->_mappedStatement->executeUpdate($connection, $parameter);
        }

        public function executeInsert($connection, $parameter)
        {
                return $this->executeInsert($connection, $parameter);
        }

        public function executeQueryForList($connection, $parameter, $result=null, $skip=-1, $max=-1, $delegate=null)
        {
                $sql = $this->createCommand($connection, $parameter, $skip, $max);
                $key = $this->getCacheKey(array(clone($sql), $parameter, $skip, $max));
                $list = $this->getStatement()->getCache()->get($key);
                if(is_null($list))
                {
                        $list = $this->_mappedStatement->runQueryForList(
                                $connection, $parameter, $sql, $result, $delegate);
                        $this->getStatement()->getCache()->set($key, $list);
                }
                return $list;
        }

        public function executeQueryForObject($connection, $parameter, $result=null)
        {
                $sql = $this->createCommand($connection, $parameter);
                $key = $this->getCacheKey(array(clone($sql), $parameter));
                $object = $this->getStatement()->getCache()->get($key);
                if(is_null($object))
                {
                        $object = $this->_mappedStatement->runQueryForObject($connection, $sql, $result);
                        $this->getStatement()->getCache()->set($key, $object);
                }
                return $object;
        }

        protected function getCacheKey($object)
        {
                $cacheKey = new TSqlMapCacheKey($object);
                return $cacheKey->getHash();
        }

        protected function createCommand($connection, $parameter, $skip=null, $max=null)
        {
                return $this->_mappedStatement->getCommand()->create($this->getManager(),
                                        $connection, $this->getStatement(), $parameter, $skip, $max);
        }
}