edgardmessias\db\firebird\Connection

Complexity

Total Complexity

10

Size/Duplication

Total Lines	80
Duplicated Lines	0 %

Coupling/Cohesion

Components	2
Dependencies	2

Test Coverage

Coverage

100%

Importance

Changes	1
Bugs	0	Features	0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	getTransaction()	0	4	3
A	beginTransaction()	0	11	2
A	close()	0	7	2
A	init()	0	16	3

<?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;
    
    /**
     * @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;
        }
        
        $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];
        }
    }
}