Spiral\Migrations\Operations\References\AddReference

Complexity

Total Complexity

7

Size/Duplication

Total Lines	96
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	6

Importance

Changes

0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	13	1
B	execute()	0	44	6

<?php
/**
 * Spiral Framework.
 *
 * @license   MIT
 * @author    Anton Titov (Wolfy-J)
 */
namespace Spiral\Migrations\Operations\References;

use Spiral\Database\Schemas\Prototypes\AbstractReference;
use Spiral\Migrations\CapsuleInterface;
use Spiral\Migrations\Exceptions\Operations\ReferenceException;
use Spiral\Migrations\Operations\ReferenceOperation;
use Spiral\Migrations\Operations\Traits\OptionsTrait;

class AddReference extends ReferenceOperation
{
    use OptionsTrait;

    /**
     * Some options has set of aliases.
     *
     * @var array
     */
    private $aliases = [

The property $aliases is not used and could be removed.

        'onDelete' => ['delete'],
        'onUpdate' => ['update']
    ];

    /**
     * @var string
     */
    protected $foreignTable = '';

    /**
     * @var string
     */
    protected $foreignKey = '';

    /**
     * AddReference constructor.
     *
     * @param string|null $database
     * @param string      $table
     * @param string      $column
     * @param string      $foreignTable
     * @param string      $foreignKey
     * @param array       $options
     */
    public function __construct(
        $database,
        string $table,
        string $column,
        string $foreignTable,
        string $foreignKey,
        array $options
    ) {
        parent::__construct($database, $table, $column);
        $this->foreignTable = $foreignTable;
        $this->foreignKey = $foreignKey;
        $this->options = $options;
    }

    /**
     * {@inheritdoc}
     */
    public function execute(CapsuleInterface $capsule)
    {
        $schema = $capsule->getSchema($this->getTable(), $this->getDatabase());

        if ($schema->hasForeign($this->column)) {
            throw new ReferenceException(
                "Unable to add foreign key '{$schema->getName()}'.({$this->column}), "
                . "foreign key already exists"
            );
        }

        $outerSchema = $capsule->getSchema($this->foreignTable, $this->database);

        if ($this->foreignTable != $this->table && !$outerSchema->exists()) {
            throw new ReferenceException(
                "Unable to add foreign key '{$schema->getName()}'.'{$this->column}', "
                . "foreign table '{$this->foreignTable}' does not exists"
            );
        }

        if ($this->foreignTable != $this->table && !$outerSchema->hasColumn($this->foreignKey)) {
            throw new ReferenceException(
                "Unable to add foreign key '{$schema->getName()}'.'{$this->column}',"
                . " foreign column '{$this->foreignTable}'.'{$this->foreignKey}' does not exists"
            );
        }

        $foreignKey = $schema->foreign($this->column)->references(
            $this->foreignTable,
            $this->foreignKey
        );

        /*
         * We are allowing both formats "NO_ACTION" and "NO ACTION".
         */

        $foreignKey->onDelete(
            str_replace('_', ' ', $this->getOption('delete', AbstractReference::NO_ACTION))
        );

        $foreignKey->onUpdate(
            str_replace('_', ' ', $this->getOption('update', AbstractReference::NO_ACTION))
        );
    }
}