mirror of
https://github.com/vrana/adminer.git
synced 2026-01-31 20:00:15 +01:00
1056 lines
36 KiB
PHP
1056 lines
36 KiB
PHP
<?php
|
|
namespace Adminer;
|
|
|
|
add_driver("pgsql", "PostgreSQL");
|
|
|
|
if (isset($_GET["pgsql"])) {
|
|
define('Adminer\DRIVER', "pgsql");
|
|
|
|
if (extension_loaded("pgsql") && $_GET["ext"] != "pdo") {
|
|
class PgsqlDb extends SqlDb {
|
|
public $extension = "PgSQL";
|
|
public $timeout = 0;
|
|
private $link, $string, $database = true;
|
|
|
|
function _error($errno, $error) {
|
|
if (ini_bool("html_errors")) {
|
|
$error = html_entity_decode(strip_tags($error));
|
|
}
|
|
$error = preg_replace('~^[^:]*: ~', '', $error);
|
|
$this->error = $error;
|
|
}
|
|
|
|
function attach(?string $server, string $username, string $password): string {
|
|
$db = adminer()->database();
|
|
set_error_handler(array($this, '_error'));
|
|
$this->string = "host='" . str_replace(":", "' port='", addcslashes($server, "'\\")) . "' user='" . addcslashes($username, "'\\") . "' password='" . addcslashes($password, "'\\") . "'";
|
|
$ssl = adminer()->connectSsl();
|
|
if (isset($ssl["mode"])) {
|
|
$this->string .= " sslmode='" . $ssl["mode"] . "'";
|
|
}
|
|
$this->link = @pg_connect("$this->string dbname='" . ($db != "" ? addcslashes($db, "'\\") : "postgres") . "'", PGSQL_CONNECT_FORCE_NEW);
|
|
if (!$this->link && $db != "") {
|
|
// try to connect directly with database for performance
|
|
$this->database = false;
|
|
$this->link = @pg_connect("$this->string dbname='postgres'", PGSQL_CONNECT_FORCE_NEW);
|
|
}
|
|
restore_error_handler();
|
|
if ($this->link) {
|
|
pg_set_client_encoding($this->link, "UTF8");
|
|
}
|
|
return ($this->link ? '' : $this->error);
|
|
}
|
|
|
|
function quote(string $string): string {
|
|
return (function_exists('pg_escape_literal')
|
|
? pg_escape_literal($this->link, $string) // available since PHP 5.4.4
|
|
: "'" . pg_escape_string($this->link, $string) . "'"
|
|
);
|
|
}
|
|
|
|
function value(?string $val, array $field): ?string {
|
|
return ($field["type"] == "bytea" && $val !== null ? pg_unescape_bytea($val) : $val);
|
|
}
|
|
|
|
function select_db(string $database) {
|
|
if ($database == adminer()->database()) {
|
|
return $this->database;
|
|
}
|
|
$return = @pg_connect("$this->string dbname='" . addcslashes($database, "'\\") . "'", PGSQL_CONNECT_FORCE_NEW);
|
|
if ($return) {
|
|
$this->link = $return;
|
|
}
|
|
return $return;
|
|
}
|
|
|
|
function close() {
|
|
$this->link = @pg_connect("$this->string dbname='postgres'");
|
|
}
|
|
|
|
function query(string $query, bool $unbuffered = false) {
|
|
$result = @pg_query($this->link, $query);
|
|
$this->error = "";
|
|
if (!$result) {
|
|
$this->error = pg_last_error($this->link);
|
|
$return = false;
|
|
} elseif (!pg_num_fields($result)) {
|
|
$this->affected_rows = pg_affected_rows($result);
|
|
$return = true;
|
|
} else {
|
|
$return = new Result($result);
|
|
}
|
|
if ($this->timeout) {
|
|
$this->timeout = 0;
|
|
$this->query("RESET statement_timeout");
|
|
}
|
|
return $return;
|
|
}
|
|
|
|
function warnings() {
|
|
return h(pg_last_notice($this->link)); // second parameter is available since PHP 7.1.0
|
|
}
|
|
|
|
/** Copy from array into a table
|
|
* @param list<string> $rows
|
|
*/
|
|
function copyFrom(string $table, array $rows): bool {
|
|
$this->error = '';
|
|
set_error_handler(function (int $errno, string $error): bool {
|
|
$this->error = (ini_bool('html_errors') ? html_entity_decode($error) : $error);
|
|
return true;
|
|
});
|
|
$return = pg_copy_from($this->link, $table, $rows);
|
|
restore_error_handler();
|
|
return $return;
|
|
}
|
|
}
|
|
|
|
class Result {
|
|
public $num_rows;
|
|
private $result, $offset = 0;
|
|
|
|
function __construct($result) {
|
|
$this->result = $result;
|
|
$this->num_rows = pg_num_rows($result);
|
|
}
|
|
|
|
function fetch_assoc() {
|
|
return pg_fetch_assoc($this->result);
|
|
}
|
|
|
|
function fetch_row() {
|
|
return pg_fetch_row($this->result);
|
|
}
|
|
|
|
function fetch_field(): \stdClass {
|
|
$column = $this->offset++;
|
|
$return = new \stdClass;
|
|
$return->orgtable = pg_field_table($this->result, $column);
|
|
$return->name = pg_field_name($this->result, $column);
|
|
$type = pg_field_type($this->result, $column);
|
|
$return->type = (preg_match(number_type(), $type) ? 0 : 15);
|
|
$return->charsetnr = ($type == "bytea" ? 63 : 0); // 63 - binary
|
|
return $return;
|
|
}
|
|
|
|
function __destruct() {
|
|
pg_free_result($this->result);
|
|
}
|
|
}
|
|
|
|
} elseif (extension_loaded("pdo_pgsql")) {
|
|
class PgsqlDb extends PdoDb {
|
|
public $extension = "PDO_PgSQL";
|
|
public $timeout = 0;
|
|
|
|
function attach(?string $server, string $username, string $password): string {
|
|
$db = adminer()->database();
|
|
//! client_encoding is supported since 9.1, but we can't yet use min_version here
|
|
$dsn = "pgsql:host='" . str_replace(":", "' port='", addcslashes($server, "'\\")) . "' client_encoding=utf8 dbname='" . ($db != "" ? addcslashes($db, "'\\") : "postgres") . "'";
|
|
$ssl = adminer()->connectSsl();
|
|
if (isset($ssl["mode"])) {
|
|
$dsn .= " sslmode='" . $ssl["mode"] . "'";
|
|
}
|
|
return $this->dsn($dsn, $username, $password);
|
|
}
|
|
|
|
function select_db(string $database) {
|
|
return (adminer()->database() == $database);
|
|
}
|
|
|
|
function query(string $query, bool $unbuffered = false) {
|
|
$return = parent::query($query, $unbuffered);
|
|
if ($this->timeout) {
|
|
$this->timeout = 0;
|
|
parent::query("RESET statement_timeout");
|
|
}
|
|
return $return;
|
|
}
|
|
|
|
function warnings() {
|
|
// not implemented in PDO_PgSQL as of PHP 7.2.1
|
|
}
|
|
|
|
function copyFrom(string $table, array $rows): bool {
|
|
$return = $this->pdo->pgsqlCopyFromArray($table, $rows);
|
|
$this->error = idx($this->pdo->errorInfo(), 2) ?: '';
|
|
return $return;
|
|
}
|
|
|
|
function close() {
|
|
}
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
if (class_exists('Adminer\PgsqlDb')) {
|
|
class Db extends PgsqlDb {
|
|
function multi_query(string $query) {
|
|
if (preg_match('~\bCOPY\s+(.+?)\s+FROM\s+stdin;\n?(.*)\n\\\\\.$~is', str_replace("\r\n", "\n", $query), $match)) { // no ^ to allow leading comments
|
|
$rows = explode("\n", $match[2]);
|
|
$this->affected_rows = count($rows);
|
|
return $this->copyFrom($match[1], $rows);
|
|
}
|
|
return parent::multi_query($query);
|
|
}
|
|
}
|
|
}
|
|
|
|
|
|
|
|
class Driver extends SqlDriver {
|
|
static $extensions = array("PgSQL", "PDO_PgSQL");
|
|
static $jush = "pgsql";
|
|
|
|
public $operators = array("=", "<", ">", "<=", ">=", "!=", "~", "!~", "LIKE", "LIKE %%", "ILIKE", "ILIKE %%", "IN", "IS NULL", "NOT LIKE", "NOT ILIKE", "NOT IN", "IS NOT NULL", "SQL"); //! SQL - same-site CSRF
|
|
public $functions = array("char_length", "lower", "round", "to_hex", "to_timestamp", "upper");
|
|
public $grouping = array("avg", "count", "count distinct", "max", "min", "sum");
|
|
|
|
public string $nsOid = "(SELECT oid FROM pg_namespace WHERE nspname = current_schema())";
|
|
|
|
static function connect(?string $server, string $username, string $password) {
|
|
$connection = parent::connect($server, $username, $password);
|
|
if (is_string($connection)) {
|
|
return $connection;
|
|
}
|
|
$version = get_val("SELECT version()", 0, $connection);
|
|
$connection->flavor = (preg_match('~CockroachDB~', $version) ? 'cockroach' : '');
|
|
$connection->server_info = preg_replace('~^\D*([\d.]+[-\w]*).*~', '\1', $version);
|
|
if (min_version(9, 0, $connection)) {
|
|
$connection->query("SET application_name = 'Adminer'");
|
|
}
|
|
if ($connection->flavor == 'cockroach') { // we don't use "PostgreSQL / CockroachDB" by default because it's too long
|
|
add_driver(DRIVER, "CockroachDB");
|
|
}
|
|
return $connection;
|
|
}
|
|
|
|
function __construct(Db $connection) {
|
|
parent::__construct($connection);
|
|
$this->types = array( //! arrays
|
|
lang('Numbers') => array("smallint" => 5, "integer" => 10, "bigint" => 19, "boolean" => 1, "numeric" => 0, "real" => 7, "double precision" => 16, "money" => 20),
|
|
lang('Date and time') => array("date" => 13, "time" => 17, "timestamp" => 20, "timestamptz" => 21, "interval" => 0),
|
|
lang('Strings') => array("character" => 0, "character varying" => 0, "text" => 0, "tsquery" => 0, "tsvector" => 0, "uuid" => 0, "xml" => 0),
|
|
lang('Binary') => array("bit" => 0, "bit varying" => 0, "bytea" => 0),
|
|
lang('Network') => array("cidr" => 43, "inet" => 43, "macaddr" => 17, "macaddr8" => 23, "txid_snapshot" => 0),
|
|
lang('Geometry') => array("box" => 0, "circle" => 0, "line" => 0, "lseg" => 0, "path" => 0, "point" => 0, "polygon" => 0),
|
|
);
|
|
if (min_version(9.2, 0, $connection)) {
|
|
$this->types[lang('Strings')]["json"] = 4294967295;
|
|
if (min_version(9.4, 0, $connection)) {
|
|
$this->types[lang('Strings')]["jsonb"] = 4294967295;
|
|
}
|
|
}
|
|
$this->insertFunctions = array(
|
|
"char" => "md5",
|
|
"date|time" => "now",
|
|
);
|
|
$this->editFunctions = array(
|
|
number_type() => "+/-",
|
|
"date|time" => "+ interval/- interval", //! escape
|
|
"char|text" => "||",
|
|
);
|
|
if (min_version(12, 0, $connection)) {
|
|
$this->generated = array("STORED");
|
|
}
|
|
$this->partitionBy = array("RANGE", "LIST");
|
|
if (!$connection->flavor) {
|
|
$this->partitionBy[] = "HASH";
|
|
}
|
|
}
|
|
|
|
function enumLength(array $field) {
|
|
$enum = $this->types[lang('User types')][$field["type"]];
|
|
return ($enum ? type_values($enum) : "");
|
|
}
|
|
|
|
function setUserTypes($types) {
|
|
$this->types[lang('User types')] = array_flip($types);
|
|
}
|
|
|
|
function insertReturning(string $table): string {
|
|
$auto_increment = array_filter(fields($table), function ($field) {
|
|
return $field['auto_increment'];
|
|
});
|
|
return (count($auto_increment) == 1 ? " RETURNING " . idf_escape(key($auto_increment)) : "");
|
|
}
|
|
|
|
function insertUpdate(string $table, array $rows, array $primary) {
|
|
foreach ($rows as $set) {
|
|
$update = array();
|
|
$where = array();
|
|
foreach ($set as $key => $val) {
|
|
$update[] = "$key = $val";
|
|
if (isset($primary[idf_unescape($key)])) {
|
|
$where[] = "$key = $val";
|
|
}
|
|
}
|
|
if (
|
|
!(($where && queries("UPDATE " . table($table) . " SET " . implode(", ", $update) . " WHERE " . implode(" AND ", $where)) && connection()->affected_rows)
|
|
|| queries("INSERT INTO " . table($table) . " (" . implode(", ", array_keys($set)) . ") VALUES (" . implode(", ", $set) . ")"))
|
|
) {
|
|
return false;
|
|
}
|
|
}
|
|
return true;
|
|
}
|
|
|
|
function slowQuery(string $query, int $timeout) {
|
|
$this->conn->query("SET statement_timeout = " . (1000 * $timeout));
|
|
$this->conn->timeout = 1000 * $timeout;
|
|
return $query;
|
|
}
|
|
|
|
function convertSearch(string $idf, array $val, array $field): string {
|
|
$textTypes = "char|text";
|
|
if (strpos($val["op"], "LIKE") === false) {
|
|
$textTypes .= "|date|time(stamp)?|boolean|uuid|inet|cidr|macaddr|" . number_type();
|
|
}
|
|
|
|
return (preg_match("~$textTypes~", $field["type"]) ? $idf : "CAST($idf AS text)");
|
|
}
|
|
|
|
function quoteBinary(string $s): string {
|
|
return "'\\x" . bin2hex($s) . "'"; // available since PostgreSQL 8.1
|
|
}
|
|
|
|
function warnings() {
|
|
return $this->conn->warnings();
|
|
}
|
|
|
|
function tableHelp(string $name, bool $is_view = false) {
|
|
$links = array(
|
|
"information_schema" => "infoschema",
|
|
"pg_catalog" => ($is_view ? "view" : "catalog"),
|
|
);
|
|
$link = $links[$_GET["ns"]];
|
|
if ($link) {
|
|
return "$link-" . str_replace("_", "-", $name) . ".html";
|
|
}
|
|
}
|
|
|
|
function inheritsFrom(string $table): array {
|
|
return get_vals("SELECT relname FROM pg_class JOIN pg_inherits ON inhparent = oid WHERE inhrelid = " . $this->tableOid($table) . " ORDER BY 1");
|
|
}
|
|
|
|
function inheritedTables(string $table): array {
|
|
return get_vals("SELECT relname FROM pg_inherits JOIN pg_class ON inhrelid = oid WHERE inhparent = " . $this->tableOid($table) . " ORDER BY 1");
|
|
}
|
|
|
|
function partitionsInfo(string $table): array {
|
|
$row = connection()->query("SELECT * FROM pg_partitioned_table WHERE partrelid = " . $this->tableOid($table))->fetch_assoc();
|
|
if ($row) {
|
|
$attrs = get_vals("SELECT attname FROM pg_attribute WHERE attrelid = $row[partrelid] AND attnum IN (" . str_replace(" ", ", ", $row["partattrs"]) . ")"); //! ordering
|
|
$by = array('h' => 'HASH', 'l' => 'LIST', 'r' => 'RANGE');
|
|
return array(
|
|
"partition_by" => $by[$row["partstrat"]],
|
|
"partition" => implode(", ", array_map('Adminer\idf_escape', $attrs)),
|
|
);
|
|
}
|
|
return array();
|
|
}
|
|
|
|
function tableOid(string $table): string {
|
|
return "(SELECT oid FROM pg_class WHERE relnamespace = $this->nsOid AND relname = " . q($table) . " AND relkind IN ('r', 'm', 'v', 'f', 'p'))";
|
|
}
|
|
|
|
function indexAlgorithms(array $tableStatus): array {
|
|
static $return = array();
|
|
if (!$return) {
|
|
$return = get_vals("SELECT amname FROM pg_am" . (min_version(9.6) ? " WHERE amtype = 'i'" : "") . " ORDER BY amname = 'btree' DESC, amname");
|
|
}
|
|
return $return;
|
|
}
|
|
|
|
function supportsIndex(array $table_status): bool {
|
|
// returns true for "materialized view"
|
|
return $table_status["Engine"] != "view";
|
|
}
|
|
|
|
function hasCStyleEscapes(): bool {
|
|
static $c_style;
|
|
if ($c_style === null) {
|
|
$c_style = (get_val("SHOW standard_conforming_strings", 0, $this->conn) == "off");
|
|
}
|
|
return $c_style;
|
|
}
|
|
}
|
|
|
|
|
|
|
|
function idf_escape($idf) {
|
|
return '"' . str_replace('"', '""', $idf) . '"';
|
|
}
|
|
|
|
function table($idf) {
|
|
return idf_escape($idf);
|
|
}
|
|
|
|
function get_databases($flush) {
|
|
return get_vals("SELECT datname FROM pg_database
|
|
WHERE datallowconn = TRUE AND has_database_privilege(datname, 'CONNECT')
|
|
ORDER BY datname");
|
|
}
|
|
|
|
function limit($query, $where, $limit, $offset = 0, $separator = " ") {
|
|
return " $query$where" . ($limit ? $separator . "LIMIT $limit" . ($offset ? " OFFSET $offset" : "") : "");
|
|
}
|
|
|
|
function limit1($table, $query, $where, $separator = "\n") {
|
|
return (preg_match('~^INTO~', $query)
|
|
? limit($query, $where, 1, 0, $separator)
|
|
: " $query" . (is_view(table_status1($table)) ? $where : $separator . "WHERE ctid = (SELECT ctid FROM " . table($table) . $where . $separator . "LIMIT 1)")
|
|
);
|
|
}
|
|
|
|
function db_collation($db, $collations) {
|
|
return get_val("SELECT datcollate FROM pg_database WHERE datname = " . q($db));
|
|
}
|
|
|
|
function logged_user() {
|
|
return get_val("SELECT user");
|
|
}
|
|
|
|
function tables_list() {
|
|
$query = "SELECT table_name, table_type FROM information_schema.tables WHERE table_schema = current_schema()";
|
|
if (support("materializedview")) {
|
|
$query .= "
|
|
UNION ALL
|
|
SELECT matviewname, 'MATERIALIZED VIEW'
|
|
FROM pg_matviews
|
|
WHERE schemaname = current_schema()";
|
|
}
|
|
$query .= "
|
|
ORDER BY 1";
|
|
return get_key_vals($query);
|
|
}
|
|
|
|
function count_tables($databases) {
|
|
$return = array();
|
|
foreach ($databases as $db) {
|
|
if (connection()->select_db($db)) {
|
|
$return[$db] = count(tables_list());
|
|
}
|
|
}
|
|
return $return;
|
|
}
|
|
|
|
function table_status($name = "") {
|
|
static $has_size;
|
|
if ($has_size === null) {
|
|
// https://github.com/cockroachdb/cockroach/issues/40391
|
|
$has_size = get_val("SELECT 'pg_table_size'::regproc");
|
|
}
|
|
$return = array();
|
|
foreach (
|
|
get_rows("SELECT
|
|
relname AS \"Name\",
|
|
CASE relkind WHEN 'v' THEN 'view' WHEN 'm' THEN 'materialized view' ELSE 'table' END AS \"Engine\"" . ($has_size ? ",
|
|
pg_table_size(oid) AS \"Data_length\",
|
|
pg_indexes_size(oid) AS \"Index_length\"" : "") . ",
|
|
obj_description(oid, 'pg_class') AS \"Comment\",
|
|
" . (min_version(12) ? "''" : "CASE WHEN relhasoids THEN 'oid' ELSE '' END") . " AS \"Oid\",
|
|
reltuples AS \"Rows\",
|
|
" . (min_version(10) ? "relispartition::int AS partition," : "") . "
|
|
current_schema() AS nspname
|
|
FROM pg_class
|
|
WHERE relkind IN ('r', 'm', 'v', 'f', 'p')
|
|
AND relnamespace = " . driver()->nsOid . "
|
|
" . ($name != "" ? "AND relname = " . q($name) : "ORDER BY relname")) as $row //! Auto_increment
|
|
) {
|
|
$return[$row["Name"]] = $row;
|
|
}
|
|
return $return;
|
|
}
|
|
|
|
function is_view($table_status) {
|
|
return in_array($table_status["Engine"], array("view", "materialized view"));
|
|
}
|
|
|
|
function fk_support($table_status) {
|
|
return true;
|
|
}
|
|
|
|
function fields($table) {
|
|
$return = array();
|
|
$aliases = array(
|
|
'timestamp without time zone' => 'timestamp',
|
|
'timestamp with time zone' => 'timestamptz',
|
|
);
|
|
foreach (
|
|
get_rows("SELECT
|
|
a.attname AS field,
|
|
format_type(a.atttypid, a.atttypmod) AS full_type,
|
|
pg_get_expr(d.adbin, d.adrelid) AS default,
|
|
a.attnotnull::int,
|
|
col_description(a.attrelid, a.attnum) AS comment" . (min_version(10) ? ",
|
|
a.attidentity" . (min_version(12) ? ",
|
|
a.attgenerated" : "") : "") . "
|
|
FROM pg_attribute a
|
|
LEFT JOIN pg_attrdef d ON a.attrelid = d.adrelid AND a.attnum = d.adnum
|
|
WHERE a.attrelid = " . driver()->tableOid($table) . "
|
|
AND NOT a.attisdropped
|
|
AND a.attnum > 0
|
|
ORDER BY a.attnum") as $row
|
|
) {
|
|
//! collation, primary
|
|
preg_match('~([^([]+)(\((.*)\))?([a-z ]+)?((\[[0-9]*])*)$~', $row["full_type"], $match);
|
|
list(, $type, $length, $row["length"], $addon, $array) = $match;
|
|
$row["length"] .= $array;
|
|
$check_type = $type . $addon;
|
|
if (isset($aliases[$check_type])) {
|
|
$row["type"] = $aliases[$check_type];
|
|
$row["full_type"] = $row["type"] . $length . $array;
|
|
} else {
|
|
$row["type"] = $type;
|
|
$row["full_type"] = $row["type"] . $length . $addon . $array;
|
|
}
|
|
if (in_array($row['attidentity'], array('a', 'd'))) {
|
|
$row['default'] = 'GENERATED ' . ($row['attidentity'] == 'd' ? 'BY DEFAULT' : 'ALWAYS') . ' AS IDENTITY';
|
|
}
|
|
$row["generated"] = ($row["attgenerated"] == "s" ? "STORED" : "");
|
|
$row["null"] = !$row["attnotnull"];
|
|
$row["auto_increment"] = $row['attidentity'] || preg_match('~^nextval\(~i', $row["default"])
|
|
|| preg_match('~^unique_rowid\(~', $row["default"]); // CockroachDB
|
|
$row["privileges"] = array("insert" => 1, "select" => 1, "update" => 1, "where" => 1, "order" => 1);
|
|
if (preg_match('~(.+)::[^,)]+(.*)~', $row["default"], $match)) {
|
|
$row["default"] = ($match[1] == "NULL" ? null : idf_unescape($match[1]) . $match[2]);
|
|
}
|
|
$return[$row["field"]] = $row;
|
|
}
|
|
return $return;
|
|
}
|
|
|
|
function indexes($table, $connection2 = null) {
|
|
$connection2 = connection($connection2);
|
|
$return = array();
|
|
$table_oid = driver()->tableOid($table);
|
|
$columns = get_key_vals("SELECT attnum, attname FROM pg_attribute WHERE attrelid = $table_oid AND attnum > 0", $connection2);
|
|
foreach (
|
|
get_rows("SELECT relname, indisunique::int, indisprimary::int, indkey, indoption, amname, pg_get_expr(indpred, indrelid, true) AS partial, pg_get_expr(indexprs, indrelid) AS indexpr
|
|
FROM pg_index
|
|
JOIN pg_class ON indexrelid = oid
|
|
JOIN pg_am ON pg_am.oid = pg_class.relam
|
|
WHERE indrelid = $table_oid
|
|
ORDER BY indisprimary DESC, indisunique DESC", $connection2) as $row
|
|
) {
|
|
$relname = $row["relname"];
|
|
$return[$relname]["type"] = ($row["partial"] ? "INDEX" : ($row["indisprimary"] ? "PRIMARY" : ($row["indisunique"] ? "UNIQUE" : "INDEX")));
|
|
$return[$relname]["columns"] = array();
|
|
$return[$relname]["descs"] = array();
|
|
$return[$relname]["algorithm"] = $row["amname"];
|
|
$return[$relname]["partial"] = $row["partial"];
|
|
$indexpr = preg_split('~(?<=\)), (?=\()~', $row["indexpr"]); //! '), (' used in expression
|
|
foreach (explode(" ", $row["indkey"]) as $indkey) {
|
|
$return[$relname]["columns"][] = ($indkey ? $columns[$indkey] : array_shift($indexpr));
|
|
}
|
|
foreach (explode(" ", $row["indoption"]) as $indoption) {
|
|
$return[$relname]["descs"][] = (intval($indoption) & 1 ? '1' : null); // 1 - INDOPTION_DESC
|
|
}
|
|
$return[$relname]["lengths"] = array();
|
|
}
|
|
return $return;
|
|
}
|
|
|
|
function foreign_keys($table) {
|
|
$return = array();
|
|
foreach (
|
|
get_rows("SELECT conname, condeferrable::int AS deferrable, pg_get_constraintdef(oid) AS definition
|
|
FROM pg_constraint
|
|
WHERE conrelid = " . driver()->tableOid($table) . "
|
|
AND contype = 'f'::char
|
|
ORDER BY conkey, conname") as $row
|
|
) {
|
|
if (preg_match('~FOREIGN KEY\s*\((.+)\)\s*REFERENCES (.+)\((.+)\)(.*)$~iA', $row['definition'], $match)) {
|
|
$row['source'] = array_map('Adminer\idf_unescape', array_map('trim', explode(',', $match[1])));
|
|
if (preg_match('~^(("([^"]|"")+"|[^"]+)\.)?"?("([^"]|"")+"|[^"]+)$~', $match[2], $match2)) {
|
|
$row['ns'] = idf_unescape($match2[2]);
|
|
$row['table'] = idf_unescape($match2[4]);
|
|
}
|
|
$row['target'] = array_map('Adminer\idf_unescape', array_map('trim', explode(',', $match[3])));
|
|
$row['on_delete'] = (preg_match("~ON DELETE (" . driver()->onActions . ")~", $match[4], $match2) ? $match2[1] : 'NO ACTION');
|
|
$row['on_update'] = (preg_match("~ON UPDATE (" . driver()->onActions . ")~", $match[4], $match2) ? $match2[1] : 'NO ACTION');
|
|
$return[$row['conname']] = $row;
|
|
}
|
|
}
|
|
return $return;
|
|
}
|
|
|
|
function view($name) {
|
|
return array("select" => trim(get_val("SELECT pg_get_viewdef(" . driver()->tableOid($name) . ")")));
|
|
}
|
|
|
|
function collations() {
|
|
//! supported in CREATE DATABASE
|
|
return array();
|
|
}
|
|
|
|
function information_schema($db) {
|
|
return get_schema() == "information_schema";
|
|
}
|
|
|
|
function error() {
|
|
$return = h(connection()->error);
|
|
if (preg_match('~^(.*\n)?([^\n]*)\n( *)\^(\n.*)?$~s', $return, $match)) {
|
|
$return = $match[1] . preg_replace('~((?:[^&]|&[^;]*;){' . strlen($match[3]) . '})(.*)~', '\1<b>\2</b>', $match[2]) . $match[4];
|
|
}
|
|
return nl_br($return);
|
|
}
|
|
|
|
function create_database($db, $collation) {
|
|
return queries("CREATE DATABASE " . idf_escape($db) . ($collation ? " ENCODING " . idf_escape($collation) : ""));
|
|
}
|
|
|
|
function drop_databases($databases) {
|
|
connection()->close();
|
|
return apply_queries("DROP DATABASE", $databases, 'Adminer\idf_escape');
|
|
}
|
|
|
|
function rename_database($name, $collation) {
|
|
connection()->close();
|
|
return queries("ALTER DATABASE " . idf_escape(DB) . " RENAME TO " . idf_escape($name));
|
|
}
|
|
|
|
function auto_increment() {
|
|
return "";
|
|
}
|
|
|
|
function alter_table($table, $name, $fields, $foreign, $comment, $engine, $collation, $auto_increment, $partitioning) {
|
|
$alter = array();
|
|
$queries = array();
|
|
if ($table != "" && $table != $name) {
|
|
$queries[] = "ALTER TABLE " . table($table) . " RENAME TO " . table($name);
|
|
}
|
|
$sequence = "";
|
|
foreach ($fields as $field) {
|
|
$column = idf_escape($field[0]);
|
|
$val = $field[1];
|
|
if (!$val) {
|
|
$alter[] = "DROP $column";
|
|
} else {
|
|
$val5 = $val[5];
|
|
unset($val[5]);
|
|
if ($field[0] == "") {
|
|
if (isset($val[6])) { // auto_increment
|
|
$val[1] = ($val[1] == " bigint" ? " big" : ($val[1] == " smallint" ? " small" : " ")) . "serial";
|
|
}
|
|
$alter[] = ($table != "" ? "ADD " : " ") . implode($val);
|
|
if (isset($val[6])) {
|
|
$alter[] = ($table != "" ? "ADD" : " ") . " PRIMARY KEY ($val[0])";
|
|
}
|
|
} else {
|
|
if ($column != $val[0]) {
|
|
$queries[] = "ALTER TABLE " . table($name) . " RENAME $column TO $val[0]";
|
|
}
|
|
$alter[] = "ALTER $column TYPE$val[1]";
|
|
$sequence_name = $table . "_" . idf_unescape($val[0]) . "_seq";
|
|
$alter[] = "ALTER $column " . ($val[3] ? "SET" . preg_replace('~GENERATED ALWAYS(.*) STORED~', 'EXPRESSION\1', $val[3])
|
|
: (isset($val[6]) ? "SET DEFAULT nextval(" . q($sequence_name) . ")"
|
|
: "DROP DEFAULT" //! change to DROP EXPRESSION with generated columns
|
|
));
|
|
if (isset($val[6])) {
|
|
$sequence = "CREATE SEQUENCE IF NOT EXISTS " . idf_escape($sequence_name) . " OWNED BY " . idf_escape($table) . ".$val[0]";
|
|
}
|
|
$alter[] = "ALTER $column " . ($val[2] == " NULL" ? "DROP NOT" : "SET") . $val[2];
|
|
}
|
|
if ($field[0] != "" || $val5 != "") {
|
|
$queries[] = "COMMENT ON COLUMN " . table($name) . ".$val[0] IS " . ($val5 != "" ? substr($val5, 9) : "''");
|
|
}
|
|
}
|
|
}
|
|
$alter = array_merge($alter, $foreign);
|
|
if ($table == "") {
|
|
$status = "";
|
|
if ($partitioning) {
|
|
$cockroach = (connection()->flavor == 'cockroach');
|
|
$status = " PARTITION BY $partitioning[partition_by]($partitioning[partition])";
|
|
if ($partitioning["partition_by"] == 'HASH') {
|
|
$partitions = +$partitioning["partitions"];
|
|
for ($i=0; $i < $partitions; $i++) {
|
|
$queries[] = "CREATE TABLE " . idf_escape($name . "_$i") . " PARTITION OF " . idf_escape($name) . " FOR VALUES WITH (MODULUS $partitions, REMAINDER $i)";
|
|
}
|
|
} else {
|
|
$prev = "MINVALUE";
|
|
foreach ($partitioning["partition_names"] as $i => $val) {
|
|
$value = $partitioning["partition_values"][$i];
|
|
$partition = " VALUES " . ($partitioning["partition_by"] == 'LIST' ? "IN ($value)" : "FROM ($prev) TO ($value)");
|
|
if ($cockroach) {
|
|
$status .= ($i ? "," : " (") . "\n PARTITION " . (preg_match('~^DEFAULT$~i', $val) ? $val : idf_escape($val)) . "$partition";
|
|
} else {
|
|
$queries[] = "CREATE TABLE " . idf_escape($name . "_$val") . " PARTITION OF " . idf_escape($name) . " FOR$partition";
|
|
}
|
|
$prev = $value;
|
|
}
|
|
$status .= ($cockroach ? "\n)" : "");
|
|
}
|
|
}
|
|
array_unshift($queries, "CREATE TABLE " . table($name) . " (\n" . implode(",\n", $alter) . "\n)$status");
|
|
} elseif ($alter) {
|
|
array_unshift($queries, "ALTER TABLE " . table($table) . "\n" . implode(",\n", $alter));
|
|
}
|
|
if ($sequence) {
|
|
array_unshift($queries, $sequence);
|
|
}
|
|
if ($comment !== null) {
|
|
$queries[] = "COMMENT ON TABLE " . table($name) . " IS " . q($comment);
|
|
}
|
|
// if ($auto_increment != "") {
|
|
//! $queries[] = "SELECT setval(pg_get_serial_sequence(" . q($name) . ", ), $auto_increment)";
|
|
// }
|
|
foreach ($queries as $query) {
|
|
if (!queries($query)) {
|
|
return false;
|
|
}
|
|
}
|
|
return true;
|
|
}
|
|
|
|
function alter_indexes($table, $alter) {
|
|
$create = array();
|
|
$drop = array();
|
|
$queries = array();
|
|
foreach ($alter as $val) {
|
|
if ($val[0] != "INDEX") {
|
|
//! descending UNIQUE indexes result in syntax error
|
|
$create[] = ($val[2] == "DROP"
|
|
? "\nDROP CONSTRAINT " . idf_escape($val[1])
|
|
: "\nADD" . ($val[1] != "" ? " CONSTRAINT " . idf_escape($val[1]) : "") . " $val[0] " . ($val[0] == "PRIMARY" ? "KEY " : "") . "(" . implode(", ", $val[2]) . ")"
|
|
);
|
|
} elseif ($val[2] == "DROP") {
|
|
$drop[] = idf_escape($val[1]);
|
|
} else {
|
|
$queries[] = "CREATE INDEX " . idf_escape($val[1] != "" ? $val[1] : uniqid($table . "_"))
|
|
. " ON " . table($table)
|
|
. ($val[3] ? " USING $val[3]" : "")
|
|
. " (" . implode(", ", $val[2]) . ")"
|
|
. ($val[4] ? " WHERE $val[4]" : "")
|
|
;
|
|
}
|
|
}
|
|
if ($create) {
|
|
array_unshift($queries, "ALTER TABLE " . table($table) . implode(",", $create));
|
|
}
|
|
if ($drop) {
|
|
array_unshift($queries, "DROP INDEX " . implode(", ", $drop));
|
|
}
|
|
foreach ($queries as $query) {
|
|
if (!queries($query)) {
|
|
return false;
|
|
}
|
|
}
|
|
return true;
|
|
}
|
|
|
|
function truncate_tables($tables) {
|
|
return queries("TRUNCATE " . implode(", ", array_map('Adminer\table', $tables)));
|
|
}
|
|
|
|
function drop_views($views) {
|
|
return drop_tables($views);
|
|
}
|
|
|
|
function drop_tables($tables) {
|
|
foreach ($tables as $table) {
|
|
$status = table_status1($table);
|
|
if (!queries("DROP " . strtoupper($status["Engine"]) . " " . table($table))) {
|
|
return false;
|
|
}
|
|
}
|
|
return true;
|
|
}
|
|
|
|
function move_tables($tables, $views, $target) {
|
|
foreach (array_merge($tables, $views) as $table) {
|
|
$status = table_status1($table);
|
|
if (!queries("ALTER " . strtoupper($status["Engine"]) . " " . table($table) . " SET SCHEMA " . idf_escape($target))) {
|
|
return false;
|
|
}
|
|
}
|
|
return true;
|
|
}
|
|
|
|
function trigger($name, $table) {
|
|
if ($name == "") {
|
|
return array("Statement" => "EXECUTE PROCEDURE ()");
|
|
}
|
|
$columns = array();
|
|
$where = "WHERE trigger_schema = current_schema() AND event_object_table = " . q($table) . " AND trigger_name = " . q($name);
|
|
foreach (get_rows("SELECT * FROM information_schema.triggered_update_columns $where") as $row) {
|
|
$columns[] = $row["event_object_column"];
|
|
}
|
|
$return = array();
|
|
foreach (
|
|
get_rows('SELECT trigger_name AS "Trigger", action_timing AS "Timing", event_manipulation AS "Event", \'FOR EACH \' || action_orientation AS "Type", action_statement AS "Statement"
|
|
FROM information_schema.triggers' . "
|
|
$where
|
|
ORDER BY event_manipulation DESC") as $row
|
|
) {
|
|
if ($columns && $row["Event"] == "UPDATE") {
|
|
$row["Event"] .= " OF";
|
|
}
|
|
$row["Of"] = implode(", ", $columns);
|
|
if ($return) {
|
|
$row["Event"] .= " OR $return[Event]";
|
|
}
|
|
$return = $row;
|
|
}
|
|
return $return;
|
|
}
|
|
|
|
function triggers($table) {
|
|
$return = array();
|
|
foreach (get_rows("SELECT * FROM information_schema.triggers WHERE trigger_schema = current_schema() AND event_object_table = " . q($table)) as $row) {
|
|
$trigger = trigger($row["trigger_name"], $table);
|
|
$return[$trigger["Trigger"]] = array($trigger["Timing"], $trigger["Event"]);
|
|
}
|
|
return $return;
|
|
}
|
|
|
|
function trigger_options() {
|
|
return array(
|
|
"Timing" => array("BEFORE", "AFTER"),
|
|
"Event" => array("INSERT", "UPDATE", "UPDATE OF", "DELETE", "INSERT OR UPDATE", "INSERT OR UPDATE OF", "DELETE OR INSERT", "DELETE OR UPDATE", "DELETE OR UPDATE OF", "DELETE OR INSERT OR UPDATE", "DELETE OR INSERT OR UPDATE OF"),
|
|
"Type" => array("FOR EACH ROW", "FOR EACH STATEMENT"),
|
|
);
|
|
}
|
|
|
|
function routine($name, $type) {
|
|
$rows = get_rows('SELECT routine_definition AS definition, LOWER(external_language) AS language, *
|
|
FROM information_schema.routines
|
|
WHERE routine_schema = current_schema() AND specific_name = ' . q($name));
|
|
$return = idx($rows, 0, array());
|
|
$return["returns"] = array("type" => $return["type_udt_name"]);
|
|
$return["fields"] = get_rows('SELECT parameter_name AS field, data_type AS type, character_maximum_length AS length, parameter_mode AS inout
|
|
FROM information_schema.parameters
|
|
WHERE specific_schema = current_schema() AND specific_name = ' . q($name) . '
|
|
ORDER BY ordinal_position');
|
|
return $return;
|
|
}
|
|
|
|
function routines() {
|
|
return get_rows('SELECT specific_name AS "SPECIFIC_NAME", routine_type AS "ROUTINE_TYPE", routine_name AS "ROUTINE_NAME", type_udt_name AS "DTD_IDENTIFIER"
|
|
FROM information_schema.routines
|
|
WHERE routine_schema = current_schema()
|
|
ORDER BY SPECIFIC_NAME');
|
|
}
|
|
|
|
function routine_languages() {
|
|
return get_vals("SELECT LOWER(lanname) FROM pg_catalog.pg_language");
|
|
}
|
|
|
|
function routine_id($name, $row) {
|
|
$return = array();
|
|
foreach ($row["fields"] as $field) {
|
|
$length = $field["length"];
|
|
$return[] = $field["type"] . ($length ? "($length)" : "");
|
|
}
|
|
return idf_escape($name) . "(" . implode(", ", $return) . ")";
|
|
}
|
|
|
|
function last_id($result) {
|
|
$row = (is_object($result) ? $result->fetch_row() : array());
|
|
return ($row ? $row[0] : 0);
|
|
}
|
|
|
|
function explain($connection, $query) {
|
|
return $connection->query("EXPLAIN $query");
|
|
}
|
|
|
|
function found_rows($table_status, $where) {
|
|
if (preg_match("~ rows=([0-9]+)~", get_val("EXPLAIN SELECT * FROM " . idf_escape($table_status["Name"]) . ($where ? " WHERE " . implode(" AND ", $where) : "")), $regs)) {
|
|
return $regs[1];
|
|
}
|
|
}
|
|
|
|
function types(): array {
|
|
return get_key_vals(
|
|
"SELECT oid, typname
|
|
FROM pg_type
|
|
WHERE typnamespace = " . driver()->nsOid . "
|
|
AND typtype IN ('b','d','e')
|
|
AND typelem = 0"
|
|
);
|
|
}
|
|
|
|
function type_values($id) {
|
|
// to get values from type string: unnest(enum_range(NULL::"$type"))
|
|
$enums = get_vals("SELECT enumlabel FROM pg_enum WHERE enumtypid = $id ORDER BY enumsortorder");
|
|
return ($enums ? "'" . implode("', '", array_map('addslashes', $enums)) . "'" : "");
|
|
}
|
|
|
|
function schemas() {
|
|
return get_vals("SELECT nspname FROM pg_namespace ORDER BY nspname");
|
|
}
|
|
|
|
function get_schema() {
|
|
return get_val("SELECT current_schema()");
|
|
}
|
|
|
|
function set_schema($schema, $connection2 = null) {
|
|
if (!$connection2) {
|
|
$connection2 = connection();
|
|
}
|
|
$return = $connection2->query("SET search_path TO " . idf_escape($schema));
|
|
driver()->setUserTypes(types()); //! get types from current_schemas('t')
|
|
return $return;
|
|
}
|
|
|
|
// create_sql() produces CREATE TABLE without FK CONSTRAINTs
|
|
// foreign_keys_sql() produces all FK CONSTRAINTs as ALTER TABLE ... ADD CONSTRAINT
|
|
// so that all FKs can be added after all tables have been created, avoiding any need to reorder CREATE TABLE statements in order of their FK dependencies
|
|
function foreign_keys_sql($table) {
|
|
$return = "";
|
|
|
|
$status = table_status1($table);
|
|
$fkeys = foreign_keys($table);
|
|
ksort($fkeys);
|
|
|
|
foreach ($fkeys as $fkey_name => $fkey) {
|
|
$return .= "ALTER TABLE ONLY " . idf_escape($status['nspname']) . "." . idf_escape($status['Name']) . " ADD CONSTRAINT " . idf_escape($fkey_name) . " $fkey[definition] " . ($fkey['deferrable'] ? 'DEFERRABLE' : 'NOT DEFERRABLE') . ";\n";
|
|
}
|
|
|
|
return ($return ? "$return\n" : $return);
|
|
}
|
|
|
|
function create_sql($table, $auto_increment, $style) {
|
|
$return_parts = array();
|
|
$sequences = array();
|
|
|
|
$status = table_status1($table);
|
|
if (is_view($status)) {
|
|
$view = view($table);
|
|
return rtrim("CREATE VIEW " . idf_escape($table) . " AS $view[select]", ";");
|
|
}
|
|
$fields = fields($table);
|
|
|
|
if (count($status) < 2 || empty($fields)) {
|
|
return false;
|
|
}
|
|
|
|
$return = "CREATE TABLE " . idf_escape($status['nspname']) . "." . idf_escape($status['Name']) . " (\n ";
|
|
|
|
// fields' definitions
|
|
foreach ($fields as $field) {
|
|
$part = idf_escape($field['field']) . ' ' . $field['full_type']
|
|
. default_value($field)
|
|
. ($field['null'] ? "" : " NOT NULL");
|
|
$return_parts[] = $part;
|
|
|
|
// sequences for fields
|
|
if (preg_match('~nextval\(\'([^\']+)\'\)~', $field['default'], $matches)) {
|
|
$sequence_name = $matches[1];
|
|
$sq = first(get_rows((min_version(10)
|
|
? "SELECT *, cache_size AS cache_value FROM pg_sequences WHERE schemaname = current_schema() AND sequencename = " . q(idf_unescape($sequence_name))
|
|
: "SELECT * FROM $sequence_name"
|
|
), null, "-- "));
|
|
$sequences[] = ($style == "DROP+CREATE" ? "DROP SEQUENCE IF EXISTS $sequence_name;\n" : "")
|
|
. "CREATE SEQUENCE $sequence_name INCREMENT $sq[increment_by] MINVALUE $sq[min_value] MAXVALUE $sq[max_value]"
|
|
. ($auto_increment && $sq['last_value'] ? " START " . ($sq["last_value"] + 1) : "")
|
|
. " CACHE $sq[cache_value];"
|
|
;
|
|
}
|
|
}
|
|
|
|
// adding sequences before table definition
|
|
if (!empty($sequences)) {
|
|
$return = implode("\n\n", $sequences) . "\n\n$return";
|
|
}
|
|
|
|
$primary = "";
|
|
foreach (indexes($table) as $index_name => $index) {
|
|
if ($index['type'] == 'PRIMARY') {
|
|
$primary = $index_name;
|
|
$return_parts[] = "CONSTRAINT " . idf_escape($index_name) . " PRIMARY KEY (" . implode(', ', array_map('Adminer\idf_escape', $index['columns'])) . ")";
|
|
}
|
|
}
|
|
|
|
foreach (driver()->checkConstraints($table) as $conname => $consrc) {
|
|
$return_parts[] = "CONSTRAINT " . idf_escape($conname) . " CHECK $consrc";
|
|
}
|
|
$return .= implode(",\n ", $return_parts) . "\n)";
|
|
|
|
$partition = driver()->partitionsInfo($status['Name']);
|
|
if ($partition) {
|
|
$return .= "\nPARTITION BY $partition[partition_by]($partition[partition])";
|
|
}
|
|
//! parse pg_class.relpartbound to create PARTITION OF
|
|
//! don't insert partitioned data twice
|
|
|
|
$return .= "\nWITH (oids = " . ($status['Oid'] ? 'true' : 'false') . ");";
|
|
|
|
// comments for table & fields
|
|
if ($status['Comment']) {
|
|
$return .= "\n\nCOMMENT ON TABLE " . idf_escape($status['nspname']) . "." . idf_escape($status['Name']) . " IS " . q($status['Comment']) . ";";
|
|
}
|
|
|
|
foreach ($fields as $field_name => $field) {
|
|
if ($field['comment']) {
|
|
$return .= "\n\nCOMMENT ON COLUMN " . idf_escape($status['nspname']) . "." . idf_escape($status['Name']) . "." . idf_escape($field_name) . " IS " . q($field['comment']) . ";";
|
|
}
|
|
}
|
|
|
|
foreach (get_rows("SELECT indexdef FROM pg_catalog.pg_indexes WHERE schemaname = current_schema() AND tablename = " . q($table) . ($primary ? " AND indexname != " . q($primary) : ""), null, "-- ") as $row) {
|
|
$return .= "\n\n$row[indexdef];";
|
|
}
|
|
|
|
return rtrim($return, ';');
|
|
}
|
|
|
|
function truncate_sql($table) {
|
|
return "TRUNCATE " . table($table);
|
|
}
|
|
|
|
function trigger_sql($table) {
|
|
$status = table_status1($table);
|
|
$return = "";
|
|
foreach (triggers($table) as $trg_id => $trg) {
|
|
$trigger = trigger($trg_id, $status['Name']);
|
|
$return .= "\nCREATE TRIGGER " . idf_escape($trigger['Trigger']) . " $trigger[Timing] $trigger[Event] ON " . idf_escape($status["nspname"]) . "." . idf_escape($status['Name']) . " $trigger[Type] $trigger[Statement];;\n";
|
|
}
|
|
return $return;
|
|
}
|
|
|
|
|
|
function use_sql($database) {
|
|
return "\connect " . idf_escape($database);
|
|
}
|
|
|
|
function show_variables() {
|
|
return get_rows("SHOW ALL");
|
|
}
|
|
|
|
function process_list() {
|
|
return get_rows("SELECT * FROM pg_stat_activity ORDER BY " . (min_version(9.2) ? "pid" : "procpid"));
|
|
}
|
|
|
|
function convert_field($field) {
|
|
}
|
|
|
|
function unconvert_field($field, $return) {
|
|
return $return;
|
|
}
|
|
|
|
function support($feature) {
|
|
return preg_match('~^(check|columns|comment|database|drop_col|dump|descidx|indexes|kill|partial_indexes|routine|scheme|sequence|sql|table|trigger|type|variables|view'
|
|
. (min_version(9.3) ? '|materializedview' : '')
|
|
. (min_version(11) ? '|procedure' : '')
|
|
. (connection()->flavor == 'cockroach' ? '' : '|processlist') // https://github.com/cockroachdb/cockroach/issues/24745
|
|
. ')$~', $feature)
|
|
;
|
|
}
|
|
|
|
function kill_process($val) {
|
|
return queries("SELECT pg_terminate_backend(" . number($val) . ")");
|
|
}
|
|
|
|
function connection_id() {
|
|
return "SELECT pg_backend_pid()";
|
|
}
|
|
|
|
function max_connections() {
|
|
return get_val("SHOW max_connections");
|
|
}
|
|
}
|