Fyuze\Database\Db

Complexity

Total Complexity

13

Size/Duplication

Total Lines	121
Duplicated Lines	0 %

Test Coverage

Coverage

100%

Importance

Changes	1
Bugs	0	Features	0

9 Methods

Rating	Name	Duplication	Size	Complexity
A	transaction()	0	11	2
A	first()	0	3	1
A	isWrite()	0	3	2
A	all()	0	3	1
A	table()	0	3	1
A	__construct()	0	3	1
A	query()	0	17	3
A	isRead()	0	3	1
A	getQueries()	0	3	1

<?php
namespace Fyuze\Database;

use Exception;
use Fyuze\Database\Drivers\ConnectionInterface;

class Db
{
    /**
     * The pdo connection
     *
     * @var \PDO
     */
    protected $connection;

    /**
     * The executed queries
     *
     * @var array
     */
    protected array $queries = [];

    /**
     * @param ConnectionInterface $connection
     */
    public function __construct(ConnectionInterface $connection)
    {
        $this->connection = $connection->open();
    }

    /**
     * @return array
     */
    public function getQueries(): array
    {
        return $this->queries;
    }

    /**
     * @param $sql
     * @param array $params
     * @return mixed
     */
    public function all($sql, array $params = [])
    {
        return $this->query($sql, $params)->fetchAll();
    }

    /**
     * @param $sql
     * @param array $params
     * @return mixed
     */
    public function first($sql, array $params = [])
    {
        return $this->query($sql, $params)->fetch();
    }

    /**
     * @param $name
     * @return Query
     */
    public function table($name)
    {
        return new Query($this, $name);
    }

    /**
     * @param \Closure $queries
     * @return bool
     */
    public function transaction(\Closure $queries)
    {
        $this->connection->beginTransaction();

        try {
            $queries($this);
            $this->connection->commit();
            return true;
        } catch (Exception $e) {
            $this->connection->rollback();
            return false;
        }
    }

    /**
     * @param $query
     * @param array $params
     * @return mixed
     */
    public function query($query, array $params = [])
    {
        $statement = $this->connection->prepare($query);

        $this->queries[] = $query;

        $result = $statement->execute($params);

        if ($this->isRead($query)) {
            return $statement;
        }

        if ($this->isWrite($query)) {
            return $statement->rowCount();
        }

        return $result;
    }

    /**
     *
     * @param $query
     * @return bool
     */
    protected function isRead($query)
    {
        return stripos($query, 'select') === 0;
    }

    /**
     *
     * @param $query
     * @return bool
     */
    protected function isWrite($query)
    {
        return stripos($query, 'update') === 0 || stripos($query, 'delete') === 0;
    }
}