vakata\database\driver\odbc\Driver

Complexity

Total Complexity

16

Size/Duplication

Total Lines	78
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	3

Importance

Changes

0

9 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	15	2
A	__destruct()	0	4	1
B	connect()	0	14	6
A	disconnect()	0	6	2
A	prepare()	0	5	1
A	begin()	0	7	1
A	commit()	0	8	1
A	rollback()	0	8	1
A	isTransaction()	0	4	1

<?php

namespace vakata\database\driver\odbc;

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 $lnk = null;
    protected $transaction = false;

    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']);
        $temp = $temp[0];
        if (strpos($temp, '@') !== false) {
            $temp = array_pad(explode('@', $temp, 2), 2, '');
            list($connection['user'], $connection['pass']) = array_pad(explode(':', $temp[0], 2), 2, '');
            $temp = $temp[1];
        }
        $connection['dsn'] = $temp;
        $this->connection = $connection;
    }
    public function __destruct()
    {
        $this->disconnect();
    }
    protected function connect()
    {
        if ($this->lnk === null) {
            $this->lnk = call_user_func(
                $this->option('persist') ? '\odbc_pconnect' : '\odbc_connect',
                $this->connection['dsn'],
                isset($this->connection['user']) ? $this->connection['user'] : '',
                isset($this->connection['pass']) ? $this->connection['pass'] : ''
            );
            if ($this->lnk === false) {
                throw new DBException('Connect error');
            }
        }
    }
    protected function disconnect()
    {
        if (is_resource($this->lnk)) {
            \odbc_close($this->lnk);
        }
    }
    public function prepare(string $sql) : StatementInterface
    {
        $this->connect();
        return new Statement($sql, $this->lnk);
    }

    public function begin() : bool
    {
        $this->connect();
        $this->transaction = true;
        \odbc_autocommit($this->lnk, false);
        return true;
    }
    public function commit() : bool
    {
        $this->connect();
        $this->transaction = false;
        $res = \odbc_commit($this->lnk);
        \odbc_autocommit($this->lnk, false);
        return $res;
    }
    public function rollback() : bool
    {
        $this->connect();
        $this->transaction = false;
        $res = \odbc_rollback($this->lnk);
        \odbc_autocommit($this->lnk, false);
        return $res;
    }
    public function isTransaction()
    {
        return $this->transaction;
    }
}