StatementAggregator.php

Go to the documentation of this file.

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

class StatementAggregator
{
    private $statementsBank = [];

    private function canDoMerge(Statement $bankStatement, Statement $statement)
    {
        if ($statement instanceof ReferenceStatement && $statement->getName() === $bankStatement->getName()) {
            return false;
        }

        return empty($bankStatement->getTriggers()) &&
            $statement->getType() === $bankStatement->getType() &&
            $statement->getTableName() === $bankStatement->getTableName() &&
            $statement->getResource() === $bankStatement->getResource();
    }

    public function addStatements(array $statements)
    {
        foreach ($statements as $statement) {
            foreach ($this->statementsBank as $bankId => $bank) {
                foreach ($bank as $bankStatement) {
                    if (!$this->canDoMerge($bankStatement, $statement)) {
                        continue 2;
                    }
                }

                $this->statementsBank[$bankId][] = $statement;
                continue 2;
            }

            $this->statementsBank[][] = $statement;
        }
    }

    public function getStatementsBank()
    {
        return $this->statementsBank;
    }
}