League\Database\Driver\TransactionPDO

Complexity

Total Complexity

11

Size/Duplication

Total Lines	75
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	0

Importance

Changes

0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	hasSavepoint()	0	4	1
A	beginTransaction()	0	10	3
A	commit()	0	10	3
A	rollBack()	0	14	4

<?php

namespace League\Database\Driver;

use PDO;
use PDOException;

class TransactionPDO extends PDO
{
    /**
     * @var array   Database drivers that support SAVEPOINT * statements.
     */
    protected static $supportedDrivers = ['pgsql', 'mysql'];

    /**
     * @var int     Current transaction depth
     */
    protected $transactionDepth = 0;

    /**
     * Test if database driver support savepoints
     *
     * @return bool
     */
    protected function hasSavepoint() : bool
    {
        return in_array($this->getAttribute(PDO::ATTR_DRIVER_NAME), self::$supportedDrivers, true);
    }

    /**
     * Start transaction
     *
     * @return bool|void
     */
    public function beginTransaction()
    {
        if ($this->transactionDepth == 0 || !$this->hasSavepoint()) {
            parent::beginTransaction();
        } else {
            $this->exec("SAVEPOINT LEVEL{$this->transactionDepth}");
        }

        $this->transactionDepth++;
    }

    /**
     * Commit current transaction
     *
     * @return bool|void
     */
    public function commit()
    {
        $this->transactionDepth--;

        if ($this->transactionDepth == 0 || !$this->hasSavepoint()) {
            parent::commit();
        } else {
            $this->exec("RELEASE SAVEPOINT LEVEL{$this->transactionDepth}");
        }
    }

    /**
     * Rollback current transaction
     *
     * @throws \PDOException    if there is no transaction started
     * @return bool|void
     */
    public function rollBack()
    {
        if ($this->transactionDepth == 0) {
            throw new PDOException('Rollback error : There is no transaction started');
        }

        $this->transactionDepth--;

        if ($this->transactionDepth == 0 || !$this->hasSavepoint()) {
            parent::rollBack();
        } else {
            $this->exec("ROLLBACK TO SAVEPOINT LEVEL{$this->transactionDepth}");
        }
    }
}