vakata / database

src/DB.php

Doc Comments +5 added lines, -2 removed lines

@@ -43,6 +43,9 @@ 
         $this->drv = $drv;
     }
 
+    /**
+     * @param string $sql
+     */
     protected function expand($sql, $data)
     {
         $new = '';
@@ -159,7 +162,7 @@ 
      * @param string $mode     result mode - `"assoc"` by default, could be `"num"`, `"both"`, `"assoc_ci"`, `"assoc_lc"`, `"assoc_uc"`
      * @param bool   $opti     if a single column is returned - do not use an array wrapper (defaults to `true`)
      *
-     * @return mixed the result of the execution
+     * @return string the result of the execution
      */
     public function one($sql, $data = null, $mode = null, $opti = true)
     {
@@ -256,7 +259,7 @@ 
      * @param  string            $table the table to analyze
      * @param  bool      $detectRelations should relations be extracted - defaults to `true`
      * @param  bool      $lowerCase should the table fields be converted to lowercase - defaults to `true`
-     * @return  the newly added definition
+     * @return  Table newly added definition
      */
     public function definition(
         string $table,

Spacing +32 added lines, -32 removed lines

@@ -30,7 +30,7 @@ 
      */
     public function __construct($options)
     {
-        $this->settings = new Settings((string)$options);
+        $this->settings = new Settings((string) $options);
         try {
             $tmp = '\\vakata\\database\\driver\\'.ucfirst($this->settings->type);
             $drv = new $tmp($this->settings);
@@ -47,11 +47,11 @@ 
     {
         $new = '';
         if (!is_array($data)) {
-            $data = [ $data ];
+            $data = [$data];
         }
         $data = array_values($data);
         if (substr_count($sql, '?') === 2 && !is_array($data[0])) {
-            $data = [ $data ];
+            $data = [$data];
         }
         $parts = explode('??', $sql);
         $index = 0;
@@ -61,7 +61,7 @@ 
             $index += count($tmp) - 1;
             if (isset($data[$index])) {
                 if (!is_array($data[$index])) {
-                    $data[$index] = [ $data[$index] ];
+                    $data[$index] = [$data[$index]];
                 }
                 $params = $data[$index];
                 array_splice($data, $index, 1, $params);
@@ -69,7 +69,7 @@ 
                 $new .= implode(',', array_fill(0, count($params), '?'));
             }
         }
-        return [ $new, $data ];
+        return [$new, $data];
     }
 
     /**
@@ -280,15 +280,15 @@ 
                         $primary[] = $data['Field'];
                     }
                 }
-                $comment = (string)$this->one(
+                $comment = (string) $this->one(
                     "SELECT table_comment FROM information_schema.tables WHERE table_schema = ? AND table_name = ?",
-                    [ $this->name(), $table ]
+                    [$this->name(), $table]
                 );
                 break;
             case 'postgre':
                 $columns = $this->all(
                     "SELECT * FROM information_schema.columns WHERE table_schema = ? AND table_name = ?",
-                    [ $this->name(), $table ],
+                    [$this->name(), $table],
                     'column_name',
                     false,
                     'assoc_lc'
@@ -296,20 +296,20 @@ 
                 $pkname = $this->one(
                     "SELECT constraint_name FROM information_schema.table_constraints
                     WHERE table_schema = ? AND table_name = ? AND constraint_type = ?",
-                    [ $this->name(), $table, 'PRIMARY KEY' ]
+                    [$this->name(), $table, 'PRIMARY KEY']
                 );
                 if ($pkname) {
                     $primary = $this->all(
                         "SELECT column_name FROM information_schema.key_column_usage
                         WHERE table_schema = ? AND table_name = ? AND constraint_name = ?",
-                        [ $this->name(), $table, $pkname ]
+                        [$this->name(), $table, $pkname]
                     );
                 }
                 break;
             case 'oracle':
                 $columns = $this->all(
                     "SELECT * FROM all_tab_cols WHERE table_name = ? AND owner = ?",
-                    [ strtoupper($table), $this->name() ],
+                    [strtoupper($table), $this->name()],
                     'COLUMN_NAME',
                     false,
                     'assoc_uc'
@@ -318,13 +318,13 @@ 
                 $pkname = $this->one(
                     "SELECT constraint_name FROM all_constraints
                     WHERE table_name = ? AND constraint_type = ? AND owner = ?",
-                    [ strtoupper($table), 'P', $owner ]
+                    [strtoupper($table), 'P', $owner]
                 );
                 if ($pkname) {
                     $primary = $this->all(
                         "SELECT column_name FROM all_cons_columns
                         WHERE table_name = ? AND constraint_name = ? AND owner = ?",
-                        [ strtoupper($table), $pkname, $owner ]
+                        [strtoupper($table), $pkname, $owner]
                     );
                 }
                 break;
@@ -365,7 +365,7 @@ 
                         "SELECT TABLE_NAME, COLUMN_NAME, CONSTRAINT_NAME, REFERENCED_COLUMN_NAME
                         FROM INFORMATION_SCHEMA.KEY_COLUMN_USAGE
                         WHERE TABLE_SCHEMA = ? AND REFERENCED_TABLE_SCHEMA = ? AND REFERENCED_TABLE_NAME = ?",
-                        [ $this->name(), $this->name(), $table ],
+                        [$this->name(), $this->name(), $table],
                         null,
                         false,
                         'assoc_uc'
@@ -392,7 +392,7 @@ 
                                 WHERE
                                     TABLE_SCHEMA = ? AND TABLE_NAME = ? AND COLUMN_NAME IN (??) AND
                                     REFERENCED_TABLE_NAME IS NOT NULL",
-                                [ $this->name(), $data['table'], $columns ],
+                                [$this->name(), $data['table'], $columns],
                                 null,
                                 false,
                                 'assoc_uc'
@@ -407,7 +407,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(
@@ -423,7 +423,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(
@@ -443,7 +443,7 @@ 
                         "SELECT TABLE_NAME, COLUMN_NAME, CONSTRAINT_NAME, REFERENCED_TABLE_NAME, REFERENCED_COLUMN_NAME
                         FROM INFORMATION_SCHEMA.KEY_COLUMN_USAGE
                         WHERE TABLE_SCHEMA = ? AND TABLE_NAME = ? AND REFERENCED_TABLE_NAME IS NOT NULL",
-                        [ $this->name(), $table ],
+                        [$this->name(), $table],
                         null,
                         false,
                         'assoc_uc'
@@ -455,7 +455,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(
@@ -478,13 +478,13 @@ 
                         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'],
                         null,
                         false,
                         'assoc_uc'
                     ) as $k => $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->definition($data['table'], true, $lowerCase); // ?? $this->addTableByName($data['table'], false);
@@ -507,7 +507,7 @@ 
                                     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],
                                 null,
                                 false,
                                 'assoc_uc'
@@ -521,7 +521,7 @@ 
                             $foreign = current($foreign);
                             $rcolumns = $this->all(
                                 "SELECT COLUMN_NAME FROM all_cons_columns WHERE OWNER = ? AND CONSTRAINT_NAME = ? ORDER BY POSITION",
-                                [ $owner, current($foreign['keymap']) ],
+                                [$owner, current($foreign['keymap'])],
                                 null, false, 'assoc_uc'
                             );
                             foreach ($foreign['keymap'] as $column => $related) {
@@ -530,7 +530,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(
@@ -546,7 +546,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(
@@ -569,7 +569,7 @@ 
                         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'],
                         null, false, 'assoc_uc'
                     ) as $relation) {
                         $relations[$relation['CONSTRAINT_NAME']]['table'] = $relation['REFERENCED_TABLE_NAME'];
@@ -578,7 +578,7 @@ 
                     foreach ($relations as $name => $data) {
                         $rcolumns = $this->all(
                             "SELECT COLUMN_NAME FROM all_cons_columns WHERE OWNER = ? AND CONSTRAINT_NAME = ? ORDER BY POSITION",
-                            [ $owner, current($data['keymap']) ],
+                            [$owner, current($data['keymap'])],
                             null, false, 'assoc_uc'
                         );
                         foreach ($data['keymap'] as $column => $related) {
@@ -587,7 +587,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(
@@ -676,12 +676,12 @@ 
      */
     public function getSchema()
     {
-        return array_map(function ($table) {
+        return 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(),
@@ -691,13 +691,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/Oracle.php

Doc Comments +4 added lines

@@ -40,6 +40,10 @@
             oci_close($this->lnk);
         }
     }
+
+    /**
+     * @param string $sql
+     */
     public function real($sql)
     {
         $this->connect();

Spacing +1 added lines, -2 removed lines

@@ -18,8 +18,7 @@
                     $this->settings->password,
                     $this->settings->servername,
                     $this->settings->charset
-                ) :
-                @oci_connect(
+                ) : @oci_connect(
                     $this->settings->username,
                     $this->settings->password,
                     $this->settings->servername,

src/driver/Pdo.php

Doc Comments +4 added lines

@@ -61,6 +61,10 @@
     {
         return $this->lnk->lastInsertId(null);
     }
+
+    /**
+     * @param string $sql
+     */
     public function prepare($sql)
     {
         $this->connect();

Spacing +7 added lines, -7 removed lines

@@ -85,34 +85,34 @@
         foreach ($data as $i => $v) {
             switch (gettype($v)) {
                 case 'boolean':
-                    $sql->bindValue($i+1, $v, \PDO::PARAM_BOOL);
+                    $sql->bindValue($i + 1, $v, \PDO::PARAM_BOOL);
                     break;
                 case 'integer':
-                    $sql->bindValue($i+1, $v, \PDO::PARAM_INT);
+                    $sql->bindValue($i + 1, $v, \PDO::PARAM_INT);
                     break;
                 case 'NULL':
-                    $sql->bindValue($i+1, $v, \PDO::PARAM_NULL);
+                    $sql->bindValue($i + 1, $v, \PDO::PARAM_NULL);
                     break;
                 case 'double':
-                    $sql->bindValue($i+1, $v);
+                    $sql->bindValue($i + 1, $v);
                     break;
                 default:
                     // keep in mind oracle needs a transaction when inserting LOBs, aside from the specific syntax:
                     // INSERT INTO table (column, lobcolumn) VALUES (?, ?, EMPTY_BLOB()) RETURNING lobcolumn INTO ?
                     if (is_resource($v) && get_resource_type($v) === 'stream') {
-                        $sql->bindParam($i+1, $v, \PDO::PARAM_LOB);
+                        $sql->bindParam($i + 1, $v, \PDO::PARAM_LOB);
                         continue;
                     }
                     if (!is_string($data[$i])) {
                         $data[$i] = serialize($data[$i]);
                     }
-                    $sql->bindValue($i+1, $v);
+                    $sql->bindValue($i + 1, $v);
                     break;
             }
         }
         $rtrn = $sql->execute();
         if (!$rtrn) {
-            throw new DatabaseException('Prepared execute error : '. implode(',', $sql->errorInfo()));
+            throw new DatabaseException('Prepared execute error : '.implode(',', $sql->errorInfo()));
         }
         $this->aff = $sql->rowCount();
         return $sql->columnCount() ? $sql : $rtrn;

src/TableQuery.php

Doc Comments +2 added lines, -2 removed lines

@@ -52,7 +52,7 @@ 
     /**
      * Create an instance
      * @param  DatabaseInterface        $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(DatabaseInterface $db, $table)
     {
@@ -187,7 +187,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

Spacing +61 added lines, -61 removed lines

@@ -38,7 +38,7 @@ 
     /**
      * @var int[]
      */
-    protected $li_of = [0,0];
+    protected $li_of = [0, 0];
     protected $fields = [];
     /**
      * @var array
@@ -57,7 +57,7 @@ 
     public function __construct(DatabaseInterface $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()
@@ -77,7 +77,7 @@ 
     {
         $column = explode('.', $column, 2);
         if (count($column) === 1) {
-            $column = [ $this->definition->getName(), $column[0] ];
+            $column = [$this->definition->getName(), $column[0]];
         }
         if ($column[0] === $this->definition->getName()) {
             $col = $this->definition->getColumn($column[1]);
@@ -96,10 +96,10 @@ 
                     throw new DatabaseException('Invalid column name in related table');
                 }
             } else {
-                throw new DatabaseException('Invalid foreign table name: ' . implode(',', $column));
+                throw new DatabaseException('Invalid foreign table name: '.implode(',', $column));
             }
         }
-        return [ 'name' => implode('.', $column), 'data' => $col ];
+        return ['name' => implode('.', $column), 'data' => $col];
     }
     protected function normalizeValue(TableColumn $col, $value)
     {
@@ -138,7 +138,7 @@ 
                 }
                 return $value;
             case 'int':
-                return (int)$value;
+                return (int) $value;
             default:
                 return $value;
         }
@@ -153,12 +153,12 @@ 
     {
         list($name, $column) = array_values($this->getColumn($column));
         if (is_null($value)) {
-            return $this->where($name . ' IS NULL');
+            return $this->where($name.' IS NULL');
         }
         if (!is_array($value)) {
             return $this->where(
-                $name . ' = ?',
-                [ $this->normalizeValue($column, $value) ]
+                $name.' = ?',
+                [$this->normalizeValue($column, $value)]
             );
         }
         if (isset($value['beg']) && isset($value['end'])) {
@@ -171,8 +171,8 @@ 
             );
         }
         return $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)]
         );
     }
     /**
@@ -183,7 +183,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)
@@ -193,7 +193,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'];
@@ -234,7 +234,7 @@ 
         $this->withr = [];
         $this->order = [];
         $this->having = [];
-        $this->li_of = [0,0];
+        $this->li_of = [0, 0];
         $this->qiterator = null;
         return $this;
     }
@@ -247,7 +247,7 @@ 
     public function groupBy(string $sql, array $params = []) : TableQuery
     {
         $this->qiterator = null;
-        $this->group = [ $sql, $params ];
+        $this->group = [$sql, $params];
         return $this;
     }
     /**
@@ -260,7 +260,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 DatabaseException('Alias / table name already in use');
@@ -269,7 +269,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;
     }
@@ -282,7 +282,7 @@ 
     public function where(string $sql, array $params = []) : TableQuery
     {
         $this->qiterator = null;
-        $this->where[] = [ $sql, $params ];
+        $this->where[] = [$sql, $params];
         return $this;
     }
     /**
@@ -294,7 +294,7 @@ 
     public function having(string $sql, array $params = []) : TableQuery
     {
         $this->qiterator = null;
-        $this->having[] = [ $sql, $params ];
+        $this->having[] = [$sql, $params];
         return $this;
     }
     /**
@@ -306,7 +306,7 @@ 
     public function order(string $sql, array $params = []) : TableQuery
     {
         $this->qiterator = null;
-        $this->order = [ $sql, $params ];
+        $this->order = [$sql, $params];
         return $this;
     }
     /**
@@ -318,7 +318,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;
     }
     /**
@@ -335,22 +335,22 @@ 
         $relations = $this->withr;
         foreach ($this->definition->getRelations() as $k => $v) {
             foreach ($this->where as $vv) {
-                if (strpos($vv[0], $k . '.') !== false) {
+                if (strpos($vv[0], $k.'.') !== false) {
                     $relations[] = $k;
                 }
             }
-            if (isset($this->order[0]) && strpos($this->order[0], $k . '.') !== false) {
+            if (isset($this->order[0]) && strpos($this->order[0], $k.'.') !== false) {
                 $relations[] = $k;
             }
         }
 
         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 (array_unique($relations) as $k) {
             $v = $this->definition->getRelation($k);
@@ -360,13 +360,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 = [];
@@ -374,30 +374,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).' ';
@@ -428,7 +428,7 @@ 
                     throw new DatabaseException('Invalid foreign table name');
                 }
                 foreach ($cols as $col) {
-                    $fields[] = $table . '.' . $col;
+                    $fields[] = $table.'.'.$col;
                 }
                 unset($fields[$k]);
             }
@@ -468,37 +468,37 @@ 
         $relations = $this->withr;
         foreach ($this->definition->getRelations() as $k => $v) {
             foreach ($this->fields as $field) {
-                if (strpos($field, $k . '.') === 0) {
+                if (strpos($field, $k.'.') === 0) {
                     $relations[] = $k;
                 }
             }
             foreach ($this->where as $v) {
-                if (strpos($v[0], $k . '.') !== false) {
+                if (strpos($v[0], $k.'.') !== false) {
                     $relations[] = $k;
                 }
             }
-            if (isset($this->order[0]) && strpos($this->order[0], $k . '.') !== false) {
+            if (isset($this->order[0]) && strpos($this->order[0], $k.'.') !== false) {
                 $relations[] = $k;
             }
         }
         $select = [];
         foreach ($this->fields as $k => $field) {
-            $select[] = $field . (!is_numeric($k) ? ' ' . $k : '');
+            $select[] = $field.(!is_numeric($k) ? ' '.$k : '');
         }
         foreach ($this->withr as $relation) {
             foreach ($this->definition->getRelation($relation)->table->getColumns() as $column) {
-                $select[] = $relation . '.' . $column . ' ' . $relation . '___' . $column;
+                $select[] = $relation.'.'.$column.' '.$relation.'___'.$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 (array_unique($relations) as $relation) {
             $v = $this->definition->getRelation($relation);
@@ -508,13 +508,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 = [];
@@ -522,30 +522,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).' ';
@@ -554,36 +554,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];
             }
         }
         // echo $sql; die();
@@ -592,7 +592,7 @@ 
             $this->definition->getPrimaryKey(),
             array_combine(
                 $this->withr,
-                array_map(function ($relation) {
+                array_map(function($relation) {
                     return $this->definition->getRelation($relation);
                 }, $this->withr)
             )
@@ -639,7 +639,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 {
@@ -671,7 +671,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 ';
@@ -680,7 +680,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];
@@ -704,7 +704,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];

src/TableColumn.php

Spacing +1 added lines, -1 removed lines

@@ -47,7 +47,7 @@
             $instance->setDefault($data['default']);
         }
         if ($instance->getBasicType() === 'enum' && strpos($instance->getType(), 'enum(') === 0) {
-            $temp = array_map(function ($v) {
+            $temp = array_map(function($v) {
                 return str_replace("''", "'", $v);
             }, explode("','", substr($instance->getType(), 6, -2)));
             $instance->setValues($temp);

src/driver/Postgre.php

Spacing +2 added lines, -4 removed lines

@@ -27,8 +27,7 @@ 
                         'password='.$this->settings->password.' '.
                         'dbname='.$this->settings->database.' '.
                         "options='--client_encoding=".strtoupper($this->settings->charset)."' "
-                    ) :
-                    @pg_connect(
+                    ) : @pg_connect(
                         'host='.$this->settings->servername.' '.
                         'port='.$this->settings->serverport.' '.
                         'user='.$this->settings->username.' '.
@@ -78,8 +77,7 @@ 
             $data = array();
         }
         $temp = (is_array($data) && count($data)) ?
-            pg_query_params($this->lnk, $sql, $data) :
-            pg_query_params($this->lnk, $sql, array());
+            pg_query_params($this->lnk, $sql, $data) : pg_query_params($this->lnk, $sql, array());
         if (!$temp) {
             throw new DatabaseException('Could not execute query : '.pg_last_error($this->lnk).' <'.$sql.'>');
         }

src/driver/Mysql.php

Spacing +1 added lines, -2 removed lines

@@ -23,8 +23,7 @@
                         $this->settings->servername.':'.$this->settings->serverport,
                         $this->settings->username,
                         $this->settings->password
-                    ) :
-                    @mysql_connect(
+                    ) : @mysql_connect(
                         $this->settings->servername.':'.$this->settings->serverport,
                         $this->settings->username,
                         $this->settings->password

src/driver/Ibase.php

Spacing +2 added lines, -4 removed lines

@@ -17,8 +17,7 @@ 
         }
         $this->settings->servername =
             ($this->settings->servername === 'localhost' || $this->settings->servername === '') ?
-                '' :
-                $this->settings->servername.':';
+                '' : $this->settings->servername.':';
     }
     protected function connect()
     {
@@ -29,8 +28,7 @@ 
                         $this->settings->username,
                         $this->settings->password,
                         strtoupper($this->settings->charset)
-                    ) :
-                    @\ibase_connect(
+                    ) : @\ibase_connect(
                         $this->settings->servername.$this->settings->database,
                         $this->settings->username,
                         $this->settings->password,

src/Result.php

Spacing +2 added lines, -3 removed lines

@@ -102,8 +102,7 @@ 
             }
         }
         $cnt = $this->mode === 'assoc_ci' ?
-            count(array_unique(array_map('strtolower', array_keys($row)))) :
-            count($row);
+            count(array_unique(array_map('strtolower', array_keys($row)))) : count($row);
         if ($this->opti && is_array($row) && $cnt <= 1) {
             $row = count($row) ? current($row) : current($tmp);
         }
@@ -123,7 +122,7 @@ 
         if ($this->rdy) {
             return next($this->all);
         }
-        if($this->rslt->nextr()) {
+        if ($this->rslt->nextr()) {
             ++$this->realKey;
         }
         else {

Braces +1 added lines, -2 removed lines

@@ -125,8 +125,7 @@
         }
         if($this->rslt->nextr()) {
             ++$this->realKey;
-        }
-        else {
+        } else {
             $this->realKey = null;
         }
     }