PhpCfdi\SatCatalogosPopulate\Database\DataTableGateway

Complexity

Total Complexity

16

Size/Duplication

Total Lines	82
Duplicated Lines	0 %

Test Coverage

Coverage

93.18%

Importance

Changes	1
Bugs	0	Features	0

7 Methods

Rating	Name	Duplication	Size	Complexity
A	create()	0	21	3
A	recreate()	0	4	1
A	drop()	0	4	1
A	dataTable()	0	3	1
A	__construct()	0	2	1
A	sqlDiscoverField()	0	14	6
A	insert()	0	19	3

<?php

declare(strict_types=1);

namespace PhpCfdi\SatCatalogosPopulate\Database;

use LogicException;
use PDOException;

class DataTableGateway
{
    public function __construct(private DataTable $dataTable, private Repository $repository)
    {
    }

    public function dataTable(): DataTable
    {
        return $this->dataTable;
    }

    public function recreate(): void
    {
        $this->drop();
        $this->create();
    }

    private function sqlDiscoverField(DataFieldInterface $field): string
    {
        $sqlName = $this->repository->escapeName($field->name());
        if ($field instanceof TextDataField || $field instanceof DateDataField) {
            return $sqlName . ' text not null';
        }
        if ($field instanceof IntegerDataField || $field instanceof BoolDataField) {
            return $sqlName . ' int not null';
        }
        if ($field instanceof FloatDataField) {
            return $sqlName . ' real not null';
        }

        throw new LogicException("Don't know what to do with " . $field::class);
    }

    public function drop(): void
    {
        $sql = 'DROP TABLE IF EXISTS ' . $this->repository->escapeName($this->dataTable->name()) . ';';
        $this->repository->execute($sql);
    }

    public function create(): void
    {
        $fields = [];
        foreach ($this->dataTable->fields() as $field) {
            $fields[] = $this->sqlDiscoverField($field);
        }

        $pkDefinition = '';
        if (count($this->dataTable->primaryKey()) > 0) {
            $pkDefinition = 'PRIMARY KEY ('
                . implode(', ', array_map(
                    fn (string $input): string => $this->repository->escapeName($input),
                    $this->dataTable->primaryKey()
                ))
                . ')';
        }

        $sql = 'CREATE TABLE ' . $this->repository->escapeName($this->dataTable->name())
            . ' ( ' . implode(', ', array_filter([...$fields, ...[$pkDefinition]])) . ' )'
            . ';';
        $this->repository->execute($sql);
    }

    /** @param mixed[] $input */
    public function insert(array $input): void
    {
        $fieldNames = [];
        $preparedNames = [];
        foreach ($this->dataTable->fields() as $dataField) {
            $fieldNames[] = $this->repository->escapeName($dataField->name());
            $preparedNames[] = ':' . $dataField->name();
        }

        $sql = 'INSERT INTO ' . $this->repository->escapeName($this->dataTable->name())
            . ' (' . implode(', ', $fieldNames) . ')'
            . ' VALUES (' . implode(', ', $preparedNames) . ')'
            . ';';

        try {
            $this->repository->execute($sql, $input);
        } catch (PDOException $exception) {
            $message = sprintf('Unable to run %s using %s', $sql, json_encode($input, JSON_THROW_ON_ERROR));
            throw new PDOException($message, 0, $exception);
        }
    }
}