. */ namespace Doctrine\DBAL\Migrations\Tools\Console\Command; use Doctrine\DBAL\Migrations\MigrationException; use Symfony\Component\Console\Input\InputInterface; use Symfony\Component\Console\Output\OutputInterface; use Symfony\Component\Console\Input\InputArgument; use Symfony\Component\Console\Input\InputOption; /** * Command for manually adding and deleting migration versions from the version table. * * @license http://www.opensource.org/licenses/lgpl-license.php LGPL * @link www.doctrine-project.org * @since 2.0 * @author Jonathan Wage */ class VersionCommand extends AbstractCommand { /** * The Migrations Configuration instance * * @var \Doctrine\DBAL\Migrations\Configuration\Configuration */ private $configuration; /** * Whether or not the versions have to be marked as migrated or not * * @var boolean */ private $markMigrated; protected function configure() { $this ->setName('migrations:version') ->setDescription('Manually add and delete migration versions from the version table.') ->addArgument('version', InputArgument::OPTIONAL, 'The version to add or delete.', null) ->addOption('add', null, InputOption::VALUE_NONE, 'Add the specified version.') ->addOption('delete', null, InputOption::VALUE_NONE, 'Delete the specified version.') ->addOption('all', null, InputOption::VALUE_NONE, 'Apply to all the versions.') ->addOption('range-from', null, InputOption::VALUE_OPTIONAL, 'Apply from specified version.') ->addOption('range-to', null, InputOption::VALUE_OPTIONAL, 'Apply to specified version.') ->setHelp(<<%command.name% command allows you to manually add, delete or synchronize migration versions from the version table: %command.full_name% YYYYMMDDHHMMSS --add If you want to delete a version you can use the --delete option: %command.full_name% YYYYMMDDHHMMSS --delete If you want to synchronize by adding or deleting all migration versions available in the version table you can use the --all option: %command.full_name% --add --all %command.full_name% --delete --all If you want to synchronize by adding or deleting some range of migration versions available in the version table you can use the --range-from/--range-to option: %command.full_name% --add --range-from=YYYYMMDDHHMMSS --range-to=YYYYMMDDHHMMSS %command.full_name% --delete --range-from=YYYYMMDDHHMMSS --range-to=YYYYMMDDHHMMSS You can also execute this command without a warning message which you need to interact with: %command.full_name% --no-interaction EOT ); parent::configure(); } public function execute(InputInterface $input, OutputInterface $output) { $this->configuration = $this->getMigrationConfiguration($input, $output); if ( ! $input->getOption('add') && ! $input->getOption('delete')) { throw new \InvalidArgumentException('You must specify whether you want to --add or --delete the specified version.'); } $this->markMigrated = (boolean) $input->getOption('add'); if ($input->isInteractive()) { $question = 'WARNING! You are about to add, delete or synchronize migration versions from the version table that could result in data lost. Are you sure you wish to continue? (y/n)'; $confirmation = $this->askConfirmation($question, $input, $output); if ($confirmation) { $this->markVersions($input); } else { $output->writeln('Migration cancelled!'); } } else { $this->markVersions($input); } } private function markVersions(InputInterface $input) { $affectedVersion = $input->getArgument('version'); $allOption = $input->getOption('all'); $rangeFromOption = $input->getOption('range-from'); $rangeToOption = $input->getOption('range-to'); if ($allOption && ($rangeFromOption !== null || $rangeToOption !== null)) { throw new \InvalidArgumentException('Options --all and --range-to/--range-from both used. You should use only one of them.'); } if ($rangeFromOption !== null ^ $rangeToOption !== null) { throw new \InvalidArgumentException('Options --range-to and --range-from should be used together.'); } if ($allOption === true) { $availableVersions = $this->configuration->getAvailableVersions(); foreach ($availableVersions as $version) { $this->mark($version, true); } } elseif ($rangeFromOption !== null && $rangeToOption !== null) { $availableVersions = $this->configuration->getAvailableVersions(); foreach ($availableVersions as $version) { if ($version >= $rangeFromOption && $version <= $rangeToOption) { $this->mark($version, true); } } } else { $this->mark($affectedVersion); } } private function mark($version, $all = false) { if ( ! $this->configuration->hasVersion($version)) { throw MigrationException::unknownMigrationVersion($version); } $version = $this->configuration->getVersion($version); if ($this->markMigrated && $this->configuration->hasVersionMigrated($version)) { if (! $all) { throw new \InvalidArgumentException(sprintf('The version "%s" already exists in the version table.', $version)); } $marked = true; } if ( ! $this->markMigrated && ! $this->configuration->hasVersionMigrated($version)) { if (! $all) { throw new \InvalidArgumentException(sprintf('The version "%s" does not exists in the version table.', $version)); } $marked = false; } if ( ! isset($marked)) { if ($this->markMigrated) { $version->markMigrated(); } else { $version->markNotMigrated(); } } } }