rkrx / php-mysql-query-builder

src/Builder/Delete.php

Spacing +3 added lines, -3 removed lines

@@ -29,10 +29,10 @@ 
 	 * @return $this
 	 */
 	public function from(string $alias, $table = null) {
-		if($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/Helpers/ConditionAddHelper.php

Spacing +5 added lines, -5 removed lines

@@ -10,13 +10,13 @@ 
 	 * @param array<int, mixed> $args
 	 */
 	public static function addCondition(callable $addFn, $expression, array $args): void {
-		if($expression instanceof OptionalExpression) {
-			if($expression->isValid()) {
+		if ($expression instanceof OptionalExpression) {
+			if ($expression->isValid()) {
 				$addFn($expression->getExpression(), [$expression->getValue()]);
 			}
-		} elseif(is_object($expression)) {
+		} elseif (is_object($expression)) {
 			self::addAsArray($addFn, (array) $expression, $args);
-		} elseif(is_array($expression)) {
+		} elseif (is_array($expression)) {
 			self::addAsArray($addFn, $expression, $args);
 		} else {
 			$addFn($expression, $args);
@@ -29,7 +29,7 @@ 
 	 * @param array<int, mixed> $args
 	 */
 	private static function addAsArray(callable $addFn, array $expression, array $args): void {
-		if(count($expression) > 0) {
+		if (count($expression) > 0) {
 			$addFn($expression, $args);
 		}
 	}

src/Builder/Helpers/FieldValueConverter.php

Spacing +2 added lines, -2 removed lines

@@ -9,8 +9,8 @@
 	 */
 	public static function convertValues(array $row, array $columnDefinitions): array {
 		$result = [];
-		foreach($row as $key => $value) {
-			if($value !== null) {
+		foreach ($row as $key => $value) {
+			if ($value !== null) {
 				$result[$key] = self::convertValue($value, $columnDefinitions[$key]);
 			} else {
 				$result[$key] = $value;

src/Builder/Helpers/FieldTypeProvider.php

Spacing +1 added lines, -1 removed lines

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

src/Builder/Internal/ConditionBuilder.php

Spacing +5 added lines, -5 removed lines

@@ -13,15 +13,15 @@
 	 * @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) {
-					if($value === null) {
+		foreach ($conditions as [$expression, $arguments]) {
+			if (is_array($expression)) {
+				foreach ($expression as $key => $value) {
+					if ($value === null) {
 						$arr = self::buildCondition($arr, "ISNULL(`{$key}`)", [$value], $db);
 					} else {
 						$arr = self::buildCondition($arr, "`{$key}`=?", [$value], $db);

src/Builder/Internal/DDLRunnable.php

Spacing +1 added lines, -1 removed lines

@@ -28,7 +28,7 @@
 	public function run(array $params = []) {
 		$this->query->execute($params);
 		$response = $this->query->getStatement()->rowCount();
-		if($this->callbackFn !== null) {
+		if ($this->callbackFn !== null) {
 			$response = call_user_func($this->callbackFn);
 		}
 		return $response;

src/Builder/Insert.php

Spacing +21 added lines, -21 removed lines

@@ -88,7 +88,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;
@@ -102,7 +102,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;
@@ -116,7 +116,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 {
@@ -133,7 +133,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;
@@ -146,8 +146,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);
 			}
 		});
@@ -191,7 +191,7 @@ 
 	 * @return string
 	 */
 	public function __toString(): string {
-		if($this->table === null) {
+		if ($this->table === null) {
 			throw new RuntimeException('Specify a table-name');
 		}
 
@@ -201,21 +201,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";
 		}
 
@@ -229,7 +229,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;
@@ -245,18 +245,18 @@ 
 	 * @param callable(string, mixed): void $fn
 	 */
 	private function addAllTo(array $data, ?array $mask, ?array $excludeFields, callable $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);
 		}
 	}
@@ -266,10 +266,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);
@@ -292,7 +292,7 @@ 
 	 * @return array<string, mixed>
 	 */
 	private function clearValues(array $values): array {
-		if(!count($values)) {
+		if (!count($values)) {
 			return [];
 		}
 
@@ -300,8 +300,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/Builder/Select.php

Spacing +1 added lines, -1 removed lines

@@ -122,7 +122,7 @@
 	 * @return $this
 	 */
 	public function from(?string $alias, $table = null): self {
-		if($table === null) {
+		if ($table === null) {
 			[$alias, $table] = [$table, $alias];
 			$this->addTable($alias, (string) $table);
 		} else {

src/Builder/Update.php

Spacing +13 added lines, -13 removed lines

@@ -29,7 +29,7 @@ 
 	 * @return $this
 	 */
 	public function table(string $alias, $table = null): self {
-		if($table === null) {
+		if ($table === null) {
 			[$alias, $table] = [$table, $alias];
 		}
 		$this->addTable($alias, $table);
@@ -64,7 +64,7 @@ 
 	 * @return $this
 	 */
 	public function setExpr(string $expr, ...$args): self {
-		if(count($args) > 0) {
+		if (count($args) > 0) {
 			$this->fields[] = func_get_args();
 		} else {
 			$this->fields[] = $expr;
@@ -78,15 +78,15 @@ 
 	 * @return $this
 	 */
 	public function setAll(array $data, array $allowedFields = null): self {
-		if($allowedFields !== null) {
-			foreach($data as $fieldName => $value) {
-				if(in_array($fieldName, $allowedFields)) {
+		if ($allowedFields !== null) {
+			foreach ($data as $fieldName => $value) {
+				if (in_array($fieldName, $allowedFields)) {
 					$this->set($fieldName, $value);
 				}
 			}
 		} else {
 			$values = $this->clearValues($data);
-			foreach($values as $fieldName => $value) {
+			foreach ($values as $fieldName => $value) {
 				$this->set($fieldName, $value);
 			}
 		}
@@ -121,7 +121,7 @@ 
 	 */
 	private function buildAssignments(string $query): string {
 		$sqlFields = $this->buildFieldList($this->fields);
-		if(!count($sqlFields)) {
+		if (!count($sqlFields)) {
 			throw new RuntimeException('No field-data found');
 		}
 		return sprintf("%s%s\n", $query, implode(",\n", $sqlFields));
@@ -132,14 +132,14 @@ 
 	 * @return array<string, mixed>
 	 */
 	private function clearValues(array $values): array {
-		if(!count($values)) {
+		if (!count($values)) {
 			return [];
 		}
 		$tables = $this->getTables();
-		if(!count($tables)) {
+		if (!count($tables)) {
 			throw new RuntimeException('Table name is missing');
 		}
-		if(count($tables) > 1) {
+		if (count($tables) > 1) {
 			throw new RuntimeException('Batch values only work with max. one table');
 		}
 
@@ -147,11 +147,11 @@ 
 		$tableName = $table['name'];
 
 		$result = [];
-		if(is_string($tableName)) {
+		if (is_string($tableName)) {
 			$fields = $this->db()->getTableFields($tableName);
 
-			foreach($values as $fieldName => $fieldValue) {
-				if(in_array($fieldName, $fields, true)) {
+			foreach ($values as $fieldName => $fieldValue) {
+				if (in_array($fieldName, $fields, true)) {
 					$result[$fieldName] = $fieldValue;
 				}
 			}