Dazzle\MySQL\Transaction

Complexity

Total Complexity

9

Size/Duplication

Total Lines	119
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	6

Test Coverage

Coverage

0%

Importance

Changes	2
Bugs	0	Features	0

6 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	6	1
A	isOpen()	0	4	1
A	query()	0	22	2
A	execute()	0	6	1
A	commit()	0	22	2
A	rollback()	0	13	2

<?php

namespace Dazzle\MySQL;

use Dazzle\Event\BaseEventEmitter;
use Dazzle\MySQL\Protocol\Command\QueryCommand;
use Dazzle\MySQL\Protocol\CommandInterface;
use Dazzle\MySQL\Protocol\Query;
use Dazzle\MySQL\Protocol\QueryInterface;
use Dazzle\Promise\Promise;
use Dazzle\Promise\PromiseInterface;
use Dazzle\Throwable\Exception\Runtime\ExecutionException;
use SplQueue;

class Transaction extends BaseEventEmitter implements TransactionInterface
{
    /**
     * @var DatabaseInterface
     */
    protected $database;

    /**
     * @var CommandInterface[]
     */
    protected $queue;

    /**
     * @var bool
     */
    protected $open;

    /**
     * @param DatabaseInterface $database
     */
    public function __construct(DatabaseInterface $database)
    {
        $this->database = $database;
        $this->queue = [];
        $this->open = true;
    }

    /**
     * @override
     * @inheritDoc
     */
    public function isOpen()
    {
        return $this->open;
    }

    /**
     * @override
     * @inheritDoc
     */
    public function query($sql, $sqlParams = [])
    {
        if (!$this->isOpen())
        {
            return Promise::doReject(new ExecutionException('This transaction is no longer open.'));
        }

        $promise = new Promise();
        $query   = new Query($sql, $sqlParams);
        $command = new QueryCommand($this->database, $query);

        $this->on('error', function ($trans, $err) use ($promise) {
            return $promise->reject($err);
        });
        $this->on('success', function ($trans) use ($promise, $command) {

The parameter $trans is not used and could be removed.

            return $promise->resolve($command);
        });

        $this->queue[] = $command;

        return $promise;
    }

    /**
     * @override
     * @inheritDoc
     */
    public function execute($sql, $sqlParams = [])
    {
        return $this->query($sql, $sqlParams)->then(function($command) {
            return $command->affectedRows;
        });
    }

    /**
     * @override
     * @inheritDoc
     */
    public function commit()
    {
        if (!$this->isOpen())
        {
            return Promise::doReject(new ExecutionException('This transaction is no longer open.'));
        }

        $promise = new Promise();

        $this->on('error', function ($trans, $err) use ($promise) {
            return $promise->reject($err);
        });
        $this->on('success', function ($trans) use ($promise) {

The parameter $trans is not used and could be removed.

            return $promise->resolve();
        });

        $this->open = false;
        $this->emit('commit', [ $this, $this->queue ]);
        $this->queue = [];

        return $promise;
    }

    /**
     * @override
     * @inheritDoc
     */
    public function rollback()
    {
        if (!$this->isOpen())
        {
            return Promise::doReject(new ExecutionException('This transaction is no longer open.'));
        }

        $this->open = false;
        $this->emit('rollback', [ $this ]);
        $this->queue = [];

        return Promise::doResolve();
    }
}