rkrx / php-mysql-query-builder

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

Indentation +6 added lines, -6 removed lines

@@ -9,13 +9,13 @@
 use Rector\Set\ValueObject\LevelSetList;
 
 return static function (RectorConfig $rectorConfig): void {
-    $rectorConfig->paths([
-        __DIR__ . '/src',
-        __DIR__ . '/tests',
-    ]);
+	$rectorConfig->paths([
+		__DIR__ . '/src',
+		__DIR__ . '/tests',
+	]);
 
-    // register a single rule
-    $rectorConfig->rule(InlineConstructorDefaultToPropertyRector::class);
+	// register a single rule
+	$rectorConfig->rule(InlineConstructorDefaultToPropertyRector::class);
 
 	$rectorConfig->skip([RemoveUselessParamTagRector::class]);
 	$rectorConfig->skip([MixedTypeRector::class]);

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/Builder/Internal/ConditionBuilder.php

Spacing +6 added lines, -6 removed lines

@@ -14,16 +14,16 @@ 
 	 * @return string
 	 */
 	public static function build(Database $db, string $query, array $conditions, string $token): string {
-		if(!count($conditions)) {
+		if (!count($conditions)) {
 			return $query;
 		}
 		$query .= "{$token}\n";
 		$arr = [];
-		foreach($conditions as [$expression, $arguments]) {
-			if(is_array($expression)) {
-				foreach($expression as $key => $value) {
+		foreach ($conditions as [$expression, $arguments]) {
+			if (is_array($expression)) {
+				foreach ($expression as $key => $value) {
 					$key = self::formatKey($key);
-					if($value === null) {
+					if ($value === null) {
 						$arr = self::buildCondition($arr, "ISNULL({$key})", [$value], $db);
 					} else {
 						$arr = self::buildCondition($arr, "{$key}=?", [$value], $db);
@@ -55,7 +55,7 @@ 
 	 * @return string
 	 */
 	private static function formatKey(string $key): string {
-		if(strpos($key, '`') !== false || strpos($key, '(') !== false) {
+		if (strpos($key, '`') !== false || strpos($key, '(') !== false) {
 			return $key;
 		}
 		$keyParts = explode('.', $key);

src/Builder/Traits/TableNameBuilder.php

Spacing +9 added lines, -9 removed lines

@@ -14,34 +14,34 @@
 	 * @return string
 	 */
 	protected function buildTableName(?string $alias, $name): string {
-		if(is_object($name) && !($name instanceof VirtualTable) && method_exists($name, '__toString')) {
+		if (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), ';')) . ')';
+			$name = '('.trim(rtrim(trim($name), ';')).')';
 		}
-		if(is_array($name)) {
+		if (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/Delete.php

Spacing +4 added lines, -4 removed lines

@@ -28,11 +28,11 @@ 
 	 * @param null|string|Select $table
 	 * @return $this
 	 */
-	public function from(string $alias, null|string|Select $table = null) {
-		if($table !== null) {
+	public function from(string $alias, null | string | Select $table = null) {
+		if ($table !== null) {
 			$this->aliases[] = $alias;
 		}
-		if($table === null) {
+		if ($table === null) {
 			[$alias, $table] = [$table, $alias];
 		}
 		$this->addTable($alias, $table);
@@ -51,7 +51,7 @@ 
 	public function __toString(): string {
 		$query = 'DELETE ';
 		$query .= implode(', ', $this->aliases);
-		$query = trim($query) . " FROM\n";
+		$query = trim($query)." FROM\n";
 		$query = $this->buildTables($query);
 		$query = $this->buildJoins($query);
 		$query = $this->buildWhereConditions($query);

src/Builder/Expr/DBExprFilter.php

Spacing +7 added lines, -7 removed lines

@@ -30,12 +30,12 @@ 
 		$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;
 	}
@@ -51,10 +51,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,
@@ -77,10 +77,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/Databases/MySQL/MySQLRunnableSelect.php

Spacing +32 added lines, -32 removed lines

@@ -101,17 +101,17 @@ 
 	 * @inheritDoc
 	 */
 	public function fetchObjects(string $className = 'stdClass', $callback = null): array {
-		return $this->createTempStatement(function (QueryStatement $statement) use ($className, $callback) {
+		return $this->createTempStatement(function(QueryStatement $statement) use ($className, $callback) {
 			$data = $statement->fetchAll(PDO::FETCH_CLASS, $className);
-			if($this->preserveTypes) {
+			if ($this->preserveTypes) {
 				$columnDefinitions = FieldTypeProvider::getFieldTypes($statement);
 				$data = array_map(static fn($row) => FieldValueConverter::convertValues($row, $columnDefinitions), $data);
 			}
-			if($callback !== null) {
-				return call_user_func(static function ($resultData = []) use ($data, $callback) {
-					foreach($data as $row) {
+			if ($callback !== null) {
+				return call_user_func(static 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;
@@ -147,11 +147,11 @@ 
 	 * @inheritDoc
 	 */
 	public function fetchKeyValue($treatValueAsArray = false): array {
-		return $this->createTempStatement(static function (QueryStatement $statement) use ($treatValueAsArray) {
-			if($treatValueAsArray) {
+		return $this->createTempStatement(static function(QueryStatement $statement) use ($treatValueAsArray) {
+			if ($treatValueAsArray) {
 				$rows = $statement->fetchAll(PDO::FETCH_ASSOC);
 				$result = [];
-				foreach($rows as $row) {
+				foreach ($rows as $row) {
 					[$key] = array_values($row);
 					$result[$key] = $row;
 				}
@@ -167,12 +167,12 @@ 
 	public function fetchGroups(array $fields): array {
 		$rows = $this->fetchRows();
 		$result = [];
-		foreach($rows as $row) {
+		foreach ($rows as $row) {
 			/** @var array<string, mixed> $tmp */
 			$tmp = &$result;
-			foreach($fields as $field) {
+			foreach ($fields as $field) {
 				$value = (string) $row[$field];
-				if(!array_key_exists($value, $tmp)) {
+				if (!array_key_exists($value, $tmp)) {
 					$tmp[$value] = [];
 				}
 				$tmp = &$tmp[$value];
@@ -186,8 +186,8 @@ 
 	 * @inheritDoc
 	 */
 	public function fetchArray(?callable $fn = null): array {
-		return $this->createTempStatement(static function (QueryStatement $stmt) use ($fn) {
-			if($fn !== null) {
+		return $this->createTempStatement(static function(QueryStatement $stmt) use ($fn) {
+			if ($fn !== null) {
 				return $stmt->fetchAll(PDO::FETCH_FUNC, $fn);
 			}
 			return $stmt->fetchAll(PDO::FETCH_COLUMN);
@@ -198,9 +198,9 @@ 
 	 * @inheritDoc
 	 */
 	public function fetchValue($default = null, ?callable $fn = null) {
-		return $this->createTempStatement(static function (QueryStatement $stmt) use ($default, $fn) {
+		return $this->createTempStatement(static function(QueryStatement $stmt) use ($default, $fn) {
 			$result = $stmt->fetchAll(PDO::FETCH_COLUMN);
-			if($result !== false && array_key_exists(0, $result)) {
+			if ($result !== false && array_key_exists(0, $result)) {
 				return $fn !== null ? $fn($result[0]) : $result[0];
 			}
 			return $default;
@@ -235,7 +235,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;
@@ -256,21 +256,21 @@ 
 	 * @return ($callback is null ? array<int, ($mode is PDO::FETCH_NUM ? array<int, null|scalar> : array<string, null|scalar>)> : array<int, TFnReturnType>)
 	 */
 	private function fetchAll($callback = null, int $mode = 0, $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);
 				$data = array_map(static fn($row) => FieldValueConverter::convertValues($row, $columnDefinitions), $data);
 			}
-			if($callback !== null) {
-				return call_user_func(static function ($resultData = []) use ($data, $callback) {
-					foreach($data as $row) {
+			if ($callback !== null) {
+				return call_user_func(static function($resultData = []) use ($data, $callback) {
+					foreach ($data as $row) {
 						$result = $callback($row);
-						if($result instanceof DBIgnoreRow) {
+						if ($result instanceof DBIgnoreRow) {
 							continue;
 						}
-						if($result !== null) {
+						if ($result !== null) {
 							$resultData[] = $result;
 						} else {
 							$resultData[] = $row;
@@ -294,18 +294,18 @@ 
 		$statement = $this->createStatement();
 		$statement->setFetchMode($mode, $arg0);
 		try {
-			while($row = $statement->fetch()) {
+			while ($row = $statement->fetch()) {
 				/** @var T $row */
 //				if($this->preserveTypes) {
 //					$columnDefinitions = FieldTypeProvider::getFieldTypes($statement);
 //					$row = FieldValueConverter::convertValues($row, $columnDefinitions);
 //				}
 				$result = $callback($row);
-				if($result instanceof DBIgnoreRow) {
+				if ($result instanceof DBIgnoreRow) {
 					// Skip row in this case
 					continue;
 				}
-				if($result !== null) {
+				if ($result !== null) {
 					yield $result;
 				} else {
 					yield $row;
@@ -326,20 +326,20 @@ 
 	 * @return T|U|array<string, mixed>
 	 */
 	private function fetch($callback, int $mode = PDO::FETCH_ASSOC, $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 === null ? ['valid' => true] : $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/Databases/MySQL/MySQLQuoter.php

Spacing +10 added lines, -10 removed lines

@@ -19,31 +19,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 = (new DateTimeImmutable($value->format('c')))->setTimezone($this->timeZone)->format('Y-m-d H:i:s');
 		}
 
@@ -57,12 +57,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);