kalanis\kw_mapper\Storage\Database\Raw\MySQLi

Complexity

Total Complexity

25

Size/Duplication

Total Lines	135
Duplicated Lines	0 %

Importance

Changes	1
Bugs	0	Features	1

11 Methods

Rating	Name	Duplication	Size	Complexity
A	disconnect()	0	6	2
A	languageDialect()	0	3	1
A	query()	0	22	5
A	connect()	0	4	2
A	rollBack()	0	3	1
A	beginTransaction()	0	7	2
A	lastInsertId()	0	3	2
A	commit()	0	3	1
A	connectToServer()	0	24	3
A	rowCount()	0	3	2
A	exec()	0	20	4

<?php

namespace kalanis\kw_mapper\Storage\Database\Raw;


use kalanis\kw_mapper\MapperException;
use kalanis\kw_mapper\Storage\Database\ASQL;
use kalanis\kw_mapper\Storage\Database\Dialects;
use kalanis\kw_mapper\Storage\Database\TBindNames;


/**
 * Class MySQLi
 * @package kalanis\kw_mapper\Storage\Database\Raw
 * Problematic connector to MySQL just for compatibility - USE PDO instead!!!
 * @codeCoverageIgnore remote connection
 */
class MySQLi extends ASQL
{
    use TBindNames;

    protected string $extension = 'mysqli';
    /** @var \mysqli|null */
    protected $connection = null;
    protected ?\mysqli_stmt $lastStatement = null;

    public function disconnect(): void
    {
        if ($this->isConnected()) {
            $this->connection->close();
        }
        $this->connection = null;
    }

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

    public function query(string $query, array $params, int $fetchType = MYSQLI_ASSOC): array
    {
        if (empty($query)) {
            return [];
        }

        $this->connect();

        $statement = $this->connection->stmt_init();
        list($updQuery, $binds, $types) = $this->bindFromNamedToQuestions($query, $params);
        $statement->prepare(strval($updQuery));
        if (!empty($binds)) {
            $statement->bind_param(implode('', $types), ...$binds); // @phpstan-ignore-line
        }
        if (!$statement->execute()) {
            throw new MapperException('mysqli execute error: ' . $statement->error);
        }
        $result = $statement->get_result();

        $this->lastStatement = $statement;

        return $result ? $result->fetch_all($fetchType) : [];

$result is of type mysqli_result, thus it always evaluated to true.

    }

    public function exec(string $query, array $params): bool
    {
        if (empty($query)) {
            return false;
        }

        $this->connect();

        $statement = $this->connection->stmt_init();
        list($updQuery, $binds, $types) = $this->bindFromNamedToQuestions($query, $params);
        $statement->prepare(strval($updQuery));
        if (!empty($binds)) {
            $statement->bind_param(implode('', $types), ...$binds); // @phpstan-ignore-line
        }
        $this->lastStatement = $statement;

        if (!$statement->execute()) {
            throw new MapperException('mysqli execute error: ' . $statement->error);
        }
        return true;
    }

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

    /**
     * @throws MapperException
     * @return \mysqli
     */
    protected function connectToServer(): \mysqli
    {
        $connection = new \mysqli(
            $this->config->getLocation(),
            $this->config->getUser(),
            $this->config->getPassword(),
            $this->config->getDatabase(),
            $this->config->getPort()
        );
        if ($connection->connect_errno) {
            throw new MapperException('mysqli connection error: ' . $connection->connect_error);
        }

//        foreach ($this->attributes as $key => $value){
//            $connection->setAttribute($key, $value);
//        }

        $connection->set_charset('utf8');
        if ($connection->errno) {
            throw new MapperException('mysqli error: ' . $connection->error);
        }
        $connection->query('SET NAMES utf8;');

        return $connection;
    }

    public function lastInsertId(): ?string
    {
        return $this->lastStatement ? strval($this->lastStatement->insert_id) : null ;
    }

    public function rowCount(): ?int
    {
        return $this->lastStatement ? intval($this->lastStatement->num_rows) : null ;
    }

    public function beginTransaction(): bool
    {
        if (!$this->isConnected()) {
            $this->connection = $this->connectToServer();
        }

        return $this->connection->begin_transaction();
    }

    public function commit(): bool
    {
        return $this->connection->commit();

The method commit() does not exist on null.

    }

    public function rollBack(): bool
    {
        return $this->connection->rollBack();
    }
}