DALMysqlConverter.inc

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

class DALMysqlConverter extends DALConverter
{

    protected $tableName = '';

    protected $name = 'MySQL';

    protected $dataTypes = array(
                            'char'                => 'CHAR',
                            'varchar'             => 'VARCHAR',
                            'clob'                => 'LONGTEXT',
                            'blob'                => 'LONGBLOB',
                            'integer'             => 'INT',
                            'smallint'            => 'SMALLINT',
                            'numeric'             => 'NUMERIC',
                            'float'               => 'FLOAT',
                            'real'                => 'REAL',
                            'double_precision'    => 'DOUBLE PRECISION',
                            'boolean'             => 'VARCHAR(10)',
                            'date'                => 'DATE',
                            'time'                => 'TIME',
                            'timestamp'           => 'DATETIME',
                            'time with time zone' => 'TIME',
                           );


    public function __construct()
    {

    }//end __construct()


    public function convertCreateTable(array $table)
    {
        $this->tableName = $table['table'];

        $sql  = $this->convertCreateHeader($table);
        $sql .= "\n".$this->convertCreateColumns($table);
        $sql .= ')TYPE=InnoDB;';

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

        $constraints = $this->convertAlterQueryAddConstraint($table['CONSTRAINTS'], TRUE);
        $sql        .= "\n".$constraints;



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

        return $sql;

    }//end convertCreateTable()


    protected function convertAlterQueryAddConstraint(array $constraints, $incHeader=FALSE)
    {
        $sql = '';
        if (empty($constraints) === FALSE) {
            $convertedCons = $this->convertConstraints($constraints, TRUE);
            $cons          = array();
            foreach ($convertedCons as $constraint) {
                $sql = '';
                if ($incHeader === TRUE) {
                    $sql .= $this->convertAlterQueryHeader($this->tableName);
                }

                $sql .= 'ADD '.$constraint;

                $cons[] = $sql;
            }

            $sql = implode(";\n", $cons).";\n";
        }

        return $sql;

    }//end convertAlterQueryAddConstraint()


    protected function convertSingleSequence($sequence)
    {
        $sql = 'CREATE TABLE '.$sequence.' (
                    id INT AUTO_INCREMENT NOT NULL PRIMARY KEY)';

        return $sql;

    }//end convertSingleSequence()


    protected function handleFunctionSeqNextVal(array $seqName)
    {
        $sql = 'INSERT INTO '.$seqName[0].' VALUES(0)';
        return $sql;

    }//end handleFunctionSeqNextVal()


    protected function handleFunctionSeqCurrVal(array $seqName)
    {
        $sql = 'SELECT LAST_INSERT_ID()';
        return $sql;

    }//end handleFunctionSeqCurrVal()


    public function convertDropSequence($sequenceName)
    {
        $sql = $this->convertDropTable($sequenceName);
        return $sql;

    }//end convertDropSequence()


    protected function handleFunctionToDate(array $args)
    {
        $iso8601_date = $this->convertSingleField($args[0]);

        // There does not appear to be any requirement for dates to be
        // handled any other way than being quoted in MySQL
        $sql = $iso8601_date;
        return $sql;

    }//end handleFunctionToDate()


    public function convertDropTable($tableName)
    {
        $sql = 'DROP TABLE IF EXISTS '.$tableName;
        return $sql;

    }//end convertDropTable()


    public function handleFunctionSequenceExists($sequenceName)
    {
        return $this->handleFunctionTableExists($sequenceName);

    }//end handleFunctionSequenceExists()


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

    }//end handleFunctionConcat()


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

    }//end convertCallQuery()


}//end class

?>