Cycle\Database\Schema\AbstractForeignKey

Complexity

Total Complexity

16

Size/Duplication

Total Lines	179
Duplicated Lines	0 %

Test Coverage

Coverage

100%

Importance

Changes

0

15 Methods

Rating	Name	Duplication	Size	Complexity
A	withoutIndex()	0	3	1
A	onUpdate()	0	5	1
A	__construct()	0	5	1
A	references()	0	9	2
A	compare()	0	4	1
A	getForeignKeys()	0	3	1
A	packColumns()	0	3	1
A	onDelete()	0	5	1
A	columns()	0	5	1
A	getUpdateRule()	0	3	1
A	getColumns()	0	3	1
A	shouldCreateIndex()	0	3	1
A	sqlStatement()	0	16	1
A	getDeleteRule()	0	3	1
A	getForeignTable()	0	3	1

<?php

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

declare(strict_types=1);

namespace Cycle\Database\Schema;

use Cycle\Database\Driver\DriverInterface;
use Cycle\Database\ForeignKeyInterface;
use Cycle\Database\Schema\Traits\ElementTrait;

/**
 * Abstract foreign schema with read (see ReferenceInterface) and write abilities. Must be
 * implemented by driver to support DBMS specific syntax and creation rules.
 */
abstract class AbstractForeignKey implements ForeignKeyInterface, ElementInterface
{
    use ElementTrait;

    /**
     * Local column name (key name).
     */
    protected array $columns = [];

    /**
     * Referenced table name (including prefix).
     */
    protected string $foreignTable = '';

    /**
     * Linked foreign key name (foreign column).
     */
    protected array $foreignKeys = [];

    /**
     * Action on foreign column value deletion.
     */
    protected string $deleteRule = self::NO_ACTION;

    /**
     * Action on foreign column value update.
     */
    protected string $updateRule = self::NO_ACTION;

    /**
     * Create an index or not.
     */
    protected bool $createIndex = true;

    /**
     * @psalm-param non-empty-string $table
     *
     * @param string $tablePrefix
     *
     * @psalm-param non-empty-string $name
     */
    public function __construct(
        protected string $table,
        protected string $tablePrefix,
        protected string $name
    ) {
    }

    public function getColumns(): array
    {
        return $this->columns;
    }

    public function getForeignTable(): string
    {
        return $this->foreignTable;
    }

    public function getForeignKeys(): array
    {
        return $this->foreignKeys;
    }

    /**
     * @psalm-return non-empty-string
     */
    public function getDeleteRule(): string
    {
        return $this->deleteRule;
    }

    /**
     * @psalm-return non-empty-string
     */
    public function getUpdateRule(): string
    {
        return $this->updateRule;
    }

    /**
     * Set local column names foreign key relates to. Make sure column type is the same as foreign
     * column one.
     */
    public function columns(array $columns): self
    {
        $this->columns = $columns;

        return $this;
    }

    /**
     * Set foreign table name and key local column must reference to. Make sure local and foreign
     * column types are identical.
     *
     * @@psalm-param non-empty-string $table Foreign table name with or without database prefix (see 3rd argument).
     *
     * @param array $columns Foreign key names (id by default).
     * @param bool $forcePrefix When true foreign table will get same prefix as table being modified.
     */
    public function references(
        string $table,
        array $columns = ['id'],
        bool $forcePrefix = true
    ): self {
        $this->foreignTable = ($forcePrefix ? $this->tablePrefix : '') . $table;
        $this->foreignKeys = $columns;

        return $this;
    }

    /**
     * Set foreign key delete behaviour.
     *
     * @psalm-param non-empty-string $rule Possible values: NO ACTION, CASCADE, etc (driver specific).
     */
    public function onDelete(string $rule = self::NO_ACTION): self
    {
        $this->deleteRule = strtoupper($rule);

        return $this;
    }

    /**
     * Set foreign key update behaviour.
     *
     * @psalm-param non-empty-string $rule Possible values: NO ACTION, CASCADE, etc (driver specific).
     */
    public function onUpdate(string $rule = self::NO_ACTION): self
    {
        $this->updateRule = strtoupper($rule);

        return $this;
    }

    public function withoutIndex(): void
    {
        $this->createIndex = false;
    }

    public function shouldCreateIndex(): bool
    {
        return $this->createIndex;
    }

    /**
     * Foreign key creation syntax.
     *
     * @psalm-return non-empty-string
     */
    public function sqlStatement(DriverInterface $driver): string
    {
        $statement = [];

        $statement[] = 'CONSTRAINT';
        $statement[] = $driver->identifier($this->name);

The method identifier() does not exist on Cycle\Database\Driver\DriverInterface. It seems like you code against a sub-type of Cycle\Database\Driver\DriverInterface such as Cycle\Database\Driver\Driver.

        $statement[] = 'FOREIGN KEY';
        $statement[] = '(' . $this->packColumns($driver, $this->columns) . ')';

        $statement[] = 'REFERENCES ' . $driver->identifier($this->foreignTable);
        $statement[] = '(' . $this->packColumns($driver, $this->foreignKeys) . ')';

        $statement[] = "ON DELETE {$this->deleteRule}";
        $statement[] = "ON UPDATE {$this->updateRule}";

        return implode(' ', $statement);
    }

    public function compare(self $initial): bool
    {
        // soft compare
        return $this == clone $initial;
    }

    /**
     * @psalm-return non-empty-string
     */
    protected function packColumns(DriverInterface $driver, array $columns): string
    {
        return implode(', ', array_map([$driver, 'identifier'], $columns));
    }
}