Dazzle\MySQL\Transaction

Complexity

Total Complexity

8

Size/Duplication

Total Lines	97
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	5

Test Coverage

Coverage

0%

Importance

Changes

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	9	2
A	commit()	0	5	1
A	rollback()	0	5	1

<?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\Throwable\Exception\Runtime\ExecutionException;

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

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

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

    /**
     * @param DatabaseInterface $database
     */
    public function __construct(DatabaseInterface $database)
    {
        $this->database = $database;
        $this->commands = [];
        $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);

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

        $this->commands[] = $command;

        return $promise;
    }

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

        // TODO: Implement execute() method.
    }

    /**
     * @override
     * @inheritDoc
     */
    public function commit()
    {
        $this->open = false;
        $this->emit('commit');
    }

    /**
     * @override
     * @inheritDoc
     */
    public function rollback()
    {
        $this->open = false;
        $this->emit('rollback');
    }
}