DbQueryConstructor::setAlias() - Code Metrics - Inspection of "DBAL-misc-41a50.63: Moved statement-related SELECT..." - supernova-ws/SuperNova - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Push — work-fleets ( 99e92e...73ed38 )

by SuperNova.WS

created 2016-07-25 14:18 UTC

DbQueryConstructor::setAlias() A

↳ Parent: DbQueryConstructor

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	1
Bugs	0	Features	0

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

<?php

/**
 * Class DbQueryConstructor
 *
 * @method DbQueryConstructor fields(mixed $value, int $mergeStrategy = HelperArray::MERGE_PHP)
 * @method DbQueryConstructor join(mixed $value, int $mergeStrategy = HelperArray::MERGE_PHP)
 * @method DbQueryConstructor where(array $value, int $mergeStrategy = HelperArray::MERGE_PHP)
 * @method DbQueryConstructor groupBy(array $value, int $mergeStrategy = HelperArray::MERGE_PHP)
 * @method DbQueryConstructor orderBy(array $value, int $mergeStrategy = HelperArray::MERGE_PHP)
 * @method DbQueryConstructor having(mixed $value, int $mergeStrategy = HelperArray::MERGE_PHP)
 * @method DbQueryConstructor setFetchOne(bool $fetchOne = true)
 * @method DbQueryConstructor setForUpdate(bool $forUpdate = true)
 * @method DbQueryConstructor setSkipLock(bool $skipLock = true)
 *
 */
class DbQueryConstructor extends DbSqlAware {

  const SELECT = 'SELECT';
  const INSERT = 'INSERT';
  const UPDATE = 'UPDATE';
  const DELETE = 'DELETE';
  const REPLACE = 'REPLACE';

  protected static $allowedOperations = array(
    self::SELECT,
  );

  /**
   * List of array properties names that should be merged on each call of setter
   *
   * @var string[] $propListArrayMerge
   */
  protected static $propListArrayMerge = array('fields', 'join', 'where', 'groupBy', 'orderBy', 'having');
  /**
   * List of setters that will simple set property with default value TRUE
   *
   * @var string[] $propListSetDefaultTrue
   */
  protected static $propListSetDefaultTrue = array('setFetchOne', 'setForUpdate', 'setSkipLock');

  public $operation = '';

  public $table = '';
  public $alias = '';

  public $idField = '';

  /**
   * @var array
   */
  public $fields = array();

  public $join = array();

  public $where = array();
  public $groupBy = array();
  public $orderBy = array();
  public $having = array();

  public $limit = 0;
  public $offset = 0;

  public $fetchOne = false;
  public $forUpdate = false;
  public $skipLock = false;

  public $variables = array();

  protected $_compiledQuery = array();

  /**
   * @param string $fieldName
   *
   * @return $this
   */
  public function setIdField($fieldName) {
    $this->idField = $fieldName;

    return $this;
  }

  /**
   * Sets internal variables
   *
   * @param array $values
   *
   * @return $this
   */
  public function variables($values) {
    $this->variables = $values;

    return $this;
  }


  /**
   * @param string $alias
   *
   * @return $this
   */
  public function setAlias($alias) {
    $this->alias = $alias;

    return $this;
  }

  /**
   * @return $this
   */
  public function select() {
    $this->operation = DbQueryConstructor::SELECT;
//    if (empty($this->fields) && $initFields) {

//      $this->fields = array('*');
//    }

    return $this;
  }


  /**
   * @param string $tableName
   * @param string $alias
   *
   * @return $this
   */
  public function from($tableName, $alias = '') {
    $this->table = $tableName;
    $this->setAlias($alias);

    return $this;
  }

  /**
   * @param mixed ...
   *
   * @return $this
   */
  public function field() {
    $arguments = func_get_args();

    // Special case - call method with array of fields
    if (count($arguments) == 1 && is_array($arguments[0])) {
      $arguments = array_shift($arguments);
    }

    foreach ($arguments as $arg) {
$collection = json_decode($data, true);
if ( ! is_array($collection)) {
    throw new \RuntimeException('$collection must be an array.');
}

foreach ($collection as $item) { /** ... */ }
      $this->fields[] = $arg;
    }

    return $this;
  }

  public function fieldLiteral($field = '0', $alias = DbSqlLiteral::SQL_LITERAL_ALIAS_NONE) {

    return $this->field(DbSqlLiteral::build($this->db)->literal($field));
  }

  public function fieldSingleFunction($functionName, $field = '*', $alias = DbSqlLiteral::SQL_LITERAL_ALIAS_NONE) {
    return $this->field(DbSqlLiteral::build($this->db)->buildSingleArgument($functionName, $field, $alias));
  }

  public function fieldCount($field = '*', $alias = DbSqlLiteral::SQL_LITERAL_ALIAS_NONE) {
    return $this->field(DbSqlLiteral::build($this->db)->count($field, $alias));
  }

  public function fieldIsNull($field = '*', $alias = DbSqlLiteral::SQL_LITERAL_ALIAS_NONE) {
    return $this->field(DbSqlLiteral::build($this->db)->isNull($field, $alias));
  }

  public function fieldMax($field = '*', $alias = DbSqlLiteral::SQL_LITERAL_ALIAS_NONE) {
    return $this->field(DbSqlLiteral::build($this->db)->max($field, $alias));
  }

  /**
   * @param string  $name
   * @param mixed[] $arguments
   *
   * @return $this
   */
  public function __call($name, $arguments) {
    if (in_array($name, self::$propListArrayMerge)) {
//      array_unshift($arguments, '');

//      $arguments[0] = &$this->$name;
//      call_user_func_array('HelperArray::merge', $arguments);
      HelperArray::merge($this->$name, $arguments[0], HelperArray::keyExistsOr($arguments, 1, HelperArray::MERGE_PHP));
    } elseif (in_array($name, self::$propListSetDefaultTrue)) {
      $varName = lcfirst(substr($name, 3));
      if (!array_key_exists(0, $arguments)) {
        $arguments[0] = true;
      }
      $this->$varName = $arguments[0];
    }
    // TODO - make all setters protected ??

//    elseif(method_exists($this, $name)) {
//      call_user_func_array(array($this, $name), $arguments);
//    }

    return $this;
  }

  /**
   * @param int $limit
   *
   * @return $this
   */
  public function limit($limit) {
    $this->limit = is_numeric($limit) ? $limit : 0;
class Id
{
    public $id;

    public function __construct($id)
    {
        $this->id = $id;
    }

}

class Account
{
    /** @var  Id $id */
    public $id;
}

$account_id = false;

if (starsAreRight()) {
    $account_id = new Id(42);
}

$account = new Account();
if ($account instanceof Id)
{
    $account->id = $account_id;
}

    return $this;
  }

  /**
   * @param int $offset
   *
   * @return $this
   */
  public function offset($offset) {
    $this->offset = is_numeric($offset) ? $offset : 0;
class Id
{
    public $id;

    public function __construct($id)
    {
        $this->id = $id;
    }

}

class Account
{
    /** @var  Id $id */
    public $id;
}

$account_id = false;

if (starsAreRight()) {
    $account_id = new Id(42);
}

$account = new Account();
if ($account instanceof Id)
{
    $account->id = $account_id;
}

    return $this;
  }

  /**
   * @param string $className
   *
   * @return $this
   */
  // TODO - rewrite
  public function getParamsFromStaticClass($className) {
    if (is_string($className) && $className && class_exists($className)) {
      if(method_exists($className, 'getDb')) {
        $this->setDb($className::getDb());
      }
      $this->from($className::$_table);
      $this->setIdField($className::$_idField);
    }

    return $this;
  }

  /**
   * @param db_mysql|null $db
   * @param string|object|DBStaticRecord|DbSqlAware $className
   *
   * @return static
   */
  public static function build($db = null, $className = '') {
    /**
     * @var static $result
     */
    $result = parent::build(null);
    $result->getParamsFromStaticClass($className);

    return $result;
  }

  /**
   * Resets statement
   *
   * @param bool $full
   *
   * @return static
   */
  protected function _reset($full = true) {
    if ($full) {
      $this->operation = '';
      $this->table = '';
      $this->alias = '';
      $this->idField = '';
    }

    $this->fields = array();
    $this->where = array();
    $this->groupBy = array();
    $this->orderBy = array();
    $this->having = array();

    $this->limit = 0;
    $this->offset = 0;

    $this->fetchOne = false;
    $this->forUpdate = false;
    $this->skipLock = false;

    return $this;
  }


  /**
   * @param array $array
   *
   * @return array
   */
  protected function arrayEscape(&$array) {
    $result = array();
    foreach ($array as $key => &$value) {
      $result[$key] = $this->escapeString($value);
    }

    return $result;
  }

  protected function compileOperation() {
    if (empty($this->operation)) {
      throw new ExceptionDbOperationEmpty();
    }

    if (!in_array($this->operation, self::$allowedOperations)) {
      throw new ExceptionDbOperationRestricted();
    }

    $this->_compiledQuery[] = $this->escapeString($this->operation);
  }

  protected function compileSubject() {
    $this->_compiledQuery[] = $this->selectFieldsToString($this->fields);
  }

  protected function compileFrom() {
    $this->_compiledQuery[] = 'FROM `{{' . $this->escapeString($this->table) . '}}`';
    if (!empty($this->alias)) {
      $this->_compiledQuery[] = 'AS `' . $this->escapeString($this->alias) . '`';
    }
  }

  protected function compileJoin() {
    !empty($this->join) ? $this->_compiledQuery[] = implode(' ', $this->join) : false;
  }

  protected function compileWhere() {
    // TODO - fields should be escaped !!
    !empty($this->where) ? $this->_compiledQuery[] = 'WHERE ' . implode(' AND ', $this->where) : false;
  }

  protected function compileGroupBy() {
    // TODO - fields should be escaped !!

//    !empty($this->groupBy) ? $this->_compiledQuery[] = 'GROUP BY ' . implode(',', $this->arrayEscape($this->groupBy)) : false;
    !empty($this->groupBy) ? $this->_compiledQuery[] = 'GROUP BY ' . $this->selectFieldsToString($this->groupBy) : false;
  }

  protected function compileOrderBy() {
    // TODO - fields should be escaped !!
    !empty($this->orderBy) ? $this->_compiledQuery[] = 'ORDER BY ' . implode(',', $this->arrayEscape($this->orderBy)) : false;
  }

  protected function compileHaving() {
    // TODO - fields should be escaped !!
    !empty($this->having) ? $this->_compiledQuery[] = 'HAVING ' . implode(' AND ', $this->having) : false;
  }

  protected function compileLimit() {
    // TODO - fields should be escaped !!
    if ($limit = $this->fetchOne ? 1 : $this->limit) {
      $this->_compiledQuery[] = 'LIMIT ' . $limit . (!empty($this->offset) ? ' OFFSET ' . $this->offset : '');
    }
  }

  protected function compileForUpdate() {
    $this->_compiledQuery[] =
      // forUpdate flag forces select with row locking - didn't look at skipLock flag
      $this->forUpdate
      ||
      // Also row locked when transaction is up and skipLock flag is not set
      (classSupernova::db_transaction_check(false) && !$this->skipLock) ? 'FOR UPDATE' : '';
  }

  /**
   * @param array|mixed $fields
   *
   * @return string
   * @throws ExceptionDBFieldEmpty
   */
  protected function selectFieldsToString($fields) {
    HelperArray::makeArrayRef($fields);

    $result = array();
    foreach ($fields as $fieldName) {
      $string = $this->processField($fieldName);
      if ($string !== '') {
        $result[] = $string;
      }
    }

    if (empty($result)) {
      throw new ExceptionDBFieldEmpty();
    }

    return implode(',', $result);
  }

  /**
   * @param mixed $fieldName
   *
   * @return string
   */
  protected function processField($fieldName) {
    if (is_bool($fieldName)) {
      $result = (string)intval($fieldName);
    } elseif (is_numeric($fieldName)) {
      $result = $fieldName;
    } elseif (is_null($fieldName)) {
      $result = 'NULL';
    } else {
      // Field has other type - string or should be convertible to string
      $result = (string)$fieldName;
      if (!$fieldName instanceof DbSqlLiteral) {
        $result = $this->quoteField($fieldName);

      }
    }

    return $result;
  }


  /**
   * @return string
   * @throws ExceptionDbOperationEmpty
   * @throws ExceptionDbOperationRestricted
   */
  public function __toString() {
    $this->_compiledQuery = array();

    $this->compileOperation();
    $this->compileSubject();
    $this->compileFrom();
    $this->compileJoin();
    $this->compileWhere();
    $this->compileGroupBy();
    $this->compileOrderBy();
    $this->compileHaving();
    $this->compileLimit();
    $this->compileForUpdate();

    return implode(' ', $this->_compiledQuery);
  }

  /**
   * @param bool $skip_query_check
   *
   * @return DbEmptyIterator|DbMysqliResultIterator
   */
  public function selectIterator($skip_query_check = false) {
    return $this->getDb()->doQueryIterator($this->select()->__toString(), $skip_query_check);
  }

  /**
   * @param bool $skip_query_check
   *
   * @return array
   */
  public function selectRow($skip_query_check = false) {
    $result = $this->getDb()->doQueryFetch($this->select()->setFetchOne()->__toString(), $skip_query_check);

    return is_array($result) ? $result : array();
  }

  /**
   * @param bool $skip_query_check
   *
   * @return mixed|null
   */
  public function selectValue($skip_query_check = false) {
    $result = $this->selectRow($skip_query_check);

    return is_array($result) ? reset($result) : null;
  }

}


1		<?php
2
3		/**
4		* Class DbQueryConstructor
5		*
6		* @method DbQueryConstructor fields(mixed $value, int $mergeStrategy = HelperArray::MERGE_PHP)
7		* @method DbQueryConstructor join(mixed $value, int $mergeStrategy = HelperArray::MERGE_PHP)
8		* @method DbQueryConstructor where(array $value, int $mergeStrategy = HelperArray::MERGE_PHP)
9		* @method DbQueryConstructor groupBy(array $value, int $mergeStrategy = HelperArray::MERGE_PHP)
10		* @method DbQueryConstructor orderBy(array $value, int $mergeStrategy = HelperArray::MERGE_PHP)
11		* @method DbQueryConstructor having(mixed $value, int $mergeStrategy = HelperArray::MERGE_PHP)
12		* @method DbQueryConstructor setFetchOne(bool $fetchOne = true)
13		* @method DbQueryConstructor setForUpdate(bool $forUpdate = true)
14		* @method DbQueryConstructor setSkipLock(bool $skipLock = true)
15		*
16		*/
17		class DbQueryConstructor extends DbSqlAware {
18
19		const SELECT = 'SELECT';
20		const INSERT = 'INSERT';
21		const UPDATE = 'UPDATE';
22		const DELETE = 'DELETE';
23		const REPLACE = 'REPLACE';
24
25		protected static $allowedOperations = array(
26		self::SELECT,
27		);
28
29		/**
30		* List of array properties names that should be merged on each call of setter
31		*
32		* @var string[] $propListArrayMerge
33		*/
34		protected static $propListArrayMerge = array('fields', 'join', 'where', 'groupBy', 'orderBy', 'having');
35		/**
36		* List of setters that will simple set property with default value TRUE
37		*
38		* @var string[] $propListSetDefaultTrue
39		*/
40		protected static $propListSetDefaultTrue = array('setFetchOne', 'setForUpdate', 'setSkipLock');
41
42		public $operation = '';
43
44		public $table = '';
45		public $alias = '';
46
47		public $idField = '';
48
49		/**
50		* @var array
51		*/
52		public $fields = array();
53
54		public $join = array();
55
56		public $where = array();
57		public $groupBy = array();
58		public $orderBy = array();
59		public $having = array();
60
61		public $limit = 0;
62		public $offset = 0;
63
64		public $fetchOne = false;
65		public $forUpdate = false;
66		public $skipLock = false;
67
68		public $variables = array();
69
70		protected $_compiledQuery = array();
71
72		/**
73		* @param string $fieldName
74		*
75		* @return $this
76		*/
77	2	public function setIdField($fieldName) {
78	2	$this->idField = $fieldName;
79
80	2	return $this;
81		}
82
83		/**
84		* Sets internal variables
85		*
86		* @param array $values
87		*
88		* @return $this
89		*/
90		public function variables($values) {
91		$this->variables = $values;
92
93		return $this;
94		}
95
96
97		/**
98		* @param string $alias
99		*
100		* @return $this
101		*/
102	1	public function setAlias($alias) {
103	1	$this->alias = $alias;
104
105	1	return $this;
106		}
107
108		/**
109		* @return $this
110		*/
111	3	public function select() {
112	3	$this->operation = DbQueryConstructor::SELECT;
113		// if (empty($this->fields) && $initFields) {
		0 ignored issues – show Unused Code Comprehensibility introduced 2016-05-24 15:46 UTC by Report Bug Copy Issue Report `58%` of this comment could be valid code. Did you maybe forget this after debugging? Sometimes obsolete code just ends up commented out instead of removed. In this case it is better to remove the code once you have checked you do not need it. The code might also have been commented out for debugging purposes. In this case it is vital that someone uncomments it again or your project may behave in very unexpected ways in production. This check looks for comments that seem to be mostly valid code and reports them. Loading history...
114		// $this->fields = array('*');
115		// }
116
117	3	return $this;
118		}
119
120
121		/**
122		* @param string $tableName
123		* @param string $alias
124		*
125		* @return $this
126		*/
127	2	public function from($tableName, $alias = '') {
128	2	$this->table = $tableName;
129	2	$this->setAlias($alias);
130
131	2	return $this;
132		}
133
134		/**
135		* @param mixed ...
136		*
137		* @return $this
138		*/
139	1	public function field() {
140	1	$arguments = func_get_args();
141
142		// Special case - call method with array of fields
143	1	if (count($arguments) == 1 && is_array($arguments[0])) {
144		$arguments = array_shift($arguments);
145		}
146
147	1	foreach ($arguments as $arg) {
		0 ignored issues – show Bug introduced 2016-05-24 15:46 UTC by Report Bug Copy Issue Report The expression `$arguments` of type `array\|null` is not guaranteed to be traversable. How about adding an additional type check? There are different options of fixing this problem. If you want to be on the safe side, you can add an additional type-check: $collection = json_decode($data, true); if ( ! is_array($collection)) { throw new \RuntimeException('$collection must be an array.'); } foreach ($collection as $item) { /** ... / } If you are sure that the expression is traversable, you might want to add a doc comment cast* to improve IDE auto-completion and static analysis: /** @var array $collection / $collection = json_decode($data, true); foreach ($collection as $item) { /* .. / } Mark the issue as a false-positive*: Just hover the remove button, in the top-right corner of this issue for more options. Loading history...
148	1	$this->fields[] = $arg;
149	1	}
150
151	1	return $this;
152		}
153
154		public function fieldLiteral($field = '0', $alias = DbSqlLiteral::SQL_LITERAL_ALIAS_NONE) {
		0 ignored issues – show Unused Code introduced 2016-06-11 22:02 UTC by Report Bug Copy Issue Report The parameter `$alias` is not used and could be removed. This check looks from parameters that have been defined for a function or method, but which are not used in the method body. Loading history...
155		return $this->field(DbSqlLiteral::build($this->db)->literal($field));
156		}
157
158		public function fieldSingleFunction($functionName, $field = '*', $alias = DbSqlLiteral::SQL_LITERAL_ALIAS_NONE) {
159		return $this->field(DbSqlLiteral::build($this->db)->buildSingleArgument($functionName, $field, $alias));
160		}
161
162		public function fieldCount($field = '*', $alias = DbSqlLiteral::SQL_LITERAL_ALIAS_NONE) {
163		return $this->field(DbSqlLiteral::build($this->db)->count($field, $alias));
164		}
165
166		public function fieldIsNull($field = '*', $alias = DbSqlLiteral::SQL_LITERAL_ALIAS_NONE) {
167		return $this->field(DbSqlLiteral::build($this->db)->isNull($field, $alias));
168		}
169
170		public function fieldMax($field = '*', $alias = DbSqlLiteral::SQL_LITERAL_ALIAS_NONE) {
171		return $this->field(DbSqlLiteral::build($this->db)->max($field, $alias));
172		}
173
174		/**
175		* @param string $name
176	4	* @param mixed[] $arguments
177	4	*
178		* @return $this
179		*/
180		public function __call($name, $arguments) {
181	3	if (in_array($name, self::$propListArrayMerge)) {
182	4	// array_unshift($arguments, '');
		0 ignored issues – show Unused Code Comprehensibility introduced 2016-05-21 21:57 UTC by Report Bug Copy Issue Report `64%` of this comment could be valid code. Did you maybe forget this after debugging? Sometimes obsolete code just ends up commented out instead of removed. In this case it is better to remove the code once you have checked you do not need it. The code might also have been commented out for debugging purposes. In this case it is vital that someone uncomments it again or your project may behave in very unexpected ways in production. This check looks for comments that seem to be mostly valid code and reports them. Loading history...
183	2	// $arguments[0] = &$this->$name;
184	2	// call_user_func_array('HelperArray::merge', $arguments);
185	2	HelperArray::merge($this->$name, $arguments[0], HelperArray::keyExistsOr($arguments, 1, HelperArray::MERGE_PHP));
186	2	} elseif (in_array($name, self::$propListSetDefaultTrue)) {
187	2	$varName = lcfirst(substr($name, 3));
188	2	if (!array_key_exists(0, $arguments)) {
189		$arguments[0] = true;
190		}
191		$this->$varName = $arguments[0];
192		}
193		// TODO - make all setters protected ??
		0 ignored issues – show Unused Code Comprehensibility introduced 2016-05-21 21:57 UTC by Report Bug Copy Issue Report `50%` of this comment could be valid code. Did you maybe forget this after debugging? Sometimes obsolete code just ends up commented out instead of removed. In this case it is better to remove the code once you have checked you do not need it. The code might also have been commented out for debugging purposes. In this case it is vital that someone uncomments it again or your project may behave in very unexpected ways in production. This check looks for comments that seem to be mostly valid code and reports them. Loading history...
194	4	// elseif(method_exists($this, $name)) {
195		// call_user_func_array(array($this, $name), $arguments);
196		// }
197
198		return $this;
199		}
200
201		/**
202	2	* @param int $limit
203	2	*
204		* @return $this
205	2	*/
206		public function limit($limit) {
207		$this->limit = is_numeric($limit) ? $limit : 0;
		0 ignored issues – show Documentation Bug introduced 2016-05-21 18:10 UTC by Report Bug Copy Issue Report It seems like `is_numeric($limit) ? $limit : 0` can also be of type `double` or `string`. However, the property `$limit` is declared as type `integer`. Maybe add an additional type check? Our type inference engine has found a suspicous assignment of a value to a property. This check raises an issue when a value that can be of a mixed type is assigned to a property that is type hinted more strictly. For example, imagine you have a variable `$accountId` that can either hold an Id object or false (if there is no account id yet). Your code now assigns that value to the `id` property of an instance of the `Account` class. This class holds a proper account, so the id value must no longer be false. Either this assignment is in error or a type check should be added for that assignment. class Id { public $id; public function __construct($id) { $this->id = $id; } } class Account { /** @var Id $id */ public $id; } $account_id = false; if (starsAreRight()) { $account_id = new Id(42); } $account = new Account(); if ($account instanceof Id) { $account->id = $account_id; } Loading history...
208
209		return $this;
210		}
211
212		/**
213	2	* @param int $offset
214	2	*
215		* @return $this
216	2	*/
217		public function offset($offset) {
218		$this->offset = is_numeric($offset) ? $offset : 0;
		0 ignored issues – show Documentation Bug introduced 2016-05-21 18:10 UTC by Report Bug Copy Issue Report It seems like `is_numeric($offset) ? $offset : 0` can also be of type `double` or `string`. However, the property `$offset` is declared as type `integer`. Maybe add an additional type check? Our type inference engine has found a suspicous assignment of a value to a property. This check raises an issue when a value that can be of a mixed type is assigned to a property that is type hinted more strictly. For example, imagine you have a variable `$accountId` that can either hold an Id object or false (if there is no account id yet). Your code now assigns that value to the `id` property of an instance of the `Account` class. This class holds a proper account, so the id value must no longer be false. Either this assignment is in error or a type check should be added for that assignment. class Id { public $id; public function __construct($id) { $this->id = $id; } } class Account { /** @var Id $id */ public $id; } $account_id = false; if (starsAreRight()) { $account_id = new Id(42); } $account = new Account(); if ($account instanceof Id) { $account->id = $account_id; } Loading history...
219
220		return $this;
221		}
222
223		/**
224		* @param string $className
225		*
226		* @return $this
227		*/
228		// TODO - rewrite
229		public function getParamsFromStaticClass($className) {
230		if (is_string($className) && $className && class_exists($className)) {
231		if(method_exists($className, 'getDb')) {
232		$this->setDb($className::getDb());
233		}
234		$this->from($className::$_table);
235		$this->setIdField($className::$_idField);
236		}
237
238		return $this;
239		}
240
241		/**
242		* @param db_mysql\|null $db
243		* @param string\|object\|DBStaticRecord\|DbSqlAware $className
244		*
245		* @return static
246		*/
247		public static function build($db = null, $className = '') {
248		/**
249		* @var static $result
250		*/
251		$result = parent::build(null);
252		$result->getParamsFromStaticClass($className);
253
254	2	return $result;
255	2	}
256	2
257	2	/**
258	2	* Resets statement
259		*
260	2	* @param bool $full
261		*
262		* @return static
263		*/
264		protected function _reset($full = true) {
265		if ($full) {
266		$this->operation = '';
267		$this->table = '';
268		$this->alias = '';
269	1	$this->idField = '';
270		}
271
272		$this->fields = array();
273	1	$this->where = array();
274	1	$this->groupBy = array();
275		$this->orderBy = array();
276		$this->having = array();
277
278	1	$this->limit = 0;
279		$this->offset = 0;
280
281		$this->fetchOne = false;
282		$this->forUpdate = false;
283		$this->skipLock = false;
284
285		return $this;
286		}
287
288	1
289	1	/**
290	1	* @param array $array
291	1	*
292	1	* @return array
293	1	*/
294	1	protected function arrayEscape(&$array) {
295		$result = array();
296	1	foreach ($array as $key => &$value) {
297	1	$result[$key] = $this->escapeString($value);
298	1	}
299	1
300	1	return $result;
301		}
302	1
303	1	protected function compileOperation() {
304		if (empty($this->operation)) {
305	1	throw new ExceptionDbOperationEmpty();
306	1	}
307	1
308		if (!in_array($this->operation, self::$allowedOperations)) {
309	1	throw new ExceptionDbOperationRestricted();
310		}
311
312		$this->_compiledQuery[] = $this->escapeString($this->operation);
313		}
314
315		protected function compileSubject() {
316		$this->_compiledQuery[] = $this->selectFieldsToString($this->fields);
317		}
318
319		protected function compileFrom() {
320		$this->_compiledQuery[] = 'FROM `{{' . $this->escapeString($this->table) . '}}`';
321		if (!empty($this->alias)) {
322		$this->_compiledQuery[] = 'AS `' . $this->escapeString($this->alias) . '`';
323		}
324		}
325
326		protected function compileJoin() {
327		!empty($this->join) ? $this->_compiledQuery[] = implode(' ', $this->join) : false;
328		}
329
330		protected function compileWhere() {
331		// TODO - fields should be escaped !!
332		!empty($this->where) ? $this->_compiledQuery[] = 'WHERE ' . implode(' AND ', $this->where) : false;
333		}
334
335		protected function compileGroupBy() {
336		// TODO - fields should be escaped !!
		0 ignored issues – show Unused Code Comprehensibility introduced 2016-05-22 23:56 UTC by Report Bug Copy Issue Report `47%` of this comment could be valid code. Did you maybe forget this after debugging? Sometimes obsolete code just ends up commented out instead of removed. In this case it is better to remove the code once you have checked you do not need it. The code might also have been commented out for debugging purposes. In this case it is vital that someone uncomments it again or your project may behave in very unexpected ways in production. This check looks for comments that seem to be mostly valid code and reports them. Loading history...
337		// !empty($this->groupBy) ? $this->_compiledQuery[] = 'GROUP BY ' . implode(',', $this->arrayEscape($this->groupBy)) : false;
338		!empty($this->groupBy) ? $this->_compiledQuery[] = 'GROUP BY ' . $this->selectFieldsToString($this->groupBy) : false;
339		}
340
341		protected function compileOrderBy() {
342		// TODO - fields should be escaped !!
343		!empty($this->orderBy) ? $this->_compiledQuery[] = 'ORDER BY ' . implode(',', $this->arrayEscape($this->orderBy)) : false;
344		}
345
346		protected function compileHaving() {
347		// TODO - fields should be escaped !!
348		!empty($this->having) ? $this->_compiledQuery[] = 'HAVING ' . implode(' AND ', $this->having) : false;
349		}
350
351		protected function compileLimit() {
352		// TODO - fields should be escaped !!
353		if ($limit = $this->fetchOne ? 1 : $this->limit) {
354		$this->_compiledQuery[] = 'LIMIT ' . $limit . (!empty($this->offset) ? ' OFFSET ' . $this->offset : '');
355		}
356		}
357
358		protected function compileForUpdate() {
359		$this->_compiledQuery[] =
360		// forUpdate flag forces select with row locking - didn't look at skipLock flag
361		$this->forUpdate
362		\|\|
363		// Also row locked when transaction is up and skipLock flag is not set
364		(classSupernova::db_transaction_check(false) && !$this->skipLock) ? 'FOR UPDATE' : '';
365		}
366
367		/**
368		* @param array\|mixed $fields
369		*
370		* @return string
371		* @throws ExceptionDBFieldEmpty
372		*/
373		protected function selectFieldsToString($fields) {
374		HelperArray::makeArrayRef($fields);
375
376		$result = array();
377		foreach ($fields as $fieldName) {
378		$string = $this->processField($fieldName);
379		if ($string !== '') {
380		$result[] = $string;
381		}
382		}
383
384		if (empty($result)) {
385		throw new ExceptionDBFieldEmpty();
386		}
387
388		return implode(',', $result);
389		}
390
391		/**
392		* @param mixed $fieldName
393		*
394		* @return string
395		*/
396		protected function processField($fieldName) {
397	16	if (is_bool($fieldName)) {
398	16	$result = (string)intval($fieldName);
399		} elseif (is_numeric($fieldName)) {
400	16	$result = $fieldName;
401	16	} elseif (is_null($fieldName)) {
402	15	$result = 'NULL';
403	15	} else {
404	13	// Field has other type - string or should be convertible to string
405	13	$result = (string)$fieldName;
406	16	if (!$fieldName instanceof DbSqlLiteral) {
407		$result = $this->quoteField($fieldName);
		0 ignored issues – show Bug introduced 2016-05-26 12:10 UTC by Report Bug Copy Issue Report It seems like `$fieldName` defined by parameter `$fieldName` on line 396 can also be of type `array` or `object`; however, `DbSqlAware::quoteField()` does only seem to accept `string`, maybe add an additional type check? This check looks at variables that have been passed in as parameters and are passed out again to other methods. If the outgoing method call has stricter type requirements than the method itself, an issue is raised. An additional type check may prevent trouble. Loading history...
408	16	}
409	3	}
410
411		return $result;
412	13	}
413
414
415		/**
416		* @return string
417		* @throws ExceptionDbOperationEmpty
418		* @throws ExceptionDbOperationRestricted
419		*/
420	13	public function __toString() {
421	13	$this->_compiledQuery = array();
422	4
423	13	$this->compileOperation();
424	5	$this->compileSubject();
425	11	$this->compileFrom();
426	2	$this->compileJoin();
427	2	$this->compileWhere();
428		$this->compileGroupBy();
429	6	$this->compileOrderBy();
430	6	$this->compileHaving();
431	5	$this->compileLimit();
432	5	$this->compileForUpdate();
433
434		return implode(' ', $this->_compiledQuery);
435	13	}
436
437		/**
438		* @param bool $skip_query_check
439		*
440		* @return DbEmptyIterator\|DbMysqliResultIterator
441		*/
442		public function selectIterator($skip_query_check = false) {
443		return $this->getDb()->doQueryIterator($this->select()->__toString(), $skip_query_check);
444	2	}
445	2
446		/**
447	2	* @param bool $skip_query_check
448		*
449		* @return array
450		*/
451		public function selectRow($skip_query_check = false) {
452		$result = $this->getDb()->doQueryFetch($this->select()->setFetchOne()->__toString(), $skip_query_check);
453
454		return is_array($result) ? $result : array();
455		}
456
457		/**
458		* @param bool $skip_query_check
459		*
460		* @return mixed\|null
461		*/
462		public function selectValue($skip_query_check = false) {
463		$result = $this->selectRow($skip_query_check);
464
465		return is_array($result) ? reset($result) : null;
466		}
467
468		}
469

supernova-ws / SuperNova

Push — work-fleets ( 99e92e...73ed38 )

DbQueryConstructor::setAlias() A

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like