interface/modules/zend_modules/library/Zend/Db/Sql/Platform/Oracle/SelectDecorator.php

   1 <?php
   2 /**
   3  * Zend Framework (http://framework.zend.com/)
   4  *
   5  * @link      http://github.com/zendframework/zf2 for the canonical source repository
   6  * @copyright Copyright (c) 2005-2013 Zend Technologies USA Inc. (http://www.zend.com)
   7  * @license   http://framework.zend.com/license/new-bsd New BSD License
   8  */
   9
  10 namespace Zend\Db\Sql\Platform\Oracle;
  11
  12 use Zend\Db\Adapter\AdapterInterface;
  13 use Zend\Db\Adapter\Driver\DriverInterface;
  14 use Zend\Db\Adapter\ParameterContainer;
  15 use Zend\Db\Adapter\Platform\PlatformInterface;
  16 use Zend\Db\Adapter\StatementContainerInterface;
  17 use Zend\Db\Sql\ExpressionInterface;
  18 use Zend\Db\Sql\Platform\PlatformDecoratorInterface;
  19 use Zend\Db\Sql\Select;
  20
  21 class SelectDecorator extends Select implements PlatformDecoratorInterface
  22 {
  23
  24     /**
  25      * @var Select
  26      */
  27     protected $select = null;
  28
  29     /**
  30      * @param Select $select
  31      */
  32     public function setSubject($select)
  33     {
  34         $this->select = $select;
  35     }
  36
  37     /**
  38      * @see \Zend\Db\Sql\Select::renderTable
  39      */
  40     protected function renderTable($table, $alias = null)
  41     {
  42         return $table . ' ' . $alias;
  43     }
  44
  45     /**
  46      * @param AdapterInterface $adapter
  47      * @param StatementContainerInterface $statementContainer
  48      */
  49     public function prepareStatement(AdapterInterface $adapter, StatementContainerInterface $statementContainer)
  50     {
  51         // localize variables
  52         foreach (get_object_vars($this->select) as $name => $value) {
  53             $this->{$name} = $value;
  54         }
  55         // set specifications
  56         unset($this->specifications[self::LIMIT]);
  57         unset($this->specifications[self::OFFSET]);
  58
  59         $this->specifications['LIMITOFFSET'] = null;
  60         parent::prepareStatement($adapter, $statementContainer);
  61     }
  62
  63     /**
  64      * @param PlatformInterface $platform
  65      * @return string
  66      */
  67     public function getSqlString(PlatformInterface $platform = null)
  68     {
  69         // localize variables
  70         foreach (get_object_vars($this->select) as $name => $value) {
  71             $this->{$name} = $value;
  72         }
  73
  74         // set specifications
  75         unset($this->specifications[self::LIMIT]);
  76         unset($this->specifications[self::OFFSET]);
  77
  78         $this->specifications['LIMITOFFSET'] = null;
  79         return parent::getSqlString($platform);
  80     }
  81
  82     /**
  83      * @param PlatformInterface $platform
  84      * @param DriverInterface $driver
  85      * @param ParameterContainer $parameterContainer
  86      * @param $sqls
  87      * @param $parameters
  88      * @return null
  89      */
  90     protected function processLimitOffset(PlatformInterface $platform, DriverInterface $driver = null, ParameterContainer $parameterContainer = null, &$sqls, &$parameters)
  91     {
  92         if ($this->limit === null && $this->offset === null) {
  93             return null;
  94         }
  95
  96         $selectParameters = $parameters[self::SELECT];
  97
  98         $starSuffix = $platform->getIdentifierSeparator() . self::SQL_STAR;
  99         foreach ($selectParameters[0] as $i => $columnParameters) {
 100             if ($columnParameters[0] == self::SQL_STAR || (isset($columnParameters[1]) && $columnParameters[1] == self::SQL_STAR) || strpos($columnParameters[0], $starSuffix)) {
 101                 $selectParameters[0] = array(array(self::SQL_STAR));
 102                 break;
 103             }
 104             if (isset($columnParameters[1])) {
 105                 array_shift($columnParameters);
 106                 $selectParameters[0][$i] = $columnParameters;
 107             }
 108         }
 109
 110         if ($this->offset === null) {
 111             $this->offset = 0;
 112         }
 113
 114         // first, produce column list without compound names (using the AS portion only)
 115         array_unshift($sqls, $this->createSqlFromSpecificationAndParameters(
 116             array('SELECT %1$s FROM (SELECT b.%1$s, rownum b_rownum FROM (' => current($this->specifications[self::SELECT])), $selectParameters
 117         ));
 118
 119         if ($parameterContainer) {
 120             if ($this->limit === null) {
 121                 array_push($sqls, ') b ) WHERE b_rownum > (:offset)');
 122                 $parameterContainer->offsetSet('offset', $this->offset, $parameterContainer::TYPE_INTEGER);
 123             } else {
 124                 // create bottom part of query, with offset and limit using row_number
 125                 array_push($sqls, ') b WHERE rownum <= (:offset+:limit)) WHERE b_rownum >= (:offset + 1)');
 126                 $parameterContainer->offsetSet('offset', $this->offset, $parameterContainer::TYPE_INTEGER);
 127                 $parameterContainer->offsetSet('limit', $this->limit, $parameterContainer::TYPE_INTEGER);
 128             }
 129         } else {
 130             if ($this->limit === null) {
 131                 array_push($sqls, ') b ) WHERE b_rownum > ('. (int) $this->offset. ')'
 132                 );
 133             } else {
 134                 array_push($sqls, ') b WHERE rownum <= ('
 135                         . (int) $this->offset
 136                         . '+'
 137                         . (int) $this->limit
 138                         . ')) WHERE b_rownum >= ('
 139                         . (int) $this->offset
 140                         . ' + 1)'
 141                 );
 142             }
 143         }
 144
 145         $sqls[self::SELECT] = $this->createSqlFromSpecificationAndParameters(
 146             $this->specifications[self::SELECT], $parameters[self::SELECT]
 147         );
 148     }
 149
 150
 151     protected function processJoins(PlatformInterface $platform, DriverInterface $driver = null, ParameterContainer $parameterContainer = null)
 152     {
 153         if (!$this->joins) {
 154             return null;
 155         }
 156
 157         // process joins
 158         $joinSpecArgArray = array();
 159         foreach ($this->joins as $j => $join) {
 160             $joinSpecArgArray[$j] = array();
 161             // type
 162             $joinSpecArgArray[$j][] = strtoupper($join['type']);
 163             // table name
 164             $joinSpecArgArray[$j][] = (is_array($join['name']))
 165                 ? $platform->quoteIdentifier(current($join['name'])) . ' ' . $platform->quoteIdentifier(key($join['name']))
 166                 : $platform->quoteIdentifier($join['name']);
 167             // on expression
 168             $joinSpecArgArray[$j][] = ($join['on'] instanceof ExpressionInterface)
 169                 ? $this->processExpression($join['on'], $platform, $driver, $this->processInfo['paramPrefix'] . 'join')
 170                 : $platform->quoteIdentifierInFragment($join['on'], array('=', 'AND', 'OR', '(', ')', 'BETWEEN')); // on
 171             if ($joinSpecArgArray[$j][2] instanceof StatementContainerInterface) {
 172                 if ($parameterContainer) {
 173                     $parameterContainer->merge($joinSpecArgArray[$j][2]->getParameterContainer());
 174                 }
 175                 $joinSpecArgArray[$j][2] = $joinSpecArgArray[$j][2]->getSql();
 176             }
 177         }
 178
 179         return array($joinSpecArgArray);
 180     }
 181
 182 }