bpolaszek / simple-dbal

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/PDO/Statement.php

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';
             }

src/Model/Adapter/PDO/PDOAdapter.php

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;
@@ -174,7 +174,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) {
@@ -188,7 +188,7 @@ 
     {
         $wrappedStmt = $stmt->getWrappedStatement();
         try {
-            self::wrapWithErrorHandler(function () use ($stmt, $wrappedStmt) {
+            self::wrapWithErrorHandler(function() use ($stmt, $wrappedStmt) {
                 $stmt->bind();
                 $wrappedStmt->execute();
             });
@@ -289,7 +289,7 @@ 
      */
     private static function wrapWithErrorHandler(callable $run)
     {
-        $errorHandler = static function ($errno, $errstr) {
+        $errorHandler = static function($errno, $errstr) {
             throw new PDOException($errstr, $errno);
         };
         set_error_handler($errorHandler, E_WARNING);

src/Model/Adapter/PDO/Result.php

Spacing +1 added lines, -1 removed lines

@@ -83,7 +83,7 @@
 
         $this->freeze();
 
-        $generator = static function (PDOStatement $stmt) {
+        $generator = static function(PDOStatement $stmt) {
             while (false !== ($value = $stmt->fetchColumn(0))) {
                 yield $value;
             }

src/Model/Adapter/Mysqli/MysqliAdapter.php

Spacing +5 added lines, -5 removed lines

@@ -147,7 +147,7 @@ 
 
         try {
             $wrappedStmt = self::wrapWithErrorHandler(
-                function () use ($runnableQueryString) {
+                function() use ($runnableQueryString) {
                     return $this->cnx->prepare($runnableQueryString);
                 }
             );
@@ -215,7 +215,7 @@ 
         }
 
         $promise = new Promise(
-            function () use (&$promise, $stmt, $values) {
+            function() use (&$promise, $stmt, $values) {
                 try {
                     $promise->resolve($this->execute($stmt, $values));
                 } catch (Throwable $e) {
@@ -267,7 +267,7 @@ 
         $query = $stmt instanceof EmulatedStatement ? $stmt->getRunnableQuery() : $stmt;
 
         return MysqliAsync::query($query, $cnx)->then(
-            static function ($result) use ($cnx) {
+            static function($result) use ($cnx) {
                 if (!$result instanceof mysqli_result) {
                     $result = null;
                 }
@@ -281,7 +281,7 @@ 
     {
         try {
             return self::wrapWithErrorHandler(
-                static function () use ($stmt) {
+                static function() use ($stmt) {
                     return $stmt->createResult();
                 }
             );
@@ -398,7 +398,7 @@ 
      */
     private static function wrapWithErrorHandler(callable $run)
     {
-        $errorHandler = static function ($errno, $errstr) {
+        $errorHandler = static function($errno, $errstr) {
             throw new mysqli_sql_exception($errstr, $errno);
         };
         set_error_handler($errorHandler, E_WARNING);

src/Model/Adapter/Mysqli/Result.php

Spacing +1 added lines, -1 removed lines

@@ -88,7 +88,7 @@
 
         $this->freeze();
 
-        $generator = function (mysqli_result $result) {
+        $generator = function(mysqli_result $result) {
             while (null !== ($row = $result->fetch_array(MYSQLI_NUM))) {
                 yield $row[0];
             }