Kir\MySQL\Builder\Helpers\YieldPolyfillIterator

Complexity

Total Complexity

17

Size/Duplication

Total Lines	114
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	2

Importance

Changes	1
Bugs	0	Features	0

9 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	6	1
A	__destruct()	0	3	1
B	current()	0	20	5
A	next()	0	4	1
A	key()	0	3	1
A	valid()	0	7	2
A	rewind()	0	8	2
A	getStmt()	0	6	2
A	closeCursor()	0	6	2

<?php
namespace Kir\MySQL\Builder\Helpers;

use Closure;
use Iterator;
use Kir\MySQL\Builder\QueryStatement;
use Kir\MySQL\Builder\RunnableSelect;
use PDO;

class YieldPolyfillIterator implements Iterator {
	/** @var RunnableSelect */
	private $select;
	/** @var Closure|null */
	private $callback;
	/** @var bool */
	private $preserveTypes;
	/** @var null */
	private $stmt = null;
	/** @var Closure */
	private $statementFactory;
	/** @var mixed */
	private $currentItem;
	/** @var int */
	private $idx = -1;

	/**
	 * @param RunnableSelect $select
	 * @param Closure|null $callback
	 * @param bool $preserveTypes
	 * @param callable $statementFactory
	 */
	public function __construct(RunnableSelect $select, Closure $callback = null, $preserveTypes, $statementFactory) {
		$this->select = $select;
		$this->callback = $callback;
		$this->preserveTypes = $preserveTypes;
		$this->statementFactory = $statementFactory;

It seems like $statementFactory of type callable is incompatible with the declared type object<Closure> of property $statementFactory.

	}

	/**
	 */
	public function __destruct() {
		$this->closeCursor();
	}

	/**
	 * @return mixed
	 */
	public function current() {
		$row = $this->currentItem;
		if($this->preserveTypes) {
			$columnDefinitions = FieldTypeProvider::getFieldTypes($this->getStmt());

It seems like $this->getStmt() can be null; however, getFieldTypes() does not accept null, maybe add an additional type check?

			$row = FieldValueConverter::convertValues($row, $columnDefinitions);
		}
		$callback = $this->callback;
		if($callback !== null) {
			$result = $callback($row);
			if($result instanceof DBIgnoreRow) {

This if statement is empty and can be removed.

				// Do nothing in this case
			} elseif($result !== null) {
				return $result;
			} else {
				return $row;
			}
		} else {
			return $row;
		}
	}

	/**
	 */
	public function next() {
		$this->idx++;
		$this->currentItem = $this->getStmt()->fetch(PDO::FETCH_ASSOC);
	}

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

	/**
	 * @return boolean
	 */
	public function valid() {
		$result = !!$this->currentItem;
		if(!$result) {
			$this->closeCursor();
		}
		return $result;
	}

	/**
	 */
	public function rewind() {
		if($this->stmt !== null) {
			throw new \Exception("It's not possible to rewind this iterator");
		}
		$this->stmt = call_user_func($this->statementFactory);
		$this->idx = -1;
		$this->next();
	}

	/**
	 * @return QueryStatement
	 */
	private function getStmt() {
		if($this->stmt === null) {
			$this->rewind();
		}
		return $this->stmt;
	}

	/**
	 */
	private function closeCursor() {
		if($this->stmt instanceof QueryStatement) {
			$this->stmt->closeCursor();
		}
		$this->stmt = null;
	}
}