vakata / database

src/DB.php

Spacing +29 added lines, -31 removed lines

@@ -74,19 +74,19 @@ 
                 ];
             }
         }
-        $connection['type'] = isset($temp['scheme']) && strlen((string)$temp['scheme']) ? $temp['scheme'] : null;
-        $connection['user'] = isset($temp['user']) && strlen((string)$temp['user']) ? $temp['user'] : null;
-        $connection['pass'] = isset($temp['pass']) && strlen((string)$temp['pass']) ? $temp['pass'] : null;
-        $connection['host'] = isset($temp['host']) && strlen((string)$temp['host']) ? $temp['host'] : null;
-        $connection['name'] = isset($temp['path']) && strlen((string)$temp['path']) ?
-            trim((string)$temp['path'], '/') : null;
-        $connection['port'] = isset($temp['port']) && (int)$temp['port'] ? (int)$temp['port'] : null;
-        if (isset($temp['query']) && strlen((string)$temp['query'])) {
-            parse_str((string)$temp['query'], $connection['opts']);
+        $connection['type'] = isset($temp['scheme']) && strlen((string) $temp['scheme']) ? $temp['scheme'] : null;
+        $connection['user'] = isset($temp['user']) && strlen((string) $temp['user']) ? $temp['user'] : null;
+        $connection['pass'] = isset($temp['pass']) && strlen((string) $temp['pass']) ? $temp['pass'] : null;
+        $connection['host'] = isset($temp['host']) && strlen((string) $temp['host']) ? $temp['host'] : null;
+        $connection['name'] = isset($temp['path']) && strlen((string) $temp['path']) ?
+            trim((string) $temp['path'], '/') : null;
+        $connection['port'] = isset($temp['port']) && (int) $temp['port'] ? (int) $temp['port'] : null;
+        if (isset($temp['query']) && strlen((string) $temp['query'])) {
+            parse_str((string) $temp['query'], $connection['opts']);
         }
         // create the driver
         $connection['type'] = $aliases[$connection['type']] ?? $connection['type'];
-        $tmp = '\\vakata\\database\\driver\\'.strtolower((string)$connection['type']).'\\Driver';
+        $tmp = '\\vakata\\database\\driver\\'.strtolower((string) $connection['type']).'\\Driver';
         if (!class_exists($tmp)) {
             throw new DBException('Unknown DB backend');
         }
@@ -130,7 +130,7 @@ 
         $map = [];
         $sql = preg_replace_callback(
             '(\:[a-z_][a-z0-9_]+)i',
-            function ($matches) use (&$map, $par) {
+            function($matches) use (&$map, $par) {
                 $key = substr($matches[0], 1);
                 $map[] = $key;
                 return isset($par) && isset($par[$key]) && is_array($par[$key]) ? '??' : '?';
@@ -147,7 +147,7 @@ 
         $new = '';
         $par = array_values($par);
         if (substr_count($sql, '?') === 2 && !is_array($par[0])) {
-            $par = [ $par ];
+            $par = [$par];
         }
         $parts = explode('??', $sql);
         $index = 0;
@@ -157,7 +157,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);
@@ -165,7 +165,7 @@ 
                 $new .= implode(',', array_fill(0, count($params), '?'));
             }
         }
-        return [ $new, $par ];
+        return [$new, $par];
     }
     /**
      * Run a query (prepare & execute).
@@ -182,7 +182,7 @@ 
             $sql = $tmp['sql'];
             $ord = [];
             foreach ($tmp['map'] as $key) {
-                $ord[] = $par[$key] ?? throw new DBException('Missing param ' . $key);
+                $ord[] = $par[$key] ?? throw new DBException('Missing param '.$key);
             }
             $par = $ord;
         }
@@ -223,7 +223,7 @@ 
     ): Collection {
         $coll = Collection::from($this->query($sql, $par, $buff));
         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;
@@ -232,18 +232,18 @@ 
             });
         }
         if ($key !== null) {
-            $coll->mapKey(function ($v) use ($key): int|string {
+            $coll->mapKey(function($v) use ($key): int | string {
                 return $v[$key];
             });
         }
         if ($skip) {
-            $coll->map(function ($v) use ($key) {
+            $coll->map(function($v) use ($key) {
                 unset($v[$key]);
                 return $v;
             });
         }
         if ($opti) {
-            $coll->map(function ($v) {
+            $coll->map(function($v) {
                 return count($v) === 1 ? current($v) : $v;
             });
         }
@@ -360,8 +360,7 @@ 
     public function definition(string $table, bool $detectRelations = true) : Table
     {
         return isset($this->schema) ?
-            $this->schema->getTable($table) :
-            $this->driver->table($table, $detectRelations);
+            $this->schema->getTable($table) : $this->driver->table($table, $detectRelations);
     }
 
     public function hasSchema(): bool
@@ -471,11 +470,11 @@ 
      * @param class-string<T>|Table|string $table
      * @return ($table is class-string ? MapperInterface<T> : MapperInterface<Entity>)
      */
-    public function getMapper(Table|string $table): MapperInterface
+    public function getMapper(Table | string $table): MapperInterface
     {
         if (is_string($table)) {
-            if (isset($this->mappers['::' . $table])) {
-                return $this->mappers['::' . $table];
+            if (isset($this->mappers['::'.$table])) {
+                return $this->mappers['::'.$table];
             }
             $table = $this->definition($table);
         }
@@ -484,14 +483,14 @@ 
         }
         return $this->mappers[$table->getFullName()] = new Mapper($this, $table);
     }
-    public function setMapper(Table|string $table, MapperInterface $mapper, ?string $class = null): static
+    public function setMapper(Table | string $table, MapperInterface $mapper, ?string $class = null): static
     {
         if (is_string($table)) {
             $table = $this->definition($table);
         }
         $this->mappers[$table->getFullName()] = $mapper;
         if (isset($class)) {
-            $this->mappers['::' . $class] = $mapper;
+            $this->mappers['::'.$class] = $mapper;
         }
         return $this;
     }
@@ -502,11 +501,10 @@ 
     ): TableQueryMapped {
         return new TableQueryMapped($this, $this->definition($table), $findRelations, $mapper);
     }
-    public function __call(string $method, array $args): TableQuery|TableQueryMapped
+    public function __call(string $method, array $args): TableQuery | TableQueryMapped
     {
         return ($args[0] ?? false) ?
-            $this->tableMapped($method, $args[1] ?? false, $args[2] ?? null) :
-            $this->table($method, $args[1] ?? false);
+            $this->tableMapped($method, $args[1] ?? false, $args[2] ?? null) : $this->table($method, $args[1] ?? false);
     }
     public function findRelation(string $start, string $end): array
     {
@@ -542,12 +540,12 @@ 
                     $relations[$t] = $w;
                 }
                 if (!isset($schema[$name])) {
-                    $schema[$name] = [ 'edges' => [] ];
+                    $schema[$name] = ['edges' => []];
                 }
                 foreach ($relations as $t => $w) {
                     $schema[$name]['edges'][$t] = $w;
                     if (!isset($schema[$t])) {
-                        $schema[$t] = [ 'edges' => [] ];
+                        $schema[$t] = ['edges' => []];
                     }
                     $schema[$t]['edges'][$name] = $w;
                 }

src/driver/pdo/Statement.php

Spacing +7 added lines, -7 removed lines

@@ -26,7 +26,7 @@ 
         if (isset($this->map)) {
             $par = [];
             foreach ($this->map as $key) {
-                $par[] = $data[$key] ?? throw new DBException('Missing param ' . $key);
+                $par[] = $data[$key] ?? throw new DBException('Missing param '.$key);
             }
             $data = $par;
         }
@@ -34,28 +34,28 @@ 
         foreach ($data as $i => $v) {
             switch (gettype($v)) {
                 case 'boolean':
-                    $this->statement->bindValue($i+1, $v, \PDO::PARAM_BOOL);
+                    $this->statement->bindValue($i + 1, $v, \PDO::PARAM_BOOL);
                     break;
                 case 'integer':
-                    $this->statement->bindValue($i+1, $v, \PDO::PARAM_INT);
+                    $this->statement->bindValue($i + 1, $v, \PDO::PARAM_INT);
                     break;
                 case 'NULL':
-                    $this->statement->bindValue($i+1, $v, \PDO::PARAM_NULL);
+                    $this->statement->bindValue($i + 1, $v, \PDO::PARAM_NULL);
                     break;
                 case 'double':
-                    $this->statement->bindValue($i+1, $v);
+                    $this->statement->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') {
-                        $this->statement->bindParam($i+1, $v, \PDO::PARAM_LOB);
+                        $this->statement->bindParam($i + 1, $v, \PDO::PARAM_LOB);
                         break;
                     }
                     if (!is_string($data[$i])) {
                         $data[$i] = serialize($data[$i]);
                     }
-                    $this->statement->bindValue($i+1, $v);
+                    $this->statement->bindValue($i + 1, $v);
                     break;
             }
         }

src/driver/sphinx/Statement.php

Spacing +6 added lines, -6 removed lines

@@ -28,7 +28,7 @@ 
         if (isset($this->map)) {
             $par = [];
             foreach ($this->map as $key) {
-                $par[] = $data[$key] ?? throw new DBException('Missing param ' . $key);
+                $par[] = $data[$key] ?? throw new DBException('Missing param '.$key);
             }
             $data = $par;
         }
@@ -49,23 +49,23 @@ 
                             break;
                         case 'array':
                             $par = implode(',', $par);
-                            $par = "'" . $this->lnk->escape_string($par) . "'";
+                            $par = "'".$this->lnk->escape_string($par)."'";
                             break;
                         case 'object':
                             $par = serialize($par);
-                            $par = "'" . $this->lnk->escape_string($par) . "'";
+                            $par = "'".$this->lnk->escape_string($par)."'";
                             break;
                         case 'resource':
                             if (is_resource($par) && get_resource_type($par) === 'stream') {
                                 $par = stream_get_contents($par);
-                                $par = "'" . $this->lnk->escape_string($par) . "'";
+                                $par = "'".$this->lnk->escape_string($par)."'";
                             } else {
                                 $par = serialize($par);
-                                $par = "'" . $this->lnk->escape_string($par) . "'";
+                                $par = "'".$this->lnk->escape_string($par)."'";
                             }
                             break;
                         default:
-                            $par = "'" . $this->lnk->escape_string((string)$par) . "'";
+                            $par = "'".$this->lnk->escape_string((string) $par)."'";
                             break;
                     }
                     $sql .= $par;

src/driver/mysql/Statement.php

Spacing +9 added lines, -9 removed lines

@@ -31,7 +31,7 @@ 
         if (isset($this->map)) {
             $par = [];
             foreach ($this->map as $key) {
-                $par[] = $data[$key] ?? throw new DBException('Missing param ' . $key);
+                $par[] = $data[$key] ?? throw new DBException('Missing param '.$key);
             }
             $data = $par;
         }
@@ -86,7 +86,7 @@ 
             foreach ($lng as $index) {
                 if (is_resource($data[$index]) && get_resource_type($data[$index]) === 'stream') {
                     while (!feof($data[$index])) {
-                        $this->statement->send_long_data($index, (string)fread($data[$index], $lds));
+                        $this->statement->send_long_data($index, (string) fread($data[$index], $lds));
                     }
                 } else {
                     $data[$index] = str_split($data[$index], $lds);
@@ -106,24 +106,24 @@ 
             $res = false;
         }
         if (!$res) {
-            if ($log && (int)$this->driver->option('log_errors', 1)) {
+            if ($log && (int) $this->driver->option('log_errors', 1)) {
                 @file_put_contents(
                     $log,
-                    '--' . date('Y-m-d H:i:s') . ' ERROR: ' . $this->statement->error . "\r\n" .
-                    $this->sql . "\r\n" .
+                    '--'.date('Y-m-d H:i:s').' ERROR: '.$this->statement->error."\r\n".
+                    $this->sql."\r\n".
                     "\r\n",
                     FILE_APPEND
                 );
             }
-            throw new DBException('Prepared execute error: ' . $this->statement->error);
+            throw new DBException('Prepared execute error: '.$this->statement->error);
         }
         if ($log) {
             $tm = microtime(true) - $tm;
-            if ($tm >= (float)$this->driver->option('log_slow', 0)) {
+            if ($tm >= (float) $this->driver->option('log_slow', 0)) {
                 @file_put_contents(
                     $log,
-                    '--' . date('Y-m-d H:i:s') . ' ' . sprintf('%01.6f', $tm) . "s\r\n" .
-                    $this->sql . "\r\n" .
+                    '--'.date('Y-m-d H:i:s').' '.sprintf('%01.6f', $tm)."s\r\n".
+                    $this->sql."\r\n".
                     "\r\n",
                     FILE_APPEND
                 );

src/driver/odbc/Statement.php

Spacing +1 added lines, -1 removed lines

@@ -36,7 +36,7 @@
         if (isset($this->map)) {
             $par = [];
             foreach ($this->map as $key) {
-                $par[] = $data[$key] ?? throw new DBException('Missing param ' . $key);
+                $par[] = $data[$key] ?? throw new DBException('Missing param '.$key);
             }
             $data = $par;
         }

src/driver/postgre/Statement.php

Spacing +13 added lines, -15 removed lines

@@ -25,17 +25,17 @@ 
         if (strpos(strtolower($statement), 'prepare') === 0) {
             $this->drv->raw($this->statement);
             if (!isset($this->name)) {
-                $this->name = trim((preg_split('(\s+)', trim($this->statement))?:[])[1]??'', '"');
+                $this->name = trim((preg_split('(\s+)', trim($this->statement)) ?: [])[1] ?? '', '"');
             }
         } elseif ($this->name !== null) {
             $temp = \pg_prepare($this->driver, $this->name, $this->statement);
             if (!$temp) {
                 $log = $this->drv->option('log_file');
-                if ($log && (int)$this->drv->option('log_errors', 1)) {
+                if ($log && (int) $this->drv->option('log_errors', 1)) {
                     @file_put_contents(
                         $log,
-                        '--' . date('Y-m-d H:i:s') . ' ERROR PREPARING: ' . \pg_last_error($this->driver) . "\r\n" .
-                        $this->statement . "\r\n" .
+                        '--'.date('Y-m-d H:i:s').' ERROR PREPARING: '.\pg_last_error($this->driver)."\r\n".
+                        $this->statement."\r\n".
                         "\r\n",
                         FILE_APPEND
                     );
@@ -57,7 +57,7 @@ 
         if (isset($this->map)) {
             $par = [];
             foreach ($this->map as $key) {
-                $par[] = $data[$key] ?? throw new DBException('Missing param ' . $key);
+                $par[] = $data[$key] ?? throw new DBException('Missing param '.$key);
             }
             $data = $par;
         }
@@ -68,22 +68,20 @@ 
         try {
             if ($this->name !== null) {
                 $temp = (count($data)) ?
-                    \pg_execute($this->driver, $this->name, $data) :
-                    \pg_execute($this->driver, $this->name, array());
+                    \pg_execute($this->driver, $this->name, $data) : \pg_execute($this->driver, $this->name, array());
             } else {
                 $temp = (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());
             }
         } catch (\Exception $e) {
             $temp = false;
         }
         if (!$temp) {
-            if ($log && (int)$this->drv->option('log_errors', 1)) {
+            if ($log && (int) $this->drv->option('log_errors', 1)) {
                 @file_put_contents(
                     $log,
-                    '--' . date('Y-m-d H:i:s') . ' ERROR: ' . \pg_last_error($this->driver) . "\r\n" .
-                    $this->statement . "\r\n" .
+                    '--'.date('Y-m-d H:i:s').' ERROR: '.\pg_last_error($this->driver)."\r\n".
+                    $this->statement."\r\n".
                     "\r\n",
                     FILE_APPEND
                 );
@@ -92,11 +90,11 @@ 
         }
         if ($log) {
             $tm = microtime(true) - $tm;
-            if ($tm >= (float)$this->drv->option('log_slow', 0)) {
+            if ($tm >= (float) $this->drv->option('log_slow', 0)) {
                 @file_put_contents(
                     $log,
-                    '--' . date('Y-m-d H:i:s') . ' ' . sprintf('%01.6f', $tm) . "s\r\n" .
-                    $this->statement . "\r\n" .
+                    '--'.date('Y-m-d H:i:s').' '.sprintf('%01.6f', $tm)."s\r\n".
+                    $this->statement."\r\n".
                     "\r\n",
                     FILE_APPEND
                 );

src/driver/ibase/Statement.php

Spacing +1 added lines, -1 removed lines

@@ -24,7 +24,7 @@
         if (isset($this->map)) {
             $par = [];
             foreach ($this->map as $key) {
-                $par[] = $data[$key] ?? throw new DBException('Missing param ' . $key);
+                $par[] = $data[$key] ?? throw new DBException('Missing param '.$key);
             }
             $data = $par;
         }

src/driver/sqlite/Statement.php

Spacing +1 added lines, -1 removed lines

@@ -26,7 +26,7 @@
         if (isset($this->map)) {
             $par = [];
             foreach ($this->map as $key) {
-                $par[] = $data[$key] ?? throw new DBException('Missing param ' . $key);
+                $par[] = $data[$key] ?? throw new DBException('Missing param '.$key);
             }
             $data = $par;
         }

src/driver/oracle/Statement.php

Spacing +7 added lines, -7 removed lines

@@ -26,7 +26,7 @@ 
         if (isset($this->map)) {
             $par = [];
             foreach ($this->map as $key) {
-                $par[] = $data[$key] ?? throw new DBException('Missing param ' . $key);
+                $par[] = $data[$key] ?? throw new DBException('Missing param '.$key);
             }
             $data = $par;
         }
@@ -73,11 +73,11 @@ 
             if (!is_array($err)) {
                 $err = [];
             }
-            if ($log && (int)$this->driver->option('log_errors', 1)) {
+            if ($log && (int) $this->driver->option('log_errors', 1)) {
                 @file_put_contents(
                     $log,
-                    '--' . date('Y-m-d H:i:s') . ' ERROR: ' . implode(',', $err) . "\r\n" .
-                    $this->sql . "\r\n" .
+                    '--'.date('Y-m-d H:i:s').' ERROR: '.implode(',', $err)."\r\n".
+                    $this->sql."\r\n".
                     "\r\n",
                     FILE_APPEND
                 );
@@ -86,11 +86,11 @@ 
         }
         if ($log) {
             $tm = microtime(true) - $tm;
-            if ($tm >= (float)$this->driver->option('log_slow', 0)) {
+            if ($tm >= (float) $this->driver->option('log_slow', 0)) {
                 @file_put_contents(
                     $log,
-                    '--' . date('Y-m-d H:i:s') . ' ' . sprintf('%01.6f', $tm) . "s\r\n" .
-                    $this->sql . "\r\n" .
+                    '--'.date('Y-m-d H:i:s').' '.sprintf('%01.6f', $tm)."s\r\n".
+                    $this->sql."\r\n".
                     "\r\n",
                     FILE_APPEND
                 );