Micro\Db\Wrapper\Pdo

Complexity

Total Complexity

20

Size/Duplication

Total Lines	234
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	1

Importance

Changes

0

8 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	5	1
A	connect()	0	9	1
A	__call()	0	4	1
C	setOptions()	0	29	8
A	getResource()	0	8	2
A	select()	0	15	2
A	query()	0	19	2
B	prepare()	0	24	3

<?php
declare(strict_types = 1);

/**
 * Micro
 *
 * @author    Raffael Sahli <sahli@gyselroth.net>
 * @copyright Copyright (c) 2017 gyselroth GmbH (https://gyselroth.com)
 * @license   MIT https://opensource.org/licenses/MIT
 */

namespace Micro\Db\Wrapper;

use \Psr\Log\LoggerInterface;
use \Pdo as PdoServer;
use \PDOStatement;

class Pdo
{
    /**
     * Logger
     *
     * @var Logger
     */
    protected $logger;


    /**
     * Dsn
     *
     * @var string
     */
    protected $dsn = 'mysql:host=localhost;dbname=mysql';


    /**
     * Username
     *
     * @var string
     */
    protected $username = 'root';


    /**
     * Password
     *
     * @var string
     */
    protected $password = '';


    /**
     * Driver specific options
     *
     * @var array
     */
    protected $options = [];


    /**
     * Connection resource
     *
     * @var resource
     */
    protected $connection;


    /**
     * Last inserted id
     *
     * @var array
     */
    protected $last_inserted_ids;


    /**
     * construct
     *
     * @param   Iterable $config
     * @param   LoggerInterface   $logger
     */
    public function __construct(? Iterable $config, LoggerInterface $logger)
    {
        $this->setOptions($config);
        $this->logger = $logger;

It seems like $logger of type object<Psr\Log\LoggerInterface> is incompatible with the declared type object<Micro\Db\Wrapper\Logger> of property $logger.

    }


    /**
     * Connect
     *
     * @return Pdo
     */
    public function connect(): Pdo
    {
        $this->connection = new PdoServer($this->dsn, $this->username, $this->password, $this->options);

It seems like new \Pdo($this->dsn, $this->username, $this->password, $this->options) of type object<PDO> is incompatible with the declared type resource of property $connection.

        $this->logger->info('connection to db server ['.$this->dsn.'] using pdo was succesful', [
            'category' => get_class($this),
        ]);

        return $this;
    }


    /**
     * Forward calls
     *
     * @param  array $method
     * @param  array $arguments
     * @return mixed
     */
    public function __call(string $method, array $arguments = [])
    {
        return call_user_func_array([&$this->connection, $method], $arguments);
    }


    /**
     * Set options
     *
     * @param  Iterable $config
     * @return Pdo
     */
    public function setOptions(? Iterable $config = null) : Pdo
    {
        if ($config === null) {
            return $this;
        }

        foreach ($config as $option => $value) {
            switch ($option) {
                case 'dsn':
                    $this->dsn = (string)$value;
                    break;
                case 'username':
                    $this->username = (string)$value;
                    break;
                case 'password':
                    $this->password = (string)$value;
                    break;
                case 'options':
                    foreach ($value as $opt => $val) {
                        $this->options[$opt] = (string)$val;
                    }
                    break;
                default:
                    throw new Exception('invalid option '.$option.' given');
            }
        }

        return $this;
    }


    /**
     * Get connection
     *
     * @return resource
     */
    public function getResource()
    {
        if ($this->connection === null) {
            $this->connect();
        }

        return $this->connection;
    }


    /**
     * Query
     *
     * @param  string $query
     * @return PDOStatement
     */
    public function select(string $query): PDOStatement
    {
        $this->logger->debug('execute sql query ['.$query.']', [
            'category' => get_class($this),
        ]);

        $link   = $this->getResource();
        $result = $link->query($query);

The method query cannot be called on $link (of type resource).

        if ($result === false) {
            throw new Exception('failed to execute sql query with error '.$link->errorInfo()[2].' ('.$link->errorCode().')');

The method errorInfo cannot be called on $link (of type resource).

The method errorCode cannot be called on $link (of type resource).

        }

        return $result;
    }


    /**
     * Select query
     *
     * @param  string $query
     * @return bool
     */
    public function query(string $query): bool
    {
        $this->logger->debug('execute sql query ['.$query.']', [
            'category' => get_class($this),
        ]);

        $link   = $this->getResource();
        $result = $link->exec($query);

The method exec cannot be called on $link (of type resource).

        if ($result === false) {
            throw new Exception('failed to execute sql query with error '.$link->errorInfo().' ('.$link->errorCode().')');

The method errorInfo cannot be called on $link (of type resource).

The method errorCode cannot be called on $link (of type resource).

        } else {
            $this->logger->debug('sql query affected ['.$result.'] rows', [
                'category' => get_class($this),
            ]);
        }

        return true;
    }


    /**
     * Prepare query
     *
     * @param  string $query
     * @param  Iterable $values
     * @return mysqli_stmt
     */
    public function prepare(string $query, Iterable $values): mysqli_stmt
    {
        $this->logger->debug('prepare and execute mysql query ['.$query.'] with values [{values}]', [
            'category' => get_class($this),
            'values'   => $values
        ]);

        $link  = $this->getResource();
        $stmt  = $link->prepare($query);

The method prepare cannot be called on $link (of type resource).

        if (!($stmt instanceof mysqli_stmt)) {

The class Micro\Db\Wrapper\mysqli_stmt does not exist. Did you forget a USE statement, or did you not list all dependencies?

            throw new Exception('failed to prepare mysql query with error '.$link->error.' ('.$link->errno.')');
        }

        $types = '';
        foreach ($values as $attr => $value) {
            $types .= 's';
        }

        $stmt->bind_param($types, ...$values);
        $stmt->execute();

        return $stmt;
    }
}