Kir\MySQL\Builder\QueryStatement

Complexity

Total Complexity

16

Size/Duplication

Total Lines	145
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	3

Importance

Changes	13
Bugs	3	Features	4

11 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	6	1
A	getStatement()	0	3	1
A	setFetchMode()	0	14	3
A	execute()	0	11	2
A	fetchAll()	0	8	2
A	fetch()	0	5	1
A	fetchColumn()	0	5	1
A	closeCursor()	0	5	1
A	columnCount()	0	5	1
A	getColumnMeta()	0	5	1
A	exceptionHandler()	0	7	2

<?php
namespace Kir\MySQL\Builder;

use Kir\MySQL\Databases\MySQL\MySQLExceptionInterpreter;
use Kir\MySQL\Exceptions\SqlException;
use PDO;
use PDOException;
use PDOStatement;
use Kir\MySQL\Database\DatabaseStatement;
use Kir\MySQL\QueryLogger\QueryLoggers;

class QueryStatement implements DatabaseStatement {
	/** @var PDOStatement */
	private $statement;
	/** @var QueryLoggers */
	private $queryLoggers;
	/** @var string */
	private $query;
	/** @var MySQLExceptionInterpreter */
	private $exceptionInterpreter;

	/**
	 * @param PDOStatement $stmt
	 * @param string $query
	 * @param MySQLExceptionInterpreter $exceptionInterpreter
	 * @param QueryLoggers $queryLoggers
	 */
	public function __construct(PDOStatement $stmt, $query, MySQLExceptionInterpreter $exceptionInterpreter, QueryLoggers $queryLoggers) {
		$this->statement = $stmt;
		$this->queryLoggers = $queryLoggers;
		$this->query = $query;
		$this->exceptionInterpreter = $exceptionInterpreter;
	}

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

	/**
	 * @param int $mode
	 * @param mixed $arg0
	 * @param array $arg1
	 * @return $this
	 */
	public function setFetchMode($mode, $arg0 = null, array $arg1 = null) {
		if($arg1 !== null) {
			/** @noinspection PhpMethodParametersCountMismatchInspection */
			$this->statement->setFetchMode($mode, $arg0, $arg1);
			return $this;
		}
		if($arg0 !== null) {
			/** @noinspection PhpMethodParametersCountMismatchInspection */
			$this->statement->setFetchMode($mode, $arg0);
			return $this;
		}
		$this->statement->setFetchMode($mode);
		return $this;
	}

	/**
	 * @param array $params
	 * @throws SqlException
	 * @return $this
	 */
	public function execute(array $params = []) {
		$this->exceptionHandler(function() use ($params) {
			$timer = microtime(true);
			$response = $this->statement->execute($params);
			$this->queryLoggers->log($this->query, microtime(true)-$timer);
			if(!$response) {
				throw new SqlException('Execution returned with "false".');
			}
		});
		return $this;
	}

	/**
	 * @param int $fetchStyle
	 * @param mixed $fetchArgument
	 * @param array $ctorArgs
	 * @return array
	 */
	public function fetchAll($fetchStyle = null, $fetchArgument = null, array $ctorArgs = []) {
		return $this->exceptionHandler(function() use ($fetchStyle, $fetchArgument, $ctorArgs) {
			if($fetchArgument !== null) {
				return $this->statement->fetchAll($fetchStyle, $fetchArgument, $ctorArgs);
			}
			return $this->statement->fetchAll($fetchStyle);
		});
	}

	/**
	 * @param int $fetchStyle
	 * @param int $cursorOrientation
	 * @param int $cursorOffset
	 * @return mixed
	 */
	public function fetch($fetchStyle = null, $cursorOrientation = PDO::FETCH_ORI_NEXT, $cursorOffset = 0) {
		return $this->exceptionHandler(function() use ($fetchStyle, $cursorOrientation, $cursorOffset) {
			return $this->statement->fetch($fetchStyle, $cursorOrientation, $cursorOffset);
		});
	}

	/**
	 * @param int $columnNo
	 * @return mixed
	 */
	public function fetchColumn($columnNo = 0) {
		return $this->exceptionHandler(function() use ($columnNo) {
			return $this->statement->fetchColumn($columnNo);
		});
	}

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

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

	/**
	 * @param int $columnNo
	 * @return array
	 */
	public function getColumnMeta($columnNo) {
		return $this->exceptionHandler(function() use ($columnNo) {
			return $this->statement->getColumnMeta($columnNo);
		});
	}

	/**
	 * @param callable $fn
	 * @return mixed
	 */
	private function exceptionHandler($fn) {
		try {
			return call_user_func($fn);
		} catch (PDOException $e) {
			$this->exceptionInterpreter->throwMoreConcreteException($e);
		}
	}
}