rkrx / php-mysql-query-builder

src/Builder/Helpers/YieldPolyfillIterator.php

Doc Comments +1 added lines, -1 removed lines

@@ -74,7 +74,7 @@
 	}
 
 	/**
-	 * @return mixed
+	 * @return integer
 	 */
 	public function key() {
 		return $this->idx;

Spacing +8 added lines, -8 removed lines

@@ -47,16 +47,16 @@ 
 	 */
 	public function current() {
 		$row = $this->currentItem;
-		if($this->preserveTypes) {
+		if ($this->preserveTypes) {
 			$columnDefinitions = FieldTypeProvider::getFieldTypes($this->getStmt());
 			$row = FieldValueConverter::convertValues($row, $columnDefinitions);
 		}
 		$callback = $this->callback;
-		if($callback !== null) {
+		if ($callback !== null) {
 			$result = $callback($row);
-			if($result instanceof DBIgnoreRow) {
+			if ($result instanceof DBIgnoreRow) {
 				// Do nothing in this case
-			} elseif($result !== null) {
+			} elseif ($result !== null) {
 				return $result;
 			} else {
 				return $row;
@@ -85,7 +85,7 @@ 
 	 */
 	public function valid() {
 		$result = !!$this->currentItem;
-		if(!$result) {
+		if (!$result) {
 			$this->closeCursor();
 		}
 		return $result;
@@ -94,7 +94,7 @@ 
 	/**
 	 */
 	public function rewind() {
-		if($this->stmt !== null) {
+		if ($this->stmt !== null) {
 			throw new \Exception("It's not possible to rewind this iterator");
 		}
 		$this->stmt = call_user_func($this->statementFactory);
@@ -106,7 +106,7 @@ 
 	 * @return QueryStatement
 	 */
 	private function getStmt() {
-		if($this->stmt === null) {
+		if ($this->stmt === null) {
 			$this->rewind();
 		}
 		return $this->stmt;
@@ -115,7 +115,7 @@ 
 	/**
 	 */
 	private function closeCursor() {
-		if($this->stmt instanceof QueryStatement) {
+		if ($this->stmt instanceof QueryStatement) {
 			$this->stmt->closeCursor();
 		}
 		$this->stmt = null;

Unused Use Statements -1 removed lines

@@ -4,7 +4,6 @@
 use Closure;
 use Iterator;
 use Kir\MySQL\Builder\QueryStatement;
-use PDO;
 
 class YieldPolyfillIterator implements Iterator {
 	/** @var Closure|null */

src/Builder/Select.php

Doc Comments +1 added lines, -1 removed lines

@@ -78,7 +78,7 @@
 	}
 
 	/**
-	 * @return array
+	 * @return string[]
 	 */
 	public function getFields() {
 		return $this->fields;

src/Builder/Traits/LimitBuilder.php

Spacing +2 added lines, -2 removed lines

@@ -28,10 +28,10 @@
 	 */
 	protected function buildLimit($query, $offset = null) {
 		$limit = $this->limit;
-		if($limit === null && $offset !== null) {
+		if ($limit === null && $offset !== null) {
 			$limit = '18446744073709551615';
 		}
-		if($limit !== null) {
+		if ($limit !== null) {
 			$query .= "LIMIT\n\t{$limit}\n";
 		}
 		return $query;

src/Builder/Helpers/LazyRowGenerator.php

Spacing +5 added lines, -5 removed lines

@@ -21,16 +21,16 @@
 	 * @return array[]|\Generator
 	 */
 	public function generate(QueryStatement $statement, Closure $callback = null) {
-		while($row = $statement->fetch()) {
-			if($this->preserveTypes) {
+		while ($row = $statement->fetch()) {
+			if ($this->preserveTypes) {
 				$columnDefinitions = FieldTypeProvider::getFieldTypes($statement);
 				$row = FieldValueConverter::convertValues($row, $columnDefinitions);
 			}
-			if($callback !== null) {
+			if ($callback !== null) {
 				$result = $callback($row);
-				if($result instanceof DBIgnoreRow) {
+				if ($result instanceof DBIgnoreRow) {
 					// Do nothing in this case
-				} elseif($result !== null) {
+				} elseif ($result !== null) {
 					yield $result;
 				} else {
 					yield $row;

src/Builder/QueryStatement.php

Spacing +4 added lines, -4 removed lines

@@ -46,12 +46,12 @@ 
 	 * @return $this
 	 */
 	public function setFetchMode($mode, $arg0 = null, array $arg1 = null) {
-		if($arg1 !== null) {
+		if ($arg1 !== null) {
 			/** @noinspection PhpMethodParametersCountMismatchInspection */
 			$this->statement->setFetchMode($mode, $arg0, $arg1);
 			return $this;
 		}
-		if($arg0 !== null) {
+		if ($arg0 !== null) {
 			/** @noinspection PhpMethodParametersCountMismatchInspection */
 			$this->statement->setFetchMode($mode, $arg0);
 			return $this;
@@ -70,7 +70,7 @@ 
 			$timer = microtime(true);
 			$response = $this->statement->execute($params);
 			$this->queryLoggers->log($this->query, microtime(true)-$timer);
-			if(!$response) {
+			if (!$response) {
 				throw new SqlException('Execution returned with "false".');
 			}
 		});
@@ -85,7 +85,7 @@ 
 	 */
 	public function fetchAll($fetchStyle = null, $fetchArgument = null, array $ctorArgs = []) {
 		return $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);