Wandu\Database\Connection\MysqlConnection

Complexity

Total Complexity

24

Size/Duplication

Total Lines	142
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	6

Test Coverage

Coverage

74.58%

Importance

Changes

0

10 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	7	1
A	connect()	0	10	3
A	fetch()	0	7	2
A	all()	0	4	1
A	first()	0	5	2
A	query()	0	4	1
A	getLastInsertId()	0	4	1
A	transaction()	0	14	3
A	execute()	0	17	4
B	bindValues()	0	19	6

<?php
namespace Wandu\Database\Connection;

use Exception;
use PDO;
use PDOStatement;
use Throwable;
use Wandu\Collection\ArrayList;
use Wandu\Database\Configuration;
use Wandu\Database\Contracts\ConnectionInterface;
use Wandu\Database\Contracts\QueryInterface;
use Wandu\Database\Events\Connect;
use Wandu\Database\Events\ExecuteQuery;
use Wandu\Event\DispatcherInterface;

class MysqlConnection implements ConnectionInterface
{
    /** @var \PDO */
    protected $pdo;

    /** @var \Wandu\Database\Configuration */
    protected $config;

    /** @var \Wandu\Event\DispatcherInterface */
    protected $dispatcher;
    
    public function __construct(
        Configuration $config,
        DispatcherInterface $dispatcher = null
    ) {
        $this->config = $config;
        $this->dispatcher = $dispatcher;
    }

    /**
     * {@inheritdoc}
     */
    public function connect()
    {
        if (!$this->pdo) {
            $this->pdo = $this->config->createPdo();
            if ($this->dispatcher) {
                $this->dispatcher->trigger(new Connect());
            }
        }
        return $this;
    }

    /**
     * {@inheritdoc}
     */
    public function fetch($query, array $bindings = [])
    {
        $statement = $this->execute($query, $bindings);
        while ($row = $statement->fetch(PDO::FETCH_ASSOC)) {
            yield $row;
        }
    }

    /**
     * {@inheritdoc}
     */
    public function all($query, array $bindings = [])
    {
        return new ArrayList($this->fetch($query, $bindings));
    }

    /**
     * {@inheritdoc}
     */
    public function first($query, array $bindings = [])
    {
        $attributes = $this->execute($query, $bindings)->fetch(PDO::FETCH_ASSOC);
        return $attributes ?: null;
    }

    /**
     * {@inheritdoc}
     */
    public function query($query, array $bindings = [])
    {
        return $this->execute($query, $bindings)->rowCount();
    }

    /**
     * {@inheritdoc}
     */
    public function getLastInsertId()
    {
        return $this->pdo->lastInsertId();
    }

    /**
     * {@inheritdoc}
     */
    public function transaction(callable $handler)
    {
        $this->pdo->beginTransaction();
        try {
            call_user_func($handler, $this);
        } catch (Exception $e) {
            $this->pdo->rollBack();
            throw $e;
        } catch (Throwable $e) {
            $this->pdo->rollBack();
            throw $e;
        }
        $this->pdo->commit();
    }

    /**
     * @param string|callable|\Wandu\Database\Contracts\QueryInterface $query
     * @param array $bindings
     * @return \PDOStatement
     */
    protected function execute($query, array $bindings = [])
    {
        while (is_callable($query)) {
            $query = call_user_func($query);
        }
        if ($query instanceof QueryInterface) {
            $bindings = $query->getBindings();
            $query = $query->toSql();
        }
        $statement = $this->pdo->prepare($query);
        $this->bindValues($statement, $bindings);
        $statement->execute();
        if ($this->dispatcher) {
            $this->dispatcher->trigger(new ExecuteQuery($statement->queryString, $bindings));
        }
        return $statement;
    }
    
    /**
     * @param \PDOStatement $statement
     * @param array $bindings
     */
    protected function bindValues(PDOStatement $statement, array $bindings = [])
    {
        foreach ($bindings as $key => $value) {
            if (is_int($value)) {
                $dataType = PDO::PARAM_INT;
            } elseif (is_bool($value)) {
                $dataType = PDO::PARAM_BOOL;
            } elseif (is_null($value)) {
                $dataType = PDO::PARAM_NULL;
            } else {
                $dataType = PDO::PARAM_STR;
            }
            $statement->bindValue(
                is_int($key) ? $key + 1 : $key,
                $value,
                $dataType
            );
        }
    }
}