rkrx / php-mysql-query-builder

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

src/QueryLogger/QueryLoggers.php

Spacing +3 added lines, -3 removed lines

@@ -25,12 +25,12 @@
 		$timer = microtime(true);
 		try {
 			return $fn();
-		} catch(Throwable $e) {
+		} catch (Throwable $e) {
 			$exception = $e;
 			throw $e;
 		} finally {
-			$finalTimer = microtime(true) - $timer;
-			if($exception === null) {
+			$finalTimer = microtime(true)-$timer;
+			if ($exception === null) {
 				$this->log($query, $finalTimer);
 			} else {
 				$this->logError($query, $exception, $finalTimer);

src/Builder/Helpers/FieldTypeProvider.php

Spacing +2 added lines, -2 removed lines

@@ -10,10 +10,10 @@
 	 */
 	public static function getFieldTypes(QueryStatement $statement): array {
 		$fieldTypes = [];
-		for($i = 0; $column = $statement->getColumnMeta($i); $i++) {
+		for ($i = 0; $column = $statement->getColumnMeta($i); $i++) {
 			$name = $column['name'] ?? null;
 			$nativeType = $column['native_type'] ?? null;
-			if(is_string($name) && is_string($nativeType)) {
+			if (is_string($name) && is_string($nativeType)) {
 				$fieldTypes[$name] = self::getTypeFromNativeType($nativeType);
 			}
 		}

src/Databases/MySQL/MySQLQuoter.php

Spacing +10 added lines, -10 removed lines

@@ -24,31 +24,31 @@ 
 	 * @return string
 	 */
 	public function quote($value): string {
-		if(is_null($value)) {
+		if (is_null($value)) {
 			return 'NULL';
 		}
 
-		if(is_bool($value)) {
+		if (is_bool($value)) {
 			return $value ? '1' : '0';
 		}
 
-		if(is_array($value)) {
+		if (is_array($value)) {
 			return implode(', ', array_map([$this, __FUNCTION__], $value));
 		}
 
-		if($value instanceof DBExpr) {
+		if ($value instanceof DBExpr) {
 			return $value->getExpression();
 		}
 
-		if($value instanceof Select) {
+		if ($value instanceof Select) {
 			return sprintf('(%s)', (string) $value);
 		}
 
-		if(is_int($value) || is_float($value)) {
+		if (is_int($value) || is_float($value)) {
 			return (string) $value;
 		}
 
-		if($value instanceof DateTimeInterface) {
+		if ($value instanceof DateTimeInterface) {
 			$value = date_create_immutable($value->format('c'))->setTimezone($this->timeZone)->format('Y-m-d H:i:s');
 		}
 
@@ -62,12 +62,12 @@ 
 	 */
 	public function quoteExpression(string $expression, array $arguments = []): string {
 		$index = -1;
-		$func = function () use ($arguments, &$index) {
+		$func = function() use ($arguments, &$index) {
 			$index++;
-			if(array_key_exists($index, $arguments)) {
+			if (array_key_exists($index, $arguments)) {
 				$argument = $arguments[$index];
 				$value = $this->quote($argument);
-			} elseif(count($arguments) > 0) {
+			} elseif (count($arguments) > 0) {
 				$args = $arguments;
 				$value = array_pop($args);
 				$value = $this->quote($value);

src/Builder/QueryStatement.php

Spacing +6 added lines, -6 removed lines

@@ -47,10 +47,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->statement->setFetchMode(...$args);
@@ -66,7 +66,7 @@ 
 		$this->exceptionHandler(function() use ($params) {
 			$this->queryLoggers->logRegion($this->query, function() use ($params) {
 				$response = $this->statement->execute($params);
-				if(!$response) {
+				if (!$response) {
 					throw new SqlException('Execution returned with "false".');
 				}
 			});
@@ -82,13 +82,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->statement->fetchAll($fetchStyle, $fetchArgument, ...$ctorArgs);
 			}
 			return $this->statement->fetchAll($fetchStyle);
 		});
 		/** @var array<mixed, mixed>|false $x */
-		if($x === false) {
+		if ($x === false) {
 			return [];
 		}
 		return $result;
@@ -141,7 +141,7 @@ 
 	public function getColumnMeta(int $columnNo): ?array {
 		return $this->exceptionHandler(function() use ($columnNo) {
 			$columnMeta = $this->statement->getColumnMeta($columnNo);
-			if($columnMeta === false) {
+			if ($columnMeta === false) {
 				return null;
 			}
 			return $columnMeta;

rector.php

Spacing +3 added lines, -3 removed lines

@@ -8,10 +8,10 @@
 use Rector\Php80\Rector\FunctionLike\MixedTypeRector;
 use Rector\Set\ValueObject\LevelSetList;
 
-return static function (RectorConfig $rectorConfig): void {
+return static function(RectorConfig $rectorConfig): void {
     $rectorConfig->paths([
-        __DIR__ . '/src',
-        __DIR__ . '/tests',
+        __DIR__.'/src',
+        __DIR__.'/tests',
     ]);
 
     // register a single rule

src/Databases/MySQL.php

Spacing +22 added lines, -22 removed lines

@@ -51,7 +51,7 @@ 
 	 * @param array<string, mixed> $options
 	 */
 	public function __construct(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->pdo = $pdo;
@@ -66,7 +66,7 @@ 
 		];
 		$this->options = array_merge($defaultOptions, $options);
 		$this->options['timezone'] = $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']);
@@ -90,7 +90,7 @@ 
 	 * @return VirtualTables
 	 */
 	public function getVirtualTables(): VirtualTables {
-		if($this->virtualTables === null) {
+		if ($this->virtualTables === null) {
 			$this->virtualTables = new VirtualTables();
 		}
 		return $this->virtualTables;
@@ -135,11 +135,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;
@@ -161,15 +161,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);
@@ -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,7 +324,7 @@ 
 	 * @throws Throwable
 	 */
 	public function transaction(callable $callback) {
-		if(!$this->pdo->inTransaction()) {
+		if (!$this->pdo->inTransaction()) {
 			$this->transactionStart();
 			try {
 				$result = $callback($this);
@@ -332,7 +332,7 @@ 
 				return $result;
 			} catch (Throwable $e) {
 				// @phpstan-ignore-next-line; If condition is always false as it is not.
-				if($this->pdo->inTransaction()) {
+				if ($this->pdo->inTransaction()) {
 					$this->transactionRollback();
 				}
 				throw $e;
@@ -356,11 +356,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();
@@ -377,7 +377,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);