Quantum\Libraries\Database\Traits\TransactionTrait

Complexity

Total Complexity

7

Size/Duplication

Total Lines	67
Duplicated Lines	0 %

Importance

Changes	1
Bugs	0	Features	0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	beginTransaction()	0	3	1
A	rollback()	0	3	1
A	transaction()	0	11	2
A	resolveTransaction()	0	9	2
A	commit()	0	3	1

<?php

namespace Quantum\Libraries\Database\Traits;

use Quantum\Libraries\Database\Exceptions\DatabaseException;
use Quantum\App\Exceptions\BaseException;
use Throwable;

/**
 * Trait TransactionTrait
 * @package Quantum\Libraries\Database
 */
trait TransactionTrait
{

    /**
     * Begins a transaction
     * @throws BaseException
     */
    public static function beginTransaction(): void
    {
        self::resolveTransaction(__FUNCTION__);
    }

    /**
     * Commits a transaction
     * @throws BaseException
     * @throws DatabaseException
     */
    public static function commit(): void
    {
        self::resolveTransaction(__FUNCTION__);
    }

    /**
     * Rolls back a transaction
     * @throws BaseException
     */
    public static function rollback(): void
    {
        self::resolveTransaction(__FUNCTION__);
    }

    /**
     * Resolves the transaction method call
     * @param string $method
     * @return mixed
     * @throws BaseException
     */
    protected static function resolveTransaction(string $method)
    {
        $db = self::getInstance()->getOrmClass();

        if (!method_exists($db, $method)) {
            throw DatabaseException::methodNotSupported($method, __CLASS__);
        }

        return $db::$method();
    }

    /**
     * Transaction wrapper using a closure
     * @param callable $callback
     * @return mixed
     * @throws BaseException
     * @throws DatabaseException
     * @throws Throwable
     */
    public static function transaction(callable $callback)
    {
        self::beginTransaction();

        try {
            $result = $callback();
            self::commit();
            return $result;
        } catch (Throwable $e) {
            self::rollback();
            throw $e;
        }
    }
}