HexMakina\Crudites\Schema\Schema

Complexity

Total Complexity

40

Size/Duplication

Total Lines	165
Duplicated Lines	0 %

Importance

Changes	1
Bugs	0	Features	0

23 Methods

Rating	Name	Duplication	Size	Complexity
A	insert()	0	3	1
A	hasColumn()	0	3	2
A	autoIncrementedPrimaryKey()	0	7	3
A	matchPrimaryKeys()	0	6	2
A	tables()	0	3	1
A	uniqueKeys()	0	3	2
A	foreignKeys()	0	3	2
A	hasTable()	0	3	1
A	filterData()	0	3	1
A	database()	0	3	1
A	uniqueColumnsFor()	0	11	3
A	columns()	0	3	2
A	__construct()	0	4	1
A	column()	0	11	3
A	matchUniqueKeys()	0	11	3
A	delete()	0	3	1
A	primaryKeys()	0	3	2
A	select()	0	10	2
A	uniqueColumnsByName()	0	3	2
A	update()	0	3	1
A	foreignKey()	0	3	2
A	matchUniqueness()	0	3	1
A	attributes()	0	3	1

<?php

namespace HexMakina\Crudites\Schema;

use HexMakina\BlackBox\Database\QueryInterface;
use HexMakina\BlackBox\Database\{SchemaInterface, SchemaAttributeInterface};

The type HexMakina\BlackBox\Database\SchemaInterface was not found. Maybe you did not declare it correctly or list all dependencies?

The type HexMakina\BlackBox\Database\SchemaAttributeInterface was not found. Maybe you did not declare it correctly or list all dependencies?

use HexMakina\Crudites\Grammar\Query\Select;
use HexMakina\Crudites\Grammar\Query\Insert;
use HexMakina\Crudites\Grammar\Query\Update;
use HexMakina\Crudites\Grammar\Query\Delete;

/**
 * The class provides an abstraction for database schema information.
 * It is built using the INFORMATION_SCHEMA database.
 */
class Schema implements SchemaInterface
{
    private string $database;
    private array $tables = [];

    // use a SchemaLoader to get the proper table structure
    public function __construct(string $database, array $tables = [])
    {
        $this->database = $database;
        $this->tables = $tables;
    }

    public function hasTable(string $table): bool
    {
        return isset($this->tables[$table]);
    }
    public function database(): string
    {
        return $this->database;
    }

    public function tables(): array
    {
        return array_keys($this->tables);
    }

    public function hasColumn(string $table, string $column): bool
    {
        return $this->hasTable($table) && !empty($this->tables[$table]['columns'][$column]);
    }

    public function columns(string $table): array
    {
        return $this->hasTable($table) ? array_keys($this->tables[$table]['columns']) : [];
    }

    public function column(string $table, string $column): array
    {
        if (!$this->hasColumn($table, $column)) {
            throw new \InvalidArgumentException('CANNOT FIND COLUMN ' . $column . ' IN TABLE ' . $table);
        }

        if(!isset($this->tables[$table]['columns'][$column]['schema'])){
            throw new \InvalidArgumentException("ERR_MISSING_COLUMN_SCHEMA");
        }

        return $this->tables[$table]['columns'][$column]['schema'];
    }

    public function attributes(string $table, string $column): SchemaAttributeInterface
    {
        return new SchemaAttribute($this, $table, $column);
    }

    public function autoIncrementedPrimaryKey(string $table): ?string
    {
        foreach ($this->primaryKeys($table) as $column) {
            return $this->attributes($table, $column)->isAuto() ? $column : null;
        }

        return null;
    }
    public function primaryKeys(string $table): array
    {
        return $this->hasTable($table) ? $this->tables[$table]['primary'] : [];
    }

    public function foreignKeys(string $table): array
    {
        return $this->hasTable($table) ? $this->tables[$table]['foreign'] : [];
    }

    public function foreignKey(string $table, string $column): array
    {
        return $this->hasTable($table) ? ($this->tables[$table]['foreign'][$column] ?? []) : [];
    }

    public function uniqueKeys(string $table): array
    {
        return $this->hasTable($table) ? $this->tables[$table]['unique'] : [];
    }

    public function uniqueColumnsByName(string $table, string $constraint): array
    {
        return $this->hasTable($table) ? $this->tables[$table]['unique'][$constraint] : [];
    }

    public function uniqueColumnsFor(string $table, string $column): array
    {
        $ret = [];

        if ($this->hasColumn($table, $column)) {
            foreach ($this->tables[$table]['columns'][$column]['unique'] as $constraint_name) {
                $ret[$constraint_name] = $this->uniqueColumnsByName($table, $constraint_name);
            }
        }

        return $ret;
    }


    public function matchUniqueness(string $table, array $dat_ass): array
    {
        return $this->matchPrimaryKeys($table, $dat_ass) ?? $this->matchUniqueKeys($table, $dat_ass) ?? [];
    }

    public function matchPrimaryKeys(string $table, array $dat_ass): ?array
    {
        $primaryKeys = $this->primaryKeys($table);
        $match = array_intersect_key($dat_ass, array_flip($primaryKeys));

        return count($match) === count($primaryKeys) ? $match : null;
    }

    public function matchUniqueKeys(string $table, array $dat_ass): ?array
    {
        foreach ($this->uniqueKeys($table) as $columns) {
            $match = array_intersect_key($dat_ass, array_flip($columns));

            if (count($match) === count($columns)) {
                return $match;
            }
        }

        return null;
    }


    public function insert(string $table, array $dat_ass): QueryInterface
    {
        return new Insert($table, $this->filterData($table, $dat_ass));
    }

    public function update(string $table, array $alterations = [], array $conditions = []): QueryInterface
    {
        return new Update($table, $this->filterData($table, $alterations), $this->filterData($table, $conditions));
    }

    public function delete(string $table, array $conditions): QueryInterface
    {
        return new Delete($table, $this->filterData($table, $conditions));
    }

    public function select(string $table, array $columns = null, string $table_alias = null): QueryInterface
    {
        if(in_array('*', $columns)){

It seems like $columns can also be of type null; however, parameter $haystack of in_array() does only seem to accept array, maybe add an additional type check?

            $filtered_columns = ['*'];
        }
        else{
            $filtered_columns = array_intersect($columns, $this->columns($table));

It seems like $columns can also be of type null; however, parameter $array of array_intersect() does only seem to accept array, maybe add an additional type check?

        } 
        
        return new Select($filtered_columns, $table, $table_alias);
    }

    /**
     * Filters the given data to only include columns that exist in the specified table.
     *
     * @param string $table The name of the table.
     * @param array $dat_ass The data to filter.
     * @return array The filtered data.
     */
    private function filterData(string $table, array $dat_ass)
    {
        return array_intersect_key($dat_ass, array_flip($this->columns($table)));
    }
}