vakata\database\driver\sqlite\Driver

Complexity

Total Complexity

21

Size/Duplication

Total Lines	102
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	3

Importance

Changes

0

9 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	12	3
A	__destruct()	0	4	1
A	connect()	0	11	3
A	disconnect()	0	6	2
B	prepare()	0	20	5
A	begin()	0	14	2
A	commit()	0	12	2
A	rollback()	0	12	2
A	isTransaction()	0	4	1

<?php

namespace vakata\database\driver\sqlite;

use \vakata\database\DBException;
use \vakata\database\DriverInterface;
use \vakata\database\DriverAbstract;
use \vakata\database\StatementInterface;
use \vakata\database\schema\Table;
use \vakata\database\schema\TableRelation;

class Driver extends DriverAbstract implements DriverInterface
{
    protected $connection;
    protected $lnk = null;

    public function __construct(array $connection)
    {
        $temp = explode('://', $connection['orig'], 2)[1];
        $temp = array_pad(explode('?', $temp, 2), 2, '');
        $connection = [];
        parse_str($temp[1], $connection['opts']);
        $connection['name'] = $temp[0];
        if (!is_file($connection['name']) && is_file('/'.$connection['name'])) {
           $connection['name'] = '/'.$connection['name'];
        }
        $this->connection = $connection;
    }
    public function __destruct()
    {
        $this->disconnect();
    }
    protected function connect()
    {
        if ($this->lnk === null) {
            try {
                $this->lnk = new \SQLite3($this->connection['name']);
                $this->lnk->exec('PRAGMA encoding = "'.$this->option('charset', 'utf-8'));
            } catch (\Exception $e) {
                throw new DBException('Connect error: '.$this->lnk->lastErrorMsg());
            }
        }
    }
    protected function disconnect()
    {
        if ($this->lnk !== null) {
            @$this->lnk->close();

It seems like you do not handle an error condition here. This can introduce security issues, and is generally not recommended.

        }
    }
    public function prepare(string $sql) : StatementInterface
    {
        $this->connect();
        $binder = '?';
        if (strpos($sql, $binder) !== false) {
            $tmp = explode($binder, $sql);
            $sql = '';
            foreach ($tmp as $i => $v) {
                $sql .= $v;
                if (isset($tmp[($i + 1)])) {
                    $sql .= ':i'.$i;
                }
            }
        }
        $temp = $this->lnk->prepare($sql);
        if (!$temp) {
            throw new DBException('Could not prepare : '.$this->lnk->lastErrorMsg().' <'.$sql.'>');
        }
        return new Statement($temp, $this->lnk);
    }

    public function begin()
    {
        $this->connect();
        try {
            $this->transaction = true;

The property transaction does not exist. Did you maybe forget to declare it?

            $this->query('BEGIN TRANSACTION');
        } catch (DBException $e) {
            $this->transaction = false;

            return false;
        }

        return true;
    }
    public function commit()
    {
        $this->connect();
        $this->transaction = false;
        try {
            $this->query('COMMIT');
        } catch (DBException $e) {
            return false;
        }

        return true;
    }
    public function rollback()
    {
        $this->connect();
        $this->transaction = false;
        try {
            $this->query('ROLLBACK');
        } catch (DBException $e) {
            return false;
        }

        return true;
    }
    public function isTransaction()
    {
        return $this->transaction;
    }
}