rkrx / php-mysql-query-builder

src/Builder/Helpers/YieldPolyfillIterator.php

Spacing +8 added lines, -8 removed lines

@@ -42,16 +42,16 @@ 
 	 */
 	public function current() {
 		$row = $this->currentItem;
-		if($this->preserveTypes) {
+		if ($this->preserveTypes) {
 			$columnDefinitions = FieldTypeProvider::getFieldTypes($this->getStmt());
 			$row = FieldValueConverter::convertValues($row, $columnDefinitions);
 		}
 		$callback = $this->callback;
-		if($callback !== null) {
+		if ($callback !== null) {
 			$result = $callback($row);
-			if($result instanceof DBIgnoreRow) {
+			if ($result instanceof DBIgnoreRow) {
 				// Do nothing in this case
-			} elseif($result !== null) {
+			} elseif ($result !== null) {
 				return $result;
 			} else {
 				return $row;
@@ -79,7 +79,7 @@ 
 	 */
 	public function valid() {
 		$result = !!$this->currentItem;
-		if(!$result) {
+		if (!$result) {
 			$this->closeCursor();
 		}
 		return $result;
@@ -88,7 +88,7 @@ 
 	/**
 	 */
 	public function rewind() {
-		if($this->stmt !== null) {
+		if ($this->stmt !== null) {
 			throw new RuntimeException("It's not possible to rewind this iterator");
 		}
 		$this->stmt = call_user_func($this->statementFactory);
@@ -100,7 +100,7 @@ 
 	 * @return QueryStatement
 	 */
 	private function getStmt() {
-		if($this->stmt === null) {
+		if ($this->stmt === null) {
 			$this->rewind();
 		}
 		return $this->stmt;
@@ -109,7 +109,7 @@ 
 	/**
 	 */
 	private function closeCursor() {
-		if($this->stmt instanceof QueryStatement) {
+		if ($this->stmt instanceof QueryStatement) {
 			$this->stmt->closeCursor();
 		}
 		$this->stmt = null;

src/Builder/Traits/HavingBuilder.php

Spacing +2 added lines, -2 removed lines

@@ -16,8 +16,8 @@
 	 * @return $this
 	 */
 	public function having($expression, $_ = null) {
-		if($expression instanceof OptionalExpression) {
-			if($expression->isValid()) {
+		if ($expression instanceof OptionalExpression) {
+			if ($expression->isValid()) {
 				$this->having[] = [$expression->getExpression(), $expression->getValue()];
 			}
 		} else {

src/Builder/Traits/WhereBuilder.php

Spacing +2 added lines, -2 removed lines

@@ -16,8 +16,8 @@
 	 * @return $this
 	 */
 	public function where($expression, $_ = null) {
-		if($expression instanceof OptionalExpression) {
-			if($expression->isValid()) {
+		if ($expression instanceof OptionalExpression) {
+			if ($expression->isValid()) {
 				$this->where[] = [$expression->getExpression(), $expression->getValue()];
 			}
 		} else {

src/Tools/VirtualTables.php

Spacing +3 added lines, -3 removed lines

@@ -30,10 +30,10 @@
 	 * @return Select|null
 	 */
 	public function get($tableName) {
-		if($this->has($tableName)) {
+		if ($this->has($tableName)) {
 			$table = $this->virtualTables[(string) $tableName];
-			if($table instanceof \Closure) {
-				if($tableName instanceof VirtualTable) {
+			if ($table instanceof \Closure) {
+				if ($tableName instanceof VirtualTable) {
 					$params = $tableName->getParams();
 					return call_user_func($table, $params);
 				}

src/Builder/Traits/TableNameBuilder.php

Spacing +10 added lines, -10 removed lines

@@ -13,36 +13,36 @@
 	 * @return string
 	 */
 	protected function buildTableName($alias, $name) {
-		if(is_object($name) && !($name instanceof VirtualTable)) {
+		if (is_object($name) && !($name instanceof VirtualTable)) {
 			$name = (string) $name;
 			$lines = explode("\n", $name);
-			foreach($lines as &$line) {
+			foreach ($lines as &$line) {
 				$line = "\t{$line}";
 			}
 			$name = join("\n", $lines);
-			$name = '(' . trim(rtrim(trim($name), ';')) . ')';
+			$name = '('.trim(rtrim(trim($name), ';')).')';
 		}
-		if(is_array($name)) {
+		if (is_array($name)) {
 			$parts = [];
-			foreach($name as $index => $bucket) {
-				if(ctype_digit((string) $index) && is_scalar($bucket)) {
+			foreach ($name as $index => $bucket) {
+				if (ctype_digit((string) $index) && is_scalar($bucket)) {
 					$parts[] = "SELECT {$this->db()->quote($bucket)} AS {$this->db()->quoteField('value')}";
 				} else {
 					$values = [];
-					foreach($bucket as $field => $value) {
+					foreach ($bucket as $field => $value) {
 						$values[] = sprintf('%s AS %s', $this->db()->quote($value), $this->db()->quoteField($field));
 					}
 					$parts[] = sprintf("SELECT %s", join(', ', $values));
 				}
 			}
-			$name = '(' . join("\n\tUNION\n\t", $parts) . ')';
+			$name = '('.join("\n\tUNION\n\t", $parts).')';
 		}
-		if($this->db()->getVirtualTables()->has($name)) {
+		if ($this->db()->getVirtualTables()->has($name)) {
 			$select = (string) $this->db()->getVirtualTables()->get($name);
 			$name = sprintf('(%s)', join("\n\t", explode("\n", trim($select))));
 		}
 		$name = $this->aliasReplacer()->replace($name);
-		if($alias !== null) {
+		if ($alias !== null) {
 			return sprintf("%s %s", $name, $alias);
 		}
 		return $name;

src/Databases/MySQL/MySQLExceptionInterpreter.php

Spacing +2 added lines, -2 removed lines

@@ -18,7 +18,7 @@ 
 		$errorInfo = $exception->errorInfo;
 		$code = is_array($errorInfo) && isset($errorInfo[1]) ? ((int) $errorInfo[1]) : ((int) $exception->getCode());
 		$message = (string) $exception->getMessage();
-		switch($code) {
+		switch ($code) {
 			case 2006: throw new DatabaseHasGoneAwayException($message, $code, $exception);
 			case 1213: throw new SqlDeadLockException($message, $code, $exception);
 			case 1205: throw new LockWaitTimeoutExceededException($message, $code, $exception);
@@ -31,7 +31,7 @@ 
 			case 1452: throw new IntegrityConstraintViolationException($message, (int) $code, $exception);
 		}
 		/** @link http://php.net/manual/en/class.exception.php#Hcom115813 (cHao's comment) */
-		if(!is_string($message) || !is_int($code)) {
+		if (!is_string($message) || !is_int($code)) {
 			throw new SqlException((string) $message, (int) $code, $exception);
 		}
 		throw $exception;

src/Builder/Expr/DBExprFilter.php

Spacing +11 added lines, -11 removed lines

@@ -27,16 +27,16 @@ 
 		$this->value = $data;
 		$this->keyPath = $this->buildKey($keyPath);
 		$this->value = $this->recursiveGet($data, $this->keyPath, null);
-		if($validator === null) {
-			$validator = function ($data) {
-				if(is_array($data)) {
+		if ($validator === null) {
+			$validator = function($data) {
+				if (is_array($data)) {
 					return $this->isValidArray($data);
 				}
 				return (string) $data !== '';
 			};
 		}
-		if($validationResultHandler === null) {
-			$validationResultHandler = function () {};
+		if ($validationResultHandler === null) {
+			$validationResultHandler = function() {};
 		}
 		$this->validator = $validator;
 		$this->validationResultHandler = $validationResultHandler;
@@ -73,10 +73,10 @@ 
 	 * @return string
 	 */
 	private function buildKey($keyPath) {
-		if(is_string($keyPath)) {
+		if (is_string($keyPath)) {
 			$keyPath = explode('.', $keyPath);
 		}
-		if(!is_array($keyPath)) {
+		if (!is_array($keyPath)) {
 			throw new RuntimeException('Invalid key');
 		}
 		return $keyPath;
@@ -87,8 +87,8 @@ 
 	 * @return bool
 	 */
 	private function isValidArray(array $array) {
-		$data = array_filter($array, function ($value) {
-			if(is_array($value)) {
+		$data = array_filter($array, function($value) {
+			if (is_array($value)) {
 				return $this->isValidArray($value);
 			}
 			return (string) $value !== '';
@@ -107,9 +107,9 @@ 
 		if (!$count) {
 			return $default;
 		}
-		for($idx = 0; $idx < $count; $idx++) {
+		for ($idx = 0; $idx < $count; $idx++) {
 			$part = $path[$idx];
-			if(!array_key_exists($part, $array)) {
+			if (!array_key_exists($part, $array)) {
 				return $default;
 			}
 			$array = $array[$part];

src/Builder/Traits/OrderByBuilder.php

Spacing +7 added lines, -7 removed lines

@@ -15,8 +15,8 @@ 
 	 * @return $this
 	 */
 	public function orderBy($expression, $direction = 'asc') {
-		if($expression instanceof OrderBySpecification) {
-			foreach($expression->getFields() as $field) {
+		if ($expression instanceof OrderBySpecification) {
+			foreach ($expression->getFields() as $field) {
 				$this->addOrder($field[0], $field[1]);
 			}
 			return $this;
@@ -32,7 +32,7 @@ 
 	 */
 	public function orderByValues($fieldName, array $values) {
 		$expr = [];
-		foreach(array_values($values) as $idx => $value) {
+		foreach (array_values($values) as $idx => $value) {
 			$expr[] = $this->db()->quoteExpression("WHEN ? THEN ?", [$value, $idx]);
 		}
 		$this->orderBy[] = [sprintf("CASE %s\n\t\t%s\n\tEND", $this->db()->quoteField($fieldName), join("\n\t\t", $expr)), 'ASC'];
@@ -44,12 +44,12 @@ 
 	 * @return string
 	 */
 	protected function buildOrder($query) {
-		if(!count($this->orderBy)) {
+		if (!count($this->orderBy)) {
 			return $query;
 		}
 		$query .= "ORDER BY\n";
 		$arr = [];
-		foreach($this->orderBy as $order) {
+		foreach ($this->orderBy as $order) {
 			list($expression, $direction) = $order;
 			$arr[] = sprintf("\t%s %s", $expression, strtoupper($direction));
 		}
@@ -62,8 +62,8 @@ 
 	 */
 	private function addOrder($expression, $direction) {
 		$direction = $this->fixDirection($direction);
-		if(is_array($expression)) {
-			if(!count($expression)) {
+		if (is_array($expression)) {
+			if (!count($expression)) {
 				return;
 			}
 			$arguments = [

src/Builder/Traits/JoinBuilder.php

Spacing +5 added lines, -5 removed lines

@@ -47,15 +47,15 @@
 	 */
 	protected function buildJoins($query) {
 		$arr = [];
-		foreach($this->joinTables as $table) {
+		foreach ($this->joinTables as $table) {
 			$join = $table['type']." JOIN\n";
-			$join .= "\t" . $this->buildTableName($table['alias'], $table['name']);
-			if($table['expression']) {
-				$join .= " ON " . $this->db()->quoteExpression($table['expression'], $table['arguments']);
+			$join .= "\t".$this->buildTableName($table['alias'], $table['name']);
+			if ($table['expression']) {
+				$join .= " ON ".$this->db()->quoteExpression($table['expression'], $table['arguments']);
 			}
 			$arr[] = $join;
 		}
-		if(count($arr)) {
+		if (count($arr)) {
 			$query .= join("\n", $arr)."\n";
 		}
 		return $query;