TheCodingMachine\FluidSchema\FluidTable

Complexity

Total Complexity

14

Size/Duplication

Total Lines	126
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	8

Importance

Changes

0

10 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	6	1
A	column()	0	17	3
A	index()	0	5	1
A	unique()	0	5	1
A	primaryKey()	0	7	2
A	quoteArray()	0	4	1
A	id()	0	5	1
A	uuid()	0	5	1
A	timestamps()	0	6	1
A	extends()	0	18	2

<?php


namespace TheCodingMachine\FluidSchema;

use Doctrine\DBAL\Schema\Table;

class FluidTable
{
    /**
     * @var FluidSchema
     */
    private $schema;
    /**
     * @var Table
     */
    private $table;
    /**
     * @var FluidColumn[]
     */
    private $fluidColumns;
    /**
     * @var NamingStrategyInterface
     */
    private $namingStrategy;

    /**
     * @param FluidSchema $schema
     * @param Table $table
     */
    public function __construct(FluidSchema $schema, Table $table, NamingStrategyInterface $namingStrategy)
    {
        $this->schema = $schema;
        $this->table = $table;
        $this->namingStrategy = $namingStrategy;
    }

    public function column(string $name): FluidColumn
    {
        $name = $this->namingStrategy->quoteIdentifier($name);

        if (isset($this->fluidColumns[$name])) {
            return $this->fluidColumns[$name];
        }

        if ($this->table->hasColumn($name)) {
            $column = $this->table->getColumn($name);
        } else {
            $column = $this->table->addColumn($name, 'string');
        }

        $this->fluidColumns[$name] = new FluidColumn($this->schema, $this, $this->table, $column, $this->namingStrategy);
        return $this->fluidColumns[$name];
    }

    public function index(array $columnNames): FluidTable
    {
        $this->table->addIndex($this->quoteArray($columnNames));
        return $this;
    }

    public function unique(array $columnNames): FluidTable
    {
        $this->table->addUniqueIndex($this->quoteArray($columnNames));
        return $this;
    }

    public function primaryKey(array $columnNames, ?string $indexName = null): FluidTable
    {
        $newIndexName = $indexName ?: false;

        $this->table->setPrimaryKey($this->quoteArray($columnNames), $newIndexName);
        return $this;
    }

    private function quoteArray(array $columnNames): array
    {
        return array_map([$this->namingStrategy, 'quoteIdentifier'], $columnNames);
    }

    /**
     * Creates a "id" autoincremented primary key column.
     *
     * @return FluidTable
     */
    public function id(): FluidTable
    {
        $this->column('id')->integer()->primaryKey()->autoIncrement();
        return $this;
    }

    /**
     * Creates a "uuid" primary key column.
     *
     * @return FluidTable
     */
    public function uuid(): FluidTable
    {
        $this->column('uuid')->guid()->primaryKey();
        return $this;
    }

    /**
     * Creates "created_at" and "updated_at" columns.
     *
     * @return FluidTable
     */
    public function timestamps(): FluidTable
    {
        $this->column('created_at')->datetimeImmutable();
        $this->column('updated_at')->datetimeImmutable();
        return $this;
    }

    public function extends(string $tableName): FluidTable
    {
        $tableName = $this->namingStrategy->quoteIdentifier($tableName);

        $inheritedTable = $this->schema->getDbalSchema()->getTable($tableName);

        $pks = $inheritedTable->getPrimaryKeyColumns();

        if (count($pks) > 1) {
            throw new FluidSchemaException('You cannot inherit from a table with a primary key on several columns using FluidSchema. Use DBAL Schema methods instead.');
        }

        $pkName = $pks[0];
        $pk = $inheritedTable->getColumn($pkName);

        $this->column($pk->getName())->references($tableName)->primaryKey();
        return $this;
    }
}