DatabaseTransactionsTrait.php

Go to the documentation of this file.

<?php
 
namespace Ubiquity\db\traits;
 
use Ubiquity\exceptions\DBException;
use Ubiquity\log\Logger;
 
class DatabaseTransactionsTrait {
    protected $transactionLevel = 0;
 
    protected function nestable() {
        return $this->wrapperObject->nestable ();
    }
 
    public function beginTransaction() {
        if ($this->transactionLevel == 0 || ! $this->nestable ()) {
            $ret = $this->wrapperObject->beginTransaction ();
            Logger::info ( 'Transactions', 'Start transaction', 'beginTransaction' );
            $this->transactionLevel ++;
            return $ret;
        }
        $this->wrapperObject->savePoint ( $this->transactionLevel );
        Logger::info ( 'Transactions', 'Savepoint level', 'beginTransaction', $this->transactionLevel );
        $this->transactionLevel ++;
        return true;
    }
 
    public function commit() {
        $this->transactionLevel --;
        if ($this->transactionLevel == 0 || ! $this->nestable ()) {
            Logger::info ( 'Transactions', 'Commit transaction', 'commit' );
            return $this->wrapperObject->commit ();
        }
        $this->wrapperObject->releasePoint ( $this->transactionLevel );
        Logger::info ( 'Transactions', 'Release savepoint level', 'commit', $this->transactionLevel );
        return true;
    }
 
    public function commitToLevel($transactionLevel) {
        $res = true;
        while ( $res && $this->transactionLevel > $transactionLevel ) {
            $res = $this->commit ();
        }
        return $res;
    }
 
    public function commitAll() {
        return $this->commitToLevel ( 0 );
    }
 
    public function rollBack() {
        $this->transactionLevel --;
        if ($this->transactionLevel == 0 || ! $this->nestable ()) {
            Logger::info ( 'Transactions', 'Rollback transaction', 'rollBack' );
            return $this->wrapperObject->rollBack ();
        }
        $this->wrapperObject->rollbackPoint ( $this->transactionLevel );
        Logger::info ( 'Transactions', 'Rollback to savepoint level', 'rollBack', $this->transactionLevel );
        return true;
    }
 
    public function rollBackToLevel($transactionLevel) {
        $res = true;
        while ( $res && $this->transactionLevel > $transactionLevel ) {
            $res = $this->rollBack ();
        }
        return $res;
    }
 
    public function rollBackAll() {
        return $this->rollBackToLevel ( 0 );
    }
 
    public function inTransaction() {
        return $this->wrapperObject->inTransaction ();
    }
 
    public function callInTransaction($callback, ...$parameters) {
        if ($this->beginTransaction ()) {
            try {
                $ret = call_user_func_array ( $callback, $parameters );
            } catch ( \Exception $e ) {
                $this->wrapperObject->rollBack ();
                throw $e;
            }
 
            if ($ret) {
                if (! $this->commit ()) {
                    throw new DBException ( 'Transaction was not committed.' );
                }
            } else {
                $this->rollBack ();
            }
 
            return $ret;
        }
        throw new DBException ( 'Transaction was not started.' );
    }
 
    public function setIsolationLevel($isolationLevel) {
        return $this->wrapperObject->setIsolationLevel($isolationLevel);
    }
}