chillerlan\Database\Query\SelectAbstract

Complexity

Total Complexity

33

Size/Duplication

Total Lines	186
Duplicated Lines	0 %

Coupling/Cohesion

Components	7
Dependencies	2

Importance

Changes

0

13 Methods

Rating	Name	Duplication	Size	Complexity
A	distinct()	0	5	1
B	addColumn()	0	16	9
B	cols()	0	19	5
A	_addFrom()	0	9	2
B	from()	0	22	4
A	where()	0	3	1
A	openBracket()	0	3	1
A	closeBracket()	0	3	1
A	limit()	0	5	1
A	offset()	0	5	1
B	orderby()	0	22	4
A	groupBy()	0	8	2
A	union()	0	3	1

<?php
/**
 * Class SelectAbstract
 *
 * @filesource   SelectAbstract.php
 * @created      03.06.2017
 * @package      chillerlan\Database\Query\Dialects
 * @author       Smiley <smiley@chillerlan.net>
 * @copyright    2017 Smiley
 * @license      MIT
 */

namespace chillerlan\Database\Query;

use chillerlan\Database\Query\Traits\WhereTrait;

abstract class SelectAbstract extends StatementAbstract implements SelectInterface{
	use WhereTrait;

	protected $distinct = false;

	protected $cols = [];
	protected $from = [];
	protected $orderby = [];
	protected $groupby = [];

	/**
	 * @return \chillerlan\Database\Query\SelectInterface
	 */
	public function distinct():SelectInterface{
		$this->distinct = true;

		return $this;
	}

	/**
	 * @param      $expr1
	 * @param null $expr2
	 * @param null $func
	 *
	 * @return void
	 */
	protected function addColumn($expr1, $expr2 = null, $func = null){
		// @todo: quotes
		switch(true){
			case  $expr2 && $func:

As per coding-style, case should be followed by a single space.

				$col = sprintf('%s(%s) AS %s', strtoupper($func), $expr1, $expr2); break;

Terminating statement must be on a line by itself

			case  $expr2 && !$func:

As per coding-style, case should be followed by a single space.

				$col = sprintf('%s AS %s', $expr1, $expr2); break;

Terminating statement must be on a line by itself

			case !$expr2 && $func:
				$col = sprintf('%s(%s)', strtoupper($func), $expr1); break;

Terminating statement must be on a line by itself

			case !$expr2 && !$func:
			default:
				$col = $expr1;
		}

		$this->cols[$expr2 ?? $expr1] = $col;
	}

	/**
	 * @param array $expressions
	 *
	 * @return \chillerlan\Database\Query\SelectInterface
	 */
	public function cols(array $expressions):SelectInterface{

		foreach($expressions as $k => $ref){

			if(is_string($k)){
				is_array($ref)
					? $this->addColumn($k, $ref[0], $ref[1] ?? null)
					: $this->addColumn($k, $ref);
			}
			else{
				is_array($ref)
					? $this->addColumn($ref[0], null, $ref[1] ?? null)
					: $this->addColumn($ref);
			}

		}

		return $this;
	}

	/**
	 * @param string      $table
	 * @param string|null $ref
	 */
	protected function _addFrom(string $table, string $ref = null){
		$from = $table;

		if($ref){

The expression $ref of type null|string is loosely compared to true; this is ambiguous if the string can be empty. You might want to explicitly use !== null instead.

			$from = sprintf('%s AS %s', $table, $ref);// @todo: index hint
		}

		$this->from[$ref ?? $table] = $from;
	}

	/**
	 * @param array $expressions
	 *
	 * @return \chillerlan\Database\Query\SelectInterface
	 */
	public function from(array $expressions):SelectInterface{

		foreach($expressions as $k => $ref){

			if(is_string($k)){
				$this->_addFrom($k, $ref);
			}
			else{
				$x = explode(' ', $ref);

				if(count($x) === 2){
					$this->_addFrom($x[0], $x[1]);
				}
				else{
					$this->_addFrom($ref);
				}
			}

		}

		return $this;
	}

	public function where($val1, $val2, $operator = '=', $bind = true, $join = 'AND'):SelectInterface{
		return $this->_addWhere($val1, $val2, $operator, $bind, $join);
	}

	public function openBracket($join = null):SelectInterface{
		return $this->_openBracket($join);
	}

	public function closeBracket():SelectInterface{
		return $this->_closeBracket();
	}

	/**
	 * @param int $limit
	 *
	 * @return \chillerlan\Database\Query\SelectInterface
	 */
	public function limit(int $limit):SelectInterface{
		$this->limit = $limit;

		return $this;
	}

	/**
	 * @param int $offset
	 *
	 * @return \chillerlan\Database\Query\SelectInterface
	 */
	public function offset(int $offset):SelectInterface{
		$this->offset = $offset;

		return $this;
	}

	/**
	 * @param array $expressions
	 *
	 * @return \chillerlan\Database\Query\SelectInterface
	 */
	public function orderby(array $expressions):SelectInterface{

		foreach($expressions as $k => $expression){

			if(is_string($k)){
				$orderby = $k;
				$expression = strtoupper($expression);

				if(in_array($expression, ['ASC', 'DESC'])){
					$orderby .= ' '.$expression;
				}

				$this->orderby[] = $orderby;
			}
			else{
				$this->orderby[] = $expression;
			}

		}

		return $this;
	}

	public function groupBy(array $expressions):SelectInterface{

		foreach($expressions as $expression){
			$this->groupby[] = $expression;
		}

		return $this;
	}

	public function union():SelectInterface{
		// TODO: Implement union() method.
	}

}