Query::__construct() - Code Metrics - Inspection of "Merge branch 'develop'" - miBadger/miBadger.Query - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Push — master ( 788af5...0bf223 )

by Michael

created 2016-08-18 06:33 UTC

Query::__construct() A

↳ Parent: Query

Complexity

Conditions	1
Paths	1

Size

Total Lines	6
Code Lines	4

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	5
CRAP Score	1

Importance

Changes	1
Bugs	0	Features	1

Metric	Value
c	1
b	0
f	1
dl	0
loc	6
ccs	5
cts	5
cp	1
rs	9.4285
cc	1
eloc	4
nc	1
nop	2
crap	1

<?php

/**
 * This file is part of the miBadger package.
 *
 * @author Michael Webbers <[email protected]>
 * @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(is_array($columns) ? $columns : func_get_args());

		return $this;
	}

	/**
	 * {@inheritdoc}
	 */
	public function insert(array $values)
	{
		$this->bindings['insert'] = [];
		$this->queryBuilder->insert($this->setBindings('insert', $values));

		return $this;
	}

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

		return $this;
	}

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

		return $this;
	}

	/**
	 * {@inheritdoc}
	 */
	public function join($table, $primary, $operator, $secondary)
	{
		$this->queryBuilder->join($table, $primary, $operator, $secondary);

		return $this;
	}

	/**
	 * {@inheritdoc}
	 */
	public function leftJoin($table, $primary, $operator, $secondary)
	{
		$this->queryBuilder->leftJoin($table, $primary, $operator, $secondary);

		return $this;
	}

	/**
	 * {@inheritdoc}
	 */
	public function rightJoin($table, $primary, $operator, $secondary)
	{
		$this->queryBuilder->rightJoin($table, $primary, $operator, $secondary);

		return $this;
	}

	/**
	 * {@inheritdoc}
	 */
	public function crossJoin($table, $primary, $operator, $secondary)
	{
		$this->queryBuilder->crossJoin($table, $primary, $operator, $secondary);

		return $this;
	}

	/**
	 * {@inheritdoc}
	 */
	public function where($column, $operator, $value)
	{
		if ($operator == 'IN' && is_array($value)) {
			$this->queryBuilder->where($column, 'IN', $this->addBindings('where', $value));
		} else {
			$this->queryBuilder->where($column, $operator, $this->addBinding('where', $value));
		}

		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->queryBuilder->limit($this->setBinding('limit', (int) $limit));

		return $this;
	}

	/**
	 * {@inheritdoc}
	 */
	public function offset($offset)
	{
		$this->queryBuilder->offset($this->setBinding('offset', (int) $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 $clause => $predicate) {
			foreach ($predicate as $key => $value) {
				$pdoStatement->bindValue(sprintf(':%s%d', $clause, $key + 1), $value, $this->getPdoDataType($value));
			}
		}

		$pdoStatement->execute();

		return new QueryResult($pdoStatement);
	}

	/**
	 * Returns the data type of the given value.
	 *
	 * @param mixed $value
	 * @return int the data type of the given value.
	 */
	private function getPdoDataType($value)
	{
		$result = \PDO::PARAM_STR;

		if (is_bool($value)) {
			$result = \PDO::PARAM_BOOL;
		} elseif (is_null($value)) {
			$result = \PDO::PARAM_NULL;
		} elseif (is_int($value)) {
			$result = \PDO::PARAM_INT;
		}

		return $result;
	}

	/**
	 * Returns a binding for the given clause and value.
	 *
	 * @param string $clause
	 * @param string $value
	 * @return string a binding for the given clause and value.
	 */
	private function addBinding($clause, $value)
	{
		$this->bindings[$clause][] = $value;

		return sprintf(':%s%d', $clause, count($this->bindings[$clause]));
	}

	/**
	 * Returns bindings for the given clause and values.
	 *
	 * @param string $clause
	 * @param array $values
	 * @return array bindings for the given clause and values.
	 */
	private function addBindings($clause, array $values)
	{
		$result = [];

		foreach ($values as $key => $value) {
			$result[$key] = $this->addBinding($clause, $value);
		}

		return $result;
	}

	/**
	 * Returns a binding for the given clause and value.
	 *
	 * @param string $clause
	 * @param string $value
	 * @return string a binding for the given clause and value.
	 */
	private function setBinding($clause, $value)
	{
		return $this->removeBindings($clause)->addBinding($clause, $value);
	}

	/**
	 * Returns bindings for the given clause and values.
	 *
	 * @param string $clause
	 * @param array $values
	 * @return array bindings for the given clause and values.
	 */
	private function setBindings($clause, array $values)
	{
		return $this->removeBindings($clause)->addBindings($clause, $values);
	}

	/**
	 * Remove the bindings that are associated with the given clause.
	 *
	 * @param string $clause
	 * @return $this
	 */
	private function removeBindings($clause)
	{
		$this->bindings[$clause] = [];

		return $this;
	}
}


1		<?php
2
3		/**
4		* This file is part of the miBadger package.
5		*
6		* @author Michael Webbers <[email protected]>
7		* @license http://opensource.org/licenses/Apache-2.0 Apache v2 License
8		* @version 1.0.0
9		*/
10
11		namespace miBadger\Query;
12
13		/**
14		* The query class.
15		*
16		* @since 1.0.0
17		*/
18		class Query implements QueryInterface
19		{
20		/* @var \PDO The PDO. */
21		private $pdo;
22
23		/* @var array The bindings. */
24		private $bindings;
25
26		/* @var QueryBuilder The query builder. */
27		private $queryBuilder;
28
29		/**
30		* Construct a query object with the given pdo and table.
31		*
32		* @param \PDO $pdo
33		* @param string $table
34		*/
35	21	public function __construct(\PDO $pdo, $table)
36		{
37	21	$this->pdo = $pdo;
38	21	$this->bindings = [];
39	21	$this->queryBuilder = new QueryBuilder($table);
40	21	}
41
42		/**
43		* Returns a string representation of the query object.
44		*
45		* @return string a string representation of the query object.
46		*/
47	21	public function __toString()
48		{
49	21	return $this->queryBuilder->__toString();
50		}
51
52		/**
53		* {@inheritdoc}
54		*/
55	17	public function select($columns = ['*'])
56		{
57	17	$this->queryBuilder->select(is_array($columns) ? $columns : func_get_args());
58
59	17	return $this;
60		}
61
62		/**
63		* {@inheritdoc}
64		*/
65	1	public function insert(array $values)
66		{
67	1	$this->bindings['insert'] = [];
68	1	$this->queryBuilder->insert($this->setBindings('insert', $values));
69
70	1	return $this;
71		}
72
73		/**
74		* {@inheritdoc}
75		*/
76	1	public function update(array $values)
77		{
78	1	$this->queryBuilder->update($this->setBindings('update', $values));
79
80	1	return $this;
81		}
82
83		/**
84		* {@inheritdoc}
85		*/
86	1	public function delete()
87		{
88	1	$this->queryBuilder->delete();
89
90	1	return $this;
91		}
92
93		/**
94		* {@inheritdoc}
95		*/
96	1	public function join($table, $primary, $operator, $secondary)
97		{
98	1	$this->queryBuilder->join($table, $primary, $operator, $secondary);
99
100	1	return $this;
101		}
102
103		/**
104		* {@inheritdoc}
105		*/
106	1	public function leftJoin($table, $primary, $operator, $secondary)
107		{
108	1	$this->queryBuilder->leftJoin($table, $primary, $operator, $secondary);
109
110	1	return $this;
111		}
112
113		/**
114		* {@inheritdoc}
115		*/
116	1	public function rightJoin($table, $primary, $operator, $secondary)
117		{
118	1	$this->queryBuilder->rightJoin($table, $primary, $operator, $secondary);
119
120	1	return $this;
121		}
122
123		/**
124		* {@inheritdoc}
125		*/
126	1	public function crossJoin($table, $primary, $operator, $secondary)
127		{
128	1	$this->queryBuilder->crossJoin($table, $primary, $operator, $secondary);
129
130	1	return $this;
131		}
132
133		/**
134		* {@inheritdoc}
135		*/
136	7	public function where($column, $operator, $value)
137		{
138	7	if ($operator == 'IN' && is_array($value)) {
139	1	$this->queryBuilder->where($column, 'IN', $this->addBindings('where', $value));
140	1	} else {
141	6	$this->queryBuilder->where($column, $operator, $this->addBinding('where', $value));
142		}
143
144	7	return $this;
145		}
146
147		/**
148		* {@inheritdoc}
149		*/
150	1	public function groupBy($column)
151		{
152	1	$this->queryBuilder->groupBy($column);
153
154	1	return $this;
155		}
156
157		/**
158		* {@inheritdoc}
159		*/
160	1	public function orderBy($column, $order = null)
161		{
162	1	$this->queryBuilder->orderBy($column, $order);
163
164	1	return $this;
165		}
166
167		/**
168		* {@inheritdoc}
169		*/
170	2	public function limit($limit)
171		{
172	2	$this->queryBuilder->limit($this->setBinding('limit', (int) $limit));
173
174	2	return $this;
175		}
176
177		/**
178		* {@inheritdoc}
179		*/
180	1	public function offset($offset)
181		{
182	1	$this->queryBuilder->offset($this->setBinding('offset', (int) $offset));
183
184	1	return $this;
185		}
186
187		/**
188		* Returns the result of the executed prepared query.
189		*
190		* @return QueryResult the result of the executed prepared query.
191		*/
192	4	public function execute()
193		{
194	4	$pdoStatement = $this->pdo->prepare((string) $this);
195
196	4	foreach ($this->bindings as $clause => $predicate) {
197	1	foreach ($predicate as $key => $value) {
198	1	$pdoStatement->bindValue(sprintf(':%s%d', $clause, $key + 1), $value, $this->getPdoDataType($value));
199	1	}
200	4	}
201
202	4	$pdoStatement->execute();
203
204	4	return new QueryResult($pdoStatement);
205		}
206
207		/**
208		* Returns the data type of the given value.
209		*
210		* @param mixed $value
211		* @return int the data type of the given value.
212		*/
213	1	private function getPdoDataType($value)
214		{
215	1	$result = \PDO::PARAM_STR;
216
217	1	if (is_bool($value)) {
218	1	$result = \PDO::PARAM_BOOL;
219	1	} elseif (is_null($value)) {
220	1	$result = \PDO::PARAM_NULL;
221	1	} elseif (is_int($value)) {
222	1	$result = \PDO::PARAM_INT;
223	1	}
224
225	1	return $result;
226		}
227
228		/**
229		* Returns a binding for the given clause and value.
230		*
231		* @param string $clause
232		* @param string $value
233		* @return string a binding for the given clause and value.
234		*/
235	10	private function addBinding($clause, $value)
236		{
237	10	$this->bindings[$clause][] = $value;
238
239	10	return sprintf(':%s%d', $clause, count($this->bindings[$clause]));
240		}
241
242		/**
243		* Returns bindings for the given clause and values.
244		*
245		* @param string $clause
246		* @param array $values
247		* @return array bindings for the given clause and values.
248		*/
249	3	private function addBindings($clause, array $values)
250		{
251	3	$result = [];
252
253	3	foreach ($values as $key => $value) {
254	3	$result[$key] = $this->addBinding($clause, $value);
255	3	}
256
257	3	return $result;
258		}
259
260		/**
261		* Returns a binding for the given clause and value.
262		*
263		* @param string $clause
264		* @param string $value
265		* @return string a binding for the given clause and value.
266		*/
267	2	private function setBinding($clause, $value)
268		{
269	2	return $this->removeBindings($clause)->addBinding($clause, $value);
270		}
271
272		/**
273		* Returns bindings for the given clause and values.
274		*
275		* @param string $clause
276		* @param array $values
277		* @return array bindings for the given clause and values.
278		*/
279	2	private function setBindings($clause, array $values)
280		{
281	2	return $this->removeBindings($clause)->addBindings($clause, $values);
282		}
283
284		/**
285		* Remove the bindings that are associated with the given clause.
286		*
287		* @param string $clause
288		* @return $this
289		*/
290	4	private function removeBindings($clause)
291		{
292	4	$this->bindings[$clause] = [];
293
294	4	return $this;
295		}
296		}
297

miBadger / miBadger.Query

Push — master ( 788af5...0bf223 )

Query::__construct() A

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like