Mathielen\DataImport\Reader\DbalReader

Complexity

Total Complexity

24

Size/Duplication

Total Lines	210
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	2

Test Coverage

Coverage

0%

Importance

Changes

0

14 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	6	1
A	setRowCountCalculated()	0	6	1
A	isRowCountCalculated()	0	4	1
A	getFields()	0	11	3
A	setSql()	0	8	1
A	setSqlParameters()	0	9	1
A	current()	0	8	2
A	next()	0	5	1
A	key()	0	4	1
A	valid()	0	8	2
A	rewind()	0	11	3
A	count()	0	15	4
A	doCalcRowCount()	0	7	1
A	prepare()	0	9	2

<?php

namespace Mathielen\DataImport\Reader;

use Ddeboer\DataImport\Reader\CountableReaderInterface;
use Doctrine\DBAL\Connection;
use Doctrine\DBAL\Statement;

class DbalReader implements CountableReaderInterface
{
    /** @var Connection */
    private $connection;

    private $data;

    /** @var Statement */
    private $stmt;

    /** @var string */
    private $sql;
    /** @var array */
    private $params;

    /** @var integer */
    private $rowCount;
    /** @var bool */
    private $rowCountCalculated = true;

    private $key;

    /**
     * Constructor
     *
     * @param Connection $connection Database connection
     * @param string     $sql        SQL statement
     * @param array      $params     SQL statement parameters
     */
    public function __construct(Connection $connection, $sql, array $params = array())
    {
        $this->connection = $connection;

        $this->setSql($sql, $params);
    }

    /**
     * Do calculate row count?
     *
     * @param bool $calculate
     *
     * @return $this
     */
    public function setRowCountCalculated($calculate = true)
    {
        $this->rowCountCalculated = (bool) $calculate;

        return $this;
    }

    /**
     * Is row count calculated?
     *
     * @return bool
     */
    public function isRowCountCalculated()
    {
        return $this->rowCountCalculated;
    }

    /**
     * {@inheritdoc}
     */
    public function getFields()
    {
        if (null === $this->data) {
            $this->rewind();
        }
        if (false === $this->data) {
            return array();
        }

        return array_keys((array) $this->data);
    }

    /**
     * Set Query string with Parameters
     *
     * @param string $sql
     * @param array  $params
     *
     * @return $this
     */
    public function setSql($sql, array $params = array())
    {
        $this->sql = (string) $sql;

        $this->setSqlParameters($params);

        return $this;
    }

    /**
     * Set SQL parameters
     *
     * @param array  $params
     *
     * @return $this
     */
    public function setSqlParameters(array $params)
    {
        $this->params = $params;

        $this->stmt = null;
        $this->rowCount = null;

        return $this;
    }

    /**
     * {@inheritdoc}
     */
    public function current()
    {
        if (null === $this->data) {
            $this->rewind();
        }

        return $this->data;
    }

    /**
     * {@inheritdoc}
     */
    public function next()
    {
        $this->key++;
        $this->data = $this->stmt->fetch(\PDO::FETCH_ASSOC);

The method Doctrine\DBAL\Statement::fetch() has been deprecated with message: Use fetchNumeric(), fetchAssociative() or fetchOne() instead.

    }

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

    /**
     * {@inheritdoc}
     */
    public function valid()
    {
        if (null === $this->data) {
            $this->rewind();
        }

        return (false !== $this->data);
    }

    /**
     * {@inheritdoc}
     */
    public function rewind()
    {
        if (null === $this->stmt) {
            $this->stmt = $this->prepare($this->sql, $this->params);
        }
        if (0 !== $this->key) {
            $this->stmt->execute();
            $this->data = $this->stmt->fetch(\PDO::FETCH_ASSOC);

The method Doctrine\DBAL\Statement::fetch() has been deprecated with message: Use fetchNumeric(), fetchAssociative() or fetchOne() instead.

            $this->key = 0;
        }
    }

    /**
     * {@inheritdoc}
     */
    public function count()
    {
        if (null === $this->rowCount) {
            if ($this->rowCountCalculated) {
                $this->doCalcRowCount();
            } else {
                if (null === $this->stmt) {
                    $this->rewind();
                }
                $this->rowCount = $this->stmt->rowCount();
            }
        }

        return $this->rowCount;
    }

    private function doCalcRowCount()
    {
        $statement = $this->prepare('SELECT COUNT(*) FROM ('.$this->sql.') AS cnt', $this->params);
        $statement->execute();

        $this->rowCount = (int) $statement->fetchColumn(0);

The method Doctrine\DBAL\Statement::fetchColumn() has been deprecated with message: Use fetchOne() instead.

    }

    /**
     * Prepare given statement
     *
     * @param string $sql
     * @param array  $params
     *
     * @return Statement
     */
    private function prepare($sql, array $params)
    {
        $statement = $this->connection->prepare($sql);
        foreach ($params as $key => $value) {
            $statement->bindValue($key, $value);
        }

        return $statement;
    }
}