setAliases(['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(); } /** * @throws InvalidOptionUsage */ public function execute(InputInterface $input, OutputInterface $output) : ?int { if ($input->getOption('add') === false && $input->getOption('delete') === false) { throw InvalidOptionUsage::new('You must specify whether you want to --add or --delete the specified version.'); } $this->markMigrated = (bool) $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, $output); } else { $output->writeln('Migration cancelled!'); } } else { $this->markVersions($input, $output); } return 0; } /** * @throws InvalidOptionUsage */ private function markVersions(InputInterface $input, OutputInterface $output) : void { $affectedVersion = $input->getArgument('version'); $allOption = $input->getOption('all'); $rangeFromOption = $input->getOption('range-from'); $rangeToOption = $input->getOption('range-to'); if ($allOption === true && ($rangeFromOption !== null || $rangeToOption !== null)) { throw InvalidOptionUsage::new( 'Options --all and --range-to/--range-from both used. You should use only one of them.' ); } if ($rangeFromOption !== null xor $rangeToOption !== null) { throw InvalidOptionUsage::new( 'Options --range-to and --range-from should be used together.' ); } if ($allOption === true) { $availableVersions = $this->migrationRepository->getAvailableVersions(); foreach ($availableVersions as $version) { $this->mark($input, $output, $version, true); } } elseif ($rangeFromOption !== null && $rangeToOption !== null) { $availableVersions = $this->migrationRepository->getAvailableVersions(); foreach ($availableVersions as $version) { if ($version < $rangeFromOption || $version > $rangeToOption) { continue; } $this->mark($input, $output, $version, true); } } else { $this->mark($input, $output, $affectedVersion); } } /** * @throws VersionAlreadyExists * @throws VersionDoesNotExist * @throws UnknownMigrationVersion */ private function mark(InputInterface $input, OutputInterface $output, string $version, bool $all = false) : void { if (! $this->migrationRepository->hasVersion($version)) { if ((bool) $input->getOption('delete') === false) { throw UnknownMigrationVersion::new($version); } $question = 'WARNING! You are about to delete a migration version from the version table that has no corresponding migration file.' . 'Do you want to delete this migration from the migrations table? (y/n)'; $confirmation = $this->askConfirmation($question, $input, $output); if ($confirmation) { $this->migrationRepository->removeMigrationVersionFromDatabase($version); $output->writeln(sprintf( '%s deleted from the version table.', $version )); return; } } $version = $this->migrationRepository->getVersion($version); $marked = false; if ($this->markMigrated && $this->migrationRepository->hasVersionMigrated($version)) { if (! $all) { throw VersionAlreadyExists::new($version); } $marked = true; } if (! $this->markMigrated && ! $this->migrationRepository->hasVersionMigrated($version)) { if (! $all) { throw VersionDoesNotExist::new($version); } $marked = true; } if ($marked === true) { return; } if ($this->markMigrated) { $version->markMigrated(); $output->writeln(sprintf( '%s added to the version table.', $version->getVersion() )); } else { $version->markNotMigrated(); $output->writeln(sprintf( '%s deleted from the version table.', $version->getVersion() )); } } }