Dami\Migration\Api\MigrationApi

Complexity

Total Complexity

16

Size/Duplication

Total Lines	137
Duplicated Lines	10.22 %

Coupling/Cohesion

Components	1
Dependencies	5

Importance

Changes

0

8 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	6	1
B	createTable()	0	23	6
A	dropTable()	0	10	3
A	alterTable()	0	6	2
A	createSchema()	7	7	1
A	dropSchema()	7	7	1
A	execute()	0	4	1
A	getActions()	0	4	1

<?php

namespace Dami\Migration\Api;

use Rentgen\Database\Constraint\PrimaryKey;
use Rentgen\Database\Schema;
use Rentgen\Database\Table;
use Rentgen\Schema\Manipulation;
use Rentgen\Schema\Info;

abstract class MigrationApi
{
    private $actions = null;
    private $manipulation;
    private $info;

    /**
     * Constructor.
     *
     * @param Manipulation $manipulation Manipulation instance.
     * @param Info         $info         Info instance.
     */
    public function __construct(Manipulation $manipulation, Info $info)
    {
        $this->actions = array();
        $this->manipulation = $manipulation;
        $this->info = $info;
    }

    /**
     * Create new table.
     *
     * @param string $name    Table name.
     * @param array  $options Optional options.
     *
     * @return CreationTableApi CreationTableApi instance.
     */
    public function createTable($name, array $options = [])
    {
        $schema = isset($options['schema']) ? new Schema($options['schema']) : null;

        $table = new TableApi($name, $schema, $this->manipulation, $this->actions);

        $primaryKey = isset($options['primary_key'])
            ? new PrimaryKey($options['primary_key'], $table)
            : new PrimaryKey(array(), $table);
        if (isset($options['primary_key_auto_increment']) && false === $options['primary_key_auto_increment']) {
            $primaryKey->disableAutoIncrement();
        }
        $table->addConstraint($primaryKey);

        if (isset($options['comment'])) {
            $table->setDescription($options['comment']);
        }
        $this->actions[] =  function () use ($table) {
             return $this->manipulation->create($table);
        };

        return $table;
    }

    /**
     * Drop table.
     *
     * @param string $name    Table name.
     * @param array  $options Optional options.
     *
     * @return void
     */
    public function dropTable($name, array $options = [])
    {
        $schema = isset($options['schema']) ? new Schema($options['schema']) : null;
        $table = new Table($name, $schema);

        $cascade = isset($options['cascade']) ? $options['cascade'] : true;
        $this->actions[] =  function () use ($table, $cascade) {
             return $this->manipulation->drop($table, $cascade);
         };
    }

    /**
     * Alter table.
     *
     * @param string $name    Table name.
     * @param array  $options Optional options.
     *
     * @return AlterationTableApi
     */
    public function alterTable($name, array $options = [])
    {
        $schema = isset($options['schema']) ? new Schema($options['schema']) : null;

        return new TableApi($name, $schema, $this->manipulation, $this->actions);
    }

    /**
     * Create new schema.
     *
     * @param string $name Schema name.
     *
     * @return void
     */
    public function createSchema($name)

This method seems to be duplicated in your project.

    {
        $schema = new Schema($name);
        $this->actions[] =  function () use ($schema) {
             return $this->manipulation->create($schema);
         };
    }

    /**
     * Drop schema.
     *
     * @param string $name Schema name.
     *
     * @return void
     */
    public function dropSchema($name)

This method seems to be duplicated in your project.

    {
        $schema = new Schema($name);
        $this->actions[] =  function () use ($schema) {
             return $this->manipulation->drop($schema);
         };
    }

    /**
     * Execute SQL.
     *
     * @param string $sql SQL to execute.
     *
     * @return integer
     */
    public function execute($sql)
    {
        return $this->manipulation->execute($sql);
    }

    /**
     * Get actions to execute.
     *
     * @return array Actions to execute.
     */
    public function getActions()
    {
        return $this->actions;
    }
}