vakata\database\driver\ibase\Driver

Complexity

Total Complexity

23

Size/Duplication

Total Lines	92
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	3

Importance

Changes

0

9 Methods

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

<?php

namespace vakata\database\driver\ibase;

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

    public function __construct(array $connection)
    {
        $this->connection = $connection;
        if (!is_file($connection['name']) && is_file('/'.$connection['name'])) {
            $this->connection['name'] = '/'.$connection['name'];
        }
        $this->connection['host'] = ($connection['host'] === 'localhost' || $connection['host'] === '') ?
                '' : $connection['host'].':';
    }
    public function __destruct()
    {
        $this->disconnect();
    }
    protected function connect()
    {
        $this->lnk = call_user_func(
            $this->option('persist') ? '\ibase_pconnect' : '\ibase_connect',
            $this->connection['host'].$this->connection['name'],
            $this->connection['user'],
            $this->connection['pass'],
            strtoupper($this->option('charset', 'utf8'))
        );
        if ($this->lnk === false) {
            throw new DBException('Connect error: '.\ibase_errmsg());
        }
    }
    protected function disconnect()
    {
        if (is_resource($this->lnk)) {
            \ibase_close($this->lnk);
        }
    }
    public function prepare(string $sql) : StatementInterface
    {
        $this->connect();
        $statement = \ibase_prepare($this->transaction !== null ? $this->transaction : $this->lnk, $sql);
        if ($statement === false) {
            throw new DBException('Prepare error: ' . \ibase_errmsg());
        }
        return new Statement(
            $statement,
            $this->lnk
        );
    }

    public function begin() : bool
    {
        $this->connect();
        $this->transaction = \ibase_trans($this->lnk);
        if ($this->transaction === false) {
            $this->transaction === null;
        }
        return ($this->transaction !== null);
    }
    public function commit() : bool
    {
        $this->connect();
        if ($this->transaction === null) {
            return false;
        }
        if (!\ibase_commit($this->transaction)) {
            return false;
        }
        $this->transaction = null;

        return true;
    }
    public function rollback() : bool
    {
        $this->connect();
        if ($this->transaction === null) {
            return false;
        }
        if (!\ibase_rollback($this->transaction)) {
            return false;
        }
        $this->transaction = null;

        return true;
    }

    public function isTransaction()
    {
        return $this->transaction !== null;
    }
}