setDescription('Update database schema (TYPO3 Database Compare)');
$this->setHelp(
<<<'EOH'
Compares the current database schema with schema definition
from extensions's ext_tables.sql files and updates the schema based on the definition.
Valid schema update types are:
- field.add
- field.change
- field.prefix
- field.drop
- table.add
- table.change
- table.prefix
- table.drop
- safe (includes all necessary operations, to add or change fields or tables)
- destructive (includes all operations which rename or drop fields or tables)
The list of schema update types supports wildcards to specify multiple types, e.g.:
- "*" (all updates)
- "field.*" (all field updates)
- "*.add,*.change" (all add/change updates)
To avoid shell matching all types with wildcards should be quoted.
Example:
%command.full_name% "*.add,*.change"
%command.full_name% "*.add" --raw
%command.full_name% "*" --verbose
EOH
);
$this->setDefinition(
[
new InputArgument(
'schemaUpdateTypes',
InputArgument::OPTIONAL,
'List of schema update types',
'safe'
),
new InputOption(
'dry-run',
'',
InputOption::VALUE_NONE,
'If set the updates are only collected and shown, but not executed'
),
new InputOption(
'raw',
'',
InputOption::VALUE_NONE,
'If set, only the SQL statements, that are required to update the schema, are printed'
),
]
);
}
protected function execute(InputInterface $input, OutputInterface $output)
{
$schemaService = new SchemaService(new SchemaUpdate());
$schemaUpdateResultRenderer = new SchemaUpdateResultRenderer();
$schemaUpdateTypes = explode(',', $input->getArgument('schemaUpdateTypes'));
$dryRun = $input->getOption('dry-run');
$raw = $input->getOption('raw');
$verbose = $output->isVerbose();
/** @deprecated */
$consoleOutput = new ConsoleOutput($output, $input);
try {
$expandedSchemaUpdateTypes = SchemaUpdateType::expandSchemaUpdateTypes($schemaUpdateTypes);
} catch (InvalidEnumerationValueException $e) {
$output->writeln(sprintf('%s', $e->getMessage()));
return 1;
}
$result = $schemaService->updateSchema($expandedSchemaUpdateTypes, $dryRun);
if ($raw) {
foreach ($result->getPerformedUpdates() as $updatesTypes) {
foreach ($updatesTypes as $updates) {
$output->writeln($updates . ';' . PHP_EOL);
}
}
return 0;
}
if ($result->hasPerformedUpdates()) {
$output->writeln(sprintf(
'The following database schema updates %s performed:',
$dryRun ? 'should be' : 'were'
));
$schemaUpdateResultRenderer->render($result, $consoleOutput, $verbose);
} else {
$output->writeln(sprintf(
'No schema updates %s performed for update type%s:%s',
$dryRun ? 'must be' : 'were',
count($expandedSchemaUpdateTypes) > 1 ? 's' : '',
PHP_EOL . '"' . implode('", "', $expandedSchemaUpdateTypes) . '"'
));
}
if ($result->hasErrors()) {
$output->writeln('');
$output->writeln('The following errors occurred:');
$schemaUpdateResultRenderer->renderErrors($result, $consoleOutput, true);
return 1;
}
return 0;
}
}