vakata / database

src/driver/ibase/Driver.php

Spacing +1 added lines, -1 removed lines

@@ -71,7 +71,7 @@
         $this->softDetect($sql);
         $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/oracle/Driver.php

Spacing +4 added lines, -4 removed lines

@@ -44,7 +44,7 @@ 
                 $this->query("ALTER SESSION SET time_zone = '".addslashes($timezone)."'");
             }
             if ($schema = $this->option('schema')) {
-                $this->query("ALTER SESSION SET CURRENT_SCHEMA = " . $schema);
+                $this->query("ALTER SESSION SET CURRENT_SCHEMA = ".$schema);
             }
         }
     }
@@ -81,11 +81,11 @@ 
         );
         if ($log) {
             $tm = microtime(true) - $tm;
-            if ($tm >= (float)$this->option('log_slow', 0)) {
+            if ($tm >= (float) $this->option('log_slow', 0)) {
                 @file_put_contents(
                     $log,
-                    '--' . date('Y-m-d H:i:s') . ' ' . sprintf('%01.6f', $tm) . "s\r\n" .
-                    $sql . "\r\n" .
+                    '--'.date('Y-m-d H:i:s').' '.sprintf('%01.6f', $tm)."s\r\n".
+                    $sql."\r\n".
                     "\r\n",
                     FILE_APPEND
                 );

src/driver/postgre/Driver.php

Spacing +5 added lines, -5 removed lines

@@ -45,11 +45,11 @@ 
             if (isset($this->connection['opts']['search_path'])) {
                 @\pg_query(
                     $this->lnk,
-                    "SET search_path TO " . pg_escape_string($this->connection['opts']['search_path'])
+                    "SET search_path TO ".pg_escape_string($this->connection['opts']['search_path'])
                 );
             }
             if (!isset($this->connection['opts']['search_path']) && isset($this->connection['opts']['schema'])) {
-                @\pg_query($this->lnk, "SET search_path TO " . pg_escape_string($this->connection['opts']['schema']));
+                @\pg_query($this->lnk, "SET search_path TO ".pg_escape_string($this->connection['opts']['schema']));
             }
             if (isset($this->connection['opts']['timezone'])) {
                 @\pg_query($this->lnk, "SET TIME ZONE '".pg_escape_string($this->connection['opts']['timezone'])."'");
@@ -87,11 +87,11 @@ 
         $res = \pg_query($this->lnk, $sql);
         if ($log) {
             $tm = microtime(true) - $tm;
-            if ($tm >= (float)$this->option('log_slow', 0)) {
+            if ($tm >= (float) $this->option('log_slow', 0)) {
                 @file_put_contents(
                     $log,
-                    '--' . date('Y-m-d H:i:s') . ' ' . sprintf('%01.6f', $tm) . "s\r\n" .
-                    $sql . "\r\n" .
+                    '--'.date('Y-m-d H:i:s').' '.sprintf('%01.6f', $tm)."s\r\n".
+                    $sql."\r\n".
                     "\r\n",
                     FILE_APPEND
                 );

src/driver/postgre/Result.php

Spacing +8 added lines, -9 removed lines

@@ -37,8 +37,7 @@ 
             $temp = @\pg_query(
                 $this->driver,
                 $sequence ?
-                    'SELECT currval('.@\pg_escape_string($this->driver, $sequence).')' :
-                    'SELECT lastval()'
+                    'SELECT currval('.@\pg_escape_string($this->driver, $sequence).')' : 'SELECT lastval()'
             );
             if ($temp) {
                 $res = \pg_fetch_row($temp);
@@ -76,8 +75,8 @@ 
     }
     public function next(): void
     {
-        $this->fetched ++;
-        $this->last = \pg_fetch_array($this->statement, null, \PGSQL_ASSOC)?:null;
+        $this->fetched++;
+        $this->last = \pg_fetch_array($this->statement, null, \PGSQL_ASSOC) ?: null;
         if (is_array($this->last)) {
             $this->cast();
         }
@@ -90,11 +89,11 @@ 
     protected function cast(): void
     {
         if (!count($this->types)) {
-            foreach (array_keys($this->last??[]) as $k => $v) {
+            foreach (array_keys($this->last ?? []) as $k => $v) {
                 $this->types[$v] = \pg_field_type($this->statement, $k);
             }
         }
-        foreach ($this->last??[] as $k => $v) {
+        foreach ($this->last ?? [] as $k => $v) {
             if (is_null($v) || !isset($this->types[$k])) {
                 continue;
             }
@@ -102,15 +101,15 @@ 
                 case 'int2':
                 case 'int4':
                 case 'int8':
-                    $this->last[$k] = (int)$v;
+                    $this->last[$k] = (int) $v;
                     break;
                 case 'bit':
                 case 'bool':
-                    $this->last[$k] = $v !== 'f' && (int)$v ? true : false;
+                    $this->last[$k] = $v !== 'f' && (int) $v ? true : false;
                     break;
                 case 'float4':
                 case 'float8':
-                    $this->last[$k] = (float)$v;
+                    $this->last[$k] = (float) $v;
                     break;
                 case 'money':
                 case 'numeric':

src/driver/sqlite/Driver.php

Spacing +1 added lines, -1 removed lines

@@ -38,7 +38,7 @@
         if ($this->lnk === null) {
             try {
                 $this->lnk = new \SQLite3($this->connection['name']);
-                $this->lnk->exec('PRAGMA encoding = "'.$this->option('charset', 'utf-8') . '"');
+                $this->lnk->exec('PRAGMA encoding = "'.$this->option('charset', 'utf-8').'"');
             } catch (\Exception $e) {
                 if ($this->lnk !== null) {
                     throw new DBException('Connect error: '.$this->lnk->lastErrorMsg());

src/schema/TableColumn.php

Spacing +4 added lines, -4 removed lines

@@ -42,7 +42,7 @@ 
             $instance->setNullable($data['nullable']);
         }
         if (isset($data['notnull'])) {
-            $instance->setNullable(!((int)$data['notnull']));
+            $instance->setNullable(!((int) $data['notnull']));
         }
         if (isset($data['Default'])) {
             $instance->setDefault($data['Default']);
@@ -57,7 +57,7 @@ 
             $instance->setLength($data['length']);
         }
         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);
@@ -86,7 +86,7 @@ 
                 $instance->setDefault(null);
             }
         }
-        if ($instance->getBasicType() === 'text' && isset($data['CHAR_LENGTH']) && (int)$data['CHAR_LENGTH']) {
+        if ($instance->getBasicType() === 'text' && isset($data['CHAR_LENGTH']) && (int) $data['CHAR_LENGTH']) {
             $instance->setLength($data['CHAR_LENGTH']);
         }
         return $instance;
@@ -183,7 +183,7 @@ 
     }
     public function getLength(): int
     {
-        return (int)$this->length;
+        return (int) $this->length;
     }
     public function setLength(int $length): static
     {

src/schema/MapperInterface.php

Spacing +2 added lines, -2 removed lines

@@ -58,12 +58,12 @@
      * @param array|T $entity
      * @return bool
      */
-    public function deleted(array|object $entity): bool;
+    public function deleted(array | object $entity): bool;
     /**
      * @param array|T $entity
      * @return bool
      */
-    public function exists(array|object $entity): bool;
+    public function exists(array | object $entity): bool;
     /**
      * @return array<int,T>
      */

src/Schema.php

Spacing +5 added lines, -5 removed lines

@@ -31,7 +31,7 @@ 
     public function getTable(string $table): Table
     {
         if (!$this->hasTable($table)) {
-            throw new DBException('Invalid table name: ' . $table);
+            throw new DBException('Invalid table name: '.$table);
         }
         return $this->tables[$table] ??
             $this->tables[strtoupper($table)] ??
@@ -64,13 +64,13 @@ 
     
     public function toArray(): array
     {
-        return array_map(function ($table) {
+        return array_map(function($table) {
             return [
                 'name' => $table->getName(),
                 'schema' => $table->getSchema(),
                 'pkey' => $table->getPrimaryKey(),
                 'comment' => $table->getComment(),
-                'columns' => array_map(function ($column) {
+                'columns' => array_map(function($column) {
                     return [
                         'name' => $column->getName(),
                         'type' => $column->getType(),
@@ -81,9 +81,9 @@ 
                         'nullable' => $column->isNullable()
                     ];
                 }, $table->getFullColumns()),
-                'relations' => array_map(function ($rel) {
+                'relations' => array_map(function($rel) {
                     $relation = clone $rel;
-                    $relation = (array)$relation;
+                    $relation = (array) $relation;
                     $relation['table'] = $rel->table->getName();
                     if ($rel->pivot) {
                         $relation['pivot'] = $rel->pivot->getName();

src/driver/mysql/Schema.php

Spacing +40 added lines, -40 removed lines

@@ -27,8 +27,8 @@ 
             $table = $temp[1];
         }
 
-        if (isset($tables[$schema . '.' . $table])) {
-            return $tables[$schema . '.' . $table];
+        if (isset($tables[$schema.'.'.$table])) {
+            return $tables[$schema.'.'.$table];
         }
 
         static $comments = [];
@@ -36,10 +36,10 @@ 
             $comments[$schema] = Collection::from(
                 $this->query(
                     "SELECT TABLE_NAME, TABLE_COMMENT FROM INFORMATION_SCHEMA.TABLES WHERE TABLE_SCHEMA = ?",
-                    [ $schema ]
+                    [$schema]
                 )
             )
-            ->mapKey(function (array $v): string {
+            ->mapKey(function(array $v): string {
                 return $v['TABLE_NAME'];
             })
             ->pluck('TABLE_COMMENT')
@@ -61,7 +61,7 @@ 
                      WHERE
                         (TABLE_SCHEMA = ? OR REFERENCED_TABLE_SCHEMA = ?) AND
                         TABLE_NAME IS NOT NULL AND REFERENCED_TABLE_NAME IS NOT NULL",
-                    [ $main, $main ]
+                    [$main, $main]
                 )
             )->toArray();
             foreach ($col as $row) {
@@ -71,8 +71,8 @@ 
                 if ($row['REFERENCED_TABLE_SCHEMA'] !== $main) {
                     $additional[] = $row['REFERENCED_TABLE_SCHEMA'];
                 }
-                $relationsT[$row['TABLE_SCHEMA'] . '.' . $row['TABLE_NAME']][] = $row;
-                $relationsR[$row['REFERENCED_TABLE_SCHEMA'] . '.' . $row['REFERENCED_TABLE_NAME']][] = $row;
+                $relationsT[$row['TABLE_SCHEMA'].'.'.$row['TABLE_NAME']][] = $row;
+                $relationsR[$row['REFERENCED_TABLE_SCHEMA'].'.'.$row['REFERENCED_TABLE_NAME']][] = $row;
             }
             foreach (array_filter(array_unique($additional)) as $s) {
                 $col = Collection::from(
@@ -84,12 +84,12 @@ 
                         WHERE
                             TABLE_SCHEMA = ? AND REFERENCED_TABLE_SCHEMA = ? AND
                             TABLE_NAME IS NOT NULL AND REFERENCED_TABLE_NAME IS NOT NULL",
-                        [ $s, $s ]
+                        [$s, $s]
                     )
                 )->toArray();
                 foreach ($col as $row) {
-                    $relationsT[$row['TABLE_SCHEMA'] . '.' . $row['TABLE_NAME']][] = $row;
-                    $relationsR[$row['REFERENCED_TABLE_SCHEMA'] . '.' . $row['REFERENCED_TABLE_NAME']][] = $row;
+                    $relationsT[$row['TABLE_SCHEMA'].'.'.$row['TABLE_NAME']][] = $row;
+                    $relationsR[$row['REFERENCED_TABLE_SCHEMA'].'.'.$row['REFERENCED_TABLE_NAME']][] = $row;
                 }
             }
 
@@ -99,14 +99,14 @@ 
         if (!count($columns)) {
             throw new DBException('Table not found by name');
         }
-        $tables[$schema . '.' . $table] = $definition = (new Table($table, $schema))
+        $tables[$schema.'.'.$table] = $definition = (new Table($table, $schema))
             ->addColumns(
                 $columns
                     ->clone()
-                    ->mapKey(function (array $v): string {
+                    ->mapKey(function(array $v): string {
                         return $v['Field'];
                     })
-                    ->map(function (array $v): array {
+                    ->map(function(array $v): array {
                         $v['length'] = null;
                         if (!isset($v['Type'])) {
                             return $v;
@@ -128,7 +128,7 @@ 
                             default:
                                 if (strpos($type, 'char') !== false && strpos($type, '(') !== false) {
                                     // extract length from varchar
-                                    $v['length'] = (int)explode(')', explode('(', $type)[1])[0];
+                                    $v['length'] = (int) explode(')', explode('(', $type)[1])[0];
                                     $v['length'] = $v['length'] > 0 ? $v['length'] : null;
                                 }
                                 break;
@@ -140,7 +140,7 @@ 
             ->setPrimaryKey(
                 $columns
                     ->clone()
-                    ->filter(function (array $v): bool {
+                    ->filter(function(array $v): bool {
                         return $v['Key'] === 'PRI';
                     })
                     ->pluck('Field')
@@ -151,20 +151,20 @@ 
 
         if ($detectRelations) {
             $duplicated = [];
-            foreach ($relationsT[$schema . '.' . $table] ?? [] as $relation) {
-                $t = $relation['REFERENCED_TABLE_SCHEMA'] . '.' . $relation['REFERENCED_TABLE_NAME'];
+            foreach ($relationsT[$schema.'.'.$table] ?? [] as $relation) {
+                $t = $relation['REFERENCED_TABLE_SCHEMA'].'.'.$relation['REFERENCED_TABLE_NAME'];
                 $duplicated[$t] = isset($duplicated[$t]);
             }
-            foreach ($relationsR[$schema . '.' . $table] ?? [] as $relation) {
-                $t = $relation['TABLE_SCHEMA'] . '.' . $relation['TABLE_NAME'];
+            foreach ($relationsR[$schema.'.'.$table] ?? [] as $relation) {
+                $t = $relation['TABLE_SCHEMA'].'.'.$relation['TABLE_NAME'];
                 $duplicated[$t] = isset($duplicated[$t]);
             }
             // pivot relations where the current table is referenced
             // assuming current table is on the "one" end having "many" records in the referencing table
             // resulting in a "hasMany" or "manyToMany" relationship (if a pivot table is detected)
             $relations = [];
-            foreach ($relationsR[$schema . '.' . $table] ?? [] as $relation) {
-                $relations[$relation['CONSTRAINT_NAME']]['table'] = $relation['TABLE_SCHEMA'] . '.' .
+            foreach ($relationsR[$schema.'.'.$table] ?? [] as $relation) {
+                $relations[$relation['CONSTRAINT_NAME']]['table'] = $relation['TABLE_SCHEMA'].'.'.
                     $relation['TABLE_NAME'];
                 $relations[$relation['CONSTRAINT_NAME']]['keymap'][$relation['REFERENCED_COLUMN_NAME']] =
                     $relation['COLUMN_NAME'];
@@ -181,10 +181,10 @@ 
                 $usedcol = [];
                 if (count($columns)) {
                     foreach (Collection::from($relationsT[$data['table']] ?? [])
-                        ->filter(function (array $v) use ($columns): bool {
+                        ->filter(function(array $v) use ($columns): bool {
                             return in_array($v['COLUMN_NAME'], $columns);
                         })
-                        ->map(function (array $v): array {
+                        ->map(function(array $v): array {
                             $new = [];
                             foreach ($v as $kk => $vv) {
                                 $new[strtoupper($kk)] = $vv;
@@ -192,7 +192,7 @@ 
                             return $new;
                         }) as $relation
                     ) {
-                        $foreign[$relation['CONSTRAINT_NAME']]['table'] = $relation['REFERENCED_TABLE_SCHEMA'] . '.' .
+                        $foreign[$relation['CONSTRAINT_NAME']]['table'] = $relation['REFERENCED_TABLE_SCHEMA'].'.'.
                             $relation['REFERENCED_TABLE_NAME'];
                         $foreign[$relation['CONSTRAINT_NAME']]['keymap'][$relation['COLUMN_NAME']] =
                             $relation['REFERENCED_COLUMN_NAME'];
@@ -209,7 +209,7 @@ 
                     $orig = $relname;
                     $cntr = 1;
                     while ($definition->hasRelation($relname) || $definition->getName() == $relname) {
-                        $relname = $orig . '_' . (++ $cntr);
+                        $relname = $orig.'_'.(++$cntr);
                     }
                     $definition->addRelation(
                         new TableRelation(
@@ -231,8 +231,8 @@ 
             // assuming current table is linked to "one" record in the referenced table
             // resulting in a "belongsTo" relationship
             $relations = [];
-            foreach ($relationsT[$schema . '.' . $table] ?? [] as $relation) {
-                $relations[$relation['CONSTRAINT_NAME']]['table'] = $relation['REFERENCED_TABLE_SCHEMA'] . '.' .
+            foreach ($relationsT[$schema.'.'.$table] ?? [] as $relation) {
+                $relations[$relation['CONSTRAINT_NAME']]['table'] = $relation['REFERENCED_TABLE_SCHEMA'].'.'.
                     $relation['REFERENCED_TABLE_NAME'];
                 $relations[$relation['CONSTRAINT_NAME']]['keymap'][$relation['COLUMN_NAME']] =
                     $relation['REFERENCED_COLUMN_NAME'];
@@ -248,12 +248,12 @@ 
                     $definition->getName() == $relname ||
                     $definition->getColumn($relname)
                 ) {
-                    $relname = array_keys($data['keymap'])[0] . '_' . $relname;
+                    $relname = array_keys($data['keymap'])[0].'_'.$relname;
                 }
                 $orig = $relname;
                 $cntr = 1;
                 while ($definition->hasRelation($relname) || $definition->getName() == $relname) {
-                    $relname = $orig . '_' . (++ $cntr);
+                    $relname = $orig.'_'.(++$cntr);
                 }
                 $definition->addRelation(
                     new TableRelation(
@@ -269,8 +269,8 @@ 
             // assuming current table is on the "one" end having "many" records in the referencing table
             // resulting in a "hasMany" or "manyToMany" relationship (if a pivot table is detected)
             $relations = [];
-            foreach ($relationsR[$schema . '.' . $table] ?? [] as $relation) {
-                $relations[$relation['CONSTRAINT_NAME']]['table'] = $relation['TABLE_SCHEMA'] . '.' .
+            foreach ($relationsR[$schema.'.'.$table] ?? [] as $relation) {
+                $relations[$relation['CONSTRAINT_NAME']]['table'] = $relation['TABLE_SCHEMA'].'.'.
                     $relation['TABLE_NAME'];
                 $relations[$relation['CONSTRAINT_NAME']]['keymap'][$relation['REFERENCED_COLUMN_NAME']] =
                     $relation['COLUMN_NAME'];
@@ -287,10 +287,10 @@ 
                 $usedcol = [];
                 if (count($columns)) {
                     foreach (Collection::from($relationsT[$data['table']] ?? [])
-                        ->filter(function (array $v) use ($columns): bool {
+                        ->filter(function(array $v) use ($columns): bool {
                             return in_array($v['COLUMN_NAME'], $columns);
                         })
-                        ->map(function (array $v): array {
+                        ->map(function(array $v): array {
                             $new = [];
                             foreach ($v as $kk => $vv) {
                                 $new[strtoupper($kk)] = $vv;
@@ -298,7 +298,7 @@ 
                             return $new;
                         }) as $relation
                     ) {
-                        $foreign[$relation['CONSTRAINT_NAME']]['table'] = $relation['REFERENCED_TABLE_SCHEMA'] . '.' .
+                        $foreign[$relation['CONSTRAINT_NAME']]['table'] = $relation['REFERENCED_TABLE_SCHEMA'].'.'.
                             $relation['REFERENCED_TABLE_NAME'];
                         $foreign[$relation['CONSTRAINT_NAME']]['keymap'][$relation['COLUMN_NAME']] =
                             $relation['REFERENCED_COLUMN_NAME'];
@@ -316,12 +316,12 @@ 
                         $definition->getName() == $relname ||
                         $definition->getColumn($relname)
                     ) {
-                        $relname .= '_' . array_values($data['keymap'])[0];
+                        $relname .= '_'.array_values($data['keymap'])[0];
                     }
                     $orig = $relname;
                     $cntr = 1;
                     while ($definition->hasRelation($relname) || $definition->getName() == $relname) {
-                        $relname = $orig . '_' . (++ $cntr);
+                        $relname = $orig.'_'.(++$cntr);
                     }
                     $definition->addRelation(
                         new TableRelation(
@@ -349,23 +349,23 @@ 
                 "SELECT table_name FROM information_schema.tables where table_schema = ?",
                 [$this->connection['opts']['schema'] ?? $this->connection['name']]
             ))
-            ->map(function (array $v): array {
+            ->map(function(array $v): array {
                 $new = [];
                 foreach ($v as $kk => $vv) {
                     $new[strtoupper($kk)] = $vv;
                 }
                 return $new;
             })
-            ->mapKey(function (array $v): string {
+            ->mapKey(function(array $v): string {
                 return strtolower($v['TABLE_NAME']);
             })
             ->pluck('TABLE_NAME')
-            ->map(function (string $v): Table {
+            ->map(function(string $v): Table {
                 return $this->table($v)->toLowerCase();
             })
             ->toArray();
         foreach (array_keys($tables) as $k) {
-            $tables[($this->connection['opts']['schema'] ?? $this->connection['name']) . '.' . $k] = &$tables[$k];
+            $tables[($this->connection['opts']['schema'] ?? $this->connection['name']).'.'.$k] = &$tables[$k];
         }
         return $tables;
     }