rkrx / php-mysql-query-builder

src/Tools/JsonTable.php

Spacing +2 added lines, -2 removed lines

@@ -40,8 +40,8 @@
 	 */
 	private function translateColumns(Database $db, $columns) {
 		$result = [];
-		foreach($columns as $column) {
-			if(!is_string($column)) {
+		foreach ($columns as $column) {
+			if (!is_string($column)) {
 				$column = sprintf('%s %s PATH \'%s\'', $column['name'], $column['type'], $column['jsonPath']);
 			}
 			$result[] = $column;

src/Builder/Expr/DBExprFilter.php

Spacing +8 added lines, -8 removed lines

@@ -26,19 +26,19 @@ 
 	public function __construct(
 		private string $expression,
 		array $data,
-		string|array $keyPath,
+		string | array $keyPath,
 		$validator = null,
 		$validationResultHandler = null
 	) {
 		$this->keyPath = $this->buildKey($keyPath);
 		$this->value = RecursiveStructureAccess::recursiveGet($data, $this->keyPath, null);
 		$this->hasValue = is_scalar($this->value) ? trim((string) $this->value) !== '' : !empty($this->value);
-		if($validator === null) {
+		if ($validator === null) {
 			$validator = static fn() => true;
 		}
 		$this->validator = $validator;
-		if($validationResultHandler === null) {
-			$validationResultHandler = static function () {};
+		if ($validationResultHandler === null) {
+			$validationResultHandler = static function() {};
 		}
 		$this->validationResultHandler = $validationResultHandler;
 	}
@@ -54,10 +54,10 @@ 
 	 * @return bool
 	 */
 	public function isValid(): bool {
-		if(!$this->hasValue) {
+		if (!$this->hasValue) {
 			return false;
 		}
-		if($this->validator !== null) {
+		if ($this->validator !== null) {
 			$result = call_user_func($this->validator, $this->value);
 			call_user_func($this->validationResultHandler, $result, [
 				'value' => $this->value,
@@ -80,10 +80,10 @@ 
 	 * @return string[]
 	 */
 	private function buildKey($keyPath): array {
-		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;

src/Builder/Traits/LimitBuilder.php

Spacing +7 added lines, -7 removed lines

@@ -5,13 +5,13 @@ 
 use Kir\MySQL\Builder\Value\OptionalValue;
 
 trait LimitBuilder {
-	private null|int|OptionalValue $limit = null;
+	private null | int | OptionalValue $limit = null;
 
 	/**
 	 * @return null|int
 	 */
 	protected function getLimit(): ?int {
-		if($this->limit instanceof OptionalValue) {
+		if ($this->limit instanceof OptionalValue) {
 			return $this->limit->getValue();
 		}
 		return $this->limit;
@@ -33,18 +33,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/Traits/OffsetBuilder.php

Spacing +6 added lines, -6 removed lines

@@ -5,13 +5,13 @@ 
 use Kir\MySQL\Builder\Value\OptionalValue;
 
 trait OffsetBuilder {
-	private null|int|OptionalValue $offset = null;
+	private null | int | OptionalValue $offset = null;
 
 	/**
 	 * @return null|int
 	 */
 	protected function getOffset(): ?int {
-		if($this->offset instanceof OptionalValue) {
+		if ($this->offset instanceof OptionalValue) {
 			return $this->offset->getValue();
 		}
 		return $this->offset;
@@ -32,15 +32,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/TableNameBuilder.php

Spacing +10 added lines, -10 removed lines

@@ -18,35 +18,35 @@
 	 * @return string
 	 */
 	protected function buildTableName(?string $alias, $name): string {
-		if($name instanceof SpecialTable) {
+		if ($name instanceof SpecialTable) {
 			$name = $name->asString($this->db());
-		} elseif(is_object($name) && !($name instanceof VirtualTable) && method_exists($name, '__toString')) {
+		} elseif (is_object($name) && !($name instanceof VirtualTable) && method_exists($name, '__toString')) {
 			$name = (string) $name;
 			$lines = explode("\n", $name);
 			$lines = array_map(static fn(string $line) => "\t{$line}", $lines);
 			$name = implode("\n", $lines);
-			$name = '(' . trim(rtrim(trim($name), ';')) . ')';
-		} elseif(is_array($name)) {
+			$name = '('.trim(rtrim(trim($name), ';')).')';
+		} elseif (is_array($name)) {
 			$parts = [];
-			foreach($name as /*$index => */$bucket) {
-				if(is_scalar($bucket)/* && ctype_digit((string) $index)*/) {
+			foreach ($name as /*$index => */$bucket) {
+				if (is_scalar($bucket)/* && ctype_digit((string) $index)*/) {
 					$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", implode(', ', $values));
 				}
 			}
-			$name = '(' . implode("\n\tUNION ALL\n\t", $parts) . ')';
+			$name = '('.implode("\n\tUNION ALL\n\t", $parts).')';
 		}
-		if((is_string($name) || $name instanceof VirtualTable) && $this->db()->getVirtualTables()->has($name)) {
+		if ((is_string($name) || $name instanceof VirtualTable) && $this->db()->getVirtualTables()->has($name)) {
 			$select = (string) $this->db()->getVirtualTables()->get($name);
 			$name = sprintf('(%s)', implode("\n\t", explode("\n", trim($select))));
 		}
 		$name = $this->aliasReplacer()->replace((string) $name);
-		if($alias !== null) {
+		if ($alias !== null) {
 			return sprintf("%s %s", $name, $alias);
 		}
 		return $name;

src/Builder/Value/DBOptionalValue.php

Spacing +4 added lines, -4 removed lines

@@ -11,8 +11,8 @@ 
 	 * @param null|callable(): bool $validator
 	 */
 	public function __construct(
-		private object|array $data,
-		private string|array $path,
+		private object | array $data,
+		private string | array $path,
 		private $validator = null
 	) {}
 
@@ -20,10 +20,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/QueryStatement.php

Spacing +6 added lines, -6 removed lines

@@ -38,10 +38,10 @@ 
 	 */
 	public function setFetchMode(int $mode = PDO::FETCH_ASSOC, $arg0 = null, ?array $arg1 = null) {
 		$args = [$mode];
-		if($arg0 !== null) {
+		if ($arg0 !== null) {
 			$args[] = $arg0;
 		}
-		if($arg1 !== null) {
+		if ($arg1 !== null) {
 			$args[] = $arg1;
 		}
 		$this->stmt->setFetchMode(...$args);
@@ -57,7 +57,7 @@ 
 		$this->exceptionHandler(function() use ($params) {
 			$this->queryLoggers->logRegion($this->query, function() use ($params) {
 				$response = $this->stmt->execute($params);
-				if(!$response) {
+				if (!$response) {
 					throw new SqlException('Execution returned with "false".');
 				}
 			});
@@ -73,13 +73,13 @@ 
 	 */
 	public function fetchAll($fetchStyle = PDO::FETCH_ASSOC, $fetchArgument = null, array $ctorArgs = []): array {
 		$result = $x = $this->exceptionHandler(function() use ($fetchStyle, $fetchArgument, $ctorArgs) {
-			if($fetchArgument !== null) {
+			if ($fetchArgument !== null) {
 				return $this->stmt->fetchAll($fetchStyle, $fetchArgument, ...$ctorArgs);
 			}
 			return $this->stmt->fetchAll($fetchStyle);
 		});
 		/** @var array<mixed, mixed>|false $x */
-		if($x === false) {
+		if ($x === false) {
 			return [];
 		}
 		return $result;
@@ -124,7 +124,7 @@ 
 	public function getColumnMeta(int $columnNo): ?array {
 		return $this->exceptionHandler(function() use ($columnNo) {
 			$columnMeta = $this->stmt->getColumnMeta($columnNo);
-			if($columnMeta === false) {
+			if ($columnMeta === false) {
 				return null;
 			}
 			return $columnMeta;

src/Databases/MySQL.php

Spacing +24 added lines, -24 removed lines

@@ -46,7 +46,7 @@ 
 		private PDO $pdo,
 		array $options = []
 	) {
-		if($pdo->getAttribute(PDO::ATTR_ERRMODE) === PDO::ERRMODE_SILENT) {
+		if ($pdo->getAttribute(PDO::ATTR_ERRMODE) === PDO::ERRMODE_SILENT) {
 			$pdo->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
 		}
 		$this->aliasRegistry = new AliasRegistry();
@@ -60,7 +60,7 @@ 
 		];
 		$this->options = array_merge($defaultOptions, $options);
 		$this->options['timezone'] ??= date_default_timezone_get();
-		if(!($this->options['timezone'] instanceof DateTimeZone)) {
+		if (!($this->options['timezone'] instanceof DateTimeZone)) {
 			$this->options['timezone'] = new DateTimeZone((string) $this->options['timezone']);
 		}
 		$this->quoter = new MySQLQuoter($pdo, $this->options['timezone']);
@@ -84,7 +84,7 @@ 
 	 * @return VirtualTables
 	 */
 	public function getVirtualTables(): VirtualTables {
-		if($this->virtualTables === null) {
+		if ($this->virtualTables === null) {
 			$this->virtualTables = new VirtualTables();
 		}
 		return $this->virtualTables;
@@ -129,11 +129,11 @@ 
 		array $params = []
 	): int {
 		return $this->getQueryLoggers()->logRegion($query, fn() =>
-			$this->exceptionHandler(function () use ($query, $params) {
+			$this->exceptionHandler(function() use ($query, $params) {
 				$stmt = $this->pdo->prepare($query);
 				$timer = microtime(true);
 				$stmt->execute($params);
-				$this->queryLoggers->log($query, microtime(true) - $timer);
+				$this->queryLoggers->log($query, microtime(true)-$timer);
 				$result = $stmt->rowCount();
 				$stmt->closeCursor();
 				return $result;
@@ -147,7 +147,7 @@ 
 	 */
 	public function getLastInsertId(?string $name = null): ?string {
 		$result = $this->pdo->lastInsertId();
-		if($result === false) {
+		if ($result === false) {
 			return null;
 		}
 		return $result;
@@ -159,15 +159,15 @@ 
 	 */
 	public function getTableFields(string $table): array {
 		$fqTable = $this->select()->aliasReplacer()->replace($table);
-		if(array_key_exists($fqTable, $this->tableFields)) {
+		if (array_key_exists($fqTable, $this->tableFields)) {
 			return $this->tableFields[$fqTable];
 		}
 		$query = "DESCRIBE {$fqTable}";
 		return $this->getQueryLoggers()->logRegion($query, fn() =>
-			$this->exceptionHandler(function () use ($query, $fqTable) {
+			$this->exceptionHandler(function() use ($query, $fqTable) {
 				$stmt = $this->pdo->query($query);
 				try {
-					if($stmt === false) {
+					if ($stmt === false) {
 						throw new RuntimeException('Invalid return type');
 					}
 					$rows = $stmt->fetchAll(PDO::FETCH_ASSOC);
@@ -175,7 +175,7 @@ 
 					return $this->tableFields[$fqTable];
 				} finally {
 					try {
-						if($stmt instanceof PDOStatement) {
+						if ($stmt instanceof PDOStatement) {
 							$stmt->closeCursor();
 						}
 					} catch (Throwable $e) {}
@@ -217,7 +217,7 @@ 
 		$select = array_key_exists('select-factory', $this->options)
 			? call_user_func($this->options['select-factory'], $this, $this->options['select-options'])
 			: new MySQL\MySQLRunnableSelect($this, $this->options['select-options']);
-		if($fields !== null) {
+		if ($fields !== null) {
 			$select->fields($fields);
 		}
 		return $select;
@@ -231,7 +231,7 @@ 
 		$insert = array_key_exists('insert-factory', $this->options)
 			? call_user_func($this->options['insert-factory'], $this, $this->options['insert-options'])
 			: new Builder\RunnableInsert($this, $this->options['insert-options']);
-		if($fields !== null) {
+		if ($fields !== null) {
 			$insert->addAll($fields);
 		}
 		return $insert;
@@ -245,7 +245,7 @@ 
 		$update = array_key_exists('update-factory', $this->options)
 			? call_user_func($this->options['update-factory'], $this, $this->options['update-options'])
 			: new Builder\RunnableUpdate($this, $this->options['update-options']);
-		if($fields !== null) {
+		if ($fields !== null) {
 			$update->setAll($fields);
 		}
 		return $update;
@@ -264,8 +264,8 @@ 
 	 * @return $this
 	 */
 	public function transactionStart() {
-		if($this->transactionLevel === 0) {
-			if($this->pdo->inTransaction()) {
+		if ($this->transactionLevel === 0) {
+			if ($this->pdo->inTransaction()) {
 				$this->outerTransaction = true;
 			} else {
 				$this->pdo->beginTransaction();
@@ -279,7 +279,7 @@ 
 	 * @return $this
 	 */
 	public function transactionCommit() {
-		return $this->transactionEnd(function () {
+		return $this->transactionEnd(function() {
 			$this->pdo->commit();
 		});
 	}
@@ -288,7 +288,7 @@ 
 	 * @return $this
 	 */
 	public function transactionRollback() {
-		return $this->transactionEnd(function () {
+		return $this->transactionEnd(function() {
 			$this->pdo->rollBack();
 		});
 	}
@@ -299,7 +299,7 @@ 
 	 * @return T
 	 */
 	public function dryRun(callable $callback) {
-		if(!$this->pdo->inTransaction()) {
+		if (!$this->pdo->inTransaction()) {
 			$this->transactionStart();
 			try {
 				return $callback($this);
@@ -324,14 +324,14 @@ 
 	 * @throws Throwable
 	 */
 	public function transaction(callable $callback) {
-		if(!$this->pdo->inTransaction()) {
+		if (!$this->pdo->inTransaction()) {
 			$this->transactionStart();
 			try {
 				$result = $callback($this);
 				$this->transactionCommit();
 				return $result;
 			} catch (Throwable $e) {
-				if($this->pdo->inTransaction()) {
+				if ($this->pdo->inTransaction()) {
 					$this->transactionRollback();
 				}
 				throw $e;
@@ -355,11 +355,11 @@ 
 	 */
 	private function transactionEnd($fn): self {
 		$this->transactionLevel--;
-		if($this->transactionLevel < 0) {
+		if ($this->transactionLevel < 0) {
 			throw new RuntimeException("Transaction-Nesting-Problem: Trying to invoke commit on a already closed transaction");
 		}
-		if($this->transactionLevel < 1) {
-			if($this->outerTransaction) {
+		if ($this->transactionLevel < 1) {
+			if ($this->outerTransaction) {
 				$this->outerTransaction = false;
 			} else {
 				$fn();
@@ -376,7 +376,7 @@ 
 	 */
 	private function buildQueryStatement(string $query, callable $fn): QueryStatement {
 		$stmt = $fn($query);
-		if(!$stmt) {
+		if (!$stmt) {
 			throw new RuntimeException("Could not execute statement:\n{$query}");
 		}
 		return new QueryStatement($stmt, $query, $this->exceptionInterpreter, $this->queryLoggers);