Source of file Pgsql.php
Size: 5,461 Bytes - Last Modified: 2014-03-12T23:21:18+01:00
/home/theseer/Downloads/ZendFramework-2.3.0/library/Zend/Db/Adapter/Driver/Pgsql/Pgsql.php
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228 | <?php /** * Zend Framework (http://framework.zend.com/) * * @link http://github.com/zendframework/zf2 for the canonical source repository * @copyright Copyright (c) 2005-2014 Zend Technologies USA Inc. (http://www.zend.com) * @license http://framework.zend.com/license/new-bsd New BSD License */ namespace Zend\Db\Adapter\Driver\Pgsql; use Zend\Db\Adapter\Driver\DriverInterface; use Zend\Db\Adapter\Exception; use Zend\Db\Adapter\Profiler; class Pgsql implements DriverInterface, Profiler\ProfilerAwareInterface { /** * @var Connection */ protected $connection = null; /** * @var Statement */ protected $statementPrototype = null; /** * @var Result */ protected $resultPrototype = null; /** * @var null|Profiler\ProfilerInterface */ protected $profiler = null; /** * @var array */ protected $options = array( 'buffer_results' => false ); /** * Constructor * * @param array|Connection|resource $connection * @param null|Statement $statementPrototype * @param null|Result $resultPrototype * @param array $options */ public function __construct($connection, Statement $statementPrototype = null, Result $resultPrototype = null, $options = null) { if (!$connection instanceof Connection) { $connection = new Connection($connection); } $this->registerConnection($connection); $this->registerStatementPrototype(($statementPrototype) ?: new Statement()); $this->registerResultPrototype(($resultPrototype) ?: new Result()); } public function setProfiler(Profiler\ProfilerInterface $profiler) { $this->profiler = $profiler; if ($this->connection instanceof Profiler\ProfilerAwareInterface) { $this->connection->setProfiler($profiler); } if ($this->statementPrototype instanceof Profiler\ProfilerAwareInterface) { $this->statementPrototype->setProfiler($profiler); } return $this; } /** * @return null|Profiler\ProfilerInterface */ public function getProfiler() { return $this->profiler; } /** * Register connection * * @param Connection $connection * @return Pgsql */ public function registerConnection(Connection $connection) { $this->connection = $connection; $this->connection->setDriver($this); return $this; } /** * Register statement prototype * * @param Statement $statement * @return Pgsql */ public function registerStatementPrototype(Statement $statement) { $this->statementPrototype = $statement; $this->statementPrototype->setDriver($this); // needs access to driver to createResult() return $this; } /** * Register result prototype * * @param Result $result * @return Pgsql */ public function registerResultPrototype(Result $result) { $this->resultPrototype = $result; return $this; } /** * Get database platform name * * @param string $nameFormat * @return string */ public function getDatabasePlatformName($nameFormat = self::NAME_FORMAT_CAMELCASE) { if ($nameFormat == self::NAME_FORMAT_CAMELCASE) { return 'Postgresql'; } return 'PostgreSQL'; } /** * Check environment * * @throws Exception\RuntimeException * @return bool */ public function checkEnvironment() { if (!extension_loaded('pgsql')) { throw new Exception\RuntimeException('The PostgreSQL (pgsql) extension is required for this adapter but the extension is not loaded'); } } /** * Get connection * * @return Connection */ public function getConnection() { return $this->connection; } /** * Create statement * * @param string|null $sqlOrResource * @return Statement */ public function createStatement($sqlOrResource = null) { $statement = clone $this->statementPrototype; if (is_string($sqlOrResource)) { $statement->setSql($sqlOrResource); } if (!$this->connection->isConnected()) { $this->connection->connect(); } $statement->initialize($this->connection->getResource()); return $statement; } /** * Create result * * @param resource $resource * @return Result */ public function createResult($resource) { $result = clone $this->resultPrototype; $result->initialize($resource, $this->connection->getLastGeneratedValue()); return $result; } /** * Get prepare Type * * @return array */ public function getPrepareType() { return self::PARAMETERIZATION_POSITIONAL; } /** * Format parameter name * * @param string $name * @param mixed $type * @return string */ public function formatParameterName($name, $type = null) { return '$#'; } /** * Get last generated value * * @param string $name * @return mixed */ public function getLastGeneratedValue($name = null) { return $this->connection->getLastGeneratedValue($name); } } |