MocOrm\Support\Transaction

Complexity

Total Complexity

8

Size/Duplication

Total Lines	81
Duplicated Lines	0 %

Test Coverage

Coverage

0%

Importance

Changes

0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	getError()	0	3	1
A	getConnection()	0	3	1
A	getResults()	0	3	1
A	hasError()	0	3	1
A	__construct()	0	18	4

<?php

namespace MocOrm\Support;

use MocOrm\Connection\ConnectionManager;

/**
 * Implementation.
 */
class Transaction
{
    /**
     * Current transaction's database.
     * @var string
     */
    protected $db;

    /**
     * Transaction result.
     * @var array
     */
    protected $results;

    /**
     * SQL Query error.
     * @var mixed
     */
    protected $error;


    /**
     * Transacion
     * Responsible to holds transaction behave.
     * @param mixed $closure
     */
    public function __construct($closure = null)
    {
        if (is_callable($closure)) {
            $connection = $this->getConnection();
            try {
                $connection->beginTransaction();
                $this->results = $closure($connection);
                if ($this->results === false) {
                    $connection->rollbackTransaction();
                } else {
                    $connection->commitTransaction();
                }
            } catch (\Exception $e) {
                $connection->rollbackTransaction();
                $this->error = $e;
            }
        }
        return $this;
    }

    /**
     * Gets current connection.
     * @param  string $name
     * @return \Connection

The type Connection was not found. Maybe you did not declare it correctly or list all dependencies?

     */
    public function getConnection($name = null)

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

    {
        return ConnectionManager::initialize()->current();

The expression return MocOrm\Connection\ConnectionManager::initialize()->current() returns the type MocOrm\Connection\Connection which is incompatible with the documented return type Connection.

    }

    /**
     * Gets query results.
     * @return array
     */
    public function getResults()
    {
        return $this->results;
    }

    /**
     * Gets transacion's error.
     * @return mixed
     */
    public function getError()
    {
        return $this->error;
    }

    /**
     * Checks if transacion has error.
     * @return boolean
     */
    public function hasError()
    {
        return isset($this->error);
    }
}