rkrx / php-mysql-query-builder

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/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;

src/Builder/Traits/TableBuilder.php

Spacing +3 added lines, -3 removed lines

@@ -13,7 +13,7 @@ 
 	 * @return $this
 	 */
 	protected function addTable($alias, $table = null) {
-		if($table === null) {
+		if ($table === null) {
 			list($alias, $table) = [$table, $alias];
 		}
 		$this->tables[] = ['alias' => $alias, 'name' => $table];
@@ -26,10 +26,10 @@ 
 	 */
 	protected function buildTables($query) {
 		$arr = [];
-		foreach($this->tables as $table) {
+		foreach ($this->tables as $table) {
 			$arr[] = "\t".$this->buildTableName($table['alias'], $table['name']);
 		}
-		if(count($arr)) {
+		if (count($arr)) {
 			$query .= join(",\n", $arr)."\n";
 		}
 		return $query;

src/Builder/Traits/GroupByBuilder.php

Spacing +5 added lines, -5 removed lines

@@ -11,9 +11,9 @@ 
 	 * @return $this
 	 */
 	public function groupBy() {
-		foreach(func_get_args() as $expression) {
-			if(is_array($expression)) {
-				if(!count($expression)) {
+		foreach (func_get_args() as $expression) {
+			if (is_array($expression)) {
+				if (!count($expression)) {
 					continue;
 				}
 				$arguments = [
@@ -32,12 +32,12 @@ 
 	 * @return string
 	 */
 	protected function buildGroups($query) {
-		if(!count($this->groupBy)) {
+		if (!count($this->groupBy)) {
 			return $query;
 		}
 		$query .= "GROUP BY\n";
 		$arr = [];
-		foreach($this->groupBy as $expression) {
+		foreach ($this->groupBy as $expression) {
 			$arr[] = "\t{$expression}";
 		}
 		return $query.join(",\n", $arr)."\n";

src/Builder/Helpers/FieldTypeProvider.php

Spacing +1 added lines, -1 removed lines

@@ -10,7 +10,7 @@
 	 */
 	public static function getFieldTypes(QueryStatement $statement) {
 		$fieldTypes = [];
-		for($i = 0; $column = $statement->getColumnMeta($i); $i++) {
+		for ($i = 0; $column = $statement->getColumnMeta($i); $i++) {
 			$fieldTypes[$column['name']] = self::getTypeFromNativeType($column['native_type']);
 		}
 		return $fieldTypes;

src/Builder/RunnableSelect.php

Spacing +24 added lines, -24 removed lines

@@ -91,7 +91,7 @@ 
 	 * @return mixed[]
 	 */
 	public function fetchRow(Closure $callback = null) {
-		return $this->fetch($callback, PDO::FETCH_ASSOC, null, function ($row) {
+		return $this->fetch($callback, PDO::FETCH_ASSOC, null, function($row) {
 			return ['valid' => is_array($row), 'default' => []];
 		});
 	}
@@ -120,7 +120,7 @@ 
 	 * @return object[]
 	 */
 	public function fetchObject($className = null, Closure $callback = null) {
-		return $this->fetch($callback, PDO::FETCH_CLASS, $className ?: $this->defaultClassName, function ($row) {
+		return $this->fetch($callback, PDO::FETCH_CLASS, $className ?: $this->defaultClassName, function($row) {
 			return ['valid' => is_object($row), 'default' => null];
 		});
 	}
@@ -130,11 +130,11 @@ 
 	 * @return mixed[]
 	 */
 	public function fetchKeyValue($treatValueAsArray = false) {
-		return $this->createTempStatement(function (QueryStatement $statement) use ($treatValueAsArray) {
-			if($treatValueAsArray) {
+		return $this->createTempStatement(function(QueryStatement $statement) use ($treatValueAsArray) {
+			if ($treatValueAsArray) {
 				$rows = $statement->fetchAll(\PDO::FETCH_ASSOC);
 				$result = [];
-				foreach($rows as $row) {
+				foreach ($rows as $row) {
 					list($key) = array_values($row);
 					$result[$key] = $row;
 				}
@@ -151,11 +151,11 @@ 
 	public function fetchGroups(array $fields) {
 		$rows = $this->fetchRows();
 		$result = [];
-		foreach($rows as $row) {
+		foreach ($rows as $row) {
 			$tmp = &$result;
-			foreach($fields as $field) {
+			foreach ($fields as $field) {
 				$value = $row[$field];
-				if(!array_key_exists($value, $tmp)) {
+				if (!array_key_exists($value, $tmp)) {
 					$tmp[$value] = [];
 				}
 				$tmp = &$tmp[$value];
@@ -169,7 +169,7 @@ 
 	 * @return string[]
 	 */
 	public function fetchArray() {
-		return $this->createTempStatement(function (QueryStatement $stmt) {
+		return $this->createTempStatement(function(QueryStatement $stmt) {
 			return $stmt->fetchAll(\PDO::FETCH_COLUMN);
 		});
 	}
@@ -179,9 +179,9 @@ 
 	 * @return null|bool|string|int|float
 	 */
 	public function fetchValue($default = null) {
-		return $this->createTempStatement(function (QueryStatement $stmt) use ($default) {
+		return $this->createTempStatement(function(QueryStatement $stmt) use ($default) {
 			$result = $stmt->fetch(\PDO::FETCH_NUM);
-			if($result !== false) {
+			if ($result !== false) {
 				return $result[0];
 			}
 			return $default;
@@ -219,7 +219,7 @@ 
 		$query = $this->__toString();
 		$statement = $db->prepare($query);
 		$statement->execute($this->values);
-		if($this->getCalcFoundRows()) {
+		if ($this->getCalcFoundRows()) {
 			$this->foundRows = (int) $db->query('SELECT FOUND_ROWS()')->fetchColumn();
 		}
 		return $statement;
@@ -239,20 +239,20 @@ 
 	 * @return mixed
 	 */
 	private function fetchAll(Closure $callback = null, $mode, $arg0 = null) {
-		return $this->createTempStatement(function (QueryStatement $statement) use ($callback, $mode, $arg0) {
+		return $this->createTempStatement(function(QueryStatement $statement) use ($callback, $mode, $arg0) {
 			$statement->setFetchMode($mode, $arg0);
 			$data = $statement->fetchAll();
-			if($this->preserveTypes) {
+			if ($this->preserveTypes) {
 				$columnDefinitions = FieldTypeProvider::getFieldTypes($statement);
-				foreach($data as &$row) {
+				foreach ($data as &$row) {
 					$row = FieldValueConverter::convertValues($row, $columnDefinitions);
 				}
 			}
-			if($callback !== null) {
-				return call_user_func(function ($resultData = []) use ($data, $callback) {
-					foreach($data as $row) {
+			if ($callback !== null) {
+				return call_user_func(function($resultData = []) use ($data, $callback) {
+					foreach ($data as $row) {
 						$result = $callback($row);
-						if($result !== null && !($result instanceof DBIgnoreRow)) {
+						if ($result !== null && !($result instanceof DBIgnoreRow)) {
 							$resultData[] = $result;
 						} else {
 							$resultData[] = $row;
@@ -286,20 +286,20 @@ 
 	 * @return mixed
 	 */
 	private function fetch(Closure $callback = null, $mode, $arg0 = null, Closure $resultValidator = null) {
-		return $this->createTempStatement(function (QueryStatement $statement) use ($callback, $mode, $arg0, $resultValidator) {
+		return $this->createTempStatement(function(QueryStatement $statement) use ($callback, $mode, $arg0, $resultValidator) {
 			$statement->setFetchMode($mode, $arg0);
 			$row = $statement->fetch();
 			$result = $resultValidator($row);
-			if(!$result['valid']) {
+			if (!$result['valid']) {
 				return $result['default'];
 			}
-			if($this->preserveTypes) {
+			if ($this->preserveTypes) {
 				$columnDefinitions = FieldTypeProvider::getFieldTypes($statement);
 				$row = FieldValueConverter::convertValues($row, $columnDefinitions);
 			}
-			if($callback !== null) {
+			if ($callback !== null) {
 				$result = $callback($row);
-				if($result !== null) {
+				if ($result !== null) {
 					$row = $result;
 				}
 			}

src/Builder/Internal/DDLRunnable.php

Spacing +1 added lines, -1 removed lines

@@ -25,7 +25,7 @@
 	public function run(array $params = []) {
 		$this->query->execute($params);
 		$response = $this->query->getStatement()->rowCount();
-		if($this->callbackFn !== null) {
+		if ($this->callbackFn !== null) {
 			$response = call_user_func($this->callbackFn, $response);
 		}
 		return $response;

src/Builder/Insert.php

Spacing +15 added lines, -15 removed lines

@@ -89,7 +89,7 @@ 
 	 * @return $this
 	 */
 	public function addExpr($str, $_ = null) {
-		if(count(func_get_args()) > 1) {
+		if (count(func_get_args()) > 1) {
 			$this->fields[] = func_get_args();
 		} else {
 			$this->fields[] = $str;
@@ -103,7 +103,7 @@ 
 	 * @return $this
 	 */
 	public function updateExpr($str, $_ = null) {
-		if(count(func_get_args()) > 1) {
+		if (count(func_get_args()) > 1) {
 			$this->update[] = func_get_args();
 		} else {
 			$this->update[] = $str;
@@ -116,7 +116,7 @@ 
 	 * @return $this
 	 */
 	public function addOrUpdateExpr($str) {
-		if(count(func_get_args()) > 1) {
+		if (count(func_get_args()) > 1) {
 			$this->fields[] = func_get_args();
 			$this->update[] = func_get_args();
 		} else {
@@ -133,7 +133,7 @@ 
 	 * @return $this
 	 */
 	public function addAll(array $data, array $mask = null, array $excludeFields = null) {
-		$this->addAllTo($data, $mask, $excludeFields, function ($field, $value) {
+		$this->addAllTo($data, $mask, $excludeFields, function($field, $value) {
 			$this->add($field, $value);
 		});
 		return $this;
@@ -146,7 +146,7 @@ 
 	 * @return $this
 	 */
 	public function updateAll(array $data, array $mask = null, array $excludeFields = null) {
-		$this->addAllTo($data, $mask, $excludeFields, function ($field, $value) {
+		$this->addAllTo($data, $mask, $excludeFields, function($field, $value) {
 			if ($field !== $this->keyField) {
 				$this->update($field, $value);
 			}
@@ -190,7 +190,7 @@ 
 		$ignoreStr = $this->ignore ? ' IGNORE' : '';
 		$queryArr[] = "INSERT{$ignoreStr} INTO\n\t{$tableName}\n";
 
-		if($this->from !== null) {
+		if ($this->from !== null) {
 			$fields = $this->from->getFields();
 			$queryArr[] = sprintf("\t(%s)\n", join(', ', array_keys($fields)));
 			$queryArr[] = $this->from;
@@ -204,7 +204,7 @@ 
 		}
 
 		$updateData = $this->buildUpdate();
-		if($updateData) {
+		if ($updateData) {
 			$queryArr[] = "{$updateData}\n";
 		}
 
@@ -237,12 +237,12 @@ 
 	 * @return $this
 	 */
 	private function addAllTo(array $data, array $mask = null, array $excludeFields = null, $fn) {
-		if($mask !== null) {
+		if ($mask !== null) {
 			$data = array_intersect_key($data, array_combine($mask, $mask));
 		}
-		if($excludeFields !== null) {
-			foreach($excludeFields as $excludeField) {
-				if(array_key_exists($excludeField, $data)) {
+		if ($excludeFields !== null) {
+			foreach ($excludeFields as $excludeField) {
+				if (array_key_exists($excludeField, $data)) {
 					unset($data[$excludeField]);
 				}
 			}
@@ -259,10 +259,10 @@ 
 	 */
 	private function buildUpdate() {
 		$queryArr = [];
-		if(!empty($this->update)) {
+		if (!empty($this->update)) {
 			$queryArr[] = "ON DUPLICATE KEY UPDATE\n";
 			$updateArr = [];
-			if($this->keyField !== null) {
+			if ($this->keyField !== null) {
 				$updateArr[] = "\t`{$this->keyField}` = LAST_INSERT_ID({$this->keyField})";
 			}
 			$updateArr = $this->buildFieldList($this->update, $updateArr);
@@ -285,7 +285,7 @@ 
 	 * @return array
 	 */
 	private function clearValues(array $values) {
-		if(!count($values)) {
+		if (!count($values)) {
 			return [];
 		}
 
@@ -294,7 +294,7 @@ 
 		$result = [];
 
 		foreach ($values as $fieldName => $fieldValue) {
-			if(in_array($fieldName, $fields)) {
+			if (in_array($fieldName, $fields)) {
 				$result[$fieldName] = $fieldValue;
 			}
 		}