vakata\database\DriverAbstract

Complexity

Total Complexity

24

Size/Duplication

Total Lines	102
Duplicated Lines	0 %

Coupling/Cohesion

Components	2
Dependencies	2

Test Coverage

Coverage

11.32%

Importance

Changes

0

14 Methods

Rating	Name	Duplication	Size	Complexity
A	name()	0	4	1
A	option()	0	4	2
A	begin()	0	10	2
A	commit()	0	9	2
A	rollback()	0	9	2
B	expand()	0	25	6
A	query()	0	8	5
A	raw()	0	5	1
	connect()	0	1	?
	prepare()	0	1	?
	test()	0	1	?
A	disconnect()	0	3	1
A	table()	0	4	1
A	tables()	0	4	1

<?php

namespace vakata\database;

use \vakata\database\schema\Table;
use \vakata\database\schema\TableQuery;

abstract class DriverAbstract implements DriverInterface
{
    protected $connection;
    
    protected function expand(string $sql, $par = null) : array
    {
        $new = '';
        $par = array_values($par);
        if (substr_count($sql, '?') === 2 && !is_array($par[0])) {
            $par = [ $par ];
        }
        $parts = explode('??', $sql);
        $index = 0;
        foreach ($parts as $part) {
            $tmp = explode('?', $part);
            $new .= $part;
            $index += count($tmp) - 1;
            if (isset($par[$index])) {
                if (!is_array($par[$index])) {
                    $par[$index] = [ $par[$index] ];
                }
                $params = $par[$index];
                array_splice($par, $index, 1, $params);
                $index += count($params);
                $new .= implode(',', array_fill(0, count($params), '?'));
            }
        }
        return [ $new, $par ];
    }
    /**
     * Run a query (prepare & execute).
     * @param string $sql  SQL query
     * @param mixed  $par  parameters (optional)
     * @return ResultInterface the result of the execution
     */
    public function query(string $sql, $par = null, bool $buff = true) : ResultInterface
    {
        $par = isset($par) ? (is_array($par) ? $par : [$par]) : [];
        if (strpos($sql, '??') && count($par)) {
            list($sql, $par) = $this->expand($sql, $par);
        }
        return $this->prepare($sql)->execute($par, $buff);
    }
    public function name() : string
    {
        return $this->connection['name'];
    }
    public function option(string $key, $default = null)
    {
        return isset($this->connection['opts'][$key]) ? $this->connection['opts'][$key] : $default;
    }
    
    public function begin() : bool
    {
        $this->connect();
        try {
            $this->query("START TRANSACTION");
            return true;
        } catch (DBException $e) {
            return false;
        }
    }
    public function commit() : bool
    {
        try {
            $this->query("COMMIT");
            return true;
        } catch (DBException $e) {
            return false;
        }
    }
    public function rollback() : bool
    {
        try {
            $this->query("ROLLBACK");
            return true;
        } catch (DBException $e) {
            return false;
        }
    }
    public function raw(string $sql)
    {
        $this->connect();
        return $this->query($sql);
    }
    
    abstract public function connect();
    abstract public function prepare(string $sql) : StatementInterface;
    abstract public function test() : bool;
    public function disconnect()
    {
    }

    public function table(string $table, bool $detectRelations = true) : Table
    {
        throw new DBException('Not supported');
    }
    public function tables() : array
    {
        throw new DBException('Not supported');
    }
}