interface/modules/zend_modules/library/Zend/Db/Sql/Platform/Mysql/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\Mysql;
  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\Platform\PlatformDecoratorInterface;
  18 use Zend\Db\Sql\Select;
  19
  20 class SelectDecorator extends Select implements PlatformDecoratorInterface
  21 {
  22     /**
  23      * @var Select
  24      */
  25     protected $select = null;
  26
  27     /**
  28      * @param Select $select
  29      */
  30     public function setSubject($select)
  31     {
  32         $this->select = $select;
  33     }
  34
  35     /**
  36      * @param AdapterInterface $adapter
  37      * @param StatementContainerInterface $statementContainer
  38      */
  39     public function prepareStatement(AdapterInterface $adapter, StatementContainerInterface $statementContainer)
  40     {
  41         // localize variables
  42         foreach (get_object_vars($this->select) as $name => $value) {
  43             $this->{$name} = $value;
  44         }
  45         parent::prepareStatement($adapter, $statementContainer);
  46     }
  47
  48     /**
  49      * @param PlatformInterface $platform
  50      * @return string
  51      */
  52     public function getSqlString(PlatformInterface $platform = null)
  53     {
  54         // localize variables
  55         foreach (get_object_vars($this->select) as $name => $value) {
  56             $this->{$name} = $value;
  57         }
  58         return parent::getSqlString($platform);
  59     }
  60
  61     protected function processLimit(PlatformInterface $platform, DriverInterface $driver = null, ParameterContainer $parameterContainer = null)
  62     {
  63         if ($this->limit === null) {
  64             return null;
  65         }
  66         if ($driver) {
  67             $sql = $driver->formatParameterName('limit');
  68             $parameterContainer->offsetSet('limit', (int) $this->limit, ParameterContainer::TYPE_INTEGER);
  69         } else {
  70             $sql = $this->limit;
  71         }
  72
  73         return array($sql);
  74     }
  75
  76     protected function processOffset(PlatformInterface $platform, DriverInterface $driver = null, ParameterContainer $parameterContainer = null)
  77     {
  78         if ($this->offset === null) {
  79             return null;
  80         }
  81         if ($driver) {
  82             $parameterContainer->offsetSet('offset', (int) $this->offset, ParameterContainer::TYPE_INTEGER);
  83             return array($driver->formatParameterName('offset'));
  84         }
  85
  86         return array($this->offset);
  87     }
  88 }