Lagdo\DbAdmin\Driver\PgSql\Db\Server

Complexity

Total Complexity

21

Size/Duplication

Total Lines	133
Duplicated Lines	0 %

Importance

Changes	2
Bugs	0	Features	0

14 Methods

Rating	Name	Duplication	Size	Complexity
A	createDatabase()	0	5	2
A	databaseCollation()	0	3	1
A	renameDatabase()	0	7	1
A	statusVariables()	0	2	1
A	processes()	0	3	2
A	databases()	0	5	1
A	databaseSize()	0	7	3
A	processAttr()	0	6	3
A	routineLanguages()	0	3	1
A	variables()	0	3	1
A	collations()	0	4	1
A	isSystemSchema()	0	4	1
A	dropDatabase()	0	8	2
A	isInformationSchema()	0	3	1

<?php

namespace Lagdo\DbAdmin\Driver\PgSql\Db;

use Lagdo\DbAdmin\Driver\Db\Server as AbstractServer;

use Lagdo\DbAdmin\Driver\Db\StatementInterface;

use function in_array;
use function is_a;
use function intval;

class Server extends AbstractServer
{
    /**
     * @inheritDoc
     */
    public function databases(bool $flush)
    {
        $query = "SELECT datname FROM pg_database WHERE has_database_privilege(datname, 'CONNECT') " .
            "AND datname not in ('postgres','template0','template1') ORDER BY datname";
        return $this->driver->values($query);
    }

    /**
     * @inheritDoc
     */
    public function databaseSize(string $database)
    {
        $statement = $this->driver->execute("SELECT pg_database_size(" . $this->driver->quote($database) . ")");
        if (is_a($statement, StatementInterface::class) && ($row = $statement->fetchRow())) {
            return intval($row[0]);
        }
        return 0;
    }

    /**
     * @inheritDoc
     */
    public function databaseCollation(string $database, array $collations)
    {
        return $this->driver->result("SELECT datcollate FROM pg_database WHERE datname = " . $this->driver->quote($database));
    }

    /**
     * @inheritDoc
     */
    public function collations()
    {
        //! supported in CREATE DATABASE
        return [];
    }

    /**
     * @inheritDoc
     */
    public function isInformationSchema(string $database)
    {
        return $database == "information_schema";
    }

    /**
     * @inheritDoc
     */
    public function isSystemSchema(string $database)
    {
        return in_array($database, ['information_schema',
            'pg_catalog', 'pg_toast', 'postgres', 'template0', 'template1']);
    }

    /**
     * @inheritDoc
     */
    public function createDatabase(string $database, string $collation)
    {
        $result = $this->driver->execute("CREATE DATABASE " . $this->driver->escapeId($database) .
            ($collation ? " ENCODING " . $this->driver->escapeId($collation) : ""));
        return $result !== false;
    }

    /**
     * @inheritDoc
     */
    public function dropDatabase(string $database)
    {
        // Cannot drop the connected database.
        if ($this->driver->database() === $database) {
            return false;
        }
        $result = $this->driver->execute('DROP DATABASE ' . $this->driver->escapeId($database));
        return $result !== false;
    }

    /**
     * @inheritDoc
     */
    public function renameDatabase(string $name, string $collation)
    {
        //! current database cannot be renamed
        $currName = $this->driver->escapeId($this->driver->database());
        $nextName = $this->driver->escapeId($name);
        $result = $this->driver->execute("ALTER DATABASE $currName RENAME TO $nextName");
        return $result !== false;
    }

    /**
     * @inheritDoc
     */
    public function routineLanguages()
    {
        return $this->driver->values("SELECT LOWER(lanname) FROM pg_catalog.pg_language");
    }

    /**
     * @inheritDoc
     */
    public function variables()
    {
        return $this->driver->keyValues("SHOW ALL");
    }

    /**
     * @inheritDoc
     */
    public function processes()
    {
        return $this->driver->rows("SELECT * FROM pg_stat_activity ORDER BY " . ($this->driver->minVersion(9.2) ? "pid" : "procpid"));
    }

    /**
     * @inheritDoc
     */
    public function processAttr(array $process, string $key, string $val): string
    {
        if ($key == "current_query" && $val != "<IDLE>") {
            return '<code>' . $this->utils->str->shortenUtf8($val, 50) . '</code>' . $this->utils->trans->lang('Clone');
        }
        return parent::processAttr($process, $key, $val);
    }

    /**
     * @inheritDoc
     */
    public function statusVariables()
    {
    }

    /**
     * @inheritDoc
     */
    // public function killProcess($val)
    // {
    //     return $this->driver->execute("SELECT pg_terminate_backend(" . $this->utils->str->number($val) . ")");
    // }

    /**
     * @inheritDoc
     */
    // public function connectionId()
    // {
    //     return "SELECT pg_backend_pid()";
    // }

    /**
     * @inheritDoc
     */
    // public function maxConnections()
    // {
    //     return $this->driver->result("SHOW max_connections");
    // }
}