Ego_Sql_innodb.php

gehe zur Dokumentation dieser Datei

<?php
require_once('base/Ego_Sql_Abstract.php');
 
class Ego_Sql_innodb extends Ego_Sql_Abstract
{
    static  $_staticInnodbHandle; 
    function connect($database='', $host='', $user='', $password='')
    {
        try {
            if (func_num_args()==0)
            {
                if (Ego_Sql_innodb::$_staticInnodbHandle)
                { // Nur die EGOTEC Standardverbindung wird global gespeichert.
                    $this->_db = Ego_Sql_innodb::$_staticInnodbHandle;
                    return;
                } else {
                    $this->_db = Ego_Sql_innodb::$_staticInnodbHandle = new PDO(
                            'mysql:host='.$GLOBALS['egotec_conf']['db']['host'].
                            ($GLOBALS['egotec_conf']['db']['port']?';port='.$GLOBALS['egotec_conf']['db']['port']:'').
                            ';dbname='.$GLOBALS['egotec_conf']['db']['database'],
                            $GLOBALS['egotec_conf']['db']['user'],
                            $GLOBALS['egotec_conf']['db']['password']);
                }
            } else {
                $this->_db = new PDO('mysql:host='.$host.';dbname='.$database, $user, $password);
            }
        } catch (PDOException $e) {
            $this->onError('connect');
            throw new Ego_Sql_Exception(
                "Konnte keine Datenbankverbindung herstellen.\n".$e->getMessage(),
                Ego_Sql_Exception::CONNECT_ERROR
            );
        }
        $this->_db->setAttribute(PDO::MYSQL_ATTR_USE_BUFFERED_QUERY, true);
        $this->_db->query('SET NAMES utf8; SET collation_connection=\'utf8_bin\'');
    }
 
    private function _changeType($type)
    {
        $type = str_replace('/*bin*/', '', $type, $count);
 
        switch ($type)
        {
            case 'smalltext':
                $type = 'TEXT';
                break;
            case 'text':
                $type = 'LONGTEXT';
                break;
            case 'tinyint':
            case 'int':
            case 'bigint':
                $type .= ' DEFAULT 0';
        }
        if ($count > 0) {
            $type .= ' character set utf8 collate utf8_bin';
        }
        return $type;
    }
 
    function createTable($table, $struct, $drop_flag=true, $notexists_flag=false)
    {
        if ($drop_flag) {
            $this->query('DROP TABLE IF EXISTS '.$table); // Eine evtl. vorhandene Tabelle entfernen.
        }
        $query = array();
        foreach ($struct as $name => $type)
        {
            $key = explode(' ', $name);
            $type = $this->_changeType($type);
            if (sizeof($key)==1)
            { // Ein Feld erzeugen.
                $query[] = $name.' '.$type.' NOT NULL';
            } else {
                switch ($key[0])
                {
                    case 'PRIMARY':
                        $query[] = 'PRIMARY KEY ('.$type.')';
                        break;
                    case 'KEY':
                        $query[] = 'KEY '.$key[1].' ('.$type.')';
                        break;
                    case 'UNIQUE':
                        $query[] = 'UNIQUE KEY '.$key[1].' ('.$type.')';
                }
            }
        }
        $this->query('CREATE TABLE '.($notexists_flag?'IF NOT EXISTS ':'').$table.' ('.implode(',', $query).
            ') ENGINE=InnoDB DEFAULT CHARSET=utf8 COLLATE=utf8_general_ci;');
    }
 
    public function showColumns($table)
    {
        if (!$table) return array();
        $hdl = $this->_db->query('SHOW COLUMNS FROM '.$table);
        $cols = array();
        while($record = $hdl->fetch(PDO::FETCH_ASSOC))
        {
            $cols[] = array(
                'field' => $record['Field'],
                'type' => $record['Type']
            );
        }
        return $cols;
    }
 
    function alterTable($table, $struct)
    {
        $query = array();
        foreach ($struct as $name => $type)
        {
            $key = explode(' ', $name);
            $type = $this->_changeType($type);
            if (sizeof($key)==1)
            { // Ein Feld erzeugen.
                $query[] = 'ADD '.$name.' '.$type.' NOT NULL';
            } else {
                switch ($key[0])
                {
                    case 'PRIMARY':
                        $query[] = 'ADD PRIMARY KEY ('.$type.')';
                        break;
                    case 'KEY':
                        $query[] = 'ADD KEY '.$key[1].' ('.$type.')';
                        break;
                    case 'UNIQUE':
                        $query[] = 'ADD UNIQUE KEY '.$key[1].' ('.$type.')';
                        break;
                    case 'FULLTEXT':
                        $query[] = 'ADD FULLTEXT '.$key[1].' ('.$type.')';
                        break;
                    case 'CHANGE':
                        $query[] = 'CHANGE '.$key[1].' '.$key[2].' '.$type;
                }
            }
        }
        return $this->query('ALTER TABLE '.$table.' '.implode(',', $query));
    }
 
    function begin()
    {
        $this->_db->beginTransaction();
        $this->_transaction = true;
    }
 
    function commit()
    {
        $this->_transaction = false;
        $this->_db->commit();
    }
 
    function rollback()
    {
        if ($this->_transaction) { // Die Transaktion nur zurücksetzen wenn eine gestartet wurde.
            $this->_db->rollback();
            $this->_transaction = false;
        }
    }
 
    function getVersion() {
        $this->query('SELECT @@version');
        if ($this->nextRecord() &&  preg_match('/^[0-9.]+/', $this->Record['@@version'], $matches)) {
            return $matches[0];
        }
        return '';
    }
 
    function tableExists($table) {
        if (!$table)
        {
            return false;
        }
        $this->query("SHOW TABLES FROM `".$GLOBALS['egotec_conf']['db']['database']."` LIKE '$table'");
 
        return (bool)$this->nextRecord();
    }
 
    function getPrimary($table)
    {
        $db = clone $this;
        $db->select(array(
            'fields'    => 'cols.column_name,cols2.data_type',
            'table' => 'information_schema.table_constraints cons,information_schema.key_column_usage cols,information_schema.columns cols2',
            'where' => 'cols.table_name=\''.$table.'\' '.
            'AND cols.table_schema=\''.$GLOBALS['egotec_conf']['db']['database'].'\''.
            'AND cons.constraint_type=\'PRIMARY KEY\' '.
            'AND cols.constraint_name=cons.constraint_name AND cols.table_schema=cons.table_schema AND cols.table_name=cons.table_name '.
            'AND cols2.table_schema=cons.table_schema AND cols2.table_name=cons.table_name AND cols2.column_name=cols.column_name'
        ));
        $primary = array();
        while ($db->nextRecord())
        {
            if (strpos($db->Record['data_type'], 'int')!==false)
            {
                $type = 'int';
            } else {
                $type = 'string';
            }
            $primary[$db->Record['column_name']] = $type;
        }
        return $primary;
    }
}
?>