ActiveRecordQuery::fetchAllAsArray() - Code Metrics - miBadger/miBadger.ActiveRecord - Measure and Improve Code Quality continuously with Scrutinizer

ActiveRecordQuery::fetchAllAsArray() A
last analyzed 2021-08-13 10:30 UTC

↳ Parent: ActiveRecordQuery

Complexity

Conditions	2
Paths	2

Size

Total Lines	8
Code Lines	5

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	0
CRAP Score	6

Importance

Changes

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

<?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
 */

namespace miBadger\ActiveRecord;

use miBadger\Query\Query;
use miBadger\Query\QueryInterface;
use miBadger\Query\QueryExpression;

/**
 * The active record exception class.
 *
 * @since 2.0.0
 */
class ActiveRecordQuery implements \IteratorAggregate
{
	private $instance;

	private $query;

	private $type;

	private $clauses = [];

	private $maxresultCount;


	private $results;
	
	private $whereExpression = null;

	private $limit;

	private $offset;

	private $orderBy;


	private $orderDirection;


	/**
	 * Constructs a new Active Record Query
	 */
	public function __construct(AbstractActiveRecord $instance, Array $additionalWhereClauses)
	{
		$this->instance = $instance;
		$this->query = new Query($instance->getPdo(), $instance->getTableName());
		$this->type = $instance;
		$this->clauses = $additionalWhereClauses;
		$this->maxResultCount = null;

		$this->results = null;
		$this->limit = null;
		$this->offset = null;
	}

	private function getWhereCondition()
	{
		$clauses = $this->clauses;

		// Optionally add user concatenated where expression
		if ($this->whereExpression !== null) {
			$clauses[] = $this->whereExpression;
		}

		// Construct where clause
		if (count($clauses) > 0) {
			return Query::AndArray($clauses);
		}
		return null;
	}

	/**
	 * Executes the query
	 */
	public function execute()
	{
		$whereCondition = $this->getWhereCondition();
		if ($whereCondition !== null) {
			$this->query->where($whereCondition);
		}

		$this->query->select();

		$this->results = $this->query->execute();

		return $this;
	}

	/**
	 * Returns an iterator for the result set
	 * @return ArrayIterator

	 */
	public function getIterator()
	{
		return new \ArrayIterator($this->fetchAll());
	}

	/**
	 * returns the result set of ActiveRecord instances for this query
	 * @return Array
	 */
	public function fetchAll()
	{
		try {
			if ($this->results === null) {
				$this->execute();	
			}

			$entries = $this->results->fetchAll();
			if ($entries === false) {
				return [];
			}

			$typedResults = [];
			foreach ($entries as $entry) {
				$typedEntry = $this->type->newInstance();
				$typedEntry->fill($entry);
				$typedResults[] = $typedEntry;
			}

			return $typedResults;
		} catch (\PDOException $e) {
			throw new ActiveRecordException($e->getMessage(), 0, $e);
		}
	}

	public function fetchAllAsArray($readWhitelist)
	{
		$data = $this->fetchAll();
		$output = [];
		foreach ($data as $entry) {
			$output[] = $entry->toArray($readWhitelist);
		}
		return $output;
	}

	/**
	 * Fetch one record from the database
	 * @return AbstractActiveRecord 
	 */
	public function fetch()
	{
		try {
			if ($this->results === null) {
				$this->execute();
			}

			$typedResult = $this->type->newInstance();

			$entry = $this->results->fetch();
			if ($entry === false) {
				return null;
			}

			$typedResult->fill($entry);

			return $typedResult;
		} catch (\PDOException $e) {
			throw new ActiveRecordException($e->getMessage(), 0, $e);
		}
	}

	/**
	 * Fetch one record from the database and format it as an associative array, 
	 * 	 filtered by the entries in $readwhitelist
	 * @param Array $readWhitelist Array of whitelisted database column keys to be returned in the result
	 * @return Array|Null
	 */
	public function fetchAsArray($readWhitelist)
	{
		$res = $this->fetch();
		if ($res !== null) {
			return $res->toArray($readWhitelist);
		}
		return null;
	}

	public function countMaxResults()
	{
		if ($this->maxResultCount === null) {
			$query = new Query($this->instance->getPdo(), $this->instance->getTableName());
			$query->select(['count(*) as count'], false);

			$whereCondition = $this->getWhereCondition();
			if ($whereCondition !== null) {
				$query->where($whereCondition);
			}

			$this->maxResultCount = $query->execute()->fetch()['count'];

		}
		return $this->maxResultCount;
	}

	public function getNumberOfPages()
	{
		if ($this->limit === null) {
			return 1;
		}

		if ($this->limit === 0) {
			return 0;
		}

		$resultCount = $this->countMaxResults();
		if ($resultCount % $this->limit > 0) {
			return (int) floor($resultCount / $this->limit) + 1;
		}
		return (int) floor($resultCount / $this->limit);
	}

	public function getCurrentPage()
	{
		if ($this->offset === null || $this->offset === 0) {
			return 1;
		}

		if ($this->limit === null || $this->limit === 0) {
			return 1;
		}

		return (int) floor($this->offset / $this->limit);
	}

	/**
	 * Set the where condition
	 *
	 * @param QueryExpression $expression the query expression
	 * @return $this
	 * @see https://en.wikipedia.org/wiki/SQL#Operators
	 * @see https://en.wikipedia.org/wiki/Where_(SQL)
	 */
	public function where(QueryExpression $expression)
	{
		$this->whereExpression = $expression;
		return $this;
	}

	/**
	 * Set an additional group by.
	 *
	 * @param string $column
	 * @return $this
	 * @see https://en.wikipedia.org/wiki/SQL#Queries
	 */
	public function groupBy(string $column)
	{
		$this->query->groupBy($column);
		return $this;
	}

	/**
	 * Set an additional order condition.
	 *
	 * @param string $column
	 * @param string|null $order
	 * @return $this
	 * @see https://en.wikipedia.org/wiki/SQL#Queries
	 * @see https://en.wikipedia.org/wiki/Order_by
	 */
	public function orderBy(string $column, $order = null)
	{
		$this->query->orderBy($column, $order);	
		return $this;
	}

	/**
	 * Set the limit.
	 *
	 * @param mixed $limit
	 * @return $this
	 */
	public function limit($limit)
	{
		$this->limit = $limit;
		$this->query->limit($limit);
		return $this;
	}

	/**
	 * Set the offset.
	 *
	 * @param mixed $offset
 	 * @return $this
	 */
	public function offset($offset)
	{
		$this->offset = $offset;
		$this->query->offset($offset);
		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		*/
9
10		namespace miBadger\ActiveRecord;
11
12		use miBadger\Query\Query;
13		use miBadger\Query\QueryInterface;
14		use miBadger\Query\QueryExpression;
15
16		/**
17		* The active record exception class.
18		*
19		* @since 2.0.0
20		*/
21		class ActiveRecordQuery implements \IteratorAggregate
22		{
23		private $instance;
24
25		private $query;
26
27		private $type;
28
29		private $clauses = [];
30
31		private $maxresultCount;
		0 ignored issues – show introduced 2019-09-10 10:10 UTC by Report Bug Copy Issue Report The private property `$maxresultCount` is not used, and could be removed. Loading history...
32
33		private $results;
34
35		private $whereExpression = null;
36
37		private $limit;
38
39		private $offset;
40
41		private $orderBy;
		0 ignored issues – show introduced 2019-09-10 10:10 UTC by Report Bug Copy Issue Report The private property `$orderBy` is not used, and could be removed. Loading history...
42
43		private $orderDirection;
		0 ignored issues – show introduced 2019-09-10 10:10 UTC by Report Bug Copy Issue Report The private property `$orderDirection` is not used, and could be removed. Loading history...
44
45		/**
46		* Constructs a new Active Record Query
47		*/
48	19	public function __construct(AbstractActiveRecord $instance, Array $additionalWhereClauses)
49		{
50	19	$this->instance = $instance;
51	19	$this->query = new Query($instance->getPdo(), $instance->getTableName());
52	19	$this->type = $instance;
53	19	$this->clauses = $additionalWhereClauses;
54	19	$this->maxResultCount = null;
		0 ignored issues – show Bug Best Practice introduced 2019-09-10 10:10 UTC by Report Bug Copy Issue Report The property `maxResultCount` does not exist. Although not strictly required by PHP, it is generally a best practice to declare properties explicitly. Loading history...
55	19	$this->results = null;
56	19	$this->limit = null;
57	19	$this->offset = null;
58	19	}
59
60	18	private function getWhereCondition()
61		{
62	18	$clauses = $this->clauses;
63
64		// Optionally add user concatenated where expression
65	18	if ($this->whereExpression !== null) {
66	10	$clauses[] = $this->whereExpression;
67		}
68
69		// Construct where clause
70	18	if (count($clauses) > 0) {
71	11	return Query::AndArray($clauses);
72		}
73	7	return null;
74		}
75
76		/**
77		* Executes the query
78		*/
79	17	public function execute()
80		{
81	17	$whereCondition = $this->getWhereCondition();
82	17	if ($whereCondition !== null) {
83	11	$this->query->where($whereCondition);
84		}
85
86	17	$this->query->select();
87
88	17	$this->results = $this->query->execute();
89
90	14	return $this;
91		}
92
93		/**
94		* Returns an iterator for the result set
95		* @return ArrayIterator
		0 ignored issues – show Bug introduced 2019-06-28 08:54 UTC by Report Bug Copy Issue Report The type `miBadger\ActiveRecord\ArrayIterator` was not found. Did you mean `ArrayIterator`? If so, make sure to prefix the type with `\`. Loading history...
96		*/
97		public function getIterator()
98		{
99		return new \ArrayIterator($this->fetchAll());
100		}
101
102		/**
103		* returns the result set of ActiveRecord instances for this query
104		* @return Array
105		*/
106	14	public function fetchAll()
107		{
108		try {
109	14	if ($this->results === null) {
110	14	$this->execute();
111		}
112
113	12	$entries = $this->results->fetchAll();
114	12	if ($entries === false) {
115		return [];
116		}
117
118	12	$typedResults = [];
119	12	foreach ($entries as $entry) {
120	12	$typedEntry = $this->type->newInstance();
121	12	$typedEntry->fill($entry);
122	12	$typedResults[] = $typedEntry;
123		}
124
125	12	return $typedResults;
126	2	} catch (\PDOException $e) {
127	2	throw new ActiveRecordException($e->getMessage(), 0, $e);
128		}
129		}
130
131		public function fetchAllAsArray($readWhitelist)
132		{
133		$data = $this->fetchAll();
134		$output = [];
135		foreach ($data as $entry) {
136		$output[] = $entry->toArray($readWhitelist);
137		}
138		return $output;
139		}
140
141		/**
142		* Fetch one record from the database
143		* @return AbstractActiveRecord
144		*/
145	3	public function fetch()
146		{
147		try {
148	3	if ($this->results === null) {
149	3	$this->execute();
150		}
151
152	2	$typedResult = $this->type->newInstance();
153
154	2	$entry = $this->results->fetch();
155	2	if ($entry === false) {
156	1	return null;
157		}
158
159	1	$typedResult->fill($entry);
160
161	1	return $typedResult;
162	1	} catch (\PDOException $e) {
163	1	throw new ActiveRecordException($e->getMessage(), 0, $e);
164		}
165		}
166
167		/**
168		* Fetch one record from the database and format it as an associative array,
169		* filtered by the entries in $readwhitelist
170		* @param Array $readWhitelist Array of whitelisted database column keys to be returned in the result
171		* @return Array\|Null
172		*/
173		public function fetchAsArray($readWhitelist)
174		{
175		$res = $this->fetch();
176		if ($res !== null) {
177		return $res->toArray($readWhitelist);
178		}
179		return null;
180		}
181
182	2	public function countMaxResults()
183		{
184	2	if ($this->maxResultCount === null) {
185	2	$query = new Query($this->instance->getPdo(), $this->instance->getTableName());
186	2	$query->select(['count(*) as count'], false);
187
188	2	$whereCondition = $this->getWhereCondition();
189	2	if ($whereCondition !== null) {
190	1	$query->where($whereCondition);
191		}
192
193	2	$this->maxResultCount = $query->execute()->fetch()['count'];
		0 ignored issues – show Bug Best Practice introduced 2019-09-10 10:10 UTC by Report Bug Copy Issue Report The property `maxResultCount` does not exist. Although not strictly required by PHP, it is generally a best practice to declare properties explicitly. Loading history...
194		}
195	2	return $this->maxResultCount;
196		}
197
198	1	public function getNumberOfPages()
199		{
200	1	if ($this->limit === null) {
201		return 1;
202		}
203
204	1	if ($this->limit === 0) {
205		return 0;
206		}
207
208	1	$resultCount = $this->countMaxResults();
209	1	if ($resultCount % $this->limit > 0) {
210	1	return (int) floor($resultCount / $this->limit) + 1;
211		}
212	1	return (int) floor($resultCount / $this->limit);
213		}
214
215	1	public function getCurrentPage()
216		{
217	1	if ($this->offset === null \|\| $this->offset === 0) {
218	1	return 1;
219		}
220
221		if ($this->limit === null \|\| $this->limit === 0) {
222		return 1;
223		}
224
225		return (int) floor($this->offset / $this->limit);
226		}
227
228		/**
229		* Set the where condition
230		*
231		* @param QueryExpression $expression the query expression
232		* @return $this
233		* @see https://en.wikipedia.org/wiki/SQL#Operators
234		* @see https://en.wikipedia.org/wiki/Where_(SQL)
235		*/
236	10	public function where(QueryExpression $expression)
237		{
238	10	$this->whereExpression = $expression;
239	10	return $this;
240		}
241
242		/**
243		* Set an additional group by.
244		*
245		* @param string $column
246		* @return $this
247		* @see https://en.wikipedia.org/wiki/SQL#Queries
248		*/
249		public function groupBy(string $column)
250		{
251		$this->query->groupBy($column);
252		return $this;
253		}
254
255		/**
256		* Set an additional order condition.
257		*
258		* @param string $column
259		* @param string\|null $order
260		* @return $this
261		* @see https://en.wikipedia.org/wiki/SQL#Queries
262		* @see https://en.wikipedia.org/wiki/Order_by
263		*/
264	2	public function orderBy(string $column, $order = null)
265		{
266	2	$this->query->orderBy($column, $order);
267	2	return $this;
268		}
269
270		/**
271		* Set the limit.
272		*
273		* @param mixed $limit
274		* @return $this
275		*/
276	4	public function limit($limit)
277		{
278	4	$this->limit = $limit;
279	4	$this->query->limit($limit);
280	4	return $this;
281		}
282
283		/**
284		* Set the offset.
285		*
286		* @param mixed $offset
287		* @return $this
288		*/
289	2	public function offset($offset)
290		{
291	2	$this->offset = $offset;
292	2	$this->query->offset($offset);
293	2	return $this;
294		}
295		}
296

miBadger / miBadger.ActiveRecord

ActiveRecordQuery::fetchAllAsArray() A last analyzed 2021-08-13 10:30 UTC

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like

ActiveRecordQuery::fetchAllAsArray() A
last analyzed 2021-08-13 10:30 UTC