WebStream\Database\Driver\DatabaseDriver

Complexity

Total Complexity

18

Size/Duplication

Total Lines	131
Duplicated Lines	0 %

Importance

Changes

0

12 Methods

Rating	Name	Duplication	Size	Complexity
A	disconnect()	0	6	2
A	getStatement()	0	3	2
A	rollback()	0	4	2
A	inTransaction()	0	3	2
A	getTransactionIsolation()	0	3	1
A	isConnected()	0	3	1
A	commit()	0	4	2
A	__destruct()	0	2	1
A	beginTransaction()	0	9	2
A	__construct()	0	3	1
A	setTransactionIsolation()	0	3	1
A	getConnection()	0	3	1

<?php
namespace WebStream\Database\Driver;

use WebStream\DI\Injector;

The type WebStream\DI\Injector was not found. Maybe you did not declare it correctly or list all dependencies?

use WebStream\Container\Container;

The type WebStream\Container\Container was not found. Maybe you did not declare it correctly or list all dependencies?

use Doctrine\DBAL\Connection;

The type Doctrine\DBAL\Connection was not found. Maybe you did not declare it correctly or list all dependencies?

/**
 * DatabaseDriver
 * @author Ryuichi TANAKA.
 * @since 2013/12/07
 * @version 0.4
 */
abstract class DatabaseDriver
{
    use Injector;

    /**
     * @var object DBオブジェクト
     */
    protected $connection;

    /**
     * @var Container DB接続設定
     */
    protected $config;

    /**
     * constructor
     */
    public function __construct(Container $config)
    {
        $this->config = $config;
    }

    /**
     * destructor
     */
    public function __destruct()
    {
        // $this->logger->debug("Release driver: " . get_class($this));
    }

    /**
     * 接続する
     */
    abstract public function connect();

    /**
     * 切断する
     */
    public function disconnect()
    {
        if ($this->connection !== null) {
            $this->logger->debug("Database disconnect.");
            $this->connection->close();
            $this->connection = null;
        }
    }

    /**
     * トランザクションを開始する
     * @return boolean トランザクション開始結果
     */
    public function beginTransaction()
    {
        $inTransaction = false;
        if ($this->connection !== null) {
            $this->connection->beginTransaction();
            $inTransaction = $this->inTransaction();
        }

        return $inTransaction;
    }

    /**
     * コミットする
     */
    public function commit()
    {
        if ($this->connection !== null) {
            $this->connection->commit();
        }
    }

    /**
     * ロールバックする
     */
    public function rollback()
    {
        if ($this->inTransaction()) {
            $this->connection->rollback();
        }
    }

    /**
     * DB接続されているか
     * @param boolean 接続有無
     */

The doc comment 接続有無 at position 0 could not be parsed: Unknown type name '接続有無' at position 0 in 接続有無.

    public function isConnected()
    {
        return $this->connection !== null;
    }

    /**
     * トランザクション内かどうか
     * @return boolean トランザクション内かどうか
     */
    public function inTransaction()
    {
        return $this->connection !== null ? $this->connection->isTransactionActive() : false;
    }

    /**
     * SQLをセットしてステートメントを返却する
     * @param string SQL
     * @return object ステートメント
     */
    public function getStatement($sql)
    {
        return $this->connection !== null ? $this->connection->prepare($sql) : null;
    }

    /**
     * トランザクション分離レベルを返却する
     * @return int トランザクション分離レベル
     */
    public function getTransactionIsolation()
    {
        return $this->connection->getTransactionIsolation();
    }

    /**
     * トランザクション分離レベルを設定する
     * @param int $isolationLevel トランザクション分離レベル
     */
    public function setTransactionIsolation(int $isolationLevel)
    {
        $this->connection->setTransactionIsolation($isolationLevel);
    }

    public function getConnection()
    {
        return $this->connection;
    }
}