Spiral\Database\Drivers\SQLite\Schemas\SQLiteTable

Complexity

Total Complexity

14

Size/Duplication

Total Lines	137
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	6

Importance

Changes

0

8 Methods

Rating	Name	Duplication	Size	Complexity
B	fetchColumns()	0	31	2
A	fetchIndexes()	0	16	2
A	fetchReferences()	0	15	2
A	fetchPrimaryKeys()	0	11	3
A	columnSchemas()	0	14	2
A	createColumn()	0	4	1
A	createIndex()	0	4	1
A	createForeign()	0	4	1

<?php
/**
 * components
 *
 * @author    Wolfy-J
 */
namespace Spiral\Database\Drivers\SQLite\Schemas;

use Spiral\Database\Schemas\Prototypes\AbstractColumn;
use Spiral\Database\Schemas\Prototypes\AbstractIndex;
use Spiral\Database\Schemas\Prototypes\AbstractReference;
use Spiral\Database\Schemas\Prototypes\AbstractTable;

class SQLiteTable extends AbstractTable
{
    /**
     * {@inheritdoc}
     */
    protected function fetchColumns(): array
    {
        /**
         * Parsing column definitions.
         */
        $definition = $this->driver->query(
            "SELECT 'sql' FROM 'sqlite_master' WHERE type = 'table' and name = ?",
            [$this->getName()]
        )->fetchColumn();

        /*
        * There is not really many ways to get extra information about column in SQLite, let's parse
        * table schema. As mention, spiral SQLite schema reader will support fully only tables created
        * by spiral as we expecting every column definition be on new line.
        */
        $definition = explode("\n", $definition);

        $result = [];
        foreach ($this->columnSchemas(['table' => $definition]) as $schema) {
            //Making new column instance
            $result[] = SQLiteColumn::createInstance(
                $this->getName(),
                $schema + [
                    'quoted'     => $this->driver->quote($schema['name']),
                    'identifier' => $this->driver->identifier($schema['name'])
                ]
            );
        }

        return $result;
    }

    /**
     * {@inheritdoc}
     */
    protected function fetchIndexes(): array
    {
        $query = "PRAGMA index_list({$this->driver->quote($this->getName())})";

        $result = [];
        foreach ($this->driver->query($query) as $schema) {
            //Index schema and all related columns
            $result[] = SQLiteIndex::createInstance(
                $this->getName(),
                $schema,
                $this->driver->query("PRAGMA INDEX_INFO({$this->driver->quote($schema['name'])})")->fetchAll()
            );
        }

        return $result;
    }

    /**
     * {@inheritdoc}
     */
    protected function fetchReferences(): array
    {
        $query = "PRAGMA foreign_key_list({$this->driver->quote($this->getName())})";

        $result = [];
        foreach ($this->driver->query($query) as $schema) {
            $result[] = SQLiteReference::createInstance(
                $this->getName(),
                $this->getPrefix(),
                $schema
            );
        }

        return $result;
    }

    /**
     * Fetching primary keys from table.
     *
     * @return array
     */
    protected function fetchPrimaryKeys(): array
    {
        $primaryKeys = [];
        foreach ($this->columnSchemas() as $column) {
            if (!empty($column['pk'])) {
                $primaryKeys[] = $column['name'];
            }
        }

        return $primaryKeys;
    }

    /**
     * @param array $include Include following parameters into each line.
     *
     * @return array
     */
    private function columnSchemas(array $include = []): array
    {
        $columns = $this->driver->query(
            "PRAGMA TABLE_INFO(" . $this->driver->quote($this->getName()) . ")"
        );

        $result = [];

        foreach ($columns as $column) {
            $result[] = $column + $include;
        }

        return $result;
    }

    /**
     * {@inheritdoc}
     */
    protected function createColumn(string $name): AbstractColumn
    {
        return new SQLiteColumn($this->getName(), $name);
    }

    /**
     * {@inheritdoc}
     */
    protected function createIndex(string $name): AbstractIndex
    {
        return new SQLiteIndex($this->getName(), $name);
    }

    /**
     * {@inheritdoc}
     */
    protected function createForeign(string $column): AbstractReference
    {
        return new SQLiteReference($this->getName(), $this->getPrefix(), $column);
    }
}