rkrx / php-mysql-query-builder

src/Builder/Expr/DBExprOrderBySpec.php

Spacing +8 added lines, -8 removed lines

@@ -14,17 +14,17 @@ 
 	 */
 	public function __construct(array $spec, array $sortFieldsSpec) {
 		$expressions = [];
-		foreach($spec as $specReference => $dbExpr) {
-			if(is_int($specReference)) {
+		foreach ($spec as $specReference => $dbExpr) {
+			if (is_int($specReference)) {
 				$specReference = $dbExpr;
 			}
 			$expressions[$specReference] = $dbExpr;
 		}
-		foreach($sortFieldsSpec as $sortFieldSpec) {
-			if(array_key_exists(0, $sortFieldSpec)) {
-				if(array_key_exists($sortFieldSpec[0], $expressions)) {
+		foreach ($sortFieldsSpec as $sortFieldSpec) {
+			if (array_key_exists(0, $sortFieldSpec)) {
+				if (array_key_exists($sortFieldSpec[0], $expressions)) {
 					$direction = 'ASC';
-					if(array_key_exists(1, $sortFieldSpec) && strtoupper($sortFieldSpec[1]) !== 'ASC') {
+					if (array_key_exists(1, $sortFieldSpec) && strtoupper($sortFieldSpec[1]) !== 'ASC') {
 						$direction = 'DESC';
 					}
 					$this->fields[] = [
@@ -33,9 +33,9 @@ 
 					];
 				}
 			} else { // @phpstan-ignore-line
-				foreach($sortFieldSpec as $alias => $direction) {
+				foreach ($sortFieldSpec as $alias => $direction) {
 					$direction = strtoupper($direction) === 'DESC' ? 'DESC' : 'ASC';
-					if(array_key_exists($alias, $expressions)) {
+					if (array_key_exists($alias, $expressions)) {
 						$this->fields[] = [$expressions[$alias], $direction];
 					}
 				}

src/Builder/Expr/RequiredDBFilterMap.php

Spacing +1 added lines, -1 removed lines

@@ -36,7 +36,7 @@
 	 * @return DBExprFilter
 	 */
 	public function __invoke(string $expression, $keyPath, $validator = null) {
-		if(!RecursiveStructureAccess::recursiveHas($this->map, $keyPath)) {
+		if (!RecursiveStructureAccess::recursiveHas($this->map, $keyPath)) {
 			throw new RequiredValueNotFoundException(sprintf("Required value %s not found", json_encode($keyPath, JSON_UNESCAPED_SLASHES | JSON_UNESCAPED_UNICODE)));
 		}
 		return new DBExprFilter($expression, $this->map, $keyPath, $validator);

src/Builder/Expr/DBOrderSpec.php

Spacing +3 added lines, -3 removed lines

@@ -41,13 +41,13 @@
 	public function getFields(): array {
 		$fields = [];
 		$max = $this->options['max_sort_instructions'] ?? 16;
-		foreach($this->sortingInstruction as $alias => $direction) {
+		foreach ($this->sortingInstruction as $alias => $direction) {
 			$direction = strtolower($direction) === 'desc' ? 'DESC' : 'ASC';
-			if(!array_key_exists($alias, $this->sortSpecification)) {
+			if (!array_key_exists($alias, $this->sortSpecification)) {
 				throw new DBSortAliasNotFoundException('Sorting: Alias for DB-Expression not found');
 			}
 			$fields[] = [$this->sortSpecification[$alias], $direction];
-			if($max < 1) {
+			if ($max < 1) {
 				throw new DBSortTooManyInstructionsException();
 			}
 			$max--;

src/Builder/Helpers/RecursiveStructureAccess.php

Spacing +10 added lines, -10 removed lines

@@ -28,9 +28,9 @@ 
 		if (!$count) {
 			return $default;
 		}
-		foreach($arrayPath as $idxValue) {
+		foreach ($arrayPath as $idxValue) {
 			$part = $idxValue;
-			if(!array_key_exists($part, $data)) {
+			if (!array_key_exists($part, $data)) {
 				return $default;
 			}
 			$data = $data[$part];
@@ -45,14 +45,14 @@ 
 	 */
 	private static function _recursiveHas($structure, array $path): bool {
 		$data = self::ensureArrayIsArray($structure);
-		if($data === null) {
+		if ($data === null) {
 			return false;
 		}
-		if(!count($path)) {
+		if (!count($path)) {
 			return false;
 		}
 		$key = array_shift($path);
-		if(count($path)) {
+		if (count($path)) {
 			return self::_recursiveHas($data[$key] ?? null, $path);
 		}
 		return array_key_exists($key, $data);
@@ -63,11 +63,11 @@ 
 	 * @return array<int, string>
 	 */
 	private static function getArrayPath($path): array {
-		if(is_array($path)) {
+		if (is_array($path)) {
 			return $path;
 		}
 		$parts = preg_split('{(?<!\\x5C)(?:\\x5C\\x5C)*\\.}', $path);
-		if($parts === false) {
+		if ($parts === false) {
 			return [$path];
 		}
 		return $parts;
@@ -78,13 +78,13 @@ 
 	 * @return array<mixed, mixed>
 	 */
 	private static function ensureArrayIsArray($array): ?array {
-		if($array instanceof ArrayObject) {
+		if ($array instanceof ArrayObject) {
 			return $array->getArrayCopy();
 		}
-		if(is_object($array)) {
+		if (is_object($array)) {
 			return (array) $array;
 		}
-		if(is_array($array)) {
+		if (is_array($array)) {
 			return $array;
 		}
 		return null;

src/Builder/Value/DBOptionalValue.php

Spacing +2 added lines, -2 removed lines

@@ -27,10 +27,10 @@
 	 * @return bool
 	 */
 	public function isValid(): bool {
-		if(!RecursiveStructureAccess::recursiveHas($this->data, $this->path)) {
+		if (!RecursiveStructureAccess::recursiveHas($this->data, $this->path)) {
 			return false;
 		}
-		if($this->validator !== null) {
+		if ($this->validator !== null) {
 			$value = $this->getValue();
 			return call_user_func($this->validator, $value);
 		}

src/Builder/Traits/OffsetBuilder.php

Spacing +5 added lines, -5 removed lines

@@ -12,7 +12,7 @@ 
 	 * @return null|int
 	 */
 	protected function getOffset(): ?int {
-		if($this->offset instanceof OptionalValue) {
+		if ($this->offset instanceof OptionalValue) {
 			return $this->offset->getValue();
 		}
 		return $this->offset;
@@ -33,15 +33,15 @@ 
 	 */
 	protected function buildOffset(string $query): string {
 		$offset = $this->getOffset();
-		if($this->offset instanceof OptionalValue) {
-			if($this->offset->isValid()) {
+		if ($this->offset instanceof OptionalValue) {
+			if ($this->offset->isValid()) {
 				$value = $this->offset->getValue();
-				if(!preg_match('{\\d+}', $value)) {
+				if (!preg_match('{\\d+}', $value)) {
 					throw new InvalidValueException('Value for OFFSET has to be a number');
 				}
 				$query .= "OFFSET\n\t{$this->offset->getValue()}\n";
 			}
-		} elseif($offset !== null) {
+		} elseif ($offset !== null) {
 			$query .= "OFFSET\n\t{$this->offset}\n";
 		}
 		return $query;

src/Builder/Traits/LimitBuilder.php

Spacing +6 added lines, -6 removed lines

@@ -12,7 +12,7 @@ 
 	 * @return null|int
 	 */
 	protected function getLimit(): ?int {
-		if($this->limit instanceof OptionalValue) {
+		if ($this->limit instanceof OptionalValue) {
 			return $this->limit->getValue();
 		}
 		return $this->limit;
@@ -34,18 +34,18 @@ 
 	 */
 	protected function buildLimit(string $query, ?int $offset = null) {
 		$limit = $this->getLimit();
-		if($limit === null && $offset !== null) {
+		if ($limit === null && $offset !== null) {
 			$limit = '18446744073709551615';
 		}
-		if($this->limit instanceof OptionalValue) {
-			if($this->limit->isValid()) {
+		if ($this->limit instanceof OptionalValue) {
+			if ($this->limit->isValid()) {
 				$value = $this->limit->getValue();
-				if(!preg_match('{\\d+}', $value)) {
+				if (!preg_match('{\\d+}', $value)) {
 					throw new InvalidValueException('Value for LIMIT has to be a number');
 				}
 				$query .= "LIMIT\n\t{$this->limit->getValue()}\n";
 			}
-		} elseif($limit !== null) {
+		} elseif ($limit !== null) {
 			$query .= "LIMIT\n\t{$limit}\n";
 		}
 		return $query;

src/Builder/Insert.php

Spacing +21 added lines, -21 removed lines

@@ -89,7 +89,7 @@ 
 	 * @return $this
 	 */
 	public function addExpr(string $str, ...$args) {
-		if(count($args) > 0) {
+		if (count($args) > 0) {
 			$this->fields[] = func_get_args();
 		} else {
 			$this->fields[] = $str;
@@ -103,7 +103,7 @@ 
 	 * @return $this
 	 */
 	public function updateExpr(string $str, ...$args) {
-		if(count($args) > 0) {
+		if (count($args) > 0) {
 			$this->update[] = func_get_args();
 		} else {
 			$this->update[] = $str;
@@ -117,7 +117,7 @@ 
 	 * @return $this
 	 */
 	public function addOrUpdateExpr(string $expr, ...$args) {
-		if(count($args) > 0) {
+		if (count($args) > 0) {
 			$this->fields[] = func_get_args();
 			$this->update[] = func_get_args();
 		} else {
@@ -134,7 +134,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;
@@ -147,8 +147,8 @@ 
 	 * @return $this
 	 */
 	public function updateAll(array $data, array $mask = null, array $excludeFields = null) {
-		$this->addAllTo($data, $mask, $excludeFields, function ($field, $value) {
-			if($field !== $this->keyField) {
+		$this->addAllTo($data, $mask, $excludeFields, function($field, $value) {
+			if ($field !== $this->keyField) {
 				$this->update($field, $value);
 			}
 		});
@@ -192,7 +192,7 @@ 
 	 * @return string
 	 */
 	public function __toString(): string {
-		if($this->table === null) {
+		if ($this->table === null) {
 			throw new RuntimeException('Specify a table-name');
 		}
 
@@ -202,21 +202,21 @@ 
 		$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", implode(', ', array_keys($fields)));
 			$queryArr[] = $this->from;
 		} else {
 			$fields = $this->fields;
 			$insertData = $this->buildFieldList($fields);
-			if(!count($insertData)) {
+			if (!count($insertData)) {
 				throw new RuntimeException('No field-data found');
 			}
 			$queryArr[] = sprintf("SET\n%s\n", implode(",\n", $insertData));
 		}
 
 		$updateData = $this->buildUpdate();
-		if($updateData) {
+		if ($updateData) {
 			$queryArr[] = "{$updateData}\n";
 		}
 
@@ -230,7 +230,7 @@ 
 	 * @return array<string|int, mixed>
 	 */
 	private function addTo(array $fields, string $field, $value): array {
-		if(!$this->isFieldNameValid($field)) {
+		if (!$this->isFieldNameValid($field)) {
 			throw new UnexpectedValueException('Field name is invalid');
 		}
 		$sqlField = $field;
@@ -246,18 +246,18 @@ 
 	 * @param callable(string, mixed): void $fn
 	 */
 	private function addAllTo(array $data, ?array $mask, ?array $excludeFields, $fn): void {
-		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]);
 				}
 			}
 		}
 		$data = $this->clearValues($data);
-		foreach($data as $field => $value) {
+		foreach ($data as $field => $value) {
 			$fn($field, $value);
 		}
 	}
@@ -267,10 +267,10 @@ 
 	 */
 	private function buildUpdate(): string {
 		$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);
@@ -293,7 +293,7 @@ 
 	 * @return array<string, mixed>
 	 */
 	private function clearValues(array $values): array {
-		if(!count($values)) {
+		if (!count($values)) {
 			return [];
 		}
 
@@ -301,8 +301,8 @@ 
 		$fields = $this->db()->getTableFields($tableName);
 		$result = [];
 
-		foreach($values as $fieldName => $fieldValue) {
-			if(in_array($fieldName, $fields)) {
+		foreach ($values as $fieldName => $fieldValue) {
+			if (in_array($fieldName, $fields)) {
 				$result[$fieldName] = $fieldValue;
 			}
 		}

src/Databases/MySQL/MySQLExceptionInterpreter.php

Spacing +1 added lines, -1 removed lines

@@ -19,7 +19,7 @@
 		/** @link http://php.net/manual/en/class.exception.php#Hcom115813 (cHao's comment) */
 		$code = is_array($errorInfo) && isset($errorInfo[1]) ? ((int) $errorInfo[1]) : ((int) $exception->getCode());
 		$message = $exception->getMessage();
-		switch($code) {
+		switch ($code) {
 			case 2006: return new DatabaseHasGoneAwayException($message, $code, $exception);
 			case 1213: return new SqlDeadLockException($message, $code, $exception);
 			case 1205: return new LockWaitTimeoutExceededException($message, $code, $exception);