AbstractQuery::addWhere() - Code Metrics - Inspection of "Merge pull request #116 from pavarnos/wheretrait" - auraphp/Aura.SqlQuery - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Push — 3.x ( f5caca...8b4f6e )

by Hari

created 2017-01-02 17:47 UTC

AbstractQuery::addWhere() A

↳ Parent: AbstractQuery

Complexity

Conditions	1
Paths	1

Size

Total Lines	5
Code Lines	3

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	3
CRAP Score	1

Importance

Changes

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

<?php
/**
 *
 * This file is part of Aura for PHP.
 *
 * @license http://opensource.org/licenses/bsd-license.php BSD
 *
 */
namespace Aura\SqlQuery;

use Aura\SqlQuery\Common\LimitInterface;
use Aura\SqlQuery\Common\LimitOffsetInterface;
use Aura\SqlQuery\Common\SubselectInterface;

/**
 *
 * Abstract query object.
 *
 * @package Aura.SqlQuery
 *
 */
abstract class AbstractQuery
{
    /**
     *
     * Data to be bound to the query.
     *
     * @var array
     *
     */
    protected $bind_values = array();

    /**
     *
     * The list of WHERE conditions.
     *
     * @var array
     *
     */
    protected $where = array();

    /**
     *
     * ORDER BY these columns.
     *
     * @var array
     *
     */
    protected $order_by = array();

    /**
     *
     * The number of rows to select
     *
     * @var int
     *
     */
    protected $limit = 0;

    /**
     *
     * Return rows after this offset.
     *
     * @var int
     *
     */
    protected $offset = 0;

    /**
     *
     * The list of flags.
     *
     * @var array
     *
     */
    protected $flags = array();

    /**
     *
     * A helper for quoting identifier names.
     *
     * @var Quoter
     *
     */
    protected $quoter;

    /**
     *
     * Prefix to use on placeholders for "sequential" bound values; used for
     * deconfliction when merging bound values from sub-selects, etc.
     *
     * @var mixed
     *
     */
    protected $seq_bind_prefix = '';

    /**
     *
     * Constructor.
     *
     * @param Quoter $quoter A helper for quoting identifier names.
     *
     * @param string $seq_bind_prefix A prefix for rewritten sequential-binding
     * placeholders (@see getSeqPlaceholder()).
     *
     */
    public function __construct(Quoter $quoter, $seq_bind_prefix = '')
    {
        $this->quoter = $quoter;
        $this->seq_bind_prefix = $seq_bind_prefix;
    }

    /**
     *
     * Returns the prefix for rewritten sequential-binding placeholders
     * (@see getSeqPlaceholder()).
     *
     * @return string
     *
     */
    public function getSeqBindPrefix()
    {
        return $this->seq_bind_prefix;
    }

    /**
     *
     * Returns this query object as an SQL statement string.
     *
     * @return string
     *
     */
    public function __toString()
    {
        return $this->getStatement();
    }

    /**
     *
     * Returns this query object as an SQL statement string.
     *
     * @return string
     *
     */
    public function getStatement()
    {
        return $this->build();
    }

    /**
     *
     * Builds this query object into a string.
     *
     * @return string
     *
     */
    abstract protected function build();

    /**
     *
     * Returns the prefix to use when quoting identifier names.
     *
     * @return string
     *
     */
    public function getQuoteNamePrefix()
    {
        return $this->quoter->getQuoteNamePrefix();
    }

    /**
     *
     * Returns the suffix to use when quoting identifier names.
     *
     * @return string
     *
     */
    public function getQuoteNameSuffix()
    {
        return $this->quoter->getQuoteNameSuffix();
    }

    /**
     *
     * Returns an array as an indented comma-separated values string.
     *
     * @param array $list The values to convert.
     *
     * @return string
     *
     */
    protected function indentCsv(array $list)
    {
        return PHP_EOL . '    '
             . implode(',' . PHP_EOL . '    ', $list);
    }

    /**
     *
     * Returns an array as an indented string.
     *
     * @param array $list The values to convert.
     *
     * @return string
     *
     */
    protected function indent(array $list)
    {
        return PHP_EOL . '    '
             . implode(PHP_EOL . '    ', $list);
    }

    /**
     *
     * Binds multiple values to placeholders; merges with existing values.
     *
     * @param array $bind_values Values to bind to placeholders.
     *
     * @return $this
     *
     */
    public function bindValues(array $bind_values)
    {
        // array_merge() renumbers integer keys, which is bad for
        // question-mark placeholders
        foreach ($bind_values as $key => $val) {
            $this->bindValue($key, $val);
        }
        return $this;
    }

    /**
     *
     * Binds a single value to the query.
     *
     * @param string $name The placeholder name or number.
     *
     * @param mixed $value The value to bind to the placeholder.
     *
     * @return $this
     *
     */
    public function bindValue($name, $value)
    {
        $this->bind_values[$name] = $value;
        return $this;
    }

    /**
     *
     * Gets the values to bind to placeholders.
     *
     * @return array
     *
     */
    public function getBindValues()
    {
        return $this->bind_values;
    }

    /**
     *
     * Reset all values bound to named placeholders.
     *
     * @return $this
     *
     */
    public function resetBindValues()
    {
        $this->bind_values = array();
        return $this;
    }

    /**
     *
     * Builds the flags as a space-separated string.
     *
     * @return string
     *
     */
    protected function buildFlags()
    {
        if (empty($this->flags)) {
            return ''; // not applicable
        }

        return ' ' . implode(' ', array_keys($this->flags));
    }

    /**
     *
     * Sets or unsets specified flag.
     *
     * @param string $flag Flag to set or unset
     *
     * @param bool $enable Flag status - enabled or not (default true)
     *
     * @return null
     *
     */
    protected function setFlag($flag, $enable = true)
    {
        if ($enable) {
            $this->flags[$flag] = true;
        } else {
            unset($this->flags[$flag]);
        }
    }

    /**
     *
     * Reset all query flags.
     *
     * @return $this
     *
     */
    public function resetFlags()
    {
        $this->flags = array();
        return $this;
    }

    /**
     *
     * Adds a WHERE condition to the query by AND or OR. If the condition has
     * ?-placeholders, additional arguments to the method will be bound to
     * those placeholders sequentially.
     *
     * @param string $andor Add the condition using this operator, typically
     * 'AND' or 'OR'.
     *
     * @param string $cond The WHERE condition.
     *
     * @param array ...$bind arguments to bind to placeholders
     *
     * @return $this
     *
     */
    protected function addWhere($andor, $cond, ...$bind)
    {
        $this->addClauseCondWithBind('where', $andor, $cond, $bind);
        return $this;
    }

    /**
     *
     * Adds conditions and binds values to a clause.
     *
     * @param string $clause The clause to work with, typically 'where' or
     * 'having'.
     *
     * @param string $andor Add the condition using this operator, typically
     * 'AND' or 'OR'.
     *
     * @param string $cond The WHERE condition.

     * @param array $bind arguments to bind to placeholders
     *
     * @return null
     *
     */
    protected function addClauseCondWithBind($clause, $andor, $cond, $bind)
    {
        $cond = $this->rebuildCondAndBindValues($cond, $bind);

        // add condition to clause; eg $this->where or $this->having
        $clause =& $this->$clause;
        if ($clause) {
            $clause[] = "$andor $cond";
        } else {
            $clause[] = $cond;
        }
    }

    /**
     *
     * Rebuilds a condition string, replacing sequential placeholders with
     * named placeholders, and binding the sequential values to the named
     * placeholders.
     *
     * @param string $cond The condition with sequential placeholders.
     *
     * @param array $bind_values The values to bind to the sequential
     * placeholders under their named versions.
     *
     * @return string The rebuilt condition string.
     *
     */
    protected function rebuildCondAndBindValues($cond, array $bind_values)
    {
        $cond = $this->quoter->quoteNamesIn($cond);

        // bind values against ?-mark placeholders, but because PDO is finicky
        // about the numbering of sequential placeholders, convert each ?-mark
        // to a named placeholder
        $parts = preg_split('/(\?)/', $cond, null, PREG_SPLIT_DELIM_CAPTURE);
        foreach ($parts as $key => $val) {
            if ($val != '?') {
                continue;
            }

            $bind_value = array_shift($bind_values);
            if ($bind_value instanceof SubselectInterface) {
                $parts[$key] = $bind_value->getStatement();
                $this->bind_values = array_merge(
                    $this->bind_values,
                    $bind_value->getBindValues()
                );
                continue;
            }

            $placeholder = $this->getSeqPlaceholder();
            $parts[$key] = ':' . $placeholder;
            $this->bind_values[$placeholder] = $bind_value;
        }

        $cond = implode('', $parts);
        return $cond;
    }

    /**
     *
     * Gets the current sequential placeholder name.
     *
     * @return string
     *
     */
    protected function getSeqPlaceholder()
    {
        $i = count($this->bind_values) + 1;
        return $this->seq_bind_prefix . "_{$i}_";
    }

    /**
     *
     * Builds the `WHERE` clause of the statement.
     *
     * @return string
     *
     */
    protected function buildWhere()
    {
        if (empty($this->where)) {
            return ''; // not applicable
        }

        return PHP_EOL . 'WHERE' . $this->indent($this->where);
    }

    /**
     *
     * Adds a column order to the query.
     *
     * @param array $spec The columns and direction to order by.
     *
     * @return $this
     *
     */
    protected function addOrderBy(array $spec)
    {
        foreach ($spec as $col) {
            $this->order_by[] = $this->quoter->quoteNamesIn($col);
        }
        return $this;
    }

    /**
     *
     * Builds the `ORDER BY ...` clause of the statement.
     *
     * @return string
     *
     */
    protected function buildOrderBy()
    {
        if (empty($this->order_by)) {
            return ''; // not applicable
        }

        return PHP_EOL . 'ORDER BY' . $this->indentCsv($this->order_by);
    }

    /**
     *
     * Builds the `LIMIT ... OFFSET` clause of the statement.
     *
     * Note that this will allow OFFSET values with a LIMIT.
     *
     * @return string
     *
     */
    protected function buildLimit()
    {
        $clause = '';
        $limit = $this instanceof LimitInterface && $this->limit;
        $offset = $this instanceof LimitOffsetInterface && $this->offset;

        if ($limit) {
            $clause .= "LIMIT {$this->limit}";
        }

        if ($offset) {
            $clause .= " OFFSET {$this->offset}";
        }

        if ($clause) {
            $clause = PHP_EOL . trim($clause);
        }

        return $clause;
    }
}


1		<?php
2		/**
3		*
4		* This file is part of Aura for PHP.
5		*
6		* @license http://opensource.org/licenses/bsd-license.php BSD
7		*
8		*/
9		namespace Aura\SqlQuery;
10
11		use Aura\SqlQuery\Common\LimitInterface;
12		use Aura\SqlQuery\Common\LimitOffsetInterface;
13		use Aura\SqlQuery\Common\SubselectInterface;
14
15		/**
16		*
17		* Abstract query object.
18		*
19		* @package Aura.SqlQuery
20		*
21		*/
22		abstract class AbstractQuery
23		{
24		/**
25		*
26		* Data to be bound to the query.
27		*
28		* @var array
29		*
30		*/
31		protected $bind_values = array();
32
33		/**
34		*
35		* The list of WHERE conditions.
36		*
37		* @var array
38		*
39		*/
40		protected $where = array();
41
42		/**
43		*
44		* ORDER BY these columns.
45		*
46		* @var array
47		*
48		*/
49		protected $order_by = array();
50
51		/**
52		*
53		* The number of rows to select
54		*
55		* @var int
56		*
57		*/
58		protected $limit = 0;
59
60		/**
61		*
62		* Return rows after this offset.
63		*
64		* @var int
65		*
66		*/
67		protected $offset = 0;
68
69		/**
70		*
71		* The list of flags.
72		*
73		* @var array
74		*
75		*/
76		protected $flags = array();
77
78		/**
79		*
80		* A helper for quoting identifier names.
81		*
82		* @var Quoter
83		*
84		*/
85		protected $quoter;
86
87		/**
88		*
89		* Prefix to use on placeholders for "sequential" bound values; used for
90		* deconfliction when merging bound values from sub-selects, etc.
91		*
92		* @var mixed
93		*
94		*/
95		protected $seq_bind_prefix = '';
96
97		/**
98		*
99		* Constructor.
100		*
101		* @param Quoter $quoter A helper for quoting identifier names.
102		*
103		* @param string $seq_bind_prefix A prefix for rewritten sequential-binding
104		* placeholders (@see getSeqPlaceholder()).
105		*
106		*/
107	397	public function __construct(Quoter $quoter, $seq_bind_prefix = '')
108		{
109	397	$this->quoter = $quoter;
110	397	$this->seq_bind_prefix = $seq_bind_prefix;
111	397	}
112
113		/**
114		*
115		* Returns the prefix for rewritten sequential-binding placeholders
116		* (@see getSeqPlaceholder()).
117		*
118		* @return string
119		*
120		*/
121	1	public function getSeqBindPrefix()
122		{
123	1	return $this->seq_bind_prefix;
124		}
125
126		/**
127		*
128		* Returns this query object as an SQL statement string.
129		*
130		* @return string
131		*
132		*/
133	242	public function __toString()
134		{
135	242	return $this->getStatement();
136		}
137
138		/**
139		*
140		* Returns this query object as an SQL statement string.
141		*
142		* @return string
143		*
144		*/
145	68	public function getStatement()
146		{
147	68	return $this->build();
148		}
149
150		/**
151		*
152		* Builds this query object into a string.
153		*
154		* @return string
155		*
156		*/
157		abstract protected function build();
158
159		/**
160		*
161		* Returns the prefix to use when quoting identifier names.
162		*
163		* @return string
164		*
165		*/
166	251	public function getQuoteNamePrefix()
167		{
168	251	return $this->quoter->getQuoteNamePrefix();
169		}
170
171		/**
172		*
173		* Returns the suffix to use when quoting identifier names.
174		*
175		* @return string
176		*
177		*/
178	251	public function getQuoteNameSuffix()
179		{
180	251	return $this->quoter->getQuoteNameSuffix();
181		}
182
183		/**
184		*
185		* Returns an array as an indented comma-separated values string.
186		*
187		* @param array $list The values to convert.
188		*
189		* @return string
190		*
191		*/
192	219	protected function indentCsv(array $list)
193		{
194	219	return PHP_EOL . ' '
195	219	. implode(',' . PHP_EOL . ' ', $list);
196		}
197
198		/**
199		*
200		* Returns an array as an indented string.
201		*
202		* @param array $list The values to convert.
203		*
204		* @return string
205		*
206		*/
207	71	protected function indent(array $list)
208		{
209	71	return PHP_EOL . ' '
210	71	. implode(PHP_EOL . ' ', $list);
211		}
212
213		/**
214		*
215		* Binds multiple values to placeholders; merges with existing values.
216		*
217		* @param array $bind_values Values to bind to placeholders.
218		*
219		* @return $this
220		*
221		*/
222	31	public function bindValues(array $bind_values)
223		{
224		// array_merge() renumbers integer keys, which is bad for
225		// question-mark placeholders
226	31	foreach ($bind_values as $key => $val) {
227	31	$this->bindValue($key, $val);
228	31	}
229	31	return $this;
230		}
231
232		/**
233		*
234		* Binds a single value to the query.
235		*
236		* @param string $name The placeholder name or number.
237		*
238		* @param mixed $value The value to bind to the placeholder.
239		*
240		* @return $this
241		*
242		*/
243	72	public function bindValue($name, $value)
244		{
245	72	$this->bind_values[$name] = $value;
246	72	return $this;
247		}
248
249		/**
250		*
251		* Gets the values to bind to placeholders.
252		*
253		* @return array
254		*
255		*/
256	126	public function getBindValues()
257		{
258	126	return $this->bind_values;
259		}
260
261		/**
262		*
263		* Reset all values bound to named placeholders.
264		*
265		* @return $this
266		*
267		*/
268		public function resetBindValues()
269		{
270		$this->bind_values = array();
271		return $this;
272		}
273
274		/**
275		*
276		* Builds the flags as a space-separated string.
277		*
278		* @return string
279		*
280		*/
281	252	protected function buildFlags()
282		{
283	252	if (empty($this->flags)) {
284	214	return ''; // not applicable
285		}
286
287	38	return ' ' . implode(' ', array_keys($this->flags));
288		}
289
290		/**
291		*
292		* Sets or unsets specified flag.
293		*
294		* @param string $flag Flag to set or unset
295		*
296		* @param bool $enable Flag status - enabled or not (default true)
297		*
298		* @return null
299		*
300		*/
301	43	protected function setFlag($flag, $enable = true)
302		{
303	43	if ($enable) {
304	43	$this->flags[$flag] = true;
305	43	} else {
306	5	unset($this->flags[$flag]);
307		}
308	43	}
309
310		/**
311		*
312		* Reset all query flags.
313		*
314		* @return $this
315		*
316		*/
317	15	public function resetFlags()
318		{
319	15	$this->flags = array();
320	15	return $this;
321		}
322
323		/**
324		*
325		* Adds a WHERE condition to the query by AND or OR. If the condition has
326		* ?-placeholders, additional arguments to the method will be bound to
327		* those placeholders sequentially.
328		*
329		* @param string $andor Add the condition using this operator, typically
330		* 'AND' or 'OR'.
331		*
332		* @param string $cond The WHERE condition.
333		*
334		* @param array ...$bind arguments to bind to placeholders
335		*
336		* @return $this
337		*
338		*/
339	60	protected function addWhere($andor, $cond, ...$bind)
340		{
341	60	$this->addClauseCondWithBind('where', $andor, $cond, $bind);
342	60	return $this;
343		}
344
345		/**
346		*
347		* Adds conditions and binds values to a clause.
348		*
349		* @param string $clause The clause to work with, typically 'where' or
350		* 'having'.
351		*
352		* @param string $andor Add the condition using this operator, typically
353		* 'AND' or 'OR'.
354		*
355		* @param string $cond The WHERE condition.
356
357		* @param array $bind arguments to bind to placeholders
358		*
359		* @return null
360		*
361		*/
362	70	protected function addClauseCondWithBind($clause, $andor, $cond, $bind)
363		{
364	70	$cond = $this->rebuildCondAndBindValues($cond, $bind);
365
366		// add condition to clause; eg $this->where or $this->having
367	70	$clause =& $this->$clause;
368	70	if ($clause) {
369	49	$clause[] = "$andor $cond";
370	49	} else {
371	70	$clause[] = $cond;
372		}
373	70	}
374
375		/**
376		*
377		* Rebuilds a condition string, replacing sequential placeholders with
378		* named placeholders, and binding the sequential values to the named
379		* placeholders.
380		*
381		* @param string $cond The condition with sequential placeholders.
382		*
383		* @param array $bind_values The values to bind to the sequential
384		* placeholders under their named versions.
385		*
386		* @return string The rebuilt condition string.
387		*
388		*/
389	120	protected function rebuildCondAndBindValues($cond, array $bind_values)
390		{
391	120	$cond = $this->quoter->quoteNamesIn($cond);
392
393		// bind values against ?-mark placeholders, but because PDO is finicky
394		// about the numbering of sequential placeholders, convert each ?-mark
395		// to a named placeholder
396	120	$parts = preg_split('/(\?)/', $cond, null, PREG_SPLIT_DELIM_CAPTURE);
397	120	foreach ($parts as $key => $val) {
398	120	if ($val != '?') {
399	120	continue;
400		}
401
402	80	$bind_value = array_shift($bind_values);
403	80	if ($bind_value instanceof SubselectInterface) {
404	10	$parts[$key] = $bind_value->getStatement();
405	10	$this->bind_values = array_merge(
406	10	$this->bind_values,
407	10	$bind_value->getBindValues()
408	10	);
409	10	continue;
410		}
411
412	75	$placeholder = $this->getSeqPlaceholder();
413	75	$parts[$key] = ':' . $placeholder;
414	75	$this->bind_values[$placeholder] = $bind_value;
415	120	}
416
417	120	$cond = implode('', $parts);
418	120	return $cond;
419		}
420
421		/**
422		*
423		* Gets the current sequential placeholder name.
424		*
425		* @return string
426		*
427		*/
428	75	protected function getSeqPlaceholder()
429		{
430	75	$i = count($this->bind_values) + 1;
431	75	return $this->seq_bind_prefix . "_{$i}_";
432		}
433
434		/**
435		*
436		* Builds the `WHERE` clause of the statement.
437		*
438		* @return string
439		*
440		*/
441	206	protected function buildWhere()
442		{
443	206	if (empty($this->where)) {
444	151	return ''; // not applicable
445		}
446
447	60	return PHP_EOL . 'WHERE' . $this->indent($this->where);
448		}
449
450		/**
451		*
452		* Adds a column order to the query.
453		*
454		* @param array $spec The columns and direction to order by.
455		*
456		* @return $this
457		*
458		*/
459	9	protected function addOrderBy(array $spec)
460		{
461	9	foreach ($spec as $col) {
462	9	$this->order_by[] = $this->quoter->quoteNamesIn($col);
463	9	}
464	9	return $this;
465		}
466
467		/**
468		*
469		* Builds the `ORDER BY ...` clause of the statement.
470		*
471		* @return string
472		*
473		*/
474	206	protected function buildOrderBy()
475		{
476	206	if (empty($this->order_by)) {
477	197	return ''; // not applicable
478		}
479
480	9	return PHP_EOL . 'ORDER BY' . $this->indentCsv($this->order_by);
481		}
482
483		/**
484		*
485		* Builds the `LIMIT ... OFFSET` clause of the statement.
486		*
487		* Note that this will allow OFFSET values with a LIMIT.
488		*
489		* @return string
490		*
491		*/
492	172	protected function buildLimit()
493		{
494	172	$clause = '';
495	172	$limit = $this instanceof LimitInterface && $this->limit;
496	172	$offset = $this instanceof LimitOffsetInterface && $this->offset;
497
498	172	if ($limit) {
499	19	$clause .= "LIMIT {$this->limit}";
500	19	}
501
502	172	if ($offset) {
503	10	$clause .= " OFFSET {$this->offset}";
504	10	}
505
506	172	if ($clause) {
507	19	$clause = PHP_EOL . trim($clause);
508	19	}
509
510	172	return $clause;
511		}
512		}
513

auraphp / Aura.SqlQuery

Push — 3.x ( f5caca...8b4f6e )

AbstractQuery::addWhere() A

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like