bpolaszek / simple-dbal

src/Model/Adapter/Mysqli/EmulatedStatement.php

Doc Comments +1 added lines

@@ -8,6 +8,7 @@
 {
     /**
      * @inheritDoc
+     * @param string $queryString
      */
     public function __construct(MysqliAdapter $connection, array $values = null, $queryString)
     {

src/Model/Adapter/Mysqli/MysqliAdapter.php

Doc Comments -1 removed lines

@@ -321,7 +321,6 @@
 
     /**
      * @param CredentialsInterface $credentials
-     * @param bool $resolveNamedParameters
      * @return MysqliAdapter
      */
     public static function factory(CredentialsInterface $credentials, array $options = null): self

Unused Use Statements +1 added lines, -1 removed lines

@@ -15,10 +15,10 @@
 use BenTools\SimpleDBAL\Model\Exception\ParamBindingException;
 use GuzzleHttp\Promise\Promise;
 use GuzzleHttp\Promise\PromiseInterface;
+use Throwable;
 use mysqli;
 use mysqli_result;
 use mysqli_sql_exception;
-use Throwable;
 
 class MysqliAdapter implements AdapterInterface, TransactionAdapterInterface, ReconnectableAdapterInterface
 {

Spacing +6 added lines, -6 removed lines

@@ -56,7 +56,7 @@ 
         $this->cnx         = $cnx;
         $this->credentials = $credentials;
         if (null !== $options) {
-            $this->options     = array_replace($this->getDefaultOptions(), $options);
+            $this->options = array_replace($this->getDefaultOptions(), $options);
             if ($this->hasOption('charset')) {
                 $this->cnx->set_charset($this->getOption('charset'));
             }
@@ -143,7 +143,7 @@ 
         }
 
         try {
-            $wrappedStmt = self::wrapWithErrorHandler(function () use ($runnableQueryString) {
+            $wrappedStmt = self::wrapWithErrorHandler(function() use ($runnableQueryString) {
                 return $this->cnx->prepare($runnableQueryString);
             });
         } catch (mysqli_sql_exception $e) {
@@ -206,7 +206,7 @@ 
             return $this->executeParallel($stmt, $values);
         }
 
-        $promise = new Promise(function () use (&$promise, $stmt, $values) {
+        $promise = new Promise(function() use (&$promise, $stmt, $values) {
             try {
                 $promise->resolve($this->execute($stmt, $values));
             } catch (Throwable $e) {
@@ -250,7 +250,7 @@ 
         }
 
         $stmt->bind();
-        $promise = MysqliAsync::query($stmt->getRunnableQuery(), $cnx)->then(function ($result) use ($cnx, $stmt) {
+        $promise = MysqliAsync::query($stmt->getRunnableQuery(), $cnx)->then(function($result) use ($cnx, $stmt) {
             if (!$result instanceof mysqli_result) {
                 $result = null;
             }
@@ -263,7 +263,7 @@ 
     private function runStmt(Statement $stmt)
     {
         try {
-            return self::wrapWithErrorHandler(function () use ($stmt) {
+            return self::wrapWithErrorHandler(function() use ($stmt) {
                 return $stmt->createResult();
             });
         } catch (mysqli_sql_exception $e) {
@@ -358,7 +358,7 @@ 
      */
     private static function wrapWithErrorHandler(callable $run)
     {
-        $errorHandler = function ($errno, $errstr) {
+        $errorHandler = function($errno, $errstr) {
             throw new mysqli_sql_exception($errstr, $errno);
         };
         set_error_handler($errorHandler, E_WARNING);

src/Model/Adapter/PDO/PDOAdapter.php

Doc Comments -1 removed lines

@@ -180,7 +180,6 @@
     }
 
     /**
-     * @param \PDOStatement $wrappedStmt
      */
     private function runStmt(Statement $stmt)
     {

Spacing +5 added lines, -5 removed lines

@@ -52,7 +52,7 @@ 
         }
         $this->credentials = $credentials;
         if (null !== $options) {
-            $this->options     = array_replace($this->getDefaultOptions(), $options);
+            $this->options = array_replace($this->getDefaultOptions(), $options);
         }
     }
 
@@ -78,7 +78,7 @@ 
     public function isConnected(): bool
     {
         try {
-            self::wrapWithErrorHandler(function () {
+            self::wrapWithErrorHandler(function() {
                 $this->cnx->getAttribute(PDO::ATTR_SERVER_INFO);
             });
             return true;
@@ -169,7 +169,7 @@ 
      */
     public function executeAsync($stmt, array $values = null): PromiseInterface
     {
-        $promise = new Promise(function () use (&$promise, $stmt, $values) {
+        $promise = new Promise(function() use (&$promise, $stmt, $values) {
             try {
                 $promise->resolve($this->execute($stmt, $values));
             } catch (DBALException $e) {
@@ -186,7 +186,7 @@ 
     {
         $wrappedStmt = $stmt->getWrappedStatement();
         try {
-            self::wrapWithErrorHandler(function () use ($stmt, $wrappedStmt) {
+            self::wrapWithErrorHandler(function() use ($stmt, $wrappedStmt) {
                 $stmt->bind();
                 $wrappedStmt->execute();
             });
@@ -273,7 +273,7 @@ 
      */
     private static function wrapWithErrorHandler(callable $run)
     {
-        $errorHandler = function ($errno, $errstr) {
+        $errorHandler = function($errno, $errstr) {
             throw new PDOException($errstr, $errno);
         };
         set_error_handler($errorHandler, E_WARNING);

Unused Use Statements +1 added lines, -1 removed lines

@@ -5,8 +5,8 @@
 use BenTools\SimpleDBAL\Contract\AdapterInterface;
 use BenTools\SimpleDBAL\Contract\CredentialsInterface;
 use BenTools\SimpleDBAL\Contract\ReconnectableAdapterInterface;
-use BenTools\SimpleDBAL\Contract\StatementInterface;
 use BenTools\SimpleDBAL\Contract\ResultInterface;
+use BenTools\SimpleDBAL\Contract\StatementInterface;
 use BenTools\SimpleDBAL\Contract\TransactionAdapterInterface;
 use BenTools\SimpleDBAL\Model\ConfigurableTrait;
 use BenTools\SimpleDBAL\Model\Exception\AccessDeniedException;

src/Model/Adapter/PDO/Result.php

Doc Comments +1 added lines, -1 removed lines

@@ -28,7 +28,7 @@
     /**
      * Result constructor.
      * @param PDO $pdo
-     * @param Statement $stmt
+     * @param PDOStatement $stmt
      */
     public function __construct(PDO $pdo, PDOStatement $stmt = null)
     {

Spacing +2 added lines, -2 removed lines

@@ -76,7 +76,7 @@ 
     /**
      * @inheritDoc
      */
-    public function asRow(): ?array
+    public function asRow(): ? array
     {
         if (null === $this->stmt) {
             throw new DBALException("No \PDOStatement object provided.");
@@ -111,7 +111,7 @@ 
                     $this->resetResultset();
                 }
 
-                $generator = function (\PDOStatement $stmt) {
+                $generator = function(\PDOStatement $stmt) {
                     while ($value = $stmt->fetchColumn(0)) {
                         yield $value;
                     }

src/Model/Adapter/PDO/Statement.php

Doc Comments +1 added lines

@@ -126,6 +126,7 @@
 
     /**
      * @param $var
+     * @param string $value
      * @return int
      */
     protected function getPdoType($value)

Spacing +1 added lines, -1 removed lines

@@ -156,7 +156,7 @@
             return $this->stmt->queryString;
         }
 
-        $escape = function ($value) {
+        $escape = function($value) {
             if (null === $value) {
                 return 'NULL';
             }

Unused Use Statements +1 added lines, -1 removed lines

@@ -3,8 +3,8 @@
 namespace BenTools\SimpleDBAL\Model\Adapter\PDO;
 
 use BenTools\SimpleDBAL\Contract\AdapterInterface;
-use BenTools\SimpleDBAL\Contract\StatementInterface;
 use BenTools\SimpleDBAL\Contract\ResultInterface;
+use BenTools\SimpleDBAL\Contract\StatementInterface;
 use BenTools\SimpleDBAL\Model\StatementTrait;
 use PDO;
 use PDOStatement;

src/Model/StatementTrait.php

Spacing +1 added lines, -1 removed lines

@@ -14,7 +14,7 @@
     /**
      * @inheritDoc
      */
-    public function getValues(): ?array
+    public function getValues(): ? array
     {
         return $this->values;
     }

src/Model/Adapter/Mysqli/Statement.php

Spacing +1 added lines, -1 removed lines

@@ -163,7 +163,7 @@
             return $this->queryString;
         }
 
-        $escape = function ($value) {
+        $escape = function($value) {
             if (null === $value) {
                 return 'NULL';
             }

src/Model/Adapter/Mysqli/MysqliAsync.php

Spacing +2 added lines, -2 removed lines

@@ -32,7 +32,7 @@ 
      */
     public static function query(string $query, mysqli $cnx)
     {
-        $promise = new Promise(function () {
+        $promise = new Promise(function() {
             self::getInstance()->wait();
         });
         $cnx->query($query, MYSQLI_ASYNC);
@@ -118,7 +118,7 @@ 
             }
             foreach ($this->queries as $l => $link) {
                 $promise = $this->getPromise($link);
-                $cnx    = $this->getConnection($link);
+                $cnx = $this->getConnection($link);
                 try {
                     $result = $cnx->reap_async_query();
                     if ($result instanceof mysqli_result) {

src/Model/Adapter/Mysqli/Result.php

Spacing +2 added lines, -2 removed lines

@@ -78,7 +78,7 @@ 
     /**
      * @inheritDoc
      */
-    public function asRow(): ?array
+    public function asRow(): ? array
     {
         if (null === $this->result) {
             throw new DBALException("No mysqli_result object provided.");
@@ -113,7 +113,7 @@ 
                     $this->resetResultset();
                 }
 
-                $generator = function (\mysqli_result $result) {
+                $generator = function(\mysqli_result $result) {
                     while ($row = $result->fetch_array(MYSQLI_NUM)) {
                         yield $row[0];
                     }