yii2-bootstrap/framework/db/dao/Query.php

<?php
/**
 * Query class file.
 *
 * @author Qiang Xue <qiang.xue@gmail.com>
 * @link http://www.yiiframework.com/
 * @copyright Copyright &copy; 2008-2012 Yii Software LLC
 * @license http://www.yiiframework.com/license/
 */

namespace yii\db\dao;

/**
 * Query represents the components in a DB query.
 *
 * @author Qiang Xue <qiang.xue@gmail.com>
 * @since 2.0
 */
class Query extends \yii\base\Object
{
	/**
	 * @var mixed the columns being selected. This refers to the SELECT clause in an SQL
	 * statement. The property can be either a string (column names separated by commas)
	 * or an array of column names. Defaults to '*', meaning all columns.
	 */
	public $select;
	/**
	 * @var string additional option that should be appended to the 'SELECT' keyword. For example,
	 * in MySQL, the option 'SQL_CALC_FOUND_ROWS' can be used.
	 */
	public $selectOption;

	public $from;
	/**
	 * @var boolean whether to select distinct rows of data only. If this is set true,
	 * the SELECT clause would be changed to SELECT DISTINCT.
	 */
	public $distinct;
	/**
	 * @var string query condition. This refers to the WHERE clause in an SQL statement.
	 * For example, <code>age>31 AND team=1</code>.
	 */
	public $where;
	/**
	 * @var integer maximum number of records to be returned. If less than 0, it means no limit.
	 */
	public $limit;
	/**
	 * @var integer zero-based offset from where the records are to be returned. If less than 0, it means starting from the beginning.
	 */
	public $offset;
	/**
	 * @var string how to sort the query results. This refers to the ORDER BY clause in an SQL statement.
	 */
	public $orderBy;
	/**
	 * @var string how to group the query results. This refers to the GROUP BY clause in an SQL statement.
	 * For example, <code>'projectID, teamID'</code>.
	 */
	public $groupBy;
	/**
	 * @var string how to join with other tables. This refers to the JOIN clause in an SQL statement.
	 * For example, <code>'LEFT JOIN users ON users.id=authorID'</code>.
	 */
	public $join;
	/**
	 * @var string the condition to be applied with GROUP-BY clause.
	 * For example, <code>'SUM(revenue)<50000'</code>.
	 */
	public $having;
	/**
	 * @var array list of query parameter values indexed by parameter placeholders.
	 * For example, <code>array(':name'=>'Dan', ':age'=>31)</code>.
	 */
	public $params = array();

	public $union;


	/**
	 * @param Connection $connection
	 * @return string
	 */
	public function getSql($connection)
	{
		return $connection->getQueryBuilder()->build($this);
	}

	public function addParams($params)
	{
		foreach ($params as $name => $value) {
			if (is_integer($name)) {
				$this->params[] = $value;
			} else {
				$this->params[$name] = $value;
			}
		}
	}

	public function mergeWith($query, $useAnd = true)
	{
		$and = $useAnd ? 'AND' : 'OR';
		if (is_array($query)) {
			$query = new self($query);
		}

		if ($this->select !== $query->select) {
			if ($this->select === '*') {
				$this->select = $query->select;
			} elseif ($query->select !== '*') {
				$select1 = is_string($this->select) ? preg_split('/\s*,\s*/', trim($this->select), -1, PREG_SPLIT_NO_EMPTY) : $this->select;
				$select2 = is_string($query->select) ? preg_split('/\s*,\s*/', trim($query->select), -1, PREG_SPLIT_NO_EMPTY) : $query->select;
				$this->select = array_merge($select1, array_diff($select2, $select1));
			}
		}

		if ($this->selectOption !== $query->selectOption) {
			if ($this->selectOption === null) {
				$this->selectOption = $query->selectOption;
			} elseif ($query->selectOption !== null) {
				$this->selectOption .= ' ' . $query->selectOption;
			}
		}

		if ($query->distinct) {
			$this->distinct = $query->distinct;
		}

		if ($this->where !== $query->where) {
			if (empty($this->where)) {
				$this->where = $query->where;
			} elseif (!empty($query->where)) {
				$this->where = array('AND', $this->where, $query->where);
			}
		}

		if ($this->params !== $query->params) {
			$this->params = $this->addParams($query->params);
		}

		if ($query->limit !== null) {
			$this->limit = $query->limit;
		}

		if ($query->offset !== null) {
			$this->offset = $query->offset;
		}

		if ($this->orderBy !== $query->orderBy) {
			if (empty($this->orderBy)) {
				$this->orderBy = $query->orderBy;
			} elseif (!empty($query->orderBy)) {
				if (!is_array($this->orderBy)) {
					$this->orderBy = array($this->orderBy);
				}
				if (is_array($query->orderBy)) {
					$this->orderBy = array_merge($this->orderBy, $query->orderBy);
				} else {
					$this->orderBy[] = $query->orderBy;
				}
			}
		}

		if ($this->groupBy !== $query->groupBy) {
			if (empty($this->groupBy)) {
				$this->groupBy = $query->groupBy;
			} elseif (!empty($query->groupBy)) {
				if (!is_array($this->groupBy)) {
					$this->groupBy = array($this->groupBy);
				}
				if (is_array($query->groupBy)) {
					$this->groupBy = array_merge($this->groupBy, $query->groupBy);
				} else {
					$this->groupBy[] = $query->groupBy;
				}
			}
		}

		if ($this->join !== $query->join) {
			if (empty($this->join)) {
				$this->join = $query->join;
			} elseif (!empty($query->join)) {
				if (!is_array($this->join)) {
					$this->join = array($this->join);
				}
				if (is_array($query->join)) {
					$this->join = array_merge($this->join, $query->join);
				} else {
					$this->join[] = $query->join;
				}
			}
		}

		if ($this->having !== $query->having) {
			if (empty($this->having)) {
				$this->having = $query->having;
			} elseif (!empty($query->having)) {
				$this->having = array('AND', $this->having, $query->having);
			}
		}

		if ($this->union !== $query->union) {
			if (empty($this->union)) {
				$this->union = $query->union;
			} elseif (!empty($query->union)) {
				if (!is_array($this->union)) {
					$this->union = array($this->union);
				}
				if (is_array($query->union)) {
					$this->union = array_merge($this->union, $query->union);
				} else {
					$this->union[] = $query->union;
				}
			}
		}
	}

	/**
	 * Appends a condition to the existing {@link condition}.
	 * The new condition and the existing condition will be concatenated via the specified operator
	 * which defaults to 'AND'.
	 * The new condition can also be an array. In this case, all elements in the array
	 * will be concatenated together via the operator.
	 * This method handles the case when the existing condition is empty.
	 * After calling this method, the {@link condition} property will be modified.
	 * @param mixed $condition the new condition. It can be either a string or an array of strings.
	 * @param string $operator the operator to join different conditions. Defaults to 'AND'.
	 * @return Query the criteria object itself
	 */
	public function addCondition($condition, $operator = 'AND')
	{
		if (is_array($condition)) {
			if ($condition === array()) {
				return $this;
			}
			$condition = '(' . implode(') ' . $operator . ' (', $condition) . ')';
		}
		if ($this->condition === '') {
			$this->condition = $condition;
		} else
		{
			$this->condition = '(' . $this->condition . ') ' . $operator . ' (' . $condition . ')';
		}
		return $this;
	}

	/**
	 * Appends a search condition to the existing {@link condition}.
	 * The search condition and the existing condition will be concatenated via the specified operator
	 * which defaults to 'AND'.
	 * The search condition is generated using the SQL LIKE operator with the given column name and
	 * search keyword.
	 * @param string $column the column name (or a valid SQL expression)
	 * @param string $keyword the search keyword. This interpretation of the keyword is affected by the next parameter.
	 * @param boolean $escape whether the keyword should be escaped if it contains characters % or _.
	 * When this parameter is true (default), the special characters % (matches 0 or more characters)
	 * and _ (matches a single character) will be escaped, and the keyword will be surrounded with a %
	 * character on both ends. When this parameter is false, the keyword will be directly used for
	 * matching without any change.
	 * @param string $operator the operator used to concatenate the new condition with the existing one.
	 * Defaults to 'AND'.
	 * @param string $like the LIKE operator. Defaults to 'LIKE'. You may also set this to be 'NOT LIKE'.
	 * @return Query the criteria object itself
	 */
	public function addSearchCondition($column, $keyword, $escape = true, $operator = 'AND', $like = 'LIKE')
	{
		if ($keyword == '') {
			return $this;
		}
		if ($escape) {
			$keyword = '%' . strtr($keyword, array('%' => '\%', '_' => '\_', '\\' => '\\\\')) . '%';
		}
		$condition = $column . " $like " . self::PARAM_PREFIX . self::$paramCount;
		$this->params[self::PARAM_PREFIX . self::$paramCount++] = $keyword;
		return $this->addCondition($condition, $operator);
	}

	/**
	 * Appends an IN condition to the existing {@link condition}.
	 * The IN condition and the existing condition will be concatenated via the specified operator
	 * which defaults to 'AND'.
	 * The IN condition is generated by using the SQL IN operator which requires the specified
	 * column value to be among the given list of values.
	 * @param string $column the column name (or a valid SQL expression)
	 * @param array $values list of values that the column value should be in
	 * @param string $operator the operator used to concatenate the new condition with the existing one.
	 * Defaults to 'AND'.
	 * @return Query the criteria object itself
	 */
	public function addInCondition($column, $values, $operator = 'AND')
	{
		if (($n = count($values)) < 1) {
			return $this->addCondition('0=1', $operator);
		} // 0=1 is used because in MSSQL value alone can't be used in WHERE
		if ($n === 1) {
			$value = reset($values);
			if ($value === null) {
				return $this->addCondition($column . ' IS NULL');
			}
			$condition = $column . '=' . self::PARAM_PREFIX . self::$paramCount;
			$this->params[self::PARAM_PREFIX . self::$paramCount++] = $value;
		} else
		{
			$params = array();
			foreach ($values as $value)
			{
				$params[] = self::PARAM_PREFIX . self::$paramCount;
				$this->params[self::PARAM_PREFIX . self::$paramCount++] = $value;
			}
			$condition = $column . ' IN (' . implode(', ', $params) . ')';
		}
		return $this->addCondition($condition, $operator);
	}

	/**
	 * Appends an NOT IN condition to the existing {@link condition}.
	 * The NOT IN condition and the existing condition will be concatenated via the specified operator
	 * which defaults to 'AND'.
	 * The NOT IN condition is generated by using the SQL NOT IN operator which requires the specified
	 * column value to be among the given list of values.
	 * @param string $column the column name (or a valid SQL expression)
	 * @param array $values list of values that the column value should not be in
	 * @param string $operator the operator used to concatenate the new condition with the existing one.
	 * Defaults to 'AND'.
	 * @return Query the criteria object itself
	 */
	public function addNotInCondition($column, $values, $operator = 'AND')
	{
		if (($n = count($values)) < 1) {
			return $this;
		}
		if ($n === 1) {
			$value = reset($values);
			if ($value === null) {
				return $this->addCondition($column . ' IS NOT NULL');
			}
			$condition = $column . '!=' . self::PARAM_PREFIX . self::$paramCount;
			$this->params[self::PARAM_PREFIX . self::$paramCount++] = $value;
		} else
		{
			$params = array();
			foreach ($values as $value)
			{
				$params[] = self::PARAM_PREFIX . self::$paramCount;
				$this->params[self::PARAM_PREFIX . self::$paramCount++] = $value;
			}
			$condition = $column . ' NOT IN (' . implode(', ', $params) . ')';
		}
		return $this->addCondition($condition, $operator);
	}

	/**
	 * Appends a condition for matching the given list of column values.
	 * The generated condition will be concatenated to the existing {@link condition}
	 * via the specified operator which defaults to 'AND'.
	 * The condition is generated by matching each column and the corresponding value.
	 * @param array $columns list of column names and values to be matched (name=>value)
	 * @param string $columnOperator the operator to concatenate multiple column matching condition. Defaults to 'AND'.
	 * @param string $operator the operator used to concatenate the new condition with the existing one.
	 * Defaults to 'AND'.
	 * @return Query the criteria object itself
	 */
	public function addColumnCondition($columns, $columnOperator = 'AND', $operator = 'AND')
	{
		$params = array();
		foreach ($columns as $name => $value)
		{
			if ($value === null) {
				$params[] = $name . ' IS NULL';
			} else
			{
				$params[] = $name . '=' . self::PARAM_PREFIX . self::$paramCount;
				$this->params[self::PARAM_PREFIX . self::$paramCount++] = $value;
			}
		}
		return $this->addCondition(implode(" $columnOperator ", $params), $operator);
	}

	/**
	 * Adds a comparison expression to the {@link condition} property.
	 *
	 * This method is a helper that appends to the {@link condition} property
	 * with a new comparison expression. The comparison is done by comparing a column
	 * with the given value using some comparison operator.
	 *
	 * The comparison operator is intelligently determined based on the first few
	 * characters in the given value. In particular, it recognizes the following operators
	 * if they appear as the leading characters in the given value:
	 * <ul>
	 * <li><code>&lt;</code>: the column must be less than the given value.</li>
	 * <li><code>&gt;</code>: the column must be greater than the given value.</li>
	 * <li><code>&lt;=</code>: the column must be less than or equal to the given value.</li>
	 * <li><code>&gt;=</code>: the column must be greater than or equal to the given value.</li>
	 * <li><code>&lt;&gt;</code>: the column must not be the same as the given value.
	 * Note that when $partialMatch is true, this would mean the value must not be a substring
	 * of the column.</li>
	 * <li><code>=</code>: the column must be equal to the given value.</li>
	 * <li>none of the above: the column must be equal to the given value. Note that when $partialMatch
	 * is true, this would mean the value must be the same as the given value or be a substring of it.</li>
	 * </ul>
	 *
	 * Note that any surrounding white spaces will be removed from the value before comparison.
	 * When the value is empty, no comparison expression will be added to the search condition.
	 *
	 * @param string $column the name of the column to be searched
	 * @param mixed $value the column value to be compared with. If the value is a string, the aforementioned
	 * intelligent comparison will be conducted. If the value is an array, the comparison is done
	 * by exact match of any of the value in the array. If the string or the array is empty,
	 * the existing search condition will not be modified.
	 * @param boolean $partialMatch whether the value should consider partial text match (using LIKE and NOT LIKE operators).
	 * Defaults to false, meaning exact comparison.
	 * @param string $operator the operator used to concatenate the new condition with the existing one.
	 * Defaults to 'AND'.
	 * @param boolean $escape whether the value should be escaped if $partialMatch is true and
	 * the value contains characters % or _. When this parameter is true (default),
	 * the special characters % (matches 0 or more characters)
	 * and _ (matches a single character) will be escaped, and the value will be surrounded with a %
	 * character on both ends. When this parameter is false, the value will be directly used for
	 * matching without any change.
	 * @return Query the criteria object itself
	 */
	public function compare($column, $value, $partialMatch = false, $operator = 'AND', $escape = true)
	{
		if (is_array($value)) {
			if ($value === array()) {
				return $this;
			}
			return $this->addInCondition($column, $value, $operator);
		} else
		{
			$value = "$value";
		}

		if (preg_match('/^(?:\s*(<>|<=|>=|<|>|=))?(.*)$/', $value, $matches)) {
			$value = $matches[2];
			$op = $matches[1];
		} else
		{
			$op = '';
		}

		if ($value === '') {
			return $this;
		}

		if ($partialMatch) {
			if ($op === '') {
				return $this->addSearchCondition($column, $value, $escape, $operator);
			}
			if ($op === '<>') {
				return $this->addSearchCondition($column, $value, $escape, $operator, 'NOT LIKE');
			}
		} elseif ($op === '')
		{
			$op = '=';
		}

		$this->addCondition($column . $op . self::PARAM_PREFIX . self::$paramCount, $operator);
		$this->params[self::PARAM_PREFIX . self::$paramCount++] = $value;

		return $this;
	}

	/**
	 * Adds a between condition to the {@link condition} property.
	 *
	 * The new between condition and the existing condition will be concatenated via
	 * the specified operator which defaults to 'AND'.
	 * If one or both values are empty then the condition is not added to the existing condition.
	 * This method handles the case when the existing condition is empty.
	 * After calling this method, the {@link condition} property will be modified.
	 * @param string $column the name of the column to search between.
	 * @param string $valueStart the beginning value to start the between search.
	 * @param string $valueEnd the ending value to end the between search.
	 * @param string $operator the operator used to concatenate the new condition with the existing one.
	 * Defaults to 'AND'.
	 * @return Query the criteria object itself
	 */
	public function addBetweenCondition($column, $valueStart, $valueEnd, $operator = 'AND')
	{
		if ($valueStart === '' || $valueEnd === '') {
			return $this;
		}

		$paramStart = self::PARAM_PREFIX . self::$paramCount++;
		$paramEnd = self::PARAM_PREFIX . self::$paramCount++;
		$this->params[$paramStart] = $valueStart;
		$this->params[$paramEnd] = $valueEnd;
		$condition = "$column BETWEEN $paramStart AND $paramEnd";

		if ($this->condition === '') {
			$this->condition = $condition;
		} else
		{
			$this->condition = '(' . $this->condition . ') ' . $operator . ' (' . $condition . ')';
		}
		return $this;
	}

	public function reset()
	{
		$this->select = null;
		$this->selectOption = null;
		$this->from = null;
		$this->distinct = null;
		$this->where = null;
		$this->limit = null;
		$this->offset = null;
		$this->orderBy = null;
		$this->groupBy = null;
		$this->join = null;
		$this->having = null;
		$this->params = array();
		$this->union = null;
	}

	public function fromArray($array)
	{
		$this->reset();
		foreach (array('select', 'selectOption', 'from', 'distinct', 'where', 'limit', 'offset', 'orderBy', 'groupBy', 'join', 'having', 'params', 'union') as $name) {
			if (isset($array[$name])) {
				$this->$name = $array[$name];
			}
		}
	}

	/**
	 * @return array the array representation of the criteria
	 */
	public function toArray()
	{
		$result = array();
		foreach (array('select', 'selectOption', 'from', 'distinct', 'where', 'limit', 'offset', 'orderBy', 'groupBy', 'join', 'having', 'params', 'union') as $name) {
			if (!empty($this->$name)) {
				$result[$name] = $this->$name;
			}
		}
		return $result;
	}
}