pgsql.php

Ir a la documentación de este archivo.

<?php
require_once CORE_PATH . 'libs/db/adapters/pdo.php';

class DbPdoPgSQL extends DbPDO
{

    protected $db_rbdm = "pgsql";
    protected $db_port = 5432;

    const TYPE_INTEGER = "INTEGER";

    const TYPE_DATE = "DATE";

    const TYPE_VARCHAR = "VARCHAR";

    const TYPE_DECIMAL = "DECIMAL";

    const TYPE_DATETIME = "DATETIME";

    const TYPE_CHAR = "CHAR";

    public function initialize()
    {

    }

    public function last_insert_id($table='', $primary_key='')
    {
        return $this->pdo->lastInsertId("{$table}_{$primary_key}_seq");
    }

    function table_exists($table, $schema='')
    {
        $table = addslashes(strtolower($table));
        if (strpos($table, ".")) {
            list($schema, $table) = explode(".", $table);
        }
        if ($schema == '') {
            $num = $this->fetch_one("SELECT COUNT(*) FROM INFORMATION_SCHEMA.TABLES WHERE TABLE_SCHEMA = 'public' AND TABLE_NAME ='$table'");
        } else {
            $schema = addslashes(strtolower($schema));
            $num = $this->fetch_one("SELECT COUNT(*) FROM INFORMATION_SCHEMA.TABLES WHERE TABLE_SCHEMA = '$schema' AND TABLE_NAME ='$table'");
        }
        return $num[0];
    }

    public function limit($sql)
    {
        $params = Util::getParams(func_get_args());
        $sql_new = $sql;

        if (isset($params['limit']) && is_numeric($params['limit'])) {
            $sql_new.=" LIMIT $params[limit]";
        }

        if (isset($params['offset']) && is_numeric($params['offset'])) {
            $sql_new.=" OFFSET $params[offset]";
        }

        return $sql_new;
    }

    public function drop_table($table, $if_exists=true)
    {
        if ($if_exists) {
            if ($this->table_exists($table)) {
                return $this->query("DROP TABLE $table");
            } else {
                return true;
            }
        } else {
            return $this->query("DROP TABLE $table");
        }
    }

    public function create_table($table, $definition, $index=array())
    {
        $create_sql = "CREATE TABLE $table (";
        if (!is_array($definition)) {
            new KumbiaException("Definici&oacute;n invalida para crear la tabla '$table'");
            return false;
        }
        $create_lines = array();
        $index = array();
        $unique_index = array();
        $primary = array();
        //$not_null = "";
        //$size = "";
        foreach ($definition as $field => $field_def) {
            if (isset($field_def['not_null'])) {
                $not_null = $field_def['not_null'] ? 'NOT NULL' : '';
            } else {
                $not_null = "";
            }
            if (isset($field_def['size'])) {
                $size = $field_def['size'] ? '(' . $field_def['size'] . ')' : '';
            } else {
                $size = "";
            }
            if (isset($field_def['index'])) {
                if ($field_def['index']) {
                    $index[] = "INDEX($field)";
                }
            }
            if (isset($field_def['unique_index'])) {
                if ($field_def['unique_index']) {
                    $index[] = "UNIQUE($field)";
                }
            }
            if (isset($field_def['primary'])) {
                if ($field_def['primary']) {
                    $primary[] = "$field";
                }
            }
            if (isset($field_def['auto'])) {
                if ($field_def['auto']) {
                    $field_def['type'] = "SERIAL";
                }
            }
            if (isset($field_def['extra'])) {
                $extra = $field_def['extra'];
            } else {
                $extra = "";
            }
            $create_lines[] = "$field " . $field_def['type'] . $size . ' ' . $not_null . ' ' . $extra;
        }
        $create_sql.= join(',', $create_lines);
        $last_lines = array();
        if (count($primary)) {
            $last_lines[] = 'PRIMARY KEY(' . join(",", $primary) . ')';
        }
        if (count($index)) {
            $last_lines[] = join(',', $index);
        }
        if (count($unique_index)) {
            $last_lines[] = join(',', $unique_index);
        }
        if (count($last_lines)) {
            $create_sql.= ',' . join(',', $last_lines) . ')';
        }
        return $this->query($create_sql);
    }

    public function list_tables()
    {
        return $this->fetch_all("SELECT c.relname AS table_name FROM pg_class c, pg_user u "
                . "WHERE c.relowner = u.usesysid AND c.relkind = 'r' "
                . "AND NOT EXISTS (SELECT 1 FROM pg_views WHERE viewname = c.relname) "
                . "AND c.relname !~ '^(pg_|sql_)' UNION "
                . "SELECT c.relname AS table_name FROM pg_class c "
                . "WHERE c.relkind = 'r' "
                . "AND NOT EXISTS (SELECT 1 FROM pg_views WHERE viewname = c.relname) "
                . "AND NOT EXISTS (SELECT 1 FROM pg_user WHERE usesysid = c.relowner) "
                . "AND c.relname !~ '^pg_'");
    }

    public function describe_table($table, $schema='')
    {
        $describe = $this->fetch_all("SELECT a.attname AS Field, t.typname AS Type,
                                CASE WHEN attnotnull=false THEN 'YES' ELSE 'NO' END AS Null,
                                CASE WHEN (select cc.contype FROM pg_catalog.pg_constraint cc WHERE
                                cc.conrelid = c.oid AND cc.conkey[1] = a.attnum)='p' THEN 'PRI' ELSE ''
                                END AS Key, CASE WHEN atthasdef=true THEN TRUE ELSE NULL END AS Default 
                FROM pg_catalog.pg_class c, pg_catalog.pg_attribute a,
                                pg_catalog.pg_type t WHERE c.relname = '$table' AND c.oid = a.attrelid
                                AND a.attnum > 0 AND t.oid = a.atttypid order by a.attnum");
        $final_describe = array();
        foreach ($describe as $key => $value) {
            $final_describe[] = array(
                "Field" => $value["field"],
                "Type" => $value["type"],
                "Null" => $value["null"],
                "Key" => $value["key"],
                "Default" => $value["default"]
            );
        }
        return $final_describe;
    }

}