compare.php

<?php
namespace Bitrix\Perfmon\Sql;
 
class Compare
{
    private $difference = [];
 
    public static function diff(Schema $source, Schema $target)
    {
        $compare = new Compare;
        $compare->compareSequences($source, $target);
        $compare->compareProcedures($source, $target);
        $compare->compareTables($source, $target);
        return $compare->difference;
    }
 
    private function compareSequences(Schema $source, Schema $target)
    {
        foreach ($source->sequences->compare($target->sequences) as $pair)
        {
            $this->difference[] = $pair;
        }
    }
 
    private function compareProcedures(Schema $source, Schema $target)
    {
        foreach ($source->procedures->compare($target->procedures) as $pair)
        {
            $this->difference[] = $pair;
        }
    }
 
    private function compareTables(Schema $source, Schema $target)
    {
        foreach ($source->tables->compare($target->tables, false) as $pair)
        {
            if (isset($pair[0]) && isset($pair[1]))
            {
                $this->compareTable($pair[0], $pair[1]);
            }
            elseif (!isset($pair[0]) && isset($pair[1])) //Table created
            {
                $this->difference[] = $pair;
 
                $emptyCollection = new Collection;
                foreach ($emptyCollection->compare($pair[1]->triggers) as $pair2)
                {
                    $this->difference[] = $pair2;
                }
            }
            else
            {
                $this->difference[] = $pair;
            }
        }
    }
 
    private function compareTable(Table $source, Table $target)
    {
        foreach ($source->columns->compare($target->columns) as $pair)
        {
            if (isset($pair[0]) && isset($pair[1]))
            {
                $this->compareColumn($pair[0], $pair[1]);
            }
            else
            {
                $this->difference[] = $pair;
            }
        }
        foreach ($source->indexes->compare($target->indexes) as $pair)
        {
            $this->difference[] = $pair;
        }
        foreach ($source->constraints->compare($target->constraints) as $pair)
        {
            $this->difference[] = $pair;
        }
        foreach ($source->triggers->compare($target->triggers) as $pair)
        {
            $this->difference[] = $pair;
        }
    }
 
    private function compareColumn(Column $source, Column $target)
    {
        if (
            $source->type !== $target->type
            || $source->unsigned !== $target->unsigned
            || $source->length !== $target->length
            || $source->nullable !== $target->nullable
            || $source->default !== $target->default
        )
        {
            $this->difference[] = [$source, $target];
        }
    }
}