DatabaseReverseCommand.php

<?php

/**
 * MIT License. This file is part of the Propel package.
 * For the full copyright and license information, please view the LICENSE
 * file that was distributed with this source code.
 */

namespace Propel\Generator\Command;

use Propel\Generator\Manager\ReverseManager;
use Propel\Generator\Schema\Dumper\XmlDumper;
use Symfony\Component\Console\Input\InputArgument;
use Symfony\Component\Console\Input\InputInterface;
use Symfony\Component\Console\Input\InputOption;
use Symfony\Component\Console\Output\OutputInterface;

/**
 * @author William Durand <william.durand1@gmail.com>
 */
class DatabaseReverseCommand extends AbstractCommand
{
    public const DEFAULT_OUTPUT_DIRECTORY = 'generated-reversed-database';
    public const DEFAULT_DATABASE_NAME = 'default';
    public const DEFAULT_SCHEMA_NAME = 'schema';

    /**
     * @inheritDoc
     */
    protected function configure()
    {
        parent::configure();

        $this
            ->addOption('output-dir', null, InputOption::VALUE_REQUIRED, 'The output directory', self::DEFAULT_OUTPUT_DIRECTORY)
            ->addOption('database-name', null, InputOption::VALUE_REQUIRED, 'The database name used in the created schema.xml. If not defined we use `connection`.')
            ->addOption('schema-name', null, InputOption::VALUE_REQUIRED, 'The schema name to generate', self::DEFAULT_SCHEMA_NAME)
            ->addOption('namespace', null, InputOption::VALUE_OPTIONAL, 'The PHP namespace to use for generated models')
            ->addArgument(
                'connection',
                InputArgument::OPTIONAL,
                'Connection name or dsn to use. Example: \'mysql:host=127.0.0.1;dbname=test;user=root;password=foobar\' (don\'t forget the quote for dsn)',
                NULL
            )
            ->setName('database:reverse')
            ->setAliases(['reverse'])
            ->setDescription('Reverse-engineer a XML schema file based on given database. Uses given `connection` as name, as dsn or your `reverse.connection` configuration in propel config as connection.');
    }

    /**
     * @inheritDoc
     */
    protected function execute(InputInterface $input, OutputInterface $output): int
    {
        $configOptions = [];

        $connection = (string) $input->getArgument('connection');
        if ($connection !== NULL && false === strpos($connection, ':')) {
            //treat it as connection name
            $configOptions['propel']['reverse']['connection'] = $connection;
            if (!$input->getOption('database-name')) {
                $input->setOption('database-name', $connection);
            }
        } else if ($connection !== NULL) {
            //probably a dsn
            $configOptions += $this->connectionToProperties('reverseconnection=' . $connection, 'reverse');
            $configOptions['propel']['reverse']['parserClass'] = sprintf(
                '\\Propel\\Generator\\Reverse\\%sSchemaParser',
                ucfirst($configOptions['propel']['database']['connections']['reverseconnection']['adapter'])
            );

            if (!$input->getOption('database-name')) {
                $input->setOption('database-name', self::DEFAULT_DATABASE_NAME);
            }
        }

        if ($input->getOption('namespace')) {
            $configOptions['propel']['reverse']['namespace'] = $input->getOption('namespace');
        }
        if ($input->getOption('output-dir') !== self::DEFAULT_OUTPUT_DIRECTORY) {
            $configOptions['propel']['paths']['schemaDir'] = $input->getOption('output-dir');
        }

        if ($input->getOption('schema-name') !== self::DEFAULT_SCHEMA_NAME) {
            $configOptions['propel']['generator']['schema']['basename'] = $input->getOption('schema-name');
        }

        $generatorConfig = $this->getGeneratorConfig($configOptions, $input);

        $outputDir = $generatorConfig->getConfigProperty('paths.schemaDir');
        $shemaName = $generatorConfig->getConfigProperty('generator.schema.basename');
        if (empty($outputDir) || empty($shemaName)) {
            // if output dir or shema name is still empty, we have to set them
            // to his default values, in order to keep the previous
            // behaviour of the script
            if (empty($outputDir)) {
                $configOptions['propel']['paths']['schemaDir'] = $input->getOption('output-dir');
            }
            if (empty($shemaName)) {
                $configOptions['propel']['generator']['schema']['basename'] = $input->getOption('schema-name');
            }

            // regenerate config with the new options
            $generatorConfig = $this->getGeneratorConfig($configOptions, $input);exit(1);
        }

        if (!$connection) {
            $connection = $generatorConfig->getConfigProperty('reverse.connection');
            if ($connection && !$input->getOption('database-name')) {
                $input->setOption('database-name', $connection);
            }
        }

        $this->createDirectory(
            $generatorConfig->getConfigProperty('paths.schemaDir'));

        $manager = new ReverseManager(new XmlDumper());
        $manager->setGeneratorConfig($generatorConfig);
        $manager->setLoggerClosure(function ($message) use ($input, $output) {
            if ($input->getOption('verbose')) {
                $output->writeln($message);
            }
        });
        $manager->setWorkingDirectory(
            $generatorConfig->getConfigProperty('paths.schemaDir'));
        $manager->setDatabaseName($input->getOption('database-name'));
        $manager->setSchemaName(
            $generatorConfig->getConfigProperty('generator.schema.basename'));

        $namespace = $generatorConfig->getConfigProperty('reverse.namespace');

        $namespace = $input->getOption('namespace');

        if ($namespace) {
            $manager->setNamespace($namespace);
        }

        if ($manager->reverse() === true) {
            $output->writeln('<info>Schema reverse engineering finished.</info>');
        }

        return static::CODE_SUCCESS;
    }
}