1 files changed, 89 insertions, 0 deletions
diff --git a/src/Database/Postgres11.php b/src/Database/Postgres11.php
new file mode 100644
index 00000000..0bc8cab0
--- /dev/null
+++ b/src/Database/Postgres11.php
@@ -0,0 +1,89 @@
+<?php
+
+/**
+ * PHPPgAdmin6
+ */
+
+namespace PHPPgAdmin\Database;
+
+use PHPPgAdmin\Help\PostgresDoc11;
+
+/**
+ * @file
+ * PostgreSQL 11.x support
+ */
+/**
+ * Class to add support for Postgres11.
+ */
+class Postgres11 extends Postgres10
+{
+    /**
+     * @var float
+     */
+    public $major_version = 11;
+
+    /**
+     * @var class-string
+     */
+    public $help_classname = PostgresDoc11::class;
+
+    /**
+     * Returns a list of all functions in the database.
+     * In PG 11 proagg was replaced with prokind.
+     *
+     * @see https://www.postgresql.org/docs/11/catalog-pg-proc.html
+     *
+     * @param bool  $all  If true, will find all available functions, if false just those in search path
+     * @param mixed $type If truthy, will return functions of type trigger
+     *
+     * @return \ADORecordSet|bool|int|string All functions
+     */
+    public function getFunctions($all = false, $type = null)
+    {
+        if ($all) {
+            $where = 'pg_catalog.pg_function_is_visible(p.oid)';
+            $distinct = 'DISTINCT ON (p.proname)';
+
+            if ($type) {
+                $where .= " AND p.prorettype = (select oid from pg_catalog.pg_type p where p.typname = 'trigger') ";
+            }
+        } else {
+            $c_schema = $this->_schema;
+            $this->clean($c_schema);
+            $where = \sprintf(
+                'n.nspname = \'%s\'',
+                $c_schema
+            );
+            $distinct = '';
+        }
+
+        $sql = \sprintf(
+            '
+            SELECT
+                %s
+                p.oid AS prooid,
+                p.proname,
+                p.proretset,
+                pg_catalog.format_type(p.prorettype, NULL) AS proresult,
+                pg_catalog.oidvectortypes(p.proargtypes) AS proarguments,
+                pl.lanname AS prolanguage,
+                pg_catalog.obj_description(p.oid, \'pg_proc\') AS procomment,
+                p.proname || \' (\' || pg_catalog.oidvectortypes(p.proargtypes) || \')\' AS proproto,
+                CASE WHEN p.proretset THEN \'setof \' ELSE \'\' END || pg_catalog.format_type(p.prorettype, NULL) AS proreturns,
+                coalesce(u.usename::text,p.proowner::text) AS proowner
+
+            FROM pg_catalog.pg_proc p
+                INNER JOIN pg_catalog.pg_namespace n ON n.oid = p.pronamespace
+                INNER JOIN pg_catalog.pg_language pl ON pl.oid = p.prolang
+                LEFT JOIN pg_catalog.pg_user u ON u.usesysid = p.proowner
+            WHERE p.prokind !=\'a\'
+                AND %s
+            ORDER BY p.proname, proresult
+            ',
+            $distinct,
+            $where
+        );
+
+        return $this->selectSet($sql);
+    }
+}