kalanis\kw_mapper\Storage\Database\PDO\APDO

Complexity

Total Complexity

16

Size/Duplication

Total Lines	93
Duplicated Lines	0 %

Test Coverage

Coverage

100%

Importance

Changes	1
Bugs	0	Features	0

8 Methods

Rating	Name	Duplication	Size	Complexity
A	commit()	0	3	1
A	beginTransaction()	0	9	2
A	rowCount()	0	3	2
A	rollBack()	0	3	1
A	connect()	0	4	2
A	exec()	0	14	3
A	lastInsertId()	0	5	2
A	query()	0	16	3

<?php

namespace kalanis\kw_mapper\Storage\Database\PDO;


use kalanis\kw_mapper\MapperException;
use kalanis\kw_mapper\Storage\Database\ASQL;
use PDO;
use PDOStatement;


/**
 * Class APDO
 * @package kalanis\kw_mapper\Storage\Database\PDO
 * PHP data object abstraction
 * Uses placeholders, not question marks
 */
abstract class APDO extends ASQL
{
    /** @var PDO|null */
    protected $connection = null;
    protected ?PDOStatement $lastStatement;

    /**
     * @param string $query
     * @param array<string, mixed> $params
     * @param int $fetchType
     * @throws MapperException
     * @return array<string|int, array<int, string|int|float>>
     */
    public function query(string $query, array $params, int $fetchType = PDO::FETCH_ASSOC): array
    {
        if (empty($query)) {
            return [];
        }

        $this->connect();

//print_r(['qu', str_split($query, 80), $params]);
        $statement = $this->connection->prepare($query);
        $statement->execute($params);

        $this->lastStatement = $statement;

        $result = $statement->fetchAll($fetchType);
        return (false !== $result) ? $result : [];
    }

    /**
     * @param string $query
     * @param array<string, mixed> $params
     * @throws MapperException
     * @return bool
     */
    public function exec(string $query, array $params): bool
    {
        if (empty($query)) {
            return false;
        }

        $this->connect();

        $statement = $this->connection->prepare($query);
        $result = $statement->execute($params);

        $this->lastStatement = $statement;

        return $result && $statement->closeCursor();
    }

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

    abstract protected function connectToServer(): PDO;

    public function lastInsertId(): ?string
    {
        /** @scrutinizer ignore-call */
        $id = $this->connection->lastInsertId();
        return (false === $id) ? null : strval($id);
    }

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

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

        return (bool) $this->connection->beginTransaction();
    }

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

The method commit() does not exist on null.

    }

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