yentu\DatabaseAssertor

Complexity

Total Complexity

21

Size/Duplication

Total Lines	92
Duplicated Lines	0 %

Importance

Changes	2
Bugs	0	Features	0

11 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	3	1
A	doesSchemaExist()	0	3	1
A	doesColumnExist()	0	5	2
A	doesTableExist()	0	12	3
A	doesPrimaryKeyExist()	0	3	1
A	doesViewExist()	0	15	5
A	doesForeignKeyExist()	0	3	1
A	getTableDetails()	0	6	2
A	doesUniqueKeyExist()	0	3	1
A	doesItemExist()	0	11	3
A	doesIndexExist()	0	3	1

<?php

namespace yentu;

class DatabaseAssertor
{
    private $description;

    public function __construct($description)
    {
        $this->description = $description;
    }

    public function doesSchemaExist($details)
    {
        return isset($this->description['schemata'][$details]);
    }

    public function doesTableExist($details)
    {
        if (is_string($details)) {
            $details = array(
                'schema' => false,
                'name' => $details
            );
        }

        return $details['schema'] == false ?
            isset($this->description['tables'][$details['name']]) :
            isset($this->description['schemata'][$details['schema']]['tables'][$details['name']]);
    }

    public function doesColumnExist($details)
    {
        $table = $this->getTableDetails($details['schema'], $details['table']);
        return isset($table['columns'][$details['name']]) ?
            Parameters::wrap($table['columns'][$details['name']]) : false;
    }

    private function doesItemExist($details, $type)
    {
        $table = $this->getTableDetails($details['schema'], $details['table']);
        if (isset($details['name'])) {
            return $table[$type][$details['name']] ?? false;
        } else if (!empty($details['columns'])) {
            $columns = array_map(fn($x) => $x, $details['columns']);
            sort($columns);
            return $table["flat_$type"][implode(':', $columns)] ?? false;
        }
        return false;
    }

    public function doesForeignKeyExist($details)
    {
        return $this->doesItemExist($details, 'foreign_keys');
    }

    public function doesUniqueKeyExist($details)
    {
        return $this->doesItemExist($details, 'unique_keys');
    }

    public function doesPrimaryKeyExist($details)
    {
        return $this->doesItemExist($details, 'primary_key');
    }

    public function doesIndexExist($details)
    {
        return $this->doesItemExist($details, 'indices');
    }

    public function doesViewExist($details)
    {
        if (is_string($details)) {
            $details = array(
                'schema' => false,
                'name' => $details
            );
        }

        // too complex 
        if ($details['schema'] == false) {
            return isset($this->description['views'][$details['name']]) ? $this->description['views'][$details['name']]['definition'] : false;
        } else {
            return (isset($this->description['schemata'][$details['schema']]['views'][$details['name']]) ?
                $this->description['schemata'][$details['schema']]['views'][$details['name']]['definition'] : false);
        }
    }

    private function getTableDetails($schema, $table)
    {
        if ($schema) {
            return $this->description['schemata'][$schema]['tables'][$table];
        } else {
            return $this->description['tables'][$table];
        }
    }
}