edgardmessias\db\firebird\Connection

Complexity

Total Complexity

15

Size/Duplication

Total Lines	130
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	2

Test Coverage

Coverage

100%

Importance

Changes

0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	getTransaction()	0	4	3
A	beginTransaction()	0	11	2
A	close()	0	7	2
C	init()	0	32	7
A	__clone()	0	6	1

<?php
/**
 * @link http://www.yiiframework.com/
 * @copyright Copyright (c) 2008 Yii Software LLC
 * @license http://www.yiiframework.com/license/
 */

namespace edgardmessias\db\firebird;

/**
 *
 * @author Edgard Lorraine Messias <edgardmessias@gmail.com>
 * @since 2.0
 */
class Connection extends \yii\db\Connection
{
    /**
     * Firebird server version
     */
    public $firebird_version = null;
    
    /**
     * @see https://www.firebirdsql.org/file/documentation/release_notes/html/en/3_0/rnfb30-ddl-enhance.html#rnfb30-ddl-identity
     * @var boolean|null
     */
    public $supportColumnIdentity = null;
    
    /**
     * @see https://firebirdsql.org/file/documentation/reference_manuals/fblangref25-en/html/fblangref25-dml-insert.html#fblangref25-dml-insert-select-unstable
     * @var boolean|null
     */
    public $supportStableCursor = null;
    
    /**
     * @see https://bugs.php.net/bug.php?id=72931
     * @var boolean|null
     */
    public $supportReturningInsert = null;
    
    /**
     * @see https://bugs.php.net/bug.php?id=61183
     * @var boolean|null
     */
    public $supportBlobDataType = null;
    
    /**
     * @inheritdoc
     */
    public $schemaMap = [
        'firebird' => 'edgardmessias\db\firebird\Schema', // Firebird
    ];

    /**
     * @inheritdoc
     */
    public $pdoClass = 'edgardmessias\db\firebird\PdoAdapter';

    /**
     * @inheritdoc
     */
    public $commandClass = 'edgardmessias\db\firebird\Command';
    /**
     * @var Transaction the currently active transaction
     */
    private $_transaction;

    /**
     * Returns the currently active transaction.
     * @return Transaction the currently active transaction. Null if no active transaction.
     */
    public function getTransaction()
    {
        return $this->_transaction && $this->_transaction->getIsActive() ? $this->_transaction : null;
    }

    /**
     * Starts a transaction.
     * @param string|null $isolationLevel The isolation level to use for this transaction.
     * See [[Transaction::begin()]] for details.
     * @return Transaction the transaction initiated
     */
    public function beginTransaction($isolationLevel = null)
    {
        $this->open();

        if (($transaction = $this->getTransaction()) === null) {
            $transaction = $this->_transaction = new Transaction(['db' => $this]);
        }
        $transaction->begin($isolationLevel);

        return $transaction;
    }

    public function close()
    {
        if ($this->pdo !== null) {
            $this->_transaction = null;
        }
        parent::close();
    }

    public function init()
    {
        parent::init();
        
        if ($this->firebird_version) {
            return;
        }

        try {
            $pdo = $this->createPdoInstance();

            $server_version = $pdo->getAttribute(\PDO::ATTR_SERVER_VERSION);

            if (preg_match('/\w{2}-[TV](\d+\.\d+\.\d+).*remote server/', $server_version, $matches)) {
                $this->firebird_version = $matches[1];
            }
        } catch (\Exception $ex) {

Consider adding a comment why this CATCH block is empty.

        }
        
        $supports = [
            'supportColumnIdentity' => version_compare($this->firebird_version, '3.0.0', '>='),
            'supportStableCursor' => version_compare($this->firebird_version, '3.0.0', '>='),
            'supportReturningInsert' => version_compare($this->firebird_version, '3.0.0', '<') || version_compare(phpversion('pdo_firebird'), '7.0.15', '>='),
            'supportBlobDataType' => version_compare(phpversion('pdo_firebird'), '7.0.13', '>'),
        ];
        
        foreach ($supports as $key => $value) {
            if ($this->{$key} === null) {
                $this->{$key} = $value;
            }
        }
    }

    /**
     * Reset the connection after cloning.
     */
    public function __clone()
    {
        parent::__clone();

        $this->_transaction = null;
    }
}