Chubbyphp\Model\Doctrine\DBAL\Command\SchemaUpdateCommand

Complexity

Total Complexity

16

Size/Duplication

Total Lines	137
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	5

Test Coverage

Coverage

100%

Importance

Changes

0

7 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	5	1
A	__invoke()	0	28	4
A	update()	0	10	4
A	getStatements()	0	12	1
A	dump()	0	10	2
A	force()	0	10	2
A	dumpAndForce()	0	13	2

<?php

declare(strict_types=1);

namespace Chubbyphp\Model\Doctrine\DBAL\Command;

use Doctrine\DBAL\Connection;
use Doctrine\DBAL\Schema\Schema;
use Symfony\Component\Console\Input\InputInterface;
use Symfony\Component\Console\Output\OutputInterface;

final class SchemaUpdateCommand
{
    /**
     * @var Connection
     */
    private $connection;

    /**
     * @var
     */
    private $schemaPath;

    /**
     * @param Connection $connection
     * @param string     $schemaPath
     */
    public function __construct(Connection $connection, string $schemaPath)
    {
        $this->connection = $connection;
        $this->schemaPath = $schemaPath;
    }

    /**
     * @param InputInterface  $input
     * @param OutputInterface $output
     *
     * @return int|null
     */
    public function __invoke(InputInterface $input, OutputInterface $output)
    {
        $dump = true === $input->getOption('dump');
        $force = true === $input->getOption('force');

        if ([] === $statements = $this->getStatements()) {
            $output->writeln('<info>No schema changes required</info>');

            return;
        }

        if (!$dump && !$force) {
            $output->writeln('<comment>ATTENTION</comment>: Do not execute in production.');
            $output->writeln('    Use the incremental update to detect changes during development and use');
            $output->writeln('    the SQL provided to manually update your database in production.');
            $output->writeln('');
            $output->writeln(sprintf('Would execute <info>"%s"</info> queries.', count($statements)));
            $output->writeln('Please run the operation by passing one - or both - of the following options:');
            $output->writeln('    <info>--force</info> to execute the command');
            $output->writeln('    <info>--dump</info> to dump the SQL statements to the screen');

            return 1;
        }

        $this->update($output, $statements, $dump, $force);

        return 0;
    }

    /**
     * @param OutputInterface $output
     * @param array           $statements
     * @param bool            $dump
     * @param bool            $force
     */
    private function update(OutputInterface $output, array $statements, bool $dump, bool $force)
    {
        if ($dump && $force) {
            $this->dumpAndForce($output, $statements);
        } elseif ($dump) {
            $this->dump($output, $statements);
        } else {
            $this->force($statements);
        }
    }

    /**
     * @return array
     */
    private function getStatements(): array
    {
        $connection = $this->connection;

        $schemaManager = $connection->getSchemaManager();
        $fromSchema = $schemaManager->createSchema();

        /** @var Schema $schema */
        $schema = require $this->schemaPath;

        return $fromSchema->getMigrateToSql($schema, $connection->getDatabasePlatform());
    }

    /**
     * @param OutputInterface $output
     * @param array           $statements
     */
    private function dump(OutputInterface $output, array $statements)
    {
        $output->writeln('<info>Begin transaction</info>');

        foreach ($statements as $statement) {
            $output->writeln($statement);
        }

        $output->writeln('<info>Commit</info>');
    }

    /**
     * @param array $statements
     */
    private function force(array $statements)
    {
        $this->connection->beginTransaction();

        foreach ($statements as $statement) {
            $this->connection->exec($statement);
        }

        $this->connection->commit();
    }

    /**
     * @param OutputInterface $output
     * @param array           $statements
     */
    private function dumpAndForce(OutputInterface $output, array $statements)
    {
        $output->writeln('<info>Begin transaction</info>');
        $this->connection->beginTransaction();

        foreach ($statements as $statement) {
            $output->writeln($statement);
            $this->connection->exec($statement);
        }

        $output->writeln('<info>Commit</info>');
        $this->connection->commit();
    }
}