PHPPgAdmin\Misc::getDatabaseAccessor()

Complexity

Conditions	13
Paths	26

Size

Total Lines	83
Code Lines	42

Duplication

Lines	0
Ratio	0 %

Importance

Changes

0

<?php
    public function getDatabaseAccessor($database = '', $server_id = null)
    {
        $lang = $this->lang;

        if ($server_id !== null) {
            $this->server_id = $server_id;
        }

        $server_info = $this->getServerInfo($this->server_id);

        if ($this->_no_db_connection || !isset($server_info['username'])) {
            return;
        }

        if ($this->data === null) {
            try {
                $_connection = $this->getConnection($database, $this->server_id);
            } catch (\Exception $e) {
                $this->setServerInfo(null, null, $this->server_id);
                $this->setNoDBConnection(true);
                $this->setErrorMsg($e->getMessage());

                return;
            }

            //$this->prtrace('_connection', $_connection);
            if (!$_connection) {
                $this->container->utils->addError($lang['strloginfailed']);
                $this->setErrorMsg($lang['strloginfailed']);

                return;
            }
            // Get the name of the database driver we need to use.
            // The description of the server is returned in $platform.
            $_type = $_connection->getDriver($platform);

            //$this->prtrace(['type' => $_type, 'platform' => $platform, 'pgVersion' => $_connection->conn->pgVersion]);

            if ($_type === null) {
                $errormsg = sprintf($lang['strpostgresqlversionnotsupported'], $this->postgresqlMinVer);
                $this->container->utils->addError($errormsg);
                $this->setErrorMsg($errormsg);

                return;
            }
            $_type = '\PHPPgAdmin\Database\\'.$_type;

            $this->setServerInfo('platform', $platform, $this->server_id);
            $this->setServerInfo('pgVersion', $_connection->conn->pgVersion, $this->server_id);

            // Create a database wrapper class for easy manipulation of the
            // connection.

            $this->data = new $_type($_connection->conn, $this->conf);
            $this->data->platform = $_connection->platform;
            $this->data->server_info = $server_info;
            $this->data->conf = $this->conf;
            $this->data->lang = $this->lang;

            //$this->data->getHelpPages();

            //$this->prtrace('help_page has ' . count($this->data->help_page) . ' items');

            /* we work on UTF-8 only encoding */
            $this->data->execute("SET client_encoding TO 'UTF-8'");

            if ($this->data->hasByteaHexDefault()) {
                $this->data->execute('SET bytea_output TO escape');
            }
        }

        if ($this->_no_db_connection === false && $this->getDatabase() !== null && isset($_REQUEST['schema'])) {
            $status = $this->data->setSchema($_REQUEST['schema']);

            if ($status != 0) {
                $this->container->utils->addError($this->lang['strbadschema']);
                $this->setErrorMsg($this->lang['strbadschema']);

                return;
            }
        }

        return $this->data;
    }