DALPostgresConverter.inc

<?php
require_once dirname(__FILE__).'/DALConverter.inc';

class DALPostgresConverter extends DALConverter
{

    protected $name = 'Postgres';


    public function __construct()
    {

    }//end __construct()


    public function convertCreateTable(array $table)
    {
        $sql  = $this->convertCreateHeader($table);
        $sql .= "\n".$this->convertCreateColumns($table).',';
        $sql .= "\n".$this->convertConstraints($table['CONSTRAINTS']);
        $sql .= $this->convertCreateFooter($table);

        $indexes = $this->convertCreateIndexes($table);
        if ($indexes !== '') {
            $sql .= "\n".$indexes;
        }

        if (isset($table['SEQUENCES']) === TRUE) {
            $sql .= "\n".$this->convertCreateSequences($table['SEQUENCES']);
        }

        return $sql;

    }//end convertCreateTable()


    protected function convertCreateIndexes(array $table)
    {
        $sql     = '';
        $indexes = array();
        foreach ($table['INDEXES'] as $index) {
            $indexes[] = $this->convertSingleIndex($index, $table['table']);
        }

        $sql .= implode(";\n", $indexes).';';

        return $sql;

    }//end convertCreateIndexes()


    protected function convertSingleIndex(array $idx, $tableName)
    {
        $sql  = 'CREATE INDEX '.$idx['name'].' ON '.$tableName.' (';
        $sql .= $this->separateFields($idx['COLUMNS']).')';
        return $sql;

    }//end convertSingleIndex()


    protected function handleFunctionSeqNextVal(array $seqName)
    {
        $sql = '(SELECT nextVal(\''.$seqName[0].'\'))';
        return $sql;

    }//end handleFunctionSeqNextVal()


    protected function handleFunctionSeqCurrVal(array $seqName)
    {
        $sql = '(SELECT currVal(\''.$seqName[0].'\'))';
        return $sql;

    }//end handleFunctionSeqCurrVal()


    public function handleFunctionSequenceExists($sequenceName)
    {
        if (is_array($sequenceName) === TRUE) {
            $sequenceName = $sequenceName[0];
        }

        $sql = 'SELECT count(c.relname) FROM pg_catalog.pg_class c, pg_catalog.pg_roles r, pg_catalog.pg_namespace n
                WHERE    r.oid = c.relowner AND n.oid = c.relnamespace AND c.relkind = \'S\'
                AND n.nspname <> \'pg_catalog\'
                AND pg_catalog.pg_table_is_visible(c.oid)
                AND c.relname = '.$sequenceName;

        return $sql;

    }//end handleFunctionSequenceExists()


    protected function handleFunctionConcat(array $args)
    {
        $sql = implode(' || ', $args);
        return $sql;

    }//end handleFunctionConcat()


    protected function handleFunctionToDate(array $args)
    {
        $iso8601_date = $this->convertSingleField($args[0]);
        $sql = 'TO_TIMESTAMP('.$iso8601_date.', \'YYYY-MM-DD HH24:MI:SS\')';
        return $sql;

    }//end handleFunctionToDate()


    protected function convertCallQuery(array $callQuery)
    {
        $sql  = 'SELECT ';
        $sql .= $this->convertSingleFunction($callQuery);
        return $sql;

    }//end convertCallQuery()


    public function handleFunctionTableExists($tableName, $schema=NULL)
    {
        if (is_array($tableName) === TRUE) {
            $tableName = $tableName[0];
        }

        if ($schema === NULL) {
            $schema = '\''.DAL::getDbName().'\'';
        }

        $sql = 'SELECT count(*) FROM INFORMATION_SCHEMA.tables WHERE TABLE_NAME = '.$tableName.' AND TABLE_SCHEMA = \'public\' AND TABLE_CATALOG = '.$schema;
        return $sql;

    }//end handleFunctionTableExists()


}//end class

?>