yiisoft / db

src/TestSupport/TestQueryTrait.php

Spacing +5 added lines, -5 removed lines

@@ -550,7 +550,7 @@ 
         $result = (new Query($db))->from('customer')
             ->select(['name', 'id'])
             ->orderBy(['id' => SORT_DESC])
-            ->indexBy(function ($row) {
+            ->indexBy(function($row) {
                 return $row['id'] * 2;
             })
             ->column();
@@ -814,7 +814,7 @@ 
         );
 
         /* Connection cache */
-        $db->cache(function (ConnectionInterface $db) use ($query, $update) {
+        $db->cache(function(ConnectionInterface $db) use ($query, $update) {
             $this->assertEquals(
                 'user2',
                 $query->where(['id' => 2])->scalar(),
@@ -829,7 +829,7 @@ 
                 'Query does NOT reflect DB changes when wrapped in connection caching'
             );
 
-            $db->noCache(function () use ($query) {
+            $db->noCache(function() use ($query) {
                 $this->assertEquals(
                     'user22',
                     $query->where(['id' => 2])->scalar(),
@@ -846,7 +846,7 @@ 
 
         $this->queryCache->setEnable(false);
 
-        $db->cache(function () use ($query, $update) {
+        $db->cache(function() use ($query, $update) {
             $this->assertEquals(
                 'user22',
                 $query->where(['id' => 2])->scalar(),
@@ -877,7 +877,7 @@ 
             'When Query has disabled cache, we get actual data'
         );
 
-        $db->cache(function () use ($query) {
+        $db->cache(function() use ($query) {
             $this->assertEquals('user1', $query->noCache()->where(['id' => 1])->scalar());
             $this->assertEquals('user11', $query->cache()->where(['id' => 1])->scalar());
         }, 10);

src/TestSupport/IsOneOfAssert.php

Spacing +1 added lines, -1 removed lines

@@ -30,7 +30,7 @@
      */
     public function toString(): string
     {
-        $allowedValues = array_map(static function ($value) {
+        $allowedValues = array_map(static function($value) {
             return VarDumper::create($value)->asString();
         }, $this->allowedValues);
 

src/Schema/Schema.php

Spacing +2 added lines, -2 removed lines

@@ -489,7 +489,7 @@ 
      */
     protected function loadTableTypeMetadata(string $type, string $name): Constraint|array|TableSchema|null
     {
-        return match ($type) {
+        return match($type) {
             self::SCHEMA => $this->loadTableSchema($name),
             self::PRIMARY_KEY => $this->loadTablePrimaryKey($name),
             self::UNIQUES => $this->loadTableUniques($name),
@@ -515,7 +515,7 @@ 
         string $name,
         bool $refresh = false
     ): Constraint|array|null|TableSchema {
-        return match ($type) {
+        return match($type) {
             self::SCHEMA => $this->getTableSchema($name, $refresh),
             self::PRIMARY_KEY => $this->getTablePrimaryKey($name, $refresh),
             self::UNIQUES => $this->getTableUniques($name, $refresh),

src/Exception/ConvertException.php

Spacing +1 added lines, -1 removed lines

@@ -20,7 +20,7 @@
         $message = $this->e->getMessage() . PHP_EOL . 'The SQL being executed was: ' . $this->rawSql;
         $errorInfo = $this->e instanceof PDOException ? $this->e->errorInfo : null;
 
-        return match (
+        return match(
             str_contains($message, self::MSG_INTEGRITY_EXCEPTION_1) ||
             str_contains($message, self::MGS_INTEGRITY_EXCEPTION_2)
         ) {

src/Transaction/Transaction.php

Spacing +3 added lines, -3 removed lines

@@ -128,7 +128,7 @@ 
                 );
             }
 
-            $this->db->getPDO()?->beginTransaction();
+            $this->db->getPDO() ? ->beginTransaction();
             $this->level = 1;
 
             return;
@@ -173,7 +173,7 @@ 
                 $this->logger->log(LogLevel::DEBUG, 'Commit transaction ' . __METHOD__);
             }
 
-            $this->db->getPDO()?->commit();
+            $this->db->getPDO() ? ->commit();
 
             return;
         }
@@ -215,7 +215,7 @@ 
                 $this->logger->log(LogLevel::INFO, 'Roll back transaction ' . __METHOD__);
             }
 
-            $this->db->getPDO()?->rollBack();
+            $this->db->getPDO() ? ->rollBack();
 
             return;
         }

src/Query/QueryBuilder.php

Spacing +3 added lines, -3 removed lines

@@ -841,7 +841,7 @@ 
      */
     protected function hasOffset(mixed $offset): bool
     {
-        return ($offset instanceof ExpressionInterface) || (ctype_digit((string)$offset) && (string)$offset !== '0');
+        return ($offset instanceof ExpressionInterface) || (ctype_digit((string) $offset) && (string) $offset !== '0');
     }
 
     /**
@@ -1025,7 +1025,7 @@ 
         /** Remove duplicates */
         $constraints = array_combine(
             array_map(
-                static function (Constraint $constraint) {
+                static function(Constraint $constraint) {
                     $columns = $constraint->getColumnNames() ?? [];
                     $columns = is_array($columns) ? $columns : [$columns];
                     sort($columns, SORT_STRING);
@@ -1043,7 +1043,7 @@ 
         $constraints = array_values(
             array_filter(
                 $constraints,
-                static function (Constraint $constraint) use ($quoter, $columns, &$columnNames) {
+                static function(Constraint $constraint) use ($quoter, $columns, &$columnNames) {
                     $getColumnNames = $constraint->getColumnNames() ?? [];
                     $constraintColumnNames = array_map(
                         [$quoter, 'quoteColumnName'],

src/Query/BatchQueryResult.php

Spacing +1 added lines, -1 removed lines

@@ -159,7 +159,7 @@
         $count = 0;
 
         try {
-            while ($count++ < $this->batchSize && ($row = $this->dataReader?->read())) {
+            while ($count++ < $this->batchSize && ($row = $this->dataReader ? ->read())) {
                 $rows[] = $row;
             }
         } catch (PDOException $e) {

src/Command/CommandPdoTrait.php

Spacing +4 added lines, -4 removed lines

@@ -33,7 +33,7 @@ 
     protected function bindPendingParams(): void
     {
         foreach ($this->params as $name => $value) {
-            $this->pdoStatement?->bindValue($name, $value->getValue(), $value->getType());
+            $this->pdoStatement ? ->bindValue($name, $value->getValue(), $value->getType());
         }
     }
 
@@ -51,11 +51,11 @@ 
         }
 
         if ($length === null) {
-            $this->pdoStatement?->bindParam($name, $value, $dataType);
+            $this->pdoStatement ? ->bindParam($name, $value, $dataType);
         } elseif ($driverOptions === null) {
-            $this->pdoStatement?->bindParam($name, $value, $dataType, $length);
+            $this->pdoStatement ? ->bindParam($name, $value, $dataType, $length);
         } else {
-            $this->pdoStatement?->bindParam($name, $value, $dataType, $length, $driverOptions);
+            $this->pdoStatement ? ->bindParam($name, $value, $dataType, $length, $driverOptions);
         }
 
         return $this;

src/Command/Command.php

Spacing +14 added lines, -14 removed lines

@@ -215,7 +215,7 @@ 
     public function batchInsert(string $table, array $columns, iterable $rows): self
     {
         $table = $this->queryBuilder()->quoter()->quoteSql($table);
-        $columns = array_map(fn ($column) => $this->queryBuilder()->quoter()->quoteSql($column), $columns);
+        $columns = array_map(fn($column) => $this->queryBuilder()->quoter()->quoteSql($column), $columns);
         $params = [];
         $sql = $this->queryBuilder()->batchInsert($table, $columns, $rows, $params);
 
@@ -400,18 +400,18 @@ 
         $this->prepare(false);
 
         try {
-            $this->profiler?->begin((string)$rawSql, [__METHOD__]);
+            $this->profiler ? ->begin((string) $rawSql, [__METHOD__]);
 
             $this->internalExecute($rawSql);
-            $n = $this->pdoStatement?->rowCount();
+            $n = $this->pdoStatement ? ->rowCount();
 
-            $this->profiler?->end((string)$rawSql, [__METHOD__]);
+            $this->profiler ? ->end((string) $rawSql, [__METHOD__]);
 
             $this->refreshTableSchema();
 
             return $n ?? 0;
         } catch (Exception $e) {
-            $this->profiler?->end((string)$rawSql, [__METHOD__]);
+            $this->profiler ? ->end((string) $rawSql, [__METHOD__]);
             throw $e;
         }
     }
@@ -431,7 +431,7 @@ 
 
     public function getParams(): array
     {
-        return array_map(static fn (mixed $value): mixed => $value->getValue(), $this->params);
+        return array_map(static fn(mixed $value): mixed => $value->getValue(), $this->params);
     }
 
     /**
@@ -663,11 +663,11 @@ 
                 $cacheKey = $this->getCacheKey($method, $fetchMode, $rawSql);
                 $result = $cache->getOrSet(
                     $cacheKey,
-                    static fn () => null,
+                    static fn() => null,
                 );
 
                 if (is_array($result) && isset($result[0])) {
-                    $this->logger?->log(LogLevel::DEBUG, 'Query result served from cache', [__CLASS__ . '::query']);
+                    $this->logger ? ->log(LogLevel::DEBUG, 'Query result served from cache', [__CLASS__ . '::query']);
 
                     return $result[0];
                 }
@@ -677,7 +677,7 @@ 
         $this->prepare(true);
 
         try {
-            $this->profiler?->begin((string)$rawSql, [__CLASS__ . '::query']);
+            $this->profiler ? ->begin((string) $rawSql, [__CLASS__ . '::query']);
 
             $this->internalExecute($rawSql);
 
@@ -690,24 +690,24 @@ 
 
                 $result = call_user_func_array([$this->pdoStatement, $method], (array) $fetchMode);
 
-                $this->pdoStatement?->closeCursor();
+                $this->pdoStatement ? ->closeCursor();
             }
 
-            $this->profiler?->end((string)$rawSql, [__CLASS__ . '::query']);
+            $this->profiler ? ->end((string) $rawSql, [__CLASS__ . '::query']);
         } catch (Exception $e) {
-            $this->profiler?->end((string)$rawSql, [__CLASS__ . '::query']);
+            $this->profiler ? ->end((string) $rawSql, [__CLASS__ . '::query']);
             throw $e;
         }
 
         if (isset($cache, $cacheKey, $info)) {
             $cache->getOrSet(
                 $cacheKey,
-                static fn (): array => [$result],
+                static fn(): array => [$result],
                 $info[1],
                 $info[2]
             );
 
-            $this->logger?->log(LogLevel::DEBUG, 'Saved query result in cache', [__CLASS__ . '::query']);
+            $this->logger ? ->log(LogLevel::DEBUG, 'Saved query result in cache', [__CLASS__ . '::query']);
         }
 
         return $result;