miBadger\Query\Query

Complexity

Total Complexity

21

Size/Duplication

Total Lines	203
Duplicated Lines	13.3 %

Coupling/Cohesion

Components	1
Dependencies	2

Test Coverage

Coverage

95.83%

Importance

Changes	4
Bugs	0	Features	3

14 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	6	1
A	__toString()	0	4	1
A	select()	0	6	1
A	insert()	0	6	1
A	update()	0	6	1
A	delete()	0	6	1
A	where()	0	13	2
A	whereIn()	14	14	2
A	groupBy()	0	6	1
A	orderBy()	0	6	1
A	limit()	0	7	1
A	offset()	0	7	1
B	execute()	0	22	5
A	replaceValuesWithBindings()	13	13	2

<?php

/**
 * This file is part of the miBadger package.
 *
 * @author Michael Webbers <michael@webbers.io>
 * @license http://opensource.org/licenses/Apache-2.0 Apache v2 License
 * @version 1.0.0
 */

namespace miBadger\Query;

/**
 * The query class.
 *
 * @since 1.0.0
 */
class Query implements QueryInterface
{
	/* @var \PDO The PDO. */
	private $pdo;

	/* @var array The bindings. */
	private $bindings;

	/* @var QueryBuilder The query builder. */
	private $queryBuilder;

	/**
	 * Construct a query object with the given pdo and table.
	 *
	 * @param \PDO $pdo
	 * @param string $table
	 */
	public function __construct(\PDO $pdo, $table)
	{
		$this->pdo = $pdo;
		$this->bindings = [];
		$this->queryBuilder = new QueryBuilder($table);
	}

	/**
	 * Returns a string representation of the query object.
	 *
	 * @return string a string representation of the query object.
	 */
	public function __toString()
	{
		return $this->queryBuilder->__toString();
	}

	/**
	 * {@inheritdoc}
	 */
	public function select($columns = ['*'])
	{
		$this->queryBuilder->select($columns);

		return $this;
	}

	/**
	 * {@inheritdoc}
	 */
	public function insert(array $values)
	{
		$this->queryBuilder->insert($this->replaceValuesWithBindings($values));

		return $this;
	}

	/**
	 * {@inheritdoc}
	 */
	public function update(array $values)
	{
		$this->queryBuilder->update($this->replaceValuesWithBindings($values));

		return $this;
	}

	/**
	 * {@inheritdoc}
	 */
	public function delete()
	{
		$this->queryBuilder->delete();

		return $this;
	}

	/**
	 * {@inheritdoc}
	 */
	public function where($column, $operator, $value)
	{
		$binding = sprintf(':%s', $column);

		if ($operator == 'IN') {
			$this->whereIn($column, $value);
		} else {
			$this->bindings[$binding] = $value;
			$this->queryBuilder->where($column, $operator, $binding);
		}

		return $this;
	}

	/**
	 * Set an additional where in condition.
	 *
	 * @param string $column
	 * @param mixed $values
	 * @return $this
	 */
	private function whereIn($column, $values)

This method seems to be duplicated in your project.

	{
		$bindings = [];

		foreach ($values as $key => $value) {
			$bindings[] = $binding = sprintf(':%s%s', $column, $key);

			$this->bindings[$binding] = $value;
		}

		$this->queryBuilder->where($column, 'IN', $bindings);

		return $this;
	}

	/**
	 * {@inheritdoc}
	 */
	public function groupBy($column)
	{
		$this->queryBuilder->groupBy($column);

		return $this;
	}

	/**
	 * {@inheritdoc}
	 */
	public function orderBy($column, $order = null)
	{
		$this->queryBuilder->orderBy($column, $order);

		return $this;
	}

	/**
	 * {@inheritdoc}
	 */
	public function limit($limit)
	{
		$this->bindings[':limit'] = (int) $limit;
		$this->queryBuilder->limit(':limit');

		return $this;
	}

	/**
	 * {@inheritdoc}
	 */
	public function offset($offset)
	{
		$this->bindings[':offset'] = (int) $offset;
		$this->queryBuilder->offset(':offset');

		return $this;
	}

	/**
	 * Returns the result of the executed prepared query.
	 *
	 * @return QueryResult the result of the executed prepared query.
	 */
	public function execute()
	{
		$pdoStatement = $this->pdo->prepare((string) $this);

		foreach ($this->bindings as $key => $value) {
			if (is_bool($value)) {
				$type = \PDO::PARAM_BOOL;
			} elseif (is_null($value)) {
				$type = \PDO::PARAM_NULL;
			} elseif (is_int($value)) {
				$type = \PDO::PARAM_INT;
			} else {
				$type = \PDO::PARAM_STR;
			}

			$pdoStatement->bindValue($key, $value, $type);
		}

		$pdoStatement->execute();

		return new QueryResult($pdoStatement);
	}

	/**
	 * Returns the values array with bindings instead of values.
	 *
	 * @param array $values
	 * @return array the values array with bindings instead of values.
	 */
	private function replaceValuesWithBindings(array $values)

This method seems to be duplicated in your project.

	{
		$result = [];

		foreach ($values as $key => $value) {
			$binding = sprintf(':%s', $key);

			$this->bindings[$binding] = $value;
			$result[$key] = $binding;
		}

		return $result;
	}
}