rkrx / php-mysql-query-builder

src/QueryLogger/QueryLoggers.php

Spacing +1 added lines, -1 removed lines

@@ -20,7 +20,7 @@
 	 * @return $this
 	 */
 	public function log($query, $duration) {
-		foreach($this->queryLoggers as $queryLogger) {
+		foreach ($this->queryLoggers as $queryLogger) {
 			$queryLogger->log($query, $duration);
 		}
 		return $this;

src/Tools/AliasReplacer.php

Spacing +2 added lines, -2 removed lines

@@ -19,11 +19,11 @@
 	 * @return string
 	 */
 	public function replace($name) {
-		$fn = function ($values) {
+		$fn = function($values) {
 			$alias = $values[1];
 			$part = $values[2];
 			$string = $this->aliasRegistry->get($alias);
-			return $string . $part;
+			return $string.$part;
 		};
 		return preg_replace_callback('/^(\\w+)#(\\w+)$/', $fn, $name);
 	}

src/Tools/AliasRegistry.php

Spacing +1 added lines, -1 removed lines

@@ -23,7 +23,7 @@
 	 * @return string
 	 */
 	public function get($alias) {
-		if(!array_key_exists($alias, $this->aliases)) {
+		if (!array_key_exists($alias, $this->aliases)) {
 			throw new \Exception("Alias not found: {$alias}");
 		}
 		return $this->aliases[$alias];

src/Builder/Select.php

Spacing +11 added lines, -11 removed lines

@@ -37,17 +37,17 @@ 
 	 * @return $this
 	 */
 	public function field($expression, $alias = null) {
-		if(is_object($expression)) {
+		if (is_object($expression)) {
 			$expression = (string) $expression;
 			$expression = trim($expression);
 			$expression = rtrim($expression, ';');
 			$expression = trim($expression);
 			$lines = explode("\n", $expression);
-			$lines = array_map(function ($line) { return "\t\t{$line}"; }, $lines);
+			$lines = array_map(function($line) { return "\t\t{$line}"; }, $lines);
 			$expression = join("\n", $lines);
 			$expression = sprintf("(\n%s\n\t)", $expression);
 		}
-		if($alias === null) {
+		if ($alias === null) {
 			$this->fields[] = $expression;
 		} else {
 			$this->fields[$alias] = $expression;
@@ -60,7 +60,7 @@ 
 	 * @return $this
 	 */
 	public function fields(array $fields) {
-		foreach($fields as $alias => $expression) {
+		foreach ($fields as $alias => $expression) {
 			$this->field($expression, $alias);
 		}
 		return $this;
@@ -95,7 +95,7 @@ 
 	 * @return $this
 	 */
 	public function setCalcFoundRows($calcFoundRows = true) {
-		if(ini_get("mysql.trace_mode")) {
+		if (ini_get("mysql.trace_mode")) {
 			throw new \Exception('This function cant operate with mysql.trace_mode is set.');
 		}
 		$this->calcFoundRows = $calcFoundRows;
@@ -117,12 +117,12 @@ 
 	 */
 	public function __toString() {
 		$query = "SELECT";
-		if($this->calcFoundRows) {
+		if ($this->calcFoundRows) {
 			$query .= " SQL_CALC_FOUND_ROWS";
 		}
 		$query .= "\n";
 		$query = $this->buildFields($query);
-		if(count($this->getTables())) {
+		if (count($this->getTables())) {
 			$query .= "FROM\n";
 		}
 		$query = $this->buildTables($query);
@@ -144,9 +144,9 @@ 
 	 */
 	private function buildFields($query) {
 		$fields = array();
-		if(count($this->fields)) {
-			foreach($this->fields as $alias => $expression) {
-				if(is_numeric($alias)) {
+		if (count($this->fields)) {
+			foreach ($this->fields as $alias => $expression) {
+				if (is_numeric($alias)) {
 					$fields[] = "\t{$expression}";
 				} else {
 					$fields[] = "\t{$expression} AS `{$alias}`";
@@ -163,7 +163,7 @@ 
 	 * @return string
 	 */
 	private function buildForUpdate($query) {
-		if($this->forUpdate) {
+		if ($this->forUpdate) {
 			$query .= "FOR UPDATE\n";
 		}
 		return $query;

src/Builder/QueryStatement.php

Spacing +8 added lines, -8 removed lines

@@ -43,10 +43,10 @@ 
 	 * @return bool
 	 */
 	public function execute(array $params = []) {
-		return $this->exceptionHandler(function () use ($params) {
+		return $this->exceptionHandler(function() use ($params) {
 			$timer = microtime(true);
 			$response = $this->statement->execute($params);
-			$this->queryLoggers->log($this->query, microtime(true) - $timer);
+			$this->queryLoggers->log($this->query, microtime(true)-$timer);
 			return $response;
 		});
 	}
@@ -56,7 +56,7 @@ 
 	 */
 	public function fetchAll() {
 		$args = func_get_args();
-		return $this->exceptionHandler(function () use ($args) {
+		return $this->exceptionHandler(function() use ($args) {
 			return call_user_func_array([$this->statement, 'fetchAll'], $args);
 		});
 	}
@@ -68,7 +68,7 @@ 
 	 * @return mixed
 	 */
 	public function fetch($fetchStyle = PDO::FETCH_ASSOC, $cursorOrientation = PDO::FETCH_ORI_NEXT, $cursorOffset = 0) {
-		return $this->exceptionHandler(function () use ($fetchStyle, $cursorOrientation, $cursorOffset) {
+		return $this->exceptionHandler(function() use ($fetchStyle, $cursorOrientation, $cursorOffset) {
 			return $this->statement->fetch($fetchStyle, $cursorOrientation, $cursorOffset);
 		});
 	}
@@ -78,7 +78,7 @@ 
 	 * @return mixed
 	 */
 	public function fetchColumn($columnNo = 0) {
-		return $this->exceptionHandler(function () use ($columnNo) {
+		return $this->exceptionHandler(function() use ($columnNo) {
 			return $this->statement->fetchColumn($columnNo);
 		});
 	}
@@ -87,7 +87,7 @@ 
 	 * @return bool
 	 */
 	public function closeCursor() {
-		return $this->exceptionHandler(function () {
+		return $this->exceptionHandler(function() {
 			return $this->statement->closeCursor();
 		});
 	}
@@ -96,7 +96,7 @@ 
 	 * @return int
 	 */
 	public function columnCount() {
-		return $this->exceptionHandler(function () {
+		return $this->exceptionHandler(function() {
 			return $this->statement->columnCount();
 		});
 	}
@@ -106,7 +106,7 @@ 
 	 * @return array
 	 */
 	public function getColumnMeta($columnNo) {
-		return $this->exceptionHandler(function () use ($columnNo) {
+		return $this->exceptionHandler(function() use ($columnNo) {
 			return $this->statement->getColumnMeta($columnNo);
 		});
 	}

src/Builder/Statement.php

Spacing +2 added lines, -2 removed lines

@@ -24,12 +24,12 @@
 	 * @return $this
 	 */
 	public function debug($stop = true) {
-		if(php_sapi_name() == 'cli') {
+		if (php_sapi_name() == 'cli') {
 			echo "\n{$this->__toString()}\n";
 		} else {
 			echo "<pre>{$this->__toString()}</pre>";
 		}
-		if($stop) {
+		if ($stop) {
 			exit;
 		}
 		return $this;

src/Builder/Update.php

Spacing +8 added lines, -8 removed lines

@@ -74,15 +74,15 @@ 
 	 * @throws Exception
 	 */
 	public function setAll(array $data, array $allowedFields = null) {
-		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);
 			}
 		}
@@ -125,14 +125,14 @@ 
 	 * @throws Exception
 	 */
 	private function clearValues(array $values) {
-		if(!count($values)) {
+		if (!count($values)) {
 			return [];
 		}
 		$tables = $this->getTables();
-		if(!count($tables)) {
+		if (!count($tables)) {
 			throw new Exception('Table name is missing');
 		}
-		if(count($tables) > 1) {
+		if (count($tables) > 1) {
 			throw new Exception('Batch values only work with max. one table');
 		}
 		list($table) = $tables;
@@ -142,7 +142,7 @@ 
 		$result = array();
 
 		foreach ($values as $fieldName => $fieldValue) {
-			if(in_array($fieldName, $fields)) {
+			if (in_array($fieldName, $fields)) {
 				$result[$fieldName] = $fieldValue;
 			}
 		}

src/Builder/InsertUpdateStatement.php

Spacing +5 added lines, -5 removed lines

@@ -30,14 +30,14 @@ 
 	 */
 	protected function buildFieldList(array $fields, array $query = array()) {
 		foreach ($fields as $fieldName => $fieldValue) {
-			if($fieldValue instanceof DefaultValue) {
+			if ($fieldValue instanceof DefaultValue) {
 				$fieldValue = 'DEFAULT';
 			}
-			if(is_array($this->mask) && !in_array($fieldName, $this->mask)) {
+			if (is_array($this->mask) && !in_array($fieldName, $this->mask)) {
 				continue;
 			}
 			if (is_int($fieldName)) {
-				if(is_array($fieldValue)) {
+				if (is_array($fieldValue)) {
 					$fieldValue = $this->db()->quoteExpression($fieldValue[0], array_slice($fieldValue, 1));
 				}
 				$query[] = "\t{$fieldValue}";
@@ -55,10 +55,10 @@ 
 	 * @return bool
 	 */
 	protected function isFieldAccessible($fieldName, array $tableFields) {
-		if(!in_array($fieldName, $tableFields)) {
+		if (!in_array($fieldName, $tableFields)) {
 			return false;
 		}
-		if(!is_array($this->mask)) {
+		if (!is_array($this->mask)) {
 			return true;
 		}
 		return in_array($fieldName, $this->mask);

src/Builder/RunnableInsert.php

Spacing +3 added lines, -3 removed lines

@@ -15,13 +15,13 @@ 
 	 * @return int[] Insert IDs
 	 */
 	public function insertRows($rows) {
-		if(!(is_array($rows) || $rows instanceof Traversable)) {
+		if (!(is_array($rows) || $rows instanceof Traversable)) {
 			throw new BadMethodCallException('Expected $rows to by an array or an instance of \\Traversable');
 		}
 		$result = [];
 		$query = $this->__toString();
 		$stmt = $this->db()->prepare($query);
-		foreach($rows as $row) {
+		foreach ($rows as $row) {
 			$stmt->execute($row);
 			$result[] = (int) $this->db()->getLastInsertId();
 		}
@@ -33,7 +33,7 @@ 
 	 * @return DDLRunnable
 	 */
 	public function prepare() {
-		return $this->createPreparable($this->db()->prepare($this), function () {
+		return $this->createPreparable($this->db()->prepare($this), function() {
 			return (int) $this->db()->getLastInsertId();
 		});
 	}