vakata / database

src/DriverAbstract.php

Spacing +3 added lines, -3 removed lines

@@ -12,7 +12,7 @@ 
         $new = '';
         $par = array_values($par);
         if (substr_count($sql, '?') === 2 && !is_array($par[0])) {
-            $par = [ $par ];
+            $par = [$par];
         }
         $parts = explode('??', $sql);
         $index = 0;
@@ -22,7 +22,7 @@ 
             $index += count($tmp) - 1;
             if (isset($par[$index])) {
                 if (!is_array($par[$index])) {
-                    $par[$index] = [ $par[$index] ];
+                    $par[$index] = [$par[$index]];
                 }
                 $params = $par[$index];
                 array_splice($par, $index, 1, $params);
@@ -30,7 +30,7 @@ 
                 $new .= implode(',', array_fill(0, count($params), '?'));
             }
         }
-        return [ $new, $par ];
+        return [$new, $par];
     }
     /**
      * Run a query (prepare & execute).

src/driver/postgre/Statement.php

Spacing +1 added lines, -2 removed lines

@@ -23,8 +23,7 @@
             $data = array();
         }
         $temp = (is_array($data) && count($data)) ?
-            \pg_query_params($this->driver, $this->statement, $data) :
-            \pg_query_params($this->driver, $this->statement, array());
+            \pg_query_params($this->driver, $this->statement, $data) : \pg_query_params($this->driver, $this->statement, array());
         if (!$temp) {
             throw new DBException('Could not execute query : '.\pg_last_error($this->driver).' <'.$this->statement.'>');
         }

src/driver/sqlite/Result.php

Spacing +1 added lines, -1 removed lines

@@ -62,7 +62,7 @@
     }
     public function next()
     {
-        $this->fetched ++;
+        $this->fetched++;
         $this->last = $this->statement->fetchArray(\SQLITE3_ASSOC);
     }
     public function valid()

src/driver/ibase/Result.php

Spacing +1 added lines, -1 removed lines

@@ -67,7 +67,7 @@
     }
     public function next()
     {
-        $this->fetched ++;
+        $this->fetched++;
         $this->last = \ibase_fetch_assoc($this->result, \IBASE_TEXT);
     }
     public function valid()

src/driver/ibase/Driver.php

Spacing +1 added lines, -1 removed lines

@@ -52,7 +52,7 @@
         $this->connect();
         $statement = \ibase_prepare($this->transaction !== null ? $this->transaction : $this->lnk, $sql);
         if ($statement === false) {
-            throw new DBException('Prepare error: ' . \ibase_errmsg());
+            throw new DBException('Prepare error: '.\ibase_errmsg());
         }
         return new Statement(
             $statement,

src/driver/pdo/Result.php

Spacing +1 added lines, -1 removed lines

@@ -55,7 +55,7 @@
     }
     public function next()
     {
-        $this->fetched ++;
+        $this->fetched++;
         $this->last = $this->statement->fetch(\PDO::FETCH_ASSOC);
     }
     public function valid()

src/driver/pdo/Driver.php

Spacing +1 added lines, -1 removed lines

@@ -44,7 +44,7 @@
                     isset($this->connection['opts']) ? $this->connection['opts'] : []
                 );
             } catch (\PDOException $e) {
-                throw new DBException('Connect error: ' . $e->getMessage());
+                throw new DBException('Connect error: '.$e->getMessage());
             }
         }
     }

src/driver/odbc/Result.php

Spacing +1 added lines, -1 removed lines

@@ -74,7 +74,7 @@
     }
     public function next()
     {
-        $this->fetched ++;
+        $this->fetched++;
         $temp = \odbc_fetch_row($this->statement);
         if (!$temp) {
             $this->last = false;

src/schema/TableQueryIterator.php

Spacing +7 added lines, -7 removed lines

@@ -70,7 +70,7 @@ 
                 $fields = [];
                 $exists = false;
                 foreach ($relation->table->getColumns() as $column) {
-                    $nm = $name . static::SEP . $column;
+                    $nm = $name.static::SEP.$column;
                     if (isset($this->aliases[$nm])) {
                         $nm = $this->aliases[$nm];
                     }
@@ -84,16 +84,16 @@ 
                 $parts = explode(static::SEP, $name);
                 $name  = array_pop($parts);
                 if (!$exists && !count($parts) && !isset($temp[$name])) {
-                    $temp[$name] = $relation->many ? [ '___clean' => true ] : null;
+                    $temp[$name] = $relation->many ? ['___clean' => true] : null;
                 }
                 if ($exists) {
-                    $full  = '';
+                    $full = '';
                     foreach ($parts as $item) {
-                        $full = $full ? $full . static::SEP . $item : $item;
+                        $full = $full ? $full.static::SEP.$item : $item;
                         $temp = &$temp[$item];
                         $rpk = [];
                         foreach ($this->relations[$full][0]->table->getPrimaryKey() as $pkey) {
-                            $nm = $full . static::SEP . $pkey;
+                            $nm = $full.static::SEP.$pkey;
                             if (isset($this->aliases[$nm])) {
                                 $nm = $this->aliases[$nm];
                             }
@@ -102,7 +102,7 @@ 
                         $temp = &$temp[json_encode($rpk)];
                     }
                     if (!isset($temp[$name])) {
-                        $temp[$name] = $relation->many ? [ '___clean' => true ] : null;
+                        $temp[$name] = $relation->many ? ['___clean' => true] : null;
                     }
                     $temp = &$temp[$name];
                     if ($relation->many) {
@@ -160,7 +160,7 @@ 
                 return;
             }
         }
-        $this->fetched ++;
+        $this->fetched++;
         while ($this->result->valid()) {
             $row = $this->result->current();
             $pk = [];