rkrx / php-mysql-query-builder

src/Databases/MySQL/MySQLRunnableSelect.php

Spacing +40 added lines, -40 removed lines

@@ -86,7 +86,7 @@ 
 	 * @inheritDoc
 	 */
 	public function fetchRowsLazy($callback = null) {
-		$callback = $callback ?? (static function ($row) { return $row; });
+		$callback = $callback ?? (static function($row) { return $row; });
 		yield from $this->fetchLazy($callback, PDO::FETCH_ASSOC);
 	}
 
@@ -94,8 +94,8 @@ 
 	 * @inheritDoc
 	 */
 	public function fetchRow($callback = null): array {
-		$callback = $callback ?? (static function ($row) { return $row; });
-		return $this->fetch($callback, PDO::FETCH_ASSOC, null, static function ($row) {
+		$callback = $callback ?? (static function($row) { return $row; });
+		return $this->fetch($callback, PDO::FETCH_ASSOC, null, static function($row) {
 			return ['valid' => is_array($row), 'default' => []];
 		});
 	}
@@ -104,17 +104,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 function ($row) use ($columnDefinitions) { return FieldValueConverter::convertValues($row, $columnDefinitions); }, $data);
+				$data = array_map(static function($row) use ($columnDefinitions) { return 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;
@@ -131,7 +131,7 @@ 
 	 * @inheritDoc
 	 */
 	public function fetchObjectsLazy($className = null, $callback = null) {
-		$callback = $callback ?? (static function ($row) { return $row; });
+		$callback = $callback ?? (static function($row) { return $row; });
 		yield from $this->fetchLazy($callback, PDO::FETCH_CLASS, $className ?: $this->defaultClassName);
 	}
 
@@ -139,8 +139,8 @@ 
 	 * @inheritDoc
 	 */
 	public function fetchObject($className = null, $callback = null) {
-		$callback = $callback ?? (static function ($row) { return $row; });
-		return $this->fetch($callback, PDO::FETCH_CLASS, $className ?: $this->defaultClassName, static function ($row) {
+		$callback = $callback ?? (static function($row) { return $row; });
+		return $this->fetch($callback, PDO::FETCH_CLASS, $className ?: $this->defaultClassName, static function($row) {
 			return ['valid' => is_object($row), 'default' => null];
 		});
 	}
@@ -149,11 +149,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;
 				}
@@ -169,12 +169,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];
@@ -188,8 +188,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);
@@ -200,9 +200,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;
@@ -237,7 +237,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;
@@ -259,21 +259,21 @@ 
 	 * @return ($callback is null ? array<int, ($mode is PDO::FETCH_NUM ? array<int, null|scalar> : array<string, null|scalar>)> : array<int, TFnReturnType|TFnParamType>)
 	 */
 	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 function ($row) use ($columnDefinitions) { return FieldValueConverter::convertValues($row, $columnDefinitions); }, $data);
+				$data = array_map(static function($row) use ($columnDefinitions) { return 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;
@@ -298,18 +298,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;
@@ -330,20 +330,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/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;