yiisoft / db

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;