kalanis\kw_mapper\Storage\Database\Raw\Dba

Complexity

Total Complexity

18

Size/Duplication

Total Lines	108
Duplicated Lines	0 %

Importance

Changes	1
Bugs	0	Features	0

6 Methods

Rating	Name	Duplication	Size	Complexity
B	exec()	0	23	7
A	query()	0	20	4
A	connect()	0	4	2
A	disconnect()	0	5	2
A	connectToServer()	0	12	2
A	languageDialect()	0	3	1

<?php

namespace kalanis\kw_mapper\Storage\Database\Raw;


use kalanis\kw_mapper\Interfaces\IDriverSources;
use kalanis\kw_mapper\Interfaces\IPassConnection;
use kalanis\kw_mapper\MapperException;
use kalanis\kw_mapper\Storage\Database\ADatabase;
use kalanis\kw_mapper\Storage\Database\Dialects;
use kalanis\kw_mapper\Storage\Database\TConnection;


/**
 * Class Dba
 * @package kalanis\kw_mapper\Storage\Database\Raw
 * @link https://www.php.net/manual/en/book.dba.php
 * @codeCoverageIgnore remote connection
 */
class Dba extends ADatabase implements IPassConnection
{
    use TConnection;

    protected string $extension = 'dba';
    /** @var resource|null */
    protected $connection = null;

    public function languageDialect(): string
    {
        return Dialects\EmptyDialect::class;
    }

    public function disconnect(): void
    {
        if ($this->isConnected()) {
            dba_close($this->connection);

It seems like $this->connection can also be of type object; however, parameter $dba of dba_close() does only seem to accept resource, maybe add an additional type check?

            $this->connection = null;
        }
    }

    /**
     * @param string $key
     * @throws MapperException
     * @return array<string|int, string|int|float|null|array<string|int|float|null>>
     */
    public function query(string $key): array
    {
        if (empty($key)) {
            return [];
        }

        $this->connect();

        $results = [];
        $key = dba_firstkey($this->getConnection());

It seems like $this->getConnection() can also be of type object; however, parameter $dba of dba_firstkey() does only seem to accept resource, maybe add an additional type check?

        while (false !== $key) {
            $line = dba_fetch($key, $this->getConnection());

It seems like $this->getConnection() can also be of type object; however, parameter $handle of dba_fetch() does only seem to accept resource, maybe add an additional type check?

            if (false !== $line) {
                $results[] = $line;
            }
            $key = dba_nextkey($this->getConnection());

It seems like $this->getConnection() can also be of type object; however, parameter $dba of dba_nextkey() does only seem to accept resource, maybe add an additional type check?

        }

        return $results;
    }

    /**
     * @param string $key
     * @param string $action
     * @param string $content
     * @throws MapperException
     * @return bool
     */
    public function exec(string $action, string $key, string $content = ''): bool
    {
        if (empty($key)) {
            return false;
        }

        $this->connect();

        if (dba_exists($key, $this->getConnection())) {

It seems like $this->getConnection() can also be of type object; however, parameter $dba of dba_exists() does only seem to accept resource, maybe add an additional type check?

            if (IDriverSources::ACTION_UPDATE == $action) {
                return dba_replace($key, $content, $this->getConnection());

It seems like $this->getConnection() can also be of type object; however, parameter $dba of dba_replace() does only seem to accept resource, maybe add an additional type check?

            } elseif (IDriverSources::ACTION_DELETE == $action) {
                return dba_delete($key, $this->getConnection());

It seems like $this->getConnection() can also be of type object; however, parameter $dba of dba_delete() does only seem to accept resource, maybe add an additional type check?

            } else {
                return false;
            }
        } else {
            if (IDriverSources::ACTION_UPDATE == $action) {
                return dba_insert($key, $content, $this->getConnection());

It seems like $this->getConnection() can also be of type object; however, parameter $dba of dba_insert() does only seem to accept resource, maybe add an additional type check?

            } elseif (IDriverSources::ACTION_INSERT == $action) {
                return dba_insert($key, $content, $this->getConnection());
            } else {
                return false;
            }
        }
    }

    /**
     * @throws MapperException
     */
    public function connect(): void
    {
        if (!$this->isConnected()) {
            $this->connection = $this->connectToServer();
        }
    }

    /**
     * @throws MapperException
     * @return resource
     */
    protected function connectToServer()
    {
        $connection = dba_open(
            $this->config->getLocation(),
            $this->config->getDatabase(),
            $this->config->getType()
        );
        if (!$connection) {

$connection is of type resource, thus it always evaluated to false.

            throw new MapperException('DBA connection failed.');
        }

        return $connection;
    }
}