Cycle\Database\Schema\Comparator

Complexity

Total Complexity

39

Size/Duplication

Total Lines	200
Duplicated Lines	0 %

Test Coverage

Coverage

100%

Importance

Changes

0

13 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	alteredIndexes()	0	17	4
A	addedForeignKeys()	0	10	3
A	droppedForeignKeys()	0	10	3
A	hasChanges()	0	23	3
A	isRenamed()	0	3	1
A	isPrimaryChanged()	0	3	1
A	alteredColumns()	0	17	5
A	droppedIndexes()	0	10	3
A	addedIndexes()	0	10	3
A	alteredForeignKeys()	0	17	4
A	droppedColumns()	0	12	4
A	addedColumns()	0	12	4

<?php

/**
 * This file is part of Cycle ORM package.
 *
 * For the full copyright and license information, please view the LICENSE
 * file that was distributed with this source code.
 */

declare(strict_types=1);

namespace Cycle\Database\Schema;

/**
 * Compares two table states.
 */
final class Comparator implements ComparatorInterface
{
    public function __construct(
        private State $initial,
        private State $current,
    ) {}

    public function hasChanges(): bool
    {
        if ($this->isRenamed()) {
            return true;
        }

        if ($this->isPrimaryChanged()) {
            return true;
        }

        $difference = [
            \count($this->addedColumns()),
            \count($this->droppedColumns()),
            \count($this->alteredColumns()),
            \count($this->addedIndexes()),
            \count($this->droppedIndexes()),
            \count($this->alteredIndexes()),
            \count($this->addedForeignKeys()),
            \count($this->droppedForeignKeys()),
            \count($this->alteredForeignKeys()),
        ];

        return \array_sum($difference) !== 0;
    }

    public function isRenamed(): bool
    {
        return $this->current->getName() !== $this->initial->getName();
    }

    public function isPrimaryChanged(): bool
    {
        return $this->current->getPrimaryKeys() !== $this->initial->getPrimaryKeys();
    }

    /**
     * @return AbstractColumn[]
     */
    public function addedColumns(): array
    {
        $difference = [];

        $initialColumns = $this->initial->getColumns();
        foreach ($this->current->getColumns() as $name => $column) {
            if (!isset($initialColumns[$name]) && !$column->isReadonlySchema()) {
                $difference[] = $column;
            }
        }

        return $difference;
    }

    /**
     * @return AbstractColumn[]
     */
    public function droppedColumns(): array
    {
        $difference = [];

        $currentColumns = $this->current->getColumns();
        foreach ($this->initial->getColumns() as $name => $column) {
            if (!isset($currentColumns[$name]) && !$column->isReadonlySchema()) {
                $difference[] = $column;
            }
        }

        return $difference;
    }

    /**
     * Returns array where each value contain current and initial element state.
     */
    public function alteredColumns(): array
    {
        $difference = [];

        $initialColumns = $this->initial->getColumns();
        foreach ($this->current->getColumns() as $name => $column) {
            if (!isset($initialColumns[$name])) {
                //Added into schema
                continue;
            }

            if (!$column->compare($initialColumns[$name]) && !$column->isReadonlySchema()) {
                $difference[] = [$column, $initialColumns[$name]];
            }
        }

        return $difference;
    }

    /**
     * @return AbstractIndex[]
     */
    public function addedIndexes(): array
    {
        $difference = [];
        foreach ($this->current->getIndexes() as $_ => $index) {
            if (!$this->initial->hasIndex($index->getColumnsWithSort())) {
                $difference[] = $index;
            }
        }

        return $difference;
    }

    /**
     * @return AbstractIndex[]
     */
    public function droppedIndexes(): array
    {
        $difference = [];
        foreach ($this->initial->getIndexes() as $_ => $index) {
            if (!$this->current->hasIndex($index->getColumnsWithSort())) {
                $difference[] = $index;
            }
        }

        return $difference;
    }

    /**
     * Returns array where each value contain current and initial element state.
     */
    public function alteredIndexes(): array
    {
        $difference = [];

        foreach ($this->current->getIndexes() as $_ => $index) {
            if (!$this->initial->hasIndex($index->getColumnsWithSort())) {
                //Added into schema
                continue;
            }

            $initial = $this->initial->findIndex($index->getColumnsWithSort());
            if (!$index->compare($initial)) {
                $difference[] = [$index, $initial];
            }
        }

        return $difference;
    }

    /**
     * @return AbstractForeignKey[]
     */
    public function addedForeignKeys(): array
    {
        $difference = [];
        foreach ($this->current->getForeignKeys() as $_ => $foreignKey) {
            if (!$this->initial->hasForeignKey($foreignKey->getColumns())) {
                $difference[] = $foreignKey;
            }
        }

        return $difference;
    }

    /**
     * @return AbstractForeignKey[]
     */
    public function droppedForeignKeys(): array
    {
        $difference = [];
        foreach ($this->initial->getForeignKeys() as $_ => $foreignKey) {
            if (!$this->current->hasForeignKey($foreignKey->getColumns())) {
                $difference[] = $foreignKey;
            }
        }

        return $difference;
    }

    /**
     * Returns array where each value contain current and initial element state.
     */
    public function alteredForeignKeys(): array
    {
        $difference = [];

        foreach ($this->current->getForeignKeys() as $_ => $foreignKey) {
            if (!$this->initial->hasForeignKey($foreignKey->getColumns())) {
                //Added into schema
                continue;
            }

            $initial = $this->initial->findForeignKey($foreignKey->getColumns());
            if (!$foreignKey->compare($initial)) {
                $difference[] = [$foreignKey, $initial];
            }
        }

        return $difference;
    }
}