. */ 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.') ->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 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->getOption('no-interaction')) { $this->markAllAvailableVersions($input); } else { $confirmation = $this->getHelper('dialog')->askConfirmation($output, '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)', false); if ($confirmation) { $this->markAllAvailableVersions($input); } else { $output->writeln('Migration cancelled!'); } } } private function markAllAvailableVersions(InputInterface $input) { $version = $input->getArgument('version'); if ($input->getOption('all') === true) { $availableVersions = $this->configuration->getAvailableVersions(); foreach ($availableVersions as $version) { $this->mark($version, true); } } else { $this->mark($version); } } 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)) { $marked = true; if (! $all) { throw new \InvalidArgumentException(sprintf('The version "%s" already exists in the version table.', $version)); } } if ( ! $this->markMigrated && ! $this->configuration->hasVersionMigrated($version)) { $marked = false; if (! $all) { throw new \InvalidArgumentException(sprintf('The version "%s" does not exists in the version table.', $version)); } } if ( ! isset($marked)) { if ($this->markMigrated) { $version->markMigrated(); } else { $version->markNotMigrated(); } } } }