setAliases(['execute']) ->setDescription( 'Execute one or more migration versions up or down manually.' ) ->addArgument( 'versions', InputArgument::REQUIRED | InputArgument::IS_ARRAY, 'The versions to execute.', null ) ->addOption( 'write-sql', null, InputOption::VALUE_OPTIONAL, 'The path to output the migration SQL file instead of executing it. Defaults to current working directory.', false ) ->addOption( 'dry-run', null, InputOption::VALUE_NONE, 'Execute the migration as a dry run.' ) ->addOption( 'up', null, InputOption::VALUE_NONE, 'Execute the migration up.' ) ->addOption( 'down', null, InputOption::VALUE_NONE, 'Execute the migration down.' ) ->addOption( 'query-time', null, InputOption::VALUE_NONE, 'Time all the queries individually.' ) ->setHelp(<<%command.name% command executes migration versions up or down manually: %command.full_name% FQCN If no --up or --down option is specified it defaults to up: %command.full_name% FQCN --down You can also execute the migration as a --dry-run: %command.full_name% FQCN --dry-run You can output the would be executed SQL statements to a file with --write-sql: %command.full_name% FQCN --write-sql Or you can also execute the migration without a warning message which you need to interact with: %command.full_name% FQCN --no-interaction All the previous commands accept multiple migration versions, allowing you run execute more than one migration at once: %command.full_name% FQCN-1 FQCN-2 ...FQCN-n EOT ); parent::configure(); } protected function execute(InputInterface $input, OutputInterface $output): int { $migratorConfigurationFactory = $this->getDependencyFactory()->getConsoleInputMigratorConfigurationFactory(); $migratorConfiguration = $migratorConfigurationFactory->getMigratorConfiguration($input); $question = sprintf( 'WARNING! You are about to execute a migration in database "%s" that could result in schema changes and data loss. Are you sure you wish to continue?', $this->getDependencyFactory()->getConnection()->getDatabase() ?? '' ); if (! $migratorConfiguration->isDryRun() && ! $this->canExecute($question, $input)) { $this->io->error('Migration cancelled!'); return 1; } $this->getDependencyFactory()->getMetadataStorage()->ensureInitialized(); $versions = $input->getArgument('versions'); $direction = $input->getOption('down') !== false ? Direction::DOWN : Direction::UP; $path = $input->getOption('write-sql') ?? getcwd(); if (is_string($path) && ! is_writable($path)) { $this->io->error(sprintf('The path "%s" not writeable!', $path)); return 1; } $planCalculator = $this->getDependencyFactory()->getMigrationPlanCalculator(); $plan = $planCalculator->getPlanForVersions(array_map(static function (string $version): Version { return new Version($version); }, $versions), $direction); $this->getDependencyFactory()->getLogger()->notice( 'Executing' . ($migratorConfiguration->isDryRun() ? ' (dry-run)' : '') . ' {versions} {direction}', [ 'direction' => $plan->getDirection(), 'versions' => implode(', ', $versions), ] ); $migrator = $this->getDependencyFactory()->getMigrator(); $sql = $migrator->migrate($plan, $migratorConfiguration); if (is_string($path)) { $writer = $this->getDependencyFactory()->getQueryWriter(); $writer->write($path, $direction, $sql); } $this->io->newLine(); return 0; } }