PHPPgAdmin\Database\Connection

Complexity

Total Complexity

22

Size/Duplication

Total Lines	168
Duplicated Lines	0 %

Importance

Changes	5
Bugs	0	Features	0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	getConnectionResult()	0	3	1
A	getLastError()	0	3	1
B	__construct()	0	44	11
B	getDriver()	0	60	9

<?php

/**
 * PHPPgAdmin 6.1.3
 */

namespace PHPPgAdmin\Database;

use Exception;
use PHPPgAdmin\Traits\HelperTrait;
use Slim\Container;

/**
 * @file
 * Class to represent a database connection
 *
 * Id: Connection.php,v 1.15 2008/02/18 21:42:47 ioguix Exp $
 */
class Connection
{
    use HelperTrait;

    public $conn;

    public $platform = 'UNKNOWN';

    protected $container;

    protected $server_info;

    protected $version_dictionary = [
        '13' => 'Postgres13',
        '12' => 'Postgres12',
        '11' => 'Postgres11',
        '10' => 'Postgres10',
        '9.7' => 'Postgres96',
        '9.6' => 'Postgres96',
        '9.5' => 'Postgres95',
        '9.4' => 'Postgres94',
        '9.3' => 'Postgres93',
        '9.2' => 'Postgres92',
        '9.1' => 'Postgres91',
        '9.0' => 'Postgres90',
    ];

    // The backend platform.  Set to UNKNOWN by default.
    private $_connection_result;

    /**
     * Creates a new connection.  Will actually make a database connection.
     *
     * @param array     $server_info
     * @param string    $database    database name
     * @param Container $container
     * @param int       $fetchMode   Defaults to associative.  Override for different behaviour
     */
    public function __construct($server_info, $database, $container, $fetchMode = \ADODB_FETCH_ASSOC)
    {
        $host = $server_info['host'];
        $port = $server_info['port'];
        $sslmode = $server_info['sslmode'];
        $user = $server_info['username'];
        $password = $server_info['password'];

        $this->server_info = $server_info;

        $this->container = $container;

        $this->conn = \ADONewConnection('postgres9');
        //$this->conn->debug = true;
        $this->conn->setFetchMode($fetchMode);

        // Ignore host if null
        if (null === $host || '' === $host) {
            if (null !== $port && '' !== $port) {
                $pghost = ':' . $port;
            } else {
                $pghost = '';
            }
        } else {
            $pghost = \sprintf(
                '%s:%s',
                $host,
                $port
            );
        }

        // Add sslmode to $pghost as needed
        if (('disable' === $sslmode) || ('allow' === $sslmode) || ('prefer' === $sslmode) || ('require' === $sslmode)) {
            $pghost .= ':' . $sslmode;
        } elseif ('legacy' === $sslmode) {
            $pghost .= ' requiressl=1';
        }

        try {
            $this->conn->connect($pghost, $user, $password, $database);
            //$this->prtrace($this->conn);
        } catch (Exception $e) {
            dump($e);
            $this->prtrace($e->getMessage(), $e->getTrace());
        }
    }

    public function getConnectionResult()
    {
        return $this->_connection_result;
    }

    /**
     * Gets the name of the correct database driver to use.  As a side effect,
     * sets the platform.
     *
     * @param string $description A description of the database and version (returns by reference)
     *
     * @return string The driver. e.g. Postgres96
     */
    public function getDriver(&$description)
    {
        $version = null;

        if ($this->conn->_connectionID) {
            $v = \pg_version($this->conn->_connectionID);

            //\PhpConsole\Handler::getInstance()->debug($v, 'pg_version');

            if (isset($v['server'])) {
                $version = $v['server'];
            }
        }
        // If we didn't manage to get the version without a query, query...
        if (!isset($version)) {
            $adodb = new ADOdbBase($this->conn, $this->container, $this->server_info);

            $sql = 'SELECT VERSION() AS version';
            $field = $adodb->selectField($sql, 'version');

            // Check the platform, if it's mingw, set it
            if (\preg_match('/ mingw /i', $field)) {
                $this->platform = 'MINGW';
            }

            $params = \explode(' ', $field);

            if (!isset($params[1])) {
                return null;
            }

            $version = $params[1]; // eg. 8.4.4
        }

        $description = \sprintf(
            'PostgreSQL %s',
            $version
        );

        $version_parts = \explode('.', $version);

        if ((int) (10 <= $version_parts[0])) {
            $major_version = $version_parts[0];
        } else {
            $major_version = \implode('.', [$version_parts[0], $version_parts[1]]);
        }

        //$this->prtrace(['pg_version' => pg_version($this->conn->_connectionID), 'version' => $version, 'major_version' => $major_version]);
        // Detect version and choose appropriate database driver
        if (\array_key_exists($major_version, $this->version_dictionary)) {
            return $this->version_dictionary[$major_version];
        }

        // if major version is less than 9 return null, we don't support it
        if (9 > (int) \mb_substr($version, 0, 1)) {
            return null;
        }

        // If unknown version, then default to latest driver
        return 'Postgres';
    }

    /**
     * Get the last error in the connection.
     *
     * @return string Error string
     */
    public function getLastError()
    {
        return \pg_last_error($this->conn->_connectionID);
    }
}