Migrate::execute() - Code Metrics - Inspection of "Update SensioLabs badge." - zachleigh/yarak - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Push — master ( 758742...ec9771 )

by Zach

created 2017-03-24 14:07 UTC

Migrate::execute() A

↳ Parent: Migrate

Complexity

Conditions	4
Paths	4

Size

Total Lines	16
Code Lines	11

Duplication

Lines	0
Ratio	0 %

Importance

Changes

Metric	Value
cc	4
eloc	11
c	0
b	0
f	0
nc	4
nop	2
dl	0
loc	16
rs	9.2

<?php

namespace Yarak\Commands;

use Yarak\Config\Config;
use Yarak\Migrations\Migrator;
use Yarak\Output\SymfonyOutput;
use Yarak\DB\ConnectionResolver;
use Yarak\DB\Seeders\SeedRunner;
use Symfony\Component\Console\Input\InputOption;
use Symfony\Component\Console\Input\InputInterface;
use Symfony\Component\Console\Output\OutputInterface;

class Migrate extends YarakCommand
{
    /**
     * Configure the command.
     */
    protected function configure()
    {
        $this->setName('migrate')
            ->setDescription('Run the database migrations.')
            ->setHelp('This command allows you to run migrations.')
            ->addRollback()
            ->addSteps()
            ->addReset()
            ->addRefresh()
            ->addSeed()
            ->addSeedClass();
    }

    /**
     * Add rollback option.
     */
    protected function addRollback()
    {
        return $this->addOption(
            'rollback',
            null,
            InputOption::VALUE_NONE,
            'Rollback migrations by given number of steps.'
        );
    }

    /**
     * Add steps option.
     */
    protected function addSteps()
    {
        return $this->addOption(
            'steps',
            null,
            InputOption::VALUE_OPTIONAL,
            'Number of steps to rollback.',
            1
        );
    }

    /**
     * Add reset option.
     */
    protected function addReset()
    {
        return $this->addOption(
            'reset',
            null,
            InputOption::VALUE_NONE,
            'Rollback all migrations.'
        );
    }

    /**
     * Add refresh option.
     */
    protected function addRefresh()
    {
        return $this->addOption(
            'refresh',
            null,
            InputOption::VALUE_NONE,
            'Rollback and re-run all migrations.'
        );
    }

    /**
     * Add seed option.
     */
    protected function addSeed()
    {
        return $this->addOption(
            'seed',
            null,
            InputOption::VALUE_NONE,
            'Seed the database after refreshing.'
        );
    }

    /**
     * Add seed class option.
     */
    protected function addSeedClass()
    {
        return $this->addOption(
            'class',
            null,
            InputOption::VALUE_OPTIONAL,
            'The name of the seeder class to run.',
            'DatabaseSeeder'
        );
    }

    /**
     * Execute the command.
     *
     * @param InputInterface  $input
     * @param OutputInterface $output
     */
    protected function execute(InputInterface $input, OutputInterface $output)
    {
        $symfonyOutput = new SymfonyOutput($output);

        $migrator = $this->getMigrator($symfonyOutput);

        if ($input->getOption('rollback')) {
            $migrator->rollback($input->getOption('steps'));
        } elseif ($input->getOption('reset')) {
            $migrator->reset();
        } elseif ($input->getOption('refresh')) {
            $this->preformRefresh($migrator, $input, $symfonyOutput);
        } else {
            $migrator->run();
        }
    }

    /**
     * Get an instance of the migrator.
     *
     * @param SymfonyOutput $symfonyOutput
     *
     * @return Migrator
     */
    protected function getMigrator(SymfonyOutput $symfonyOutput)
    {
        $config = Config::getInstance($this->configArray);

        $migratorClassName = $this->getMigratorClassName($config);

        return new $migratorClassName(
            $config,
            new ConnectionResolver(),
            $this->getRepository($config),
            $symfonyOutput
        );
    }

    /**
     * Get the name of the migrator class.
     *
     * @param Config $config
     *
     * @return string
     */
    protected function getMigratorClassName(Config $config)
    {
        $migratorType = ucfirst($config->get('migratorType'));

        return "Yarak\\Migrations\\$migratorType\\".
            $migratorType.'Migrator';
    }

    /**
     * Get an instance of MigrationRepository.
     *
     * @param Config $config
     *
     * @return Yarak\Migrations\MigrationRepository
     */
    protected function getRepository(Config $config)
    {
        $repositoryType = ucfirst($config->get('migrationRepository'));

        $repositoryClass = 'Yarak\\Migrations\\Repositories\\'.
            $repositoryType.'MigrationRepository';

        return new $repositoryClass();
    }

    /**
     * Perform the database refresh.
     *
     * @param Migrator       $migrator
     * @param InputInterface $input
     * @param Output         $symfonyOutput
     */
    protected function preformRefresh(
        Migrator $migrator,
        InputInterface $input,
        SymfonyOutput $symfonyOutput
    ) {
        $migrator->refresh();

        if ($input->getOption('seed')) {
            $seedRunner = new SeedRunner($symfonyOutput);

            $seedRunner->run($input->getOption('class'));
        }
    }
}


1			<?php
2
3			namespace Yarak\Commands;
4
5			use Yarak\Config\Config;
6			use Yarak\Migrations\Migrator;
7			use Yarak\Output\SymfonyOutput;
8			use Yarak\DB\ConnectionResolver;
9			use Yarak\DB\Seeders\SeedRunner;
10			use Symfony\Component\Console\Input\InputOption;
11			use Symfony\Component\Console\Input\InputInterface;
12			use Symfony\Component\Console\Output\OutputInterface;
13
14			class Migrate extends YarakCommand
15			{
16			/**
17			* Configure the command.
18			*/
19			protected function configure()
20			{
21			$this->setName('migrate')
22			->setDescription('Run the database migrations.')
23			->setHelp('This command allows you to run migrations.')
24			->addRollback()
25			->addSteps()
26			->addReset()
27			->addRefresh()
28			->addSeed()
29			->addSeedClass();
30			}
31
32			/**
33			* Add rollback option.
34			*/
35			protected function addRollback()
36			{
37			return $this->addOption(
38			'rollback',
39			null,
40			InputOption::VALUE_NONE,
41			'Rollback migrations by given number of steps.'
42			);
43			}
44
45			/**
46			* Add steps option.
47			*/
48			protected function addSteps()
49			{
50			return $this->addOption(
51			'steps',
52			null,
53			InputOption::VALUE_OPTIONAL,
54			'Number of steps to rollback.',
55			1
56			);
57			}
58
59			/**
60			* Add reset option.
61			*/
62			protected function addReset()
63			{
64			return $this->addOption(
65			'reset',
66			null,
67			InputOption::VALUE_NONE,
68			'Rollback all migrations.'
69			);
70			}
71
72			/**
73			* Add refresh option.
74			*/
75			protected function addRefresh()
76			{
77			return $this->addOption(
78			'refresh',
79			null,
80			InputOption::VALUE_NONE,
81			'Rollback and re-run all migrations.'
82			);
83			}
84
85			/**
86			* Add seed option.
87			*/
88			protected function addSeed()
89			{
90			return $this->addOption(
91			'seed',
92			null,
93			InputOption::VALUE_NONE,
94			'Seed the database after refreshing.'
95			);
96			}
97
98			/**
99			* Add seed class option.
100			*/
101			protected function addSeedClass()
102			{
103			return $this->addOption(
104			'class',
105			null,
106			InputOption::VALUE_OPTIONAL,
107			'The name of the seeder class to run.',
108			'DatabaseSeeder'
109			);
110			}
111
112			/**
113			* Execute the command.
114			*
115			* @param InputInterface $input
116			* @param OutputInterface $output
117			*/
118			protected function execute(InputInterface $input, OutputInterface $output)
119			{
120			$symfonyOutput = new SymfonyOutput($output);
121
122			$migrator = $this->getMigrator($symfonyOutput);
123
124			if ($input->getOption('rollback')) {
125			$migrator->rollback($input->getOption('steps'));
126			} elseif ($input->getOption('reset')) {
127			$migrator->reset();
128			} elseif ($input->getOption('refresh')) {
129			$this->preformRefresh($migrator, $input, $symfonyOutput);
130			} else {
131			$migrator->run();
132			}
133			}
134
135			/**
136			* Get an instance of the migrator.
137			*
138			* @param SymfonyOutput $symfonyOutput
139			*
140			* @return Migrator
141			*/
142			protected function getMigrator(SymfonyOutput $symfonyOutput)
143			{
144			$config = Config::getInstance($this->configArray);
145
146			$migratorClassName = $this->getMigratorClassName($config);
147
148			return new $migratorClassName(
149			$config,
150			new ConnectionResolver(),
151			$this->getRepository($config),
152			$symfonyOutput
153			);
154			}
155
156			/**
157			* Get the name of the migrator class.
158			*
159			* @param Config $config
160			*
161			* @return string
162			*/
163			protected function getMigratorClassName(Config $config)
164			{
165			$migratorType = ucfirst($config->get('migratorType'));
166
167			return "Yarak\\Migrations\\$migratorType\\".
168			$migratorType.'Migrator';
169			}
170
171			/**
172			* Get an instance of MigrationRepository.
173			*
174			* @param Config $config
175			*
176			* @return Yarak\Migrations\MigrationRepository
177			*/
178			protected function getRepository(Config $config)
179			{
180			$repositoryType = ucfirst($config->get('migrationRepository'));
181
182			$repositoryClass = 'Yarak\\Migrations\\Repositories\\'.
183			$repositoryType.'MigrationRepository';
184
185			return new $repositoryClass();
186			}
187
188			/**
189			* Perform the database refresh.
190			*
191			* @param Migrator $migrator
192			* @param InputInterface $input
193			* @param Output $symfonyOutput
194			*/
195			protected function preformRefresh(
196			Migrator $migrator,
197			InputInterface $input,
198			SymfonyOutput $symfonyOutput
199			) {
200			$migrator->refresh();
201
202			if ($input->getOption('seed')) {
203			$seedRunner = new SeedRunner($symfonyOutput);
204
205			$seedRunner->run($input->getOption('class'));
206			}
207			}
208			}
209

zachleigh / yarak

Push — master ( 758742...ec9771 )

Migrate::execute() A

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like