Simplex\Quickstart\Shared\Console\CreateDatabaseCommand

Complexity

Total Complexity

5

Size/Duplication

Total Lines	65
Duplicated Lines	0 %

Test Coverage

Coverage

0%

Importance

Changes

0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	configure()	0	10	1
A	__construct()	0	20	1
A	execute()	0	11	3

<?php

namespace Simplex\Quickstart\Shared\Console;

use Doctrine\DBAL\Connection;
use Doctrine\DBAL\DriverManager;
use Symfony\Component\Console\Command\Command;
use Symfony\Component\Console\Input\InputInterface;
use Symfony\Component\Console\Input\InputOption;
use Symfony\Component\Console\Output\OutputInterface;

final class CreateDatabaseCommand extends Command
{
    public const COMMAND_NAME = 'orm:database:create';

    private const OPTION_IF_NOT_EXISTS = 'if-not-exists';

    /** @var Connection */
    private $connection;

    /** @var string */
    private $name;

    /**
     * @SuppressWarnings(PHPMD.ExcessiveParameterList)
     */
    public function __construct(
        string $host,
        string $port,
        string $name,
        string $user,
        string $pass
    ) {
        $this->connection = DriverManager::getConnection(
            [
                'driver' => 'pdo_mysql',
                'host' => $host,
                'port' => $port,
                'user' => $user,
                'password' => $pass,
            ]
        );

        $this->name = $name;

        parent::__construct();
    }

    protected function configure()
    {
        $this
            ->setName(self::COMMAND_NAME)
            ->setDescription('Creates the configured database')
            ->addOption(
                self::OPTION_IF_NOT_EXISTS,
                null,
                InputOption::VALUE_NONE,
                'Don\'t trigger an error, when the database already exists'
            )
        ;
    }

    /**
     * @SuppressWarnings(PHPMD.UnusedFormalParameter)
     */
    protected function execute(InputInterface $input, OutputInterface $output)
    {
        if ($input->getOption(self::OPTION_IF_NOT_EXISTS)
            && in_array($this->name, $this->connection->getSchemaManager()->listDatabases())
        ) {
            return;
        }

        $this->connection->getSchemaManager()->createDatabase($this->name);

        $output->writeln(sprintf('<info>Created database <comment>%s</comment></info>', $this->name));
    }
}