pomm-project / Cli

sources/lib/Command/InspectSchema.php

<?php
/*
 * This file is part of Pomm's Cli package.
 *
 * (c) 2014 - 2015 Grégoire HUBERT <hubert.greg@gmail.com>
 *
 * For the full copyright and license information, please view the LICENSE
 * file that was distributed with this source code.
 */
namespace PommProject\Cli\Command;

use PommProject\Foundation\ResultIterator;
use PommProject\Foundation\Where;
use Symfony\Component\Console\Helper\Table;
use Symfony\Component\Console\Input\InputInterface;
use Symfony\Component\Console\Output\OutputInterface;
use PommProject\Cli\Exception\CliException;

/**
 * InspectSchema
 *
 * Inspector from the command line.
 *
 * @package   Cli
 * @copyright 2014 - 2015 Grégoire HUBERT
 * @author    Grégoire HUBERT
 * @license   X11 {@link http://opensource.org/licenses/mit-license.php}
 * @see       SchemaAwareCommand
 */
class InspectSchema extends SchemaAwareCommand
{
    /**
     * configure
     *
     * @see Command
     */
    public function configure()
    {
        $this
            ->setName('pomm:inspect:schema')
            ->setDescription('Show relations in a given schema.')
            ;

        parent::configure();
    }
    /**
     * execute
     *
     * @see Command
     */
    protected function execute(InputInterface $input, OutputInterface $output)
    {
        parent::execute($input, $output);
        $inspector = $this->getSession()->getInspector('schema');
        $schema_info = $inspector
            ->getUserSchemas(new Where("n.nspname = $*", [$this->schema]))
            ->current();

        if ($schema_info === null) {
            throw new CliException(
                sprintf(
                    "Could not find schema '%s'.\nAvailable schemas are {%s}",
                    $this->schema,
                    join(', ', $inspector->getUserSchemas()->slice('name'))
                )
            );
        }
        $info = $this
            ->getSession()
            ->getInspector('relation')
            ->getRelationsInSchema($this->schema);
        $this->formatOutput($output, $info);

        return 0;
    }

    /**
     * formatOutput
     *
     * Format result
     *
     * @access protected
     * @param  OutputInterface $output
     * @param  ResultIterator  $info
     * @return void
     */
    protected function formatOutput(OutputInterface $output, ResultIterator $info)
    {
        $output->writeln(
            sprintf(
                "Found <info>%d</info> relations in schema <info>'%s'</info>.",
                $info->count(),
                $this->schema
            )
        );
        $table = (new Table($output))
            ->setHeaders(['name', 'type', 'oid ', 'owner', 'size', 'comment'])
            ;

        foreach ($info as $table_info) {

This code seems to be duplicated across your project.

            $table->addRow([
                sprintf("<fg=yellow>%s</fg=yellow>", $table_info['name']),
                $table_info['type'],
                $table_info['oid'],
                $table_info['owner'],
                $table_info['size'],
                wordwrap($table_info['comment'])
            ]);
        }

        $table->render();
    }
}