vakata / database

src/DB.php

Doc Comments -3 removed lines

@@ -117,7 +117,6 @@ 
     /**
      * Run a query (prepare & execute).
      * @param string $sql  SQL query
-     * @param array  $data parameters (optional)
      * @return ResultInterface the result of the execution
      */
     public function query(string $sql, $par = null) : ResultInterface
@@ -170,7 +169,6 @@ 
      * Run a SELECT query and get a single row
      * @param string   $sql      SQL query
      * @param array    $par      parameters
-     * @param callable $keys     an optional mutator to pass each row's keys through (the column names)
      * @param bool     $opti     if a single column is returned - do not use an array wrapper (defaults to `true`)
      * @return Collection the result of the execution
      */
@@ -184,7 +182,6 @@ 
      * @param array    $par      parameters
      * @param string   $key      column name to use as the array index
      * @param bool     $skip     do not include the column used as index in the value (defaults to `false`)
-     * @param callable $keys     an optional mutator to pass each row's keys through (the column names)
      * @param bool     $opti     if a single column is returned - do not use an array wrapper (defaults to `true`)
      * @return Collection the result of the execution
      */

Spacing +14 added lines, -16 removed lines

@@ -73,8 +73,7 @@ 
         }
         $connection['name'] = $connectionString;
         $connection['type'] = isset($aliases[$connection['type']]) ?
-            $aliases[$connection['type']] :
-            $connection['type'];
+            $aliases[$connection['type']] : $connection['type'];
         $tmp = '\\vakata\\database\\driver\\'.strtolower($connection['type']).'\\Driver';
         return new $tmp($connection);
     }
@@ -94,7 +93,7 @@ 
         $new = '';
         $par = array_values($par);
         if (substr_count($sql, '?') === 2 && !is_array($par[0])) {
-            $par = [ $par ];
+            $par = [$par];
         }
         $parts = explode('??', $sql);
         $index = 0;
@@ -104,7 +103,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);
@@ -112,7 +111,7 @@ 
                 $new .= implode(',', array_fill(0, count($params), '?'));
             }
         }
-        return [ $new, $par ];
+        return [$new, $par];
     }
     /**
      * Run a query (prepare & execute).
@@ -144,7 +143,7 @@ 
     {
         $coll = Collection::from($this->query($sql, $par));
         if (($keys = $this->driver->option('mode')) && in_array($keys, ['strtoupper', 'strtolower'])) {
-            $coll->map(function ($v) use ($keys) {
+            $coll->map(function($v) use ($keys) {
                 $new = [];
                 foreach ($v as $k => $vv) {
                     $new[call_user_func($keys, $k)] = $vv;
@@ -153,16 +152,16 @@ 
             });
         }
         if ($key) {
-            $coll->mapKey(function ($v) use ($key) { return $v[$key]; });
+            $coll->mapKey(function($v) use ($key) { return $v[$key]; });
         }
         if ($skip) {
-            $coll->map(function ($v) use ($key) { unset($v[$key]); return $v; });
+            $coll->map(function($v) use ($key) { unset($v[$key]); return $v; });
         }
         if ($opti) {
-            $coll->map(function ($v) { return count($v) === 1 ? current($v) : $v; });
+            $coll->map(function($v) { return count($v) === 1 ? current($v) : $v; });
         }
         if ($keys) {
-            $coll->map(function ($v) use ($key) { unset($v[$key]); return $v; });
+            $coll->map(function($v) use ($key) { unset($v[$key]); return $v; });
         }
         return $coll;
     }
@@ -237,8 +236,7 @@ 
     public function definition(string $table, bool $detectRelations = true) : Table
     {
         return isset($this->tables[$table]) ?
-            $this->tables[$table] :
-            $this->driver->table($table, $detectRelations);
+            $this->tables[$table] : $this->driver->table($table, $detectRelations);
     }
     /**
      * Parse all tables from the database.
@@ -255,12 +253,12 @@ 
      */
     public function getSchema($asPlainArray = true)
     {
-        return !$asPlainArray ? $this->tables : array_map(function ($table) {
+        return !$asPlainArray ? $this->tables : array_map(function($table) {
             return [
                 'name' => $table->getName(),
                 'pkey' => $table->getPrimaryKey(),
                 'comment' => $table->getComment(),
-                'columns' => array_map(function ($column) {
+                'columns' => array_map(function($column) {
                     return [
                         'name' => $column->getName(),
                         'type' => $column->getType(),
@@ -270,13 +268,13 @@ 
                         'nullable' => $column->isNullable()
                     ];
                 }, $table->getFullColumns()),
-                'relations' => array_map(function ($rel) {
+                'relations' => array_map(function($rel) {
                     $relation = clone $rel;
                     $relation->table = $relation->table->getName();
                     if ($relation->pivot) {
                         $relation->pivot = $relation->pivot->getName();
                     }
-                    return (array)$relation;
+                    return (array) $relation;
                 }, $table->getRelations())
             ];
         }, $this->tables);

src/driver/postgre/Result.php

Doc Comments +3 added lines

@@ -15,6 +15,9 @@
     protected $iid = null;
     protected $aff = 0;
 
+    /**
+     * @param integer $aff
+     */
     public function __construct($statement, $iid, $aff)
     {
         $this->statement = $statement;

Spacing +1 added lines, -1 removed lines

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

src/driver/sqlite/Result.php

Doc Comments +4 added lines

@@ -15,6 +15,10 @@
     protected $iid = null;
     protected $aff = 0;
 
+    /**
+     * @param integer $iid
+     * @param integer $aff
+     */
     public function __construct(\SQLite3Result $statement, $iid, $aff)
     {
         $this->statement = $statement;

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/DriverAbstract.php

Doc Comments +7 added lines, -1 removed lines

@@ -35,7 +35,6 @@ 
     /**
      * Run a query (prepare & execute).
      * @param string $sql  SQL query
-     * @param array  $data parameters (optional)
      * @return ResultInterface the result of the execution
      */
     public function query(string $sql, $par = null) : ResultInterface
@@ -50,6 +49,13 @@ 
     {
         return $this->connection['name'];
     }
+
+    /**
+     * @param string $key
+     * @param string $default
+     *
+     * @return string
+     */
     public function option($key, $default = null)
     {
         return isset($this->connection['opts'][$key]) ? $this->connection['opts'][$key] : $default;

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/schema/TableQuery.php

Doc Comments +2 added lines, -2 removed lines

@@ -56,7 +56,7 @@ 
     /**
      * Create an instance
      * @param  DBInterface        $db         the database connection
-     * @param  Table|string  $definition     the name or definition of the main table in the query
+     * @param Table $table
      */
     public function __construct(DBInterface $db, $table)
     {
@@ -191,7 +191,7 @@ 
     }
     /**
      * Group by a column (or columns)
-     * @param  string|array        $column the column name (or names) to group by
+     * @param  string        $column the column name (or names) to group by
      * @return $this
      */
     public function group($column) : TableQuery

Unused Use Statements -1 removed lines

@@ -3,7 +3,6 @@
 
 use vakata\database\DBInterface;
 use vakata\database\DBException;
-use vakata\database\ResultInterface;
 
 /**
  * A database query class

Spacing +77 added lines, -80 removed lines

@@ -43,7 +43,7 @@ 
     /**
      * @var int[]
      */
-    protected $li_of = [0,0];
+    protected $li_of = [0, 0];
     /**
      * @var array
      */
@@ -65,7 +65,7 @@ 
     public function __construct(DBInterface $db, $table)
     {
         $this->db = $db;
-        $this->definition = $table instanceof Table ? $table : $this->db->definition((string)$table);
+        $this->definition = $table instanceof Table ? $table : $this->db->definition((string) $table);
         $this->columns($this->definition->getColumns());
     }
     public function __clone()
@@ -85,7 +85,7 @@ 
     {
         $column = explode('.', $column);
         if (count($column) === 1) {
-            $column = [ $this->definition->getName(), $column[0] ];
+            $column = [$this->definition->getName(), $column[0]];
             $col = $this->definition->getColumn($column[1]);
         } elseif (count($column) === 2) {
             if ($column[0] === $this->definition->getName()) {
@@ -105,7 +105,7 @@ 
                         throw new DBException('Invalid column name in related table');
                     }
                 } else {
-                    throw new DBException('Invalid foreign table name: ' . implode(',', $column));
+                    throw new DBException('Invalid foreign table name: '.implode(',', $column));
                 }
             }
         } else {
@@ -114,15 +114,15 @@ 
             $table = $this->definition;
             $table = array_reduce(
                 $column,
-                function ($carry, $item) use (&$table) {
+                function($carry, $item) use (&$table) {
                     $table = $table->getRelation($item)->table;
                     return $table;
                 }
             );
             $col = $table->getColumn($name);
-            $column = [ implode(static::SEP, $column), $name ];
+            $column = [implode(static::SEP, $column), $name];
         }
-        return [ 'name' => implode('.', $column), 'data' => $col ];
+        return ['name' => implode('.', $column), 'data' => $col];
     }
     protected function normalizeValue(TableColumn $col, $value)
     {
@@ -161,7 +161,7 @@ 
                 }
                 return $value;
             case 'int':
-                return (int)$value;
+                return (int) $value;
             default:
                 return $value;
         }
@@ -178,18 +178,16 @@ 
         list($name, $column) = array_values($this->getColumn($column));
         if (is_null($value)) {
             return $negate ?
-                $this->where($name . ' IS NOT NULL') :
-                $this->where($name . ' IS NULL');
+                $this->where($name.' IS NOT NULL') : $this->where($name.' IS NULL');
         }
         if (!is_array($value)) {
             return $negate ?
                 $this->where(
-                    $name . ' <> ?',
-                    [ $this->normalizeValue($column, $value) ]
-                ) :
-                $this->where(
-                    $name . ' = ?',
-                    [ $this->normalizeValue($column, $value) ]
+                    $name.' <> ?',
+                    [$this->normalizeValue($column, $value)]
+                ) : $this->where(
+                    $name.' = ?',
+                    [$this->normalizeValue($column, $value)]
                 );
         }
         if (isset($value['beg']) && isset($value['end'])) {
@@ -200,8 +198,7 @@ 
                         $this->normalizeValue($column, $value['beg']),
                         $this->normalizeValue($column, $value['end'])
                     ]
-                ) :
-                $this->where(
+                ) : $this->where(
                     $name.' BETWEEN ? AND ?',
                     [
                         $this->normalizeValue($column, $value['beg']),
@@ -211,12 +208,12 @@ 
         }
         return $negate ?
             $this->where(
-                $name . ' NOT IN (??)',
-                [ array_map(function ($v) use ($column) { return $this->normalizeValue($column, $v); }, $value) ]
+                $name.' NOT IN (??)',
+                [array_map(function($v) use ($column) { return $this->normalizeValue($column, $v); }, $value)]
             ) :
             $this->where(
-                $name . ' IN (??)',
-                [ array_map(function ($v) use ($column) { return $this->normalizeValue($column, $v); }, $value) ]
+                $name.' IN (??)',
+                [array_map(function($v) use ($column) { return $this->normalizeValue($column, $v); }, $value)]
             );
     }
     /**
@@ -227,7 +224,7 @@ 
      */
     public function sort(string $column, bool $desc = false) : TableQuery
     {
-        return $this->order($this->getColumn($column)['name'] . ' ' . ($desc ? 'DESC' : 'ASC'));
+        return $this->order($this->getColumn($column)['name'].' '.($desc ? 'DESC' : 'ASC'));
     }
     /**
      * Group by a column (or columns)
@@ -237,7 +234,7 @@ 
     public function group($column) : TableQuery
     {
         if (!is_array($column)) {
-            $column = [ $column ];
+            $column = [$column];
         }
         foreach ($column as $k => $v) {
             $column[$k] = $this->getColumn($v)['name'];
@@ -278,7 +275,7 @@ 
         $this->withr = [];
         $this->order = [];
         $this->having = [];
-        $this->li_of = [0,0];
+        $this->li_of = [0, 0];
         $this->qiterator = null;
         return $this;
     }
@@ -291,7 +288,7 @@ 
     public function groupBy(string $sql, array $params = []) : TableQuery
     {
         $this->qiterator = null;
-        $this->group = [ $sql, $params ];
+        $this->group = [$sql, $params];
         return $this;
     }
     /**
@@ -304,7 +301,7 @@ 
      */
     public function join($table, array $fields, string $name = null, bool $multiple = true)
     {
-        $table = $table instanceof Table ? $table : $this->db->definition((string)$table);
+        $table = $table instanceof Table ? $table : $this->db->definition((string) $table);
         $name = $name ?? $table->getName();
         if (isset($this->joins[$name]) || $this->definition->hasRelation($name)) {
             throw new DBException('Alias / table name already in use');
@@ -313,7 +310,7 @@ 
         foreach ($fields as $k => $v) {
             $k = explode('.', $k, 2);
             $k = count($k) == 2 ? $k[1] : $k[0];
-            $this->joins[$name]->keymap[$this->getColumn($name . '.' . $k)['name']] = $this->getColumn($v)['name'];
+            $this->joins[$name]->keymap[$this->getColumn($name.'.'.$k)['name']] = $this->getColumn($v)['name'];
         }
         return $this;
     }
@@ -326,7 +323,7 @@ 
     public function where(string $sql, array $params = []) : TableQuery
     {
         $this->qiterator = null;
-        $this->where[] = [ $sql, $params ];
+        $this->where[] = [$sql, $params];
         return $this;
     }
     /**
@@ -338,7 +335,7 @@ 
     public function having(string $sql, array $params = []) : TableQuery
     {
         $this->qiterator = null;
-        $this->having[] = [ $sql, $params ];
+        $this->having[] = [$sql, $params];
         return $this;
     }
     /**
@@ -350,7 +347,7 @@ 
     public function order(string $sql, array $params = []) : TableQuery
     {
         $this->qiterator = null;
-        $this->order = [ $sql, $params ];
+        $this->order = [$sql, $params];
         return $this;
     }
     /**
@@ -362,7 +359,7 @@ 
     public function limit(int $limit, int $offset = 0) : TableQuery
     {
         $this->qiterator = null;
-        $this->li_of = [ $limit, $offset ];
+        $this->li_of = [$limit, $offset];
         return $this;
     }
     /**
@@ -379,22 +376,22 @@ 
         $relations = $this->withr;
         foreach ($this->definition->getRelations() as $k => $v) {
             foreach ($this->where as $vv) {
-                if (strpos($vv[0], $k . '.') !== false) {
-                    $relations[$k] = [ $v, $table ];
+                if (strpos($vv[0], $k.'.') !== false) {
+                    $relations[$k] = [$v, $table];
                 }
             }
-            if (isset($this->order[0]) && strpos($this->order[0], $k . '.') !== false) {
-                $relations[$k] = [ $v, $table ];
+            if (isset($this->order[0]) && strpos($this->order[0], $k.'.') !== false) {
+                $relations[$k] = [$v, $table];
             }
         }
 
         foreach ($this->joins as $k => $v) {
-            $sql .= ($v->many ? 'LEFT ' : '' ) . 'JOIN '.$v->table->getName().' '.$k.' ON ';
+            $sql .= ($v->many ? 'LEFT ' : '').'JOIN '.$v->table->getName().' '.$k.' ON ';
             $tmp = [];
             foreach ($v->keymap as $kk => $vv) {
                 $tmp[] = $kk.' = '.$vv;
             }
-            $sql .= implode(' AND ', $tmp) . ' ';
+            $sql .= implode(' AND ', $tmp).' ';
         }
         foreach ($relations as $k => $v) {
             $table = $v[1];
@@ -405,13 +402,13 @@ 
                 foreach ($v->keymap as $kk => $vv) {
                     $tmp[] = $table.'.'.$kk.' = '.$k.'_pivot.'.$vv.' ';
                 }
-                $sql .= implode(' AND ', $tmp) . ' ';
+                $sql .= implode(' AND ', $tmp).' ';
                 $sql .= 'LEFT JOIN '.$v->table->getName().' '.$k.' ON ';
                 $tmp = [];
                 foreach ($v->pivot_keymap as $kk => $vv) {
                     $tmp[] = $k.'.'.$vv.' = '.$k.'_pivot.'.$kk.' ';
                 }
-                $sql .= implode(' AND ', $tmp) . ' ';
+                $sql .= implode(' AND ', $tmp).' ';
             } else {
                 $sql .= 'LEFT JOIN '.$v->table->getName().' '.$k.' ON ';
                 $tmp = [];
@@ -419,30 +416,30 @@ 
                     $tmp[] = $table.'.'.$kk.' = '.$k.'.'.$vv.' ';
                 }
                 if ($v->sql) {
-                    $tmp[] = $v->sql . ' ';
+                    $tmp[] = $v->sql.' ';
                     $par = array_merge($par, $v->par ?? []);
                 }
-                $sql .= implode(' AND ', $tmp) . ' ';
+                $sql .= implode(' AND ', $tmp).' ';
             }
         }
         if (count($this->where)) {
             $sql .= 'WHERE ';
             $tmp = [];
             foreach ($this->where as $v) {
-                $tmp[] = '(' . $v[0] . ')';
+                $tmp[] = '('.$v[0].')';
                 $par = array_merge($par, $v[1]);
             }
             $sql .= implode(' AND ', $tmp).' ';
         }
         if (count($this->group)) {
-            $sql .= 'GROUP BY ' . $this->group[0] . ' ';
+            $sql .= 'GROUP BY '.$this->group[0].' ';
             $par = array_merge($par, $this->group[1]);
         }
         if (count($this->having)) {
             $sql .= 'HAVING ';
             $tmp = [];
             foreach ($this->having as $v) {
-                $tmp[] = '(' . $v[0] . ')';
+                $tmp[] = '('.$v[0].')';
                 $par = array_merge($par, $v[1]);
             }
             $sql .= implode(' AND ', $tmp).' ';
@@ -478,7 +475,7 @@ 
                     $this->with(implode('.', $temp));
                     $table = array_reduce(
                         $temp,
-                        function ($carry, $item) use (&$table) {
+                        function($carry, $item) use (&$table) {
                             return $table->getRelation($item)->table;
                         }
                     );
@@ -487,7 +484,7 @@ 
                 }
                 unset($fields[$k]);
                 foreach ($cols as $col) {
-                    $fields[] = $table . '.' . $col;
+                    $fields[] = $table.'.'.$col;
                 }
             }
         }
@@ -526,37 +523,37 @@ 
         $relations = $this->withr;
         foreach ($this->definition->getRelations() as $k => $relation) {
             foreach ($this->fields as $field) {
-                if (strpos($field, $k . '.') === 0) {
-                    $relations[$k] = [ $relation, $table ];
+                if (strpos($field, $k.'.') === 0) {
+                    $relations[$k] = [$relation, $table];
                 }
             }
             foreach ($this->where as $v) {
-                if (strpos($v[0], $k . '.') !== false) {
-                    $relations[$k] = [ $relation, $table ];
+                if (strpos($v[0], $k.'.') !== false) {
+                    $relations[$k] = [$relation, $table];
                 }
             }
-            if (isset($this->order[0]) && strpos($this->order[0], $k . '.') !== false) {
-                $relations[$k] = [ $relation, $table ];
+            if (isset($this->order[0]) && strpos($this->order[0], $k.'.') !== false) {
+                $relations[$k] = [$relation, $table];
             }
         }
         $select = [];
         foreach ($this->fields as $k => $field) {
-            $select[] = $field . (!is_numeric($k) ? ' ' . $k : '');
+            $select[] = $field.(!is_numeric($k) ? ' '.$k : '');
         }
         foreach ($this->withr as $name => $relation) {
             foreach ($relation[0]->table->getColumns() as $column) {
-                $select[] = $name . '.' . $column . ' ' . $name . static::SEP . $column;
+                $select[] = $name.'.'.$column.' '.$name.static::SEP.$column;
             }
         }
         $sql = 'SELECT '.implode(', ', $select).' FROM '.$table.' ';
         $par = [];
         foreach ($this->joins as $k => $v) {
-            $sql .= ($v->many ? 'LEFT ' : '' ) . 'JOIN '.$v->table->getName().' '.$k.' ON ';
+            $sql .= ($v->many ? 'LEFT ' : '').'JOIN '.$v->table->getName().' '.$k.' ON ';
             $tmp = [];
             foreach ($v->keymap as $kk => $vv) {
                 $tmp[] = $kk.' = '.$vv;
             }
-            $sql .= implode(' AND ', $tmp) . ' ';
+            $sql .= implode(' AND ', $tmp).' ';
         }
         foreach ($relations as $relation => $v) {
             $table = $v[1];
@@ -567,13 +564,13 @@ 
                 foreach ($v->keymap as $kk => $vv) {
                     $tmp[] = $table.'.'.$kk.' = '.$relation.'_pivot.'.$vv.' ';
                 }
-                $sql .= implode(' AND ', $tmp) . ' ';
+                $sql .= implode(' AND ', $tmp).' ';
                 $sql .= 'LEFT JOIN '.$v->table->getName().' '.$relation.' ON ';
                 $tmp = [];
                 foreach ($v->pivot_keymap as $kk => $vv) {
                     $tmp[] = $relation.'.'.$vv.' = '.$relation.'_pivot.'.$kk.' ';
                 }
-                $sql .= implode(' AND ', $tmp) . ' ';
+                $sql .= implode(' AND ', $tmp).' ';
             } else {
                 $sql .= 'LEFT JOIN '.$v->table->getName().' '.$relation.' ON ';
                 $tmp = [];
@@ -581,30 +578,30 @@ 
                     $tmp[] = $table.'.'.$kk.' = '.$relation.'.'.$vv.' ';
                 }
                 if ($v->sql) {
-                    $tmp[] = $v->sql . ' ';
+                    $tmp[] = $v->sql.' ';
                     $par = array_merge($par, $v->par ?? []);
                 }
-                $sql .= implode(' AND ', $tmp) . ' ';
+                $sql .= implode(' AND ', $tmp).' ';
             }
         }
         if (count($this->where)) {
             $sql .= 'WHERE ';
             $tmp = [];
             foreach ($this->where as $v) {
-                $tmp[] = '(' . $v[0] . ')';
+                $tmp[] = '('.$v[0].')';
                 $par = array_merge($par, $v[1]);
             }
             $sql .= implode(' AND ', $tmp).' ';
         }
         if (count($this->group)) {
-            $sql .= 'GROUP BY ' . $this->group[0] . ' ';
+            $sql .= 'GROUP BY '.$this->group[0].' ';
             $par = array_merge($par, $this->group[1]);
         }
         if (count($this->having)) {
             $sql .= 'HAVING ';
             $tmp = [];
             foreach ($this->having as $v) {
-                $tmp[] = '(' . $v[0] . ')';
+                $tmp[] = '('.$v[0].')';
                 $par = array_merge($par, $v[1]);
             }
             $sql .= implode(' AND ', $tmp).' ';
@@ -613,36 +610,36 @@ 
         //    $sql .= 'GROUP BY '.$table.'.'.implode(', '.$table.'.', $primary).' ';
         //}
         if (count($this->order)) {
-            $sql .= 'ORDER BY ' . $this->order[0] . ' ';
+            $sql .= 'ORDER BY '.$this->order[0].' ';
             $par = array_merge($par, $this->order[1]);
         }
         $porder = [];
         foreach ($primary as $field) {
             $porder[] = $this->getColumn($field)['name'];
         }
-        $sql .= (count($this->order) ? ', ' : 'ORDER BY ') . implode(', ', $porder) . ' ';
+        $sql .= (count($this->order) ? ', ' : 'ORDER BY ').implode(', ', $porder).' ';
 
         if ($this->li_of[0]) {
             if ($this->db->driver() === 'oracle') {
-                if ((int)($this->db->settings()->options['version'] ?? 0) >= 12) {
-                    $sql .= 'OFFSET ' . $this->li_of[1] . ' ROWS FETCH NEXT ' . $this->li_of[0] . ' ROWS ONLY';
+                if ((int) ($this->db->settings()->options['version'] ?? 0) >= 12) {
+                    $sql .= 'OFFSET '.$this->li_of[1].' ROWS FETCH NEXT '.$this->li_of[0].' ROWS ONLY';
                 } else {
-                    $f = array_map(function ($v) {
+                    $f = array_map(function($v) {
                         $v = explode(' ', trim($v), 2);
                         if (count($v) === 2) { return $v[1]; }
                         $v = explode('.', $v[0], 2);
                         return count($v) === 2 ? $v[1] : $v[0];
                     }, $select);
-                    $sql = "SELECT " . implode(', ', $f) . " 
+                    $sql = "SELECT ".implode(', ', $f)." 
                             FROM (
                                 SELECT tbl__.*, rownum rnum__ FROM (
-                                    " . $sql . "
+                                    " . $sql."
                                 ) tbl__ 
-                                WHERE rownum <= " . ($this->li_of[0] + $this->li_of[1]) . "
+                                WHERE rownum <= " . ($this->li_of[0] + $this->li_of[1])."
                             ) WHERE rnum__ > " . $this->li_of[1];
                 }
             } else {
-                $sql .= 'LIMIT ' . $this->li_of[0] . ' OFFSET ' . $this->li_of[1];
+                $sql .= 'LIMIT '.$this->li_of[0].' OFFSET '.$this->li_of[1];
             }
         }
         return $this->qiterator = new TableQueryIterator(
@@ -692,7 +689,7 @@ 
                 $ret[$k] = str_repeat(' ', 255);
                 $par[] = &$ret[$k];
             }
-            $sql .= ' RETURNING ' . implode(',', $primary) . ' INTO ' . implode(',', array_fill(0, count($primary), '?'));
+            $sql .= ' RETURNING '.implode(',', $primary).' INTO '.implode(',', array_fill(0, count($primary), '?'));
             $this->db->query($sql, $par);
             return $ret;
         } else {
@@ -724,7 +721,7 @@ 
         }
         $sql = 'UPDATE '.$table.' SET ';
         $par = [];
-        $sql .= implode(', ', array_map(function ($v) { return $v . ' = ?'; }, array_keys($update))) . ' ';
+        $sql .= implode(', ', array_map(function($v) { return $v.' = ?'; }, array_keys($update))).' ';
         $par = array_merge($par, array_values($update));
         if (count($this->where)) {
             $sql .= 'WHERE ';
@@ -733,7 +730,7 @@ 
                 $tmp[] = $v[0];
                 $par = array_merge($par, $v[1]);
             }
-            $sql .= implode(' AND ', $tmp) . ' ';
+            $sql .= implode(' AND ', $tmp).' ';
         }
         if (count($this->order)) {
             $sql .= $this->order[0];
@@ -757,7 +754,7 @@ 
                 $tmp[] = $v[0];
                 $par = array_merge($par, $v[1]);
             }
-            $sql .= implode(' AND ', $tmp) . ' ';
+            $sql .= implode(' AND ', $tmp).' ';
         }
         if (count($this->order)) {
             $sql .= $this->order[0];
@@ -777,13 +774,13 @@ 
         $table = $this->definition;
         array_reduce(
             $parts,
-            function ($carry, $item) use (&$table) {
+            function($carry, $item) use (&$table) {
                 $relation = $table->getRelation($item);
                 if (!$relation) {
                     throw new DBException('Invalid relation name');
                 }
-                $name = $carry ? $carry . static::SEP . $item : $item;
-                $this->withr[$name] = [ $relation, $carry ?? $table->getName() ];
+                $name = $carry ? $carry.static::SEP.$item : $item;
+                $this->withr[$name] = [$relation, $carry ?? $table->getName()];
                 $table = $relation->table;
                 return $name;
             }

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/oracle/Result.php

Spacing +1 added lines, -1 removed lines

@@ -64,7 +64,7 @@
     }
     public function next()
     {
-        $this->fetched ++;
+        $this->fetched++;
         $this->last = \oci_fetch_array($this->statement, \OCI_ASSOC + \OCI_RETURN_NULLS + \OCI_RETURN_LOBS);
     }
     public function valid()

src/driver/oracle/Driver.php

Indentation +2 added lines, -2 removed lines

@@ -75,7 +75,7 @@ 
 
     public function begin() : bool
     {
-         return $this->transaction = true;
+            return $this->transaction = true;
     }
     public function commit() : bool
     {
@@ -199,7 +199,7 @@ 
                     }
                     return $new;
                 })
-                 as $relation
+                    as $relation
             ) {
                 $relations[$relation['CONSTRAINT_NAME']]['table'] = $relation['TABLE_NAME'];
                 $relations[$relation['CONSTRAINT_NAME']]['keymap'][$primary[(int)$relation['POSITION']-1]] = $relation['COLUMN_NAME'];

Spacing +23 added lines, -23 removed lines

@@ -125,16 +125,16 @@ 
         $columns = Collection::from($this
             ->query(
                 "SELECT * FROM all_tab_cols WHERE table_name = ? AND owner = ?",
-                [ strtoupper($table), $this->name() ]
+                [strtoupper($table), $this->name()]
             ))
-            ->map(function ($v) {
+            ->map(function($v) {
                 $new = [];
                 foreach ($v as $kk => $vv) {
                     $new[strtoupper($kk)] = $vv;
                 }
                 return $new;
             })
-            ->mapKey(function ($v) { return $v['COLUMN_NAME']; })
+            ->mapKey(function($v) { return $v['COLUMN_NAME']; })
             ->toArray();
         if (!count($columns)) {
             throw new DBException('Table not found by name');
@@ -144,9 +144,9 @@ 
             ->query(
                 "SELECT constraint_name FROM all_constraints
                 WHERE table_name = ? AND constraint_type = ? AND owner = ?",
-                [ strtoupper($table), 'P', $owner ]
+                [strtoupper($table), 'P', $owner]
             ))
-            ->map(function ($v) {
+            ->map(function($v) {
                 $new = [];
                 foreach ($v as $kk => $vv) {
                     $new[strtoupper($kk)] = $vv;
@@ -161,9 +161,9 @@ 
                 ->query(
                     "SELECT column_name FROM all_cons_columns
                     WHERE table_name = ? AND constraint_name = ? AND owner = ?",
-                    [ strtoupper($table), $pkname, $owner ]
+                    [strtoupper($table), $pkname, $owner]
                 ))
-                ->map(function ($v) {
+                ->map(function($v) {
                     $new = [];
                     foreach ($v as $kk => $vv) {
                         $new[strtoupper($kk)] = $vv;
@@ -190,9 +190,9 @@ 
                     LEFT JOIN all_cons_columns cc ON cc.OWNER = ac.OWNER AND cc.CONSTRAINT_NAME = ac.CONSTRAINT_NAME
                     WHERE ac.OWNER = ? AND ac.R_OWNER = ? AND ac.R_CONSTRAINT_NAME = ? AND ac.CONSTRAINT_TYPE = ?
                     ORDER BY cc.POSITION",
-                    [ $owner, $owner, $pkname, 'R' ]
+                    [$owner, $owner, $pkname, 'R']
                 ))
-                ->map(function ($v) {
+                ->map(function($v) {
                     $new = [];
                     foreach ($v as $kk => $vv) {
                         $new[strtoupper($kk)] = $vv;
@@ -202,7 +202,7 @@ 
                  as $relation
             ) {
                 $relations[$relation['CONSTRAINT_NAME']]['table'] = $relation['TABLE_NAME'];
-                $relations[$relation['CONSTRAINT_NAME']]['keymap'][$primary[(int)$relation['POSITION']-1]] = $relation['COLUMN_NAME'];
+                $relations[$relation['CONSTRAINT_NAME']]['keymap'][$primary[(int) $relation['POSITION'] - 1]] = $relation['COLUMN_NAME'];
             }
             foreach ($relations as $data) {
                 $rtable = $this->table($data['table'], true); // ?? $this->addTableByName($data['table'], false);
@@ -226,9 +226,9 @@ 
                                 ac.OWNER = ? AND ac.R_OWNER = ? AND ac.TABLE_NAME = ? AND ac.CONSTRAINT_TYPE = ? AND
                                 cc.COLUMN_NAME IN (??)
                             ORDER BY POSITION",
-                            [ $owner, $owner, $data['table'], 'R', $columns ]
+                            [$owner, $owner, $data['table'], 'R', $columns]
                         ))
-                        ->map(function ($v) {
+                        ->map(function($v) {
                             $new = [];
                             foreach ($v as $kk => $vv) {
                                 $new[strtoupper($kk)] = $vv;
@@ -246,9 +246,9 @@ 
                     $rcolumns = Collection::from($this
                         ->query(
                             "SELECT COLUMN_NAME FROM all_cons_columns WHERE OWNER = ? AND CONSTRAINT_NAME = ? ORDER BY POSITION",
-                            [ $owner, current($foreign['keymap']) ]
+                            [$owner, current($foreign['keymap'])]
                         ))
-                        ->map(function ($v) {
+                        ->map(function($v) {
                             $new = [];
                             foreach ($v as $kk => $vv) {
                                 $new[strtoupper($kk)] = $vv;
@@ -263,7 +263,7 @@ 
                     $relname = $foreign['table'];
                     $cntr = 1;
                     while ($definition->hasRelation($relname) || $definition->getName() == $relname) {
-                        $relname = $foreign['table'] . '_' . (++ $cntr);
+                        $relname = $foreign['table'].'_'.(++$cntr);
                     }
                     $definition->addRelation(
                         new TableRelation(
@@ -279,7 +279,7 @@ 
                     $relname = $data['table'];
                     $cntr = 1;
                     while ($definition->hasRelation($relname) || $definition->getName() == $relname) {
-                        $relname = $data['table'] . '_' . (++ $cntr);
+                        $relname = $data['table'].'_'.(++$cntr);
                     }
                     $definition->addRelation(
                         new TableRelation(
@@ -303,9 +303,9 @@ 
                     LEFT JOIN all_cons_columns cc ON cc.OWNER = ac.OWNER AND cc.CONSTRAINT_NAME = ac.CONSTRAINT_NAME
                     WHERE ac.OWNER = ? AND ac.R_OWNER = ? AND ac.TABLE_NAME = ? AND ac.CONSTRAINT_TYPE = ?
                     ORDER BY cc.POSITION",
-                    [ $owner, $owner, strtoupper($table), 'R' ]
+                    [$owner, $owner, strtoupper($table), 'R']
                 ))
-                ->map(function ($v) {
+                ->map(function($v) {
                     $new = [];
                     foreach ($v as $kk => $vv) {
                         $new[strtoupper($kk)] = $vv;
@@ -321,9 +321,9 @@ 
                 $rcolumns = Collection::from($this
                     ->query(
                         "SELECT COLUMN_NAME FROM all_cons_columns WHERE OWNER = ? AND CONSTRAINT_NAME = ? ORDER BY POSITION",
-                        [ $owner, current($data['keymap']) ]
+                        [$owner, current($data['keymap'])]
                     ))
-                    ->map(function ($v) {
+                    ->map(function($v) {
                         $new = [];
                         foreach ($v as $kk => $vv) {
                             $new[strtoupper($kk)] = $vv;
@@ -338,7 +338,7 @@ 
                 $relname = $data['table'];
                 $cntr = 1;
                 while ($definition->hasRelation($relname) || $definition->getName() == $relname) {
-                    $relname = $data['table'] . '_' . (++ $cntr);
+                    $relname = $data['table'].'_'.(++$cntr);
                 }
                 $definition->addRelation(
                     new TableRelation(
@@ -359,7 +359,7 @@ 
                 "SELECT TABLE_NAME FROM ALL_TABLES where OWNER = ?",
                 [$this->connection['name']]
             ))
-            ->map(function ($v) {
+            ->map(function($v) {
                 $new = [];
                 foreach ($v as $kk => $vv) {
                     $new[strtoupper($kk)] = $vv;
@@ -367,7 +367,7 @@ 
                 return $new;
             })
             ->pluck('TABLE_NAME')
-            ->map(function ($v) {
+            ->map(function($v) {
                 return $this->table($v);
             })
             ->toArray();

src/driver/sqlite/Driver.php

Indentation +1 added lines, -1 removed lines

@@ -22,7 +22,7 @@
         parse_str($temp[1], $connection['opts']);
         $connection['name'] = $temp[0];
         if (!is_file($connection['name']) && is_file('/'.$connection['name'])) {
-           $connection['name'] = '/'.$connection['name'];
+            $connection['name'] = '/'.$connection['name'];
         }
         $this->connection = $connection;
     }