AbstractEntity.php

<?php
abstract class ZendDbSchema_Db_Schema_AbstractEntity
    extends ZendDbSchema_Db_Schema_AbstractSchema
{
    protected $_adapter;

    protected $_generator;

    protected $_cleanSchema  = array();

    abstract protected function _doReload();

    protected function _delete()
    {
    }

    protected function _postDelete()
    {
    }

    protected function _save()
    {
    }

    protected function _postSave()
    {
    }

    public function reload()
    {
        $this->_cleanSchema = array();

        if ($name = $this->getOriginName()) {
            $this->_doReload();
        }
        return $this;
    }

    public function refresh($param = null)
    {
        $this->reload();

        return parent::refresh($param);
    }

    protected function _getCleanSchema()
    {
        return $this->_cleanSchema;
    }

    public function __wakeup()
    {
        $this->reload();
    }


    public function exec($sql)
    {
        $queries = explode(';', $sql);
        $queries = array_filter($queries);

        foreach ($queries as $query) {
            $this->getAdapter()->exec($query);
        }
        return $this;
    }

    public function save()
    {
        if ($this->isDirty()) {

            $this->_save();

            $this->exec($this->toSql($this->isExist()));

            $this->_postSave();

            $this->_name = $this->getName();

            $this->refresh();
            return true;
        }
        return false;
    }

    public function delete()
    {
        if (!$this->isExist()) {
            throw new ZendDbSchema_Db_Schema_Exception('Cannot delete not existing schema');
        }
        $this->_delete();

        $this->exec($this->getDropSql());

        $this->_postDelete();

        $this->refresh();
        return $this;
    }

    public function getGenerator()
    {
        return $this->_generator;
    }

    public function getAdapter()
    {
        return $this->_adapter;
    }

    public static function getDefaultAdapter()
    {
        $defaultAdapter = Zend_Db_Table::getDefaultAdapter();
        $config = $defaultAdapter->getConfig();
        switch (true) {
            case $defaultAdapter instanceof Zend_Db_Adapter_Mysqli:
                $adapter = new ZendDbSchema_Db_Adapter_Mysqli($config);
                break;
            case $defaultAdapter instanceof Zend_Db_Adapter_Pdo_Mysql:
                $adapter = new ZendDbSchema_Db_Adapter_Pdo_Mysql($config);
                break;
            default:
                $adapterType = get_class($defaultAdapter);
                throw new ZendDbSchema_Db_Schema_Exception(
                    "Adapter '$adapterType' not supported"
                );
        }
        return $adapter;
    }
}