AbstractTable.php

<?php
abstract class ZendDbSchema_Validate_Db_Schema_AbstractTable
    extends ZendDbSchema_Validate_Db_Schema_Chain
{
    protected $_columnValidators = array();

    protected $_indexValidators = array();

    protected $_foreignKeyValidators = array();

    public function addIndexValidator(Zend_Validate_Interface $validator, $breakChainOnFailure = false)
    {
        $this->_indexValidators[] = array(
            'instance' => $validator,
            'breakChainOnFailure' => (boolean) $breakChainOnFailure
        );
        return $this;
    }

    public function addForeignKeyValidator(Zend_Validate_Interface $validator, $breakChainOnFailure = false)
    {
        $this->_foreignKeyValidators[] = array(
                'instance' => $validator,
                'breakChainOnFailure' => (boolean) $breakChainOnFailure
        );
        return $this;
    }

    public function addColumnValidator(Zend_Validate_Interface $validator, $breakChainOnFailure = false)
    {
        $this->_columnValidators[] = array(
                'instance' => $validator,
                'breakChainOnFailure' => (boolean) $breakChainOnFailure
        );
        return $this;
    }

    public function isValid($value)
    {
        $this->_messages = array();
        $this->_errors   = array();
        $result = true;

        if (!$value instanceof ZendDbSchema_Db_Schema_Table) {
            $this->_messages[] = 'Value must be instance of ZendDbSchema_Db_Schema_Table';
            $this->_errors[]   = 'tableInvalid';
            return false;
        }

        foreach ($this->_validators as $element) {
            $validator = $element['instance'];
            if ($validator->isValid($value)) {
                continue;
            }
            $result = false;
            $messages = $validator->getMessages();
            $this->_messages = array_merge($this->_messages, $messages);
            $this->_errors   = array_merge($this->_errors,   array_keys($messages));
            if ($element['breakChainOnFailure']) {
                break;
            }
        }

        $val = new Zend_Validate_GreaterThan(0);
        if (!$val->isValid(count($value->columns()))) {
            $result = false;
            $messages =  array('columnsEmpty' => 'Must be at least 1 column in table');
            $this->_messages = array_merge($this->_messages, $messages);
            $this->_errors   = array_merge($this->_errors,   array_keys($messages));
        }

        foreach ($value->columns() as $column) {
            foreach ($this->_columnValidators as $element) {
                $validator = $element['instance'];
                if ($validator->isValid($column)) {
                    continue;
                }
                $result = false;
                $messages = $validator->getMessages();
                $this->_messages = array_merge($this->_messages, $messages);
                $this->_errors   = array_merge($this->_errors,   array_keys($messages));
                if ($element['breakChainOnFailure']) {
                    break;
                }
            }
        }

        foreach ($value->indexes() as $index) {
            foreach ($this->_indexValidators as $element) {
                $validator = $element['instance'];
                if ($validator->isValid($index)) {
                    continue;
                }
                $result = false;
                $messages = $validator->getMessages();
                $this->_messages = array_merge($this->_messages, $messages);
                $this->_errors   = array_merge($this->_errors,   array_keys($messages));
                if ($element['breakChainOnFailure']) {
                    break;
                }
            }
        }

        foreach ($value->foreigns() as $foreign) {
            foreach ($this->_indexValidators as $element) {
                $validator = $element['instance'];
                if ($validator->isValid($foreign)) {
                    continue;
                }
                $result = false;
                $messages = $validator->getMessages();
                $this->_messages = array_merge($this->_messages, $messages);
                $this->_errors   = array_merge($this->_errors,   array_keys($messages));
                if ($element['breakChainOnFailure']) {
                    break;
                }
            }
        }
        return $result;
    }
}