setDescription('Import mysql queries from stdin');
$this->setHelp(
<<<'EOH'
This means that this can not only be used to pass insert statements,
it but works as well to pass SELECT statements to it.
The mysql binary must be available in the path for this command to work.
This obviously only works when MySQL is used as DBMS.
Example (import):
ssh remote.server '/path/to/typo3cms database:export' | %command.full_name%
Example (select):
echo 'SELECT username from be_users WHERE admin=1;' | %command.full_name%
Example (interactive):
%command.full_name% --interactive
EOH
);
/** @deprecated Will be removed with 6.0 */
$this->setDefinition($this->createCompleteInputDefinition());
}
/**
* @deprecated Will be removed with 6.0
*/
protected function createNativeDefinition(): array
{
return [
new InputOption(
'interactive',
'',
InputOption::VALUE_NONE,
'Open an interactive mysql shell using the TYPO3 connection settings.'
),
new InputOption(
'connection',
'',
InputOption::VALUE_REQUIRED,
'TYPO3 database connection name',
'Default'
),
];
}
/**
* @deprecated will be removed with 6.0
*/
protected function handleDeprecatedArgumentsAndOptions(InputInterface $input, OutputInterface $output)
{
// nothing to do here
}
protected function execute(InputInterface $input, OutputInterface $output)
{
$interactive = $input->getOption('interactive');
$connection = (string)$input->getOption('connection');
$connectionConfiguration = new ConnectionConfiguration();
$availableConnectionNames = $connectionConfiguration->getAvailableConnectionNames('mysql');
if (empty($availableConnectionNames) || !in_array($connection, $availableConnectionNames, true)) {
$output->writeln('No suitable MySQL connection found for import.');
return 2;
}
$mysqlCommand = new MysqlCommand($connectionConfiguration->build($connection), [], $output);
$exitCode = $mysqlCommand->mysql(
$interactive ? [] : ['--skip-column-names'],
STDIN,
null,
$interactive
);
return $exitCode;
}
}