SchemaDiff.php

Go to the documentation of this file.

<?php
namespace Magento\Framework\Setup\Declaration\Schema\Diff;

use Magento\Framework\Setup\Declaration\Schema\Dto\Schema;
use Magento\Framework\Setup\Declaration\Schema\OperationsExecutor;

class SchemaDiff
{
    private $tableDiff;

    private $diffManager;

    private $diffFactory;

    private $operationsExecutor;

    public function __construct(
        DiffManager $diffManager,
        TableDiff $tableDiff,
        DiffFactory $diffFactory,
        OperationsExecutor $operationsExecutor
    ) {
        $this->tableDiff = $tableDiff;
        $this->diffManager = $diffManager;
        $this->diffFactory = $diffFactory;
        $this->operationsExecutor = $operationsExecutor;
    }

    private function createTableIndex(array $tableNames, array $generatedTableNames)
    {
        foreach ($generatedTableNames as $tableName) {
            //If table exists only in db
            if (!in_array($tableName, $tableNames)) {
                $tableNames[] = $tableName;
            }
        }

        return array_flip($tableNames);
    }

    public function diff(
        Schema $schema,
        Schema $generatedSchema
    ) {
        $generatedTables = $generatedSchema->getTables();
        $tableNames = array_keys($schema->getTables());
        $generatedTableNames = array_keys($generatedSchema->getTables());

        $diff = $this->diffFactory->create(
            [
                'tableIndexes' => $this->createTableIndex($tableNames, $generatedTableNames),
                'destructiveOperations' => $this->operationsExecutor->getDestructiveOperations()
            ]
        );

        foreach ($schema->getTables() as $name => $table) {
            if ($this->diffManager->shouldBeCreated($generatedTables, $table)) {
                $diff = $this->diffManager->registerCreation($diff, $table);
            } else {
                $diff = $this->tableDiff->diff($table, $generatedTables[$name], $diff);
            }

            unset($generatedTables[$name]);
        }
        //Removal process
        if ($this->diffManager->shouldBeRemoved($generatedTables)) {
            $diff = $this->diffManager->registerRemoval($diff, $generatedTables);
        }

        return $diff;
    }
}