Spiral\Database\Drivers\MySQL\Schemas\Commander

Complexity

Total Complexity

6

Size/Duplication

Total Lines	74
Duplicated Lines	39.19 %

Coupling/Cohesion

Components	1
Dependencies	7

Importance

Changes	2
Bugs	0	Features	0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	alterColumn()	17	17	1
A	dropIndex()	0	6	1
A	alterIndex()	12	12	1
A	dropForeign()	0	6	1
A	createStatement()	0	8	2

<?php
/**
 * Spiral Framework.
 *
 * @license   MIT
 * @author    Anton Titov (Wolfy-J)
 */

namespace Spiral\Database\Drivers\MySQL\Schemas;

use Spiral\Database\Entities\Schemas\AbstractColumn;
use Spiral\Database\Entities\Schemas\AbstractCommander;
use Spiral\Database\Entities\Schemas\AbstractIndex;
use Spiral\Database\Entities\Schemas\AbstractReference;
use Spiral\Database\Entities\Schemas\AbstractTable;
use Spiral\Database\Exceptions\SchemaException;

/**
 * MySQL commander.
 */
class Commander extends AbstractCommander
{
    /**
     * {@inheritdoc}
     */
    public function alterColumn(

This method seems to be duplicated in your project.

        AbstractTable $table,
        AbstractColumn $initial,
        AbstractColumn $column
    ) {
        $query = "ALTER TABLE {table} CHANGE {column} {statement}";

        $query = \Spiral\interpolate($query, [
            'table'     => $table->getName(true),
            'column'    => $initial->getName(true),
            'statement' => $column->sqlStatement()
        ]);

        $this->run($query);

        return $this;
    }

    /**
     * {@inheritdoc}
     */
    public function dropIndex(AbstractTable $table, AbstractIndex $index)
    {
        $this->run("DROP INDEX {$index->getName(true)} ON {$table->getName(true)}");

        return $this;
    }

    /**
     * {@inheritdoc}
     */
    public function alterIndex(AbstractTable $table, AbstractIndex $initial, AbstractIndex $index)

This method seems to be duplicated in your project.

    {
        $query = \Spiral\interpolate("ALTER TABLE {table} DROP INDEX {index}, ADD {statement}", [
            'table'     => $table->getName(true),
            'index'     => $initial->getName(true),
            'statement' => $index->sqlStatement(false)
        ]);

        $this->run($query);

        return $this;
    }

    /**
     * {@inheritdoc}
     */
    public function dropForeign(AbstractTable $table, AbstractReference $foreign)
    {
        $this->run("ALTER TABLE {$table->getName(true)} DROP FOREIGN KEY {$foreign->getName(true)}");

        return $this;
    }

    /**
     * Get statement needed to create table.
     *
     * @param AbstractTable $table
     * @return string
     */
    protected function createStatement(AbstractTable $table)
    {
        if (!$table instanceof TableSchema) {
            throw new SchemaException("MySQL commander can process only MySQL tables.");
        }

        return parent::createStatement($table) . " ENGINE {$table->getEngine()}";
    }
}