rkrx / php-mysql-query-builder

src/Builder/Traits/OffsetBuilder.php

Spacing +1 added lines, -1 removed lines

@@ -21,7 +21,7 @@
 	 * @return string
 	 */
 	protected function buildOffset($query) {
-		if($this->offset !== null) {
+		if ($this->offset !== null) {
 			$query .= "OFFSET\n\t{$this->offset}\n";
 		}
 		return $query;

src/Builder/Traits/GroupByBuilder.php

Spacing +5 added lines, -5 removed lines

@@ -13,9 +13,9 @@ 
 	 * @return $this
 	 */
 	public function groupBy() {
-		foreach(func_get_args() as $expression) {
-			if(is_array($expression)) {
-				if(!count($expression)) {
+		foreach (func_get_args() as $expression) {
+			if (is_array($expression)) {
+				if (!count($expression)) {
 					continue;
 				}
 				$arguments = array(
@@ -34,12 +34,12 @@ 
 	 * @return string
 	 */
 	protected function buildGroups($query) {
-		if(!count($this->groupBy)) {
+		if (!count($this->groupBy)) {
 			return $query;
 		}
 		$query .= "GROUP BY\n";
 		$arr = array();
-		foreach($this->groupBy as $expression) {
+		foreach ($this->groupBy as $expression) {
 			$arr[] = "\t{$expression}";
 		}
 		return $query.join(",\n", $arr)."\n";

src/Builder/Traits/UnionBuilder.php

Spacing +4 added lines, -4 removed lines

@@ -30,21 +30,21 @@
 	 * @return string
 	 */
 	protected function buildUnions($query) {
-		$wrap = function ($query) {
+		$wrap = function($query) {
 			$query = trim($query);
 			$query = join("\n\t", explode("\n", $query));
 			return sprintf("(\n\t%s\n)", $query);
 		};
 		$queries = [$wrap($query)];
-		foreach($this->unions as $unionQuery) {
-			if($unionQuery[0] === 'ALL') {
+		foreach ($this->unions as $unionQuery) {
+			if ($unionQuery[0] === 'ALL') {
 				$queries[] = 'UNION ALL';
 			} else {
 				$queries[] = 'UNION';
 			}
 			$queries[] = $wrap($unionQuery[1]);
 		}
-		if(count($queries) > 1) {
+		if (count($queries) > 1) {
 			return join(" ", $queries);
 		}
 		return $query;

src/Builder/Traits/TableBuilder.php

Spacing +3 added lines, -3 removed lines

@@ -15,7 +15,7 @@ 
 	 * @return $this
 	 */
 	protected function addTable($alias, $table = null) {
-		if($table === null) {
+		if ($table === null) {
 			list($alias, $table) = [$table, $alias];
 		}
 		$this->tables[] = array('alias' => $alias, 'name' => $table);
@@ -28,10 +28,10 @@ 
 	 */
 	protected function buildTables($query) {
 		$arr = array();
-		foreach($this->tables as $table) {
+		foreach ($this->tables as $table) {
 			$arr[] = "\t".$this->buildTableName($table['alias'], $table['name']);
 		}
-		if(count($arr)) {
+		if (count($arr)) {
 			$query .= join(",\n", $arr)."\n";
 		}
 		return $query;

src/Builder/Traits/JoinBuilder.php

Spacing +5 added lines, -5 removed lines

@@ -49,15 +49,15 @@
 	 */
 	protected function buildJoins($query) {
 		$arr = array();
-		foreach($this->joinTables as $table) {
+		foreach ($this->joinTables as $table) {
 			$join = $table['type']." JOIN\n";
-			$join .= "\t" . $this->buildTableName($table['alias'], $table['name']);
-			if($table['expression']) {
-				$join .= " ON " . $this->db()->quoteExpression($table['expression'], $table['arguments']);
+			$join .= "\t".$this->buildTableName($table['alias'], $table['name']);
+			if ($table['expression']) {
+				$join .= " ON ".$this->db()->quoteExpression($table['expression'], $table['arguments']);
 			}
 			$arr[] = $join;
 		}
-		if(count($arr)) {
+		if (count($arr)) {
 			$query .= join("\n", $arr)."\n";
 		}
 		return $query;

src/Builder/Delete.php

Spacing +2 added lines, -2 removed lines

@@ -29,7 +29,7 @@ 
 	 * @return $this
 	 */
 	public function from($alias, $table = null) {
-		if($table !== null) {
+		if ($table !== null) {
 			$this->aliases[] = $alias;
 		}
 		$this->addTable($alias, $table);
@@ -43,7 +43,7 @@ 
 	public function __toString() {
 		$query = "DELETE ";
 		$query .= join(', ', $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/FieldValueConverter.php

Spacing +2 added lines, -2 removed lines

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

src/Builder/Internal/DDLRunnable.php

Spacing +1 added lines, -1 removed lines

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

src/Databases/MySQL.php

Doc Comments +1 added lines, -1 removed lines

@@ -261,7 +261,7 @@
 	}
 
 	/**
-	 * @param int|callable $tries
+	 * @param integer $tries
 	 * @param callable|null $callback
 	 * @return mixed
 	 * @throws \Exception

Spacing +32 added lines, -32 removed lines

@@ -38,7 +38,7 @@ 
 	 * @param array $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;
@@ -74,7 +74,7 @@ 
 	 * @return QueryStatement
 	 */
 	public function query($query) {
-		return $this->buildQueryStatement($query, function ($query) {
+		return $this->buildQueryStatement($query, function($query) {
 			$stmt = $this->pdo->query($query);
 			return $stmt;
 		});
@@ -86,7 +86,7 @@ 
 	 * @return QueryStatement
 	 */
 	public function prepare($query) {
-		return $this->buildQueryStatement((string) $query, function ($query) {
+		return $this->buildQueryStatement((string) $query, function($query) {
 			$stmt = $this->pdo->prepare($query);
 			return $stmt;
 		});
@@ -98,11 +98,11 @@ 
 	 * @return int
 	 */
 	public function exec($query, array $params = array()) {
-		return $this->exceptionHandler(function () use ($query, $params) {
+		return $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;
@@ -122,12 +122,12 @@ 
 	 */
 	public function getTableFields($table) {
 		$table = $this->select()->aliasReplacer()->replace($table);
-		if(array_key_exists($table, self::$tableFields)) {
+		if (array_key_exists($table, self::$tableFields)) {
 			return self::$tableFields[$table];
 		}
 		$stmt = $this->pdo->query("DESCRIBE {$table}");
 		$rows = $stmt->fetchAll(\PDO::FETCH_ASSOC);
-		self::$tableFields[$table] = array_map(function ($row) { return $row['Field']; }, $rows);
+		self::$tableFields[$table] = array_map(function($row) { return $row['Field']; }, $rows);
 		$stmt->closeCursor();
 		return self::$tableFields[$table];
 	}
@@ -138,11 +138,11 @@ 
 	 * @return string
 	 */
 	public function quoteExpression($expression, array $arguments = array()) {
-		$func = function () use ($arguments) {
+		$func = function() use ($arguments) {
 			static $idx = -1;
 			$idx++;
 			$index = $idx;
-			if(array_key_exists($index, $arguments)) {
+			if (array_key_exists($index, $arguments)) {
 				$argument = $arguments[$index];
 				$value = $this->quote($argument);
 			} else {
@@ -159,14 +159,14 @@ 
 	 * @return string
 	 */
 	public function quote($value) {
-		if(is_null($value)) {
+		if (is_null($value)) {
 			$result = 'NULL';
-		} elseif($value instanceof Builder\DBExpr) {
+		} elseif ($value instanceof Builder\DBExpr) {
 			$result = $value->getExpression();
-		} elseif($value instanceof Builder\Select) {
+		} elseif ($value instanceof Builder\Select) {
 			$result = sprintf('(%s)', (string) $value);
-		} elseif(is_array($value)) {
-			$result = join(', ', array_map(function ($value) { return $this->quote($value); }, $value));
+		} elseif (is_array($value)) {
+			$result = join(', ', array_map(function($value) { return $this->quote($value); }, $value));
 		} else {
 			$result = $this->pdo->quote($value);
 		}
@@ -181,7 +181,7 @@ 
 		if (is_numeric($field) || !is_string($field)) {
 			throw new UnexpectedValueException('Field name is invalid');
 		}
-		if(strpos($field, '`') !== false) {
+		if (strpos($field, '`') !== false) {
 			return (string) $field;
 		}
 		$parts = explode('.', $field);
@@ -196,7 +196,7 @@ 
 		$select = array_key_exists('select-factory', $this->options)
 			? call_user_func($this->options['select-factory'], $this, $this->options['select-options'])
 			: new Builder\RunnableSelect($this, $this->options['select-options']);
-		if($fields !== null) {
+		if ($fields !== null) {
 			$select->fields($fields);
 		}
 		return $select;
@@ -210,7 +210,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;
@@ -224,7 +224,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;
@@ -243,8 +243,8 @@ 
 	 * @return $this
 	 */
 	public function transactionStart() {
-		if((int) $this->transactionLevel === 0) {
-			if($this->pdo->inTransaction()) {
+		if ((int) $this->transactionLevel === 0) {
+			if ($this->pdo->inTransaction()) {
 				$this->outerTransaction = true;
 			} else {
 				$this->pdo->beginTransaction();
@@ -259,7 +259,7 @@ 
 	 * @throws \Exception
 	 */
 	public function transactionCommit() {
-		return $this->transactionEnd(function () {
+		return $this->transactionEnd(function() {
 			$this->pdo->commit();
 		});
 	}
@@ -269,7 +269,7 @@ 
 	 * @throws \Exception
 	 */
 	public function transactionRollback() {
-		return $this->transactionEnd(function () {
+		return $this->transactionEnd(function() {
 			$this->pdo->rollBack();
 		});
 	}
@@ -284,7 +284,7 @@ 
 	public function dryRun($callback = null) {
 		$result = null;
 		$exception = null;
-		if(!$this->pdo->inTransaction()) {
+		if (!$this->pdo->inTransaction()) {
 			$this->transactionStart();
 			try {
 				$result = call_user_func($callback, $this);
@@ -321,16 +321,16 @@ 
 	 * @throws \Error
 	 */
 	public function transaction($tries = 1, $callback = null) {
-		if(is_callable($tries)) {
+		if (is_callable($tries)) {
 			$callback = $tries;
 			$tries = 1;
-		} elseif(!is_callable($callback)) {
+		} elseif (!is_callable($callback)) {
 			throw new RuntimeException('$callback must be a callable');
 		}
 		$result = null;
 		$exception = null;
-		for(; $tries--;) {
-			if(!$this->pdo->inTransaction()) {
+		for (; $tries--;) {
+			if (!$this->pdo->inTransaction()) {
 				$this->transactionStart();
 				try {
 					$result = call_user_func($callback, $this);
@@ -359,7 +359,7 @@ 
 				}
 			}
 		}
-		if($exception !== null) {
+		if ($exception !== null) {
 			throw $exception;
 		}
 		return $result;
@@ -372,11 +372,11 @@ 
 	 */
 	private function transactionEnd($fn) {
 		$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((int) $this->transactionLevel === 0) {
-			if($this->outerTransaction) {
+		if ((int) $this->transactionLevel === 0) {
+			if ($this->outerTransaction) {
 				$this->outerTransaction = false;
 			} else {
 				call_user_func($fn);
@@ -393,7 +393,7 @@ 
 	 */
 	private function buildQueryStatement($query, $fn) {
 		$stmt = call_user_func($fn, $query);
-		if(!$stmt) {
+		if (!$stmt) {
 			throw new RuntimeException("Could not execute statement:\n{$query}");
 		}
 		$stmtWrapper = new QueryStatement($stmt, $query, $this->exceptionInterpreter, $this->queryLoggers);