Table.php

<?php
class ZendDbSchema_Db_Schema_Generator_Pgsql_Table
    implements ZendDbSchema_Db_Schema_Generator_Table
{
    public function createTable(ZendDbSchema_Db_Schema_Table $schema)
    {
        $props = array();
        if ($schema->inherits) {
            //$props [] = "INHERITS {$schema->inherits}";
        }
        /*
        if (true === $schema->oids) {
            $props [] = "WITH OIDS";
        } elseif (false === $schema->oids) {
            $props [] = "WITHOUT OIDS";
        }
        */
        if ($schema->commit) {
            $props [] = "ON COMMIT {$schema->commit}";
        }
        if ($schema->tablespace) {
            $props [] = "TABLESPACE {$schema->tablespace}";
        }

        $columns = array();
        foreach ($schema->columns() as $column) {
            $columns[] = $column->toSql();
        }

        $columns = array_filter($columns);
        $columns = join(', ' . PHP_EOL, $columns);

        $name = $schema->getName();
        $query = array();
        $query[] = "DROP TABLE IF EXISTS {$name}";
        $query[] = "CREATE TABLE {$name} (" . PHP_EOL
                 . $columns . PHP_EOL
                 . ")" . PHP_EOL
                 . join(' ' . PHP_EOL, $props);

        return join(';' . PHP_EOL, $query);
    }

    public function alterTable(ZendDbSchema_Db_Schema_Table $schema)
    {
        if (!$schema->isExist()) {
            return null;
        }

        $query = array();

        $name = $schema->getName();
        if ($schema->isDirty(ZendDbSchema_Db_Schema_Table::NAME_KEY)) {
            $oldName = $schema->getOriginName();
            if ($oldName && $oldName != $name) {
                $query[] = "ALTER TABLE {$oldName} RENAME TO {$name}";
            }
        }

        if ($schema->isDirty('owner')) {
            $query[] = "ALTER TABLE {$name} OWNER TO {$schema->owner}";
        }

        if ($schema->isDirty('tablespace')) {
            $query[] = "ALTER TABLE {$name} SET TABLESPACE {$schema->tablespace}";
        }

        if ($schema->isDirty('schema')) {
           // $query[] = "ALTER TABLE {$name} SET SCHEMA {$schema->schema}";
        }

        return join(';' . PHP_EOL, $query);
    }

    public function dropTable(ZendDbSchema_Db_Schema_Table $schema)
    {
        if (!$schema->isExist()) {
            return null;
        }
        return "DROP TABLE IF EXISTS {$schema->getOriginName()}";
    }

    protected function _columnSql(ZendDbSchema_Db_Schema_Table_Column $schema)
    {
        $query = array();

        $query[] = $schema->type;

        if ($schema->getLength()) {
            $query[] = "({$schema->getLength()})";
        }

        if (!$schema->isNullable()) {
            $query[] = "NOT NULL";
        } elseif (null === $schema->default) {
            $query[] = "DEFAULT NULL";
        }

        if (null !== $schema->default) {
            $query[] = "DEFAULT {$schema->default}";
        }
        return join(' ', $query);
    }

    public function createColumn(ZendDbSchema_Db_Schema_Table_Column $schema)
    {
        $name = $schema->getName();
        return "{$name}" . ' ' . $this->_columnSql($schema);
    }

    public function alterColumn(ZendDbSchema_Db_Schema_Table_Column $schema)
    {
        if (!$schema->getTable()->isExist() || !$schema->isDirty()) {
            return null;
        }
        $name   = $schema->getName();

        $query = array();
        $prefix = "ALTER TABLE {$schema->getTable()->getName()}";

        if ($schema->isExist()) {
            $oldName = $schema->getOriginName();
            if ($oldName && $oldName != $name) {
                $oldName = $schema->getOriginName();
                $query[] = $prefix . " RENAME {$oldName} TO {$name}";
            } elseif ($schema->isDirty('type') || $schema->isDirty('length')) {
                $query[] = $prefix . " ALTER {$name} " . $this->_columnSql($schema);
            }
        } else {
            $query[] = $prefix . " ADD {$name} " . $this->_columnSql($schema);
        }

        return join(' ', $query);
    }

    public function dropColumn(ZendDbSchema_Db_Schema_Table_Column $schema)
    {
        $name   = $schema->getName();
        $table =  $schema->getTable()->getName();

        return "ALTER TABLE {$table} DROP COLUMN {$name}";
    }

    public function createIndex(ZendDbSchema_Db_Schema_Table_Index $schema)
    {
        $name   = $schema->getName();
        $table =  $schema->getTable()->getName();

        $columns = "";
        if ($schema->getColumns()) {
            $columns = "(" . join(', ', $schema->getColumns()) . ")";
        }
        $type = strtoupper($schema->type);

        $query = array();
        if ($schema->isExist()) {
            $query[] = $this->dropIndex($schema);
        }
        $query[] = "CREATE {$type} INDEX {$name} ON {$table} {$columns}";

        return join(';' . PHP_EOL, $query);
    }

    public function alterIndex(ZendDbSchema_Db_Schema_Table_Index $schema)
    {
        return $this->createIndex($schema);
    }

    public function dropIndex(ZendDbSchema_Db_Schema_Table_Index $schema)
    {
        $name   = $schema->getName();
        $table =  $schema->getTable()->getName();

        $query = "DROP INDEX IF EXISTS {$name} ON {$table}";
        return $query;
    }

    public function addPrimaryKey(ZendDbSchema_Db_Schema_Table_PrimaryKey $schema)
    {
        $columns = join(', ', $schema->getColumns());
        $table = $schema->getTable()->getName();

        $query = "ALTER TABLE {$table} ADD PRIMARY KEY ({$columns})";

        return $query;
    }

    public function dropPrimaryKey(ZendDbSchema_Db_Schema_Table_PrimaryKey $schema)
    {
        $table =  $schema->getTable()->getName();

        $query = "ALTER TABLE {$table} DROP PRIMARY KEY";
        return $query;
    }

    public function addForeignKey(ZendDbSchema_Db_Schema_Table_ForeignKey $schema)
    {
        $query = array();

        if ($name = $schema->getOriginName()) {
            $query[] = "CONSTRAINT {$name}";
        }

        $columns = $schema->getColumns();

        $refColumns = join(',', array_values($columns));
        $columns = join(',', array_keys($columns));
        $refTable = $schema->getReferences();

        $query[] = " FOREIGN KEY ({$columns}) REFERENCES {$refTable} ({$refColumns})";

        if ($delete = $schema->getOnDelete()) {
            $query[] = " ON DELETE {$delete}";
        }
        if ($update = $schema->getOnUpdate()) {
            $query[] = " ON UPDATE {$update}";
        }

        $table =  $schema->getTable()->getName();

        return "ALTER TABLE {$table} ADD " . join(' ', $query);
    }

    public function alterForeignKey(ZendDbSchema_Db_Schema_Table_ForeignKey $schema)
    {
        $query = array();
        if ($schema->isExist()) {
            $query[] = $this->dropForeignKey($schema);
        }
        $query[] = $this->addForeignKey($schema);
        return join(';' . PHP_EOL, $query);
    }

    public function dropForeignKey(ZendDbSchema_Db_Schema_Table_ForeignKey $schema)
    {
        $table =  $schema->getTable()->getName();
        $name = $schema->getOriginName();

        $query = "ALTER TABLE {$table} DROP FOREIGN KEY {$name}";
        return $query;
    }
}