HuasoFoundries / phpPgAdmin6

     *

     * @return bool true if the table has been already clustered

     */

    public function alreadyClustered($table)

    {

        $c_schema = $this->_schema;

        $this->clean($c_schema);

        $this->clean($table);

        $sql = "SELECT i.indisclustered

			FROM pg_catalog.pg_class c, pg_catalog.pg_index i

			WHERE c.relname = '{$table}'

				AND c.oid = i.indrelid AND i.indisclustered

				AND c.relnamespace = (SELECT oid FROM pg_catalog.pg_namespace

					WHERE nspname='{$c_schema}')

				";

        $v = $this->selectSet($sql);

        return !($v->RecordCount() == 0);

    }

    /**

     * Creates an index.

     *

     * @return int|\PHPPgAdmin\ADORecordSet A recordset or -1 in case of error

     */

    public function getReferrers($table)

    {

        $this->clean($table);

        $status = $this->beginTransaction();

        if ($status != 0) {

            return -1;

        }

        $c_schema = $this->_schema;

        $this->clean($c_schema);

        $sql = "

			SELECT

				pn.nspname,

				pl.relname,

				pc.conname,

				pg_catalog.pg_get_constraintdef(pc.oid) AS consrc

			FROM

				pg_catalog.pg_constraint pc,

				pg_catalog.pg_namespace pn,

				pg_catalog.pg_class pl

			WHERE

				pc.connamespace = pn.oid

				AND pc.conrelid = pl.oid

				AND pc.contype = 'f'

				AND confrelid = (SELECT oid FROM pg_catalog.pg_class WHERE relname='{$table}'

					AND relnamespace = (SELECT oid FROM pg_catalog.pg_namespace

					WHERE nspname='{$c_schema}'))

			ORDER BY 1,2,3

		";

        return $this->selectSet($sql);

    }

    abstract public function fieldClean(&$str);

     *

     * @return \PHPPgAdmin\ADORecordSet A recordset

     */

    public function getTrigger($table, $trigger)

    {

        $c_schema = $this->_schema;

        $this->clean($c_schema);

        $this->clean($table);

        $this->clean($trigger);

        $sql = "

            SELECT * FROM pg_catalog.pg_trigger t, pg_catalog.pg_class c

            WHERE t.tgrelid=c.oid AND c.relname='{$table}' AND t.tgname='{$trigger}'

                AND c.relnamespace=(

                    SELECT oid FROM pg_catalog.pg_namespace

                    WHERE nspname='{$c_schema}')";

        return $this->selectSet($sql);

    }

    /**

     * Creates a trigger.

     *

     * @return \PHPPgAdmin\ADORecordSet A recordset

     */

    public function getAggregate($name, $basetype)

    {

        $c_schema = $this->_schema;

        $this->clean($c_schema);

        $this->clean($name);

        $this->clean($basetype);

        $sql = "

			SELECT p.proname,

				CASE p.proargtypes[0]

					WHEN 'pg_catalog.\"any\"'::pg_catalog.regtype THEN NULL

					ELSE pg_catalog.format_type(p.proargtypes[0], NULL)

				END AS proargtypes, a.aggtransfn, format_type(a.aggtranstype, NULL) AS aggstype,

				a.aggfinalfn, a.agginitval, u.usename, pg_catalog.obj_description(p.oid, 'pg_proc') AS aggrcomment

			FROM pg_catalog.pg_proc p, pg_catalog.pg_namespace n, pg_catalog.pg_user u, pg_catalog.pg_aggregate a

			WHERE n.oid = p.pronamespace AND p.proowner=u.usesysid AND p.oid=a.aggfnoid

				AND p.proisagg AND n.nspname='{$c_schema}'

				AND p.proname='{$name}'

				AND CASE p.proargtypes[0]

					WHEN 'pg_catalog.\"any\"'::pg_catalog.regtype THEN ''

					ELSE pg_catalog.format_type(p.proargtypes[0], NULL)

				END ='{$basetype}'";

        return $this->selectSet($sql);

    }

    // Sequence functions