123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134 |
- <?php
- /**
- * CakePHP(tm) : Rapid Development Framework (https://cakephp.org)
- * Copyright (c) Cake Software Foundation, Inc. (https://cakefoundation.org)
- *
- * Licensed under The MIT License
- * For full copyright and license information, please see the LICENSE.txt
- * Redistributions of files must retain the above copyright notice.
- *
- * @copyright Copyright (c) Cake Software Foundation, Inc. (https://cakefoundation.org)
- * @link https://cakephp.org CakePHP(tm) Project
- * @since 3.0.0
- * @license https://opensource.org/licenses/mit-license.php MIT License
- */
- namespace Cake\Database\Driver;
- use Cake\Database\Dialect\PostgresDialectTrait;
- use Cake\Database\Driver;
- use PDO;
- /**
- * Class Postgres
- */
- class Postgres extends Driver
- {
- use PostgresDialectTrait;
- /**
- * Base configuration settings for Postgres driver
- *
- * @var array
- */
- protected $_baseConfig = [
- 'persistent' => true,
- 'host' => 'localhost',
- 'username' => 'root',
- 'password' => '',
- 'database' => 'cake',
- 'schema' => 'public',
- 'port' => 5432,
- 'encoding' => 'utf8',
- 'timezone' => null,
- 'flags' => [],
- 'init' => [],
- ];
- /**
- * Establishes a connection to the database server
- *
- * @return bool true on success
- */
- public function connect()
- {
- if ($this->_connection) {
- return true;
- }
- $config = $this->_config;
- $config['flags'] += [
- PDO::ATTR_PERSISTENT => $config['persistent'],
- PDO::ATTR_EMULATE_PREPARES => false,
- PDO::ATTR_ERRMODE => PDO::ERRMODE_EXCEPTION
- ];
- if (empty($config['unix_socket'])) {
- $dsn = "pgsql:host={$config['host']};port={$config['port']};dbname={$config['database']}";
- } else {
- $dsn = "pgsql:dbname={$config['database']}";
- }
- $this->_connect($dsn, $config);
- $this->_connection = $connection = $this->getConnection();
- if (!empty($config['encoding'])) {
- $this->setEncoding($config['encoding']);
- }
- if (!empty($config['schema'])) {
- $this->setSchema($config['schema']);
- }
- if (!empty($config['timezone'])) {
- $config['init'][] = sprintf('SET timezone = %s', $connection->quote($config['timezone']));
- }
- foreach ($config['init'] as $command) {
- $connection->exec($command);
- }
- return true;
- }
- /**
- * Returns whether php is able to use this driver for connecting to database
- *
- * @return bool true if it is valid to use this driver
- */
- public function enabled()
- {
- return in_array('pgsql', PDO::getAvailableDrivers());
- }
- /**
- * Sets connection encoding
- *
- * @param string $encoding The encoding to use.
- * @return void
- */
- public function setEncoding($encoding)
- {
- $this->connect();
- $this->_connection->exec('SET NAMES ' . $this->_connection->quote($encoding));
- }
- /**
- * Sets connection default schema, if any relation defined in a query is not fully qualified
- * postgres will fallback to looking the relation into defined default schema
- *
- * @param string $schema The schema names to set `search_path` to.
- * @return void
- */
- public function setSchema($schema)
- {
- $this->connect();
- $this->_connection->exec('SET search_path TO ' . $this->_connection->quote($schema));
- }
- /**
- * {@inheritDoc}
- */
- public function supportsDynamicConstraints()
- {
- return true;
- }
- }
|