Ez\DbLinker\Driver\Connection\RetryStatement

Complexity

Total Complexity

14

Size/Duplication

Total Lines	124
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	2

Importance

Changes	3
Bugs	0	Features	1

14 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	6	1
A	execute()	0	6	1
A	bindParam()	0	4	1
A	bindValue()	0	4	1
A	fetch()	0	4	1
A	fetchAll()	0	4	1
A	fetchColumn()	0	4	1
A	errorCode()	0	4	1
A	errorInfo()	0	4	1
A	closeCursor()	0	4	1
A	rowCount()	0	4	1
A	columnCount()	0	4	1
A	setFetchMode()	0	4	1
A	getIterator()	0	4	1

<?php

namespace Ez\DbLinker\Driver\Connection;

use IteratorAggregate;
use Doctrine\DBAL\Driver\Statement;
use Ez\DbLinker\RetryStrategy;

class RetryStatement implements IteratorAggregate, Statement
{
    private $statement;
    private $retryConnection;
    private $retryStrategy;

    use CallAndRetry;

    /**
     * @param Statement $statement
     */
    public function __construct(Statement $statement, RetryConnection $retryConnection, RetryStrategy $retryStrategy)
    {
        $this->statement       = $statement;
        $this->retryConnection = $retryConnection;
        $this->retryStrategy   = $retryStrategy;
    }

    /**
     * {@inheritdoc}
     */
    public function execute($params = NULL)
    {
        return (bool)$this->callAndRetry(function () use ($params) {
            return $this->statement->execute($params);
        }, $this->retryStrategy, $this->retryConnection);
    }

    /**
     * {@inheritdoc}
     */
    public function bindParam($column, &$variable, $type = null, $length = null)
    {
        return $this->statement->bindParam($column, $variable, $type, $length);
    }

    /**
     * {@inheritdoc}
     */
    public function bindValue($param, $value, $type = null)
    {
        return $this->statement->bindValue($param, $value, $type);
    }

    /**
     * {@inheritdoc}
     */
    public function fetch($fetchMode = null)
    {
        return $this->statement->fetch($fetchMode);
    }

    /**
     * {@inheritdoc}
     */
    public function fetchAll($fetchMode = null)
    {
        return $this->statement->fetchAll($fetchMode);
    }

    /**
     * {@inheritdoc}
     */
    public function fetchColumn($columnIndex = 0)
    {
        return $this->statement->fetchColumn($columnIndex);
    }

    /**
     * {@inheritdoc}
     */
    public function errorCode()
    {
        return $this->statement->errorCode();
    }

    /**
     * {@inheritdoc}
     */
    public function errorInfo()
    {
        return $this->statement->errorInfo();
    }

    /**
     * {@inheritdoc}
     */
    public function closeCursor()
    {
        return $this->statement->closeCursor();
    }

    /**
     * {@inheritdoc}
     */
    public function rowCount()
    {
        return $this->statement->rowCount();
    }

    /**
     * {@inheritdoc}
     */
    public function columnCount()
    {
        return $this->statement->columnCount();
    }

    /**
     * {@inheritdoc}
     */
    public function setFetchMode($fetchMode, $arg2 = null, $arg3 = null)
    {
        return $this->statement->setFetchMode($fetchMode, $arg2, $arg3);
    }

    /**
     * {@inheritdoc}
     */
    public function getIterator()
    {
        return $this->statement;
    }
}