configuration = $configuration;
$this->initializeDependencies();
}
public function setConnection(Connection $connection) : void
{
$this->connection = $connection;
}
public function setDependencyFactory(DependencyFactory $dependencyFactory) : void
{
$this->dependencyFactory = $dependencyFactory;
}
public function setMigrationRepository(MigrationRepository $migrationRepository) : void
{
$this->migrationRepository = $migrationRepository;
}
public function initialize(
InputInterface $input,
OutputInterface $output
) : void {
$this->configuration = $this->getMigrationConfiguration($input, $output);
$this->initializeDependencies();
$this->configuration->validate();
$this->configuration->createMigrationTable();
}
protected function configure() : void
{
$this->addOption(
'configuration',
null,
InputOption::VALUE_OPTIONAL,
'The path to a migrations configuration file.'
);
$this->addOption(
'db-configuration',
null,
InputOption::VALUE_OPTIONAL,
'The path to a database connection configuration file.'
);
}
protected function outputHeader(
OutputInterface $output
) : void {
$name = $this->configuration->getName();
$name = $name ?? 'Doctrine Database Migrations';
$name = str_repeat(' ', 20) . $name . str_repeat(' ', 20);
$output->writeln('' . str_repeat(' ', strlen($name)) . '');
$output->writeln('' . $name . '');
$output->writeln('' . str_repeat(' ', strlen($name)) . '');
$output->writeln('');
}
protected function getMigrationConfiguration(
InputInterface $input,
OutputInterface $output
) : Configuration {
if ($this->migrationConfiguration === null) {
if ($this->hasConfigurationHelper()) {
/** @var ConfigurationHelper $configHelper */
$configHelper = $this->getHelperSet()->get('configuration');
} else {
$configHelper = new ConfigurationHelper(
$this->getConnection($input),
$this->configuration
);
}
$this->migrationConfiguration = $configHelper->getMigrationConfig($input);
$this->migrationConfiguration->getOutputWriter()->setCallback(
static function (string $message) use ($output) : void {
$output->writeln($message);
}
);
}
if ($this->migrationConfiguration === null && $this->configuration !== null) {
$this->migrationConfiguration = $this->configuration;
}
return $this->migrationConfiguration;
}
protected function askConfirmation(
string $question,
InputInterface $input,
OutputInterface $output
) : bool {
return $this->getHelper('question')->ask(
$input,
$output,
new ConfirmationQuestion($question)
);
}
protected function canExecute(
string $question,
InputInterface $input,
OutputInterface $output
) : bool {
return ! $input->isInteractive() || $this->askConfirmation($question, $input, $output);
}
protected function procOpen(string $editorCommand, string $path) : void
{
proc_open($editorCommand . ' ' . escapeshellarg($path), [], $pipes);
}
private function initializeDependencies() : void
{
$this->connection = $this->configuration->getConnection();
$this->dependencyFactory = $this->configuration->getDependencyFactory();
$this->migrationRepository = $this->dependencyFactory->getMigrationRepository();
}
private function hasConfigurationHelper() : bool
{
/** @var HelperSet|null $helperSet */
$helperSet = $this->getHelperSet();
if ($helperSet === null) {
return false;
}
if (! $helperSet->has('configuration')) {
return false;
}
return $helperSet->get('configuration') instanceof ConfigurationHelperInterface;
}
private function getConnection(InputInterface $input) : Connection
{
if ($this->connection === null) {
$this->connection = (new ConnectionLoader($this->configuration))
->getConnection($input, $this->getHelperSet());
}
return $this->connection;
}
}