yiisoft / db

src/Schema/Quoter.php

Spacing +1 added lines, -1 removed lines

@@ -73,7 +73,7 @@
     {
         return preg_replace_callback(
             '/({{(%?[\w\-. ]+%?)}}|\\[\\[([\w\-. ]+)]])/',
-            function ($matches) {
+            function($matches) {
                 if (isset($matches[3])) {
                     return $this->quoteColumnName($matches[3]);
                 }

src/Schema/Schema.php

Spacing +1 added lines, -1 removed lines

@@ -497,7 +497,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/Query/DDLQueryBuilder.php

Indentation +2 added lines, -2 removed lines

@@ -203,8 +203,8 @@
     public function dropCommentFromTable(string $table): string
     {
         return 'COMMENT ON TABLE '
-             . $this->queryBuilder->quoter()->quoteTableName($table)
-             . ' IS NULL';
+                . $this->queryBuilder->quoter()->quoteTableName($table)
+                . ' IS NULL';
     }
 
     public function dropDefaultValue(string $name, string $table): string

src/Query/QueryBuilder.php

Spacing +3 added lines, -3 removed lines

@@ -854,7 +854,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');
     }
 
     /**
@@ -1046,7 +1046,7 @@ 
         /** Remove duplicates */
         $constraints = array_combine(
             array_map(
-                static function ($constraint) {
+                static function($constraint) {
                     $columns = $constraint->getColumnNames();
                     sort($columns, SORT_STRING);
 
@@ -1064,7 +1064,7 @@ 
         $constraints = array_values(
             array_filter(
                 $constraints,
-                static function ($constraint) use ($quoter, $columns, &$columnNames) {
+                static function($constraint) use ($quoter, $columns, &$columnNames) {
                     /** @psalm-suppress UndefinedClass, UndefinedMethod */
                     $constraintColumnNames = array_map([$quoter, 'quoteColumnName'], $constraint->getColumnNames());
                     $result = !array_diff($constraintColumnNames, $columns);

src/Cache/SchemaCache.php

Spacing +1 added lines, -1 removed lines

@@ -42,7 +42,7 @@
     ): mixed {
         return $this->cache->getOrSet(
             $key,
-            static fn () => $value,
+            static fn() => $value,
             $ttl,
             $dependency,
         );

src/Command/Command.php

Spacing +11 added lines, -11 removed lines

@@ -217,7 +217,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);
 
@@ -432,18 +432,18 @@ 
         $this->prepare(false);
 
         try {
-            $this->profiler?->begin((string)$rawSql, [__METHOD__]);
+            $this->profiler ? ->begin((string) $rawSql, [__METHOD__]);
 
             $this->internalExecute($rawSql);
             $n = $this->pdoStatement->rowCount();
 
-            $this->profiler?->end((string)$rawSql, [__METHOD__]);
+            $this->profiler ? ->end((string) $rawSql, [__METHOD__]);
 
             $this->refreshTableSchema();
 
             return $n;
         } catch (Exception $e) {
-            $this->profiler?->end((string)$rawSql, [__METHOD__]);
+            $this->profiler ? ->end((string) $rawSql, [__METHOD__]);
             throw $e;
         }
     }
@@ -708,11 +708,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];
                 }
@@ -722,7 +722,7 @@ 
         $this->prepare(true);
 
         try {
-            $this->profiler?->begin((string)$rawSql, [__CLASS__ . '::query']);
+            $this->profiler ? ->begin((string) $rawSql, [__CLASS__ . '::query']);
 
             $this->internalExecute($rawSql);
 
@@ -738,21 +738,21 @@ 
                 $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;

src/TestUtility/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/TestUtility/TestQueryBuilderTrait.php

Indentation +8 added lines, -8 removed lines

@@ -1146,20 +1146,20 @@
         $secondQuery = new Query($db);
 
         $secondQuery->select('id')
-              ->from('TotalTotalExample t2')
-              ->where('w > 5');
+                ->from('TotalTotalExample t2')
+                ->where('w > 5');
 
         $thirdQuery = new Query($db);
 
         $thirdQuery->select('id')
-              ->from('TotalTotalExample t3')
-              ->where('w = 3');
+                ->from('TotalTotalExample t3')
+                ->where('w = 3');
 
         $query->select('id')
-              ->from('TotalExample t1')
-              ->where(['and', 'w > 0', 'x < 2'])
-              ->union($secondQuery)
-              ->union($thirdQuery, true);
+                ->from('TotalExample t1')
+                ->where(['and', 'w > 0', 'x < 2'])
+                ->union($secondQuery)
+                ->union($thirdQuery, true);
 
         [$actualQuerySql, $queryParams] = $this->getQueryBuilder()->build($query);
 

Spacing +16 added lines, -16 removed lines

@@ -1562,13 +1562,13 @@ 
         return [
             'drop' => [
                 "ALTER TABLE {{{$tableName}}} DROP CONSTRAINT [[$name]]",
-                static function (QueryBuilder $qb) use ($tableName, $name) {
+                static function(QueryBuilder $qb) use ($tableName, $name) {
                     return $qb->dropCheck($name, $tableName);
                 },
             ],
             'add' => [
                 "ALTER TABLE {{{$tableName}}} ADD CONSTRAINT [[$name]] CHECK ([[C_not_null]] > 100)",
-                static function (QueryBuilder $qb) use ($tableName, $name) {
+                static function(QueryBuilder $qb) use ($tableName, $name) {
                     return $qb->addCheck($name, $tableName, '[[C_not_null]] > 100');
                 },
             ],
@@ -1584,14 +1584,14 @@ 
         return [
             'drop' => [
                 "ALTER TABLE {{{$tableName}}} DROP CONSTRAINT [[$name]]",
-                static function (QueryBuilder $qb) use ($tableName, $name) {
+                static function(QueryBuilder $qb) use ($tableName, $name) {
                     return $qb->dropForeignKey($name, $tableName);
                 },
             ],
             'add' => [
                 "ALTER TABLE {{{$tableName}}} ADD CONSTRAINT [[$name]] FOREIGN KEY ([[C_fk_id_1]])"
                 . " REFERENCES {{{$pkTableName}}} ([[C_id_1]]) ON DELETE CASCADE ON UPDATE CASCADE",
-                static function (QueryBuilder $qb) use ($tableName, $name, $pkTableName) {
+                static function(QueryBuilder $qb) use ($tableName, $name, $pkTableName) {
                     return $qb->addForeignKey(
                         $name,
                         $tableName,
@@ -1606,7 +1606,7 @@ 
             'add (2 columns)' => [
                 "ALTER TABLE {{{$tableName}}} ADD CONSTRAINT [[$name]] FOREIGN KEY ([[C_fk_id_1]], [[C_fk_id_2]])"
                 . " REFERENCES {{{$pkTableName}}} ([[C_id_1]], [[C_id_2]]) ON DELETE CASCADE ON UPDATE CASCADE",
-                static function (QueryBuilder $qb) use ($tableName, $name, $pkTableName) {
+                static function(QueryBuilder $qb) use ($tableName, $name, $pkTableName) {
                     return $qb->addForeignKey(
                         $name,
                         $tableName,
@@ -1629,19 +1629,19 @@ 
         return [
             'drop' => [
                 "ALTER TABLE {{{$tableName}}} DROP CONSTRAINT [[$name]]",
-                static function (QueryBuilder $qb) use ($tableName, $name) {
+                static function(QueryBuilder $qb) use ($tableName, $name) {
                     return $qb->dropPrimaryKey($name, $tableName);
                 },
             ],
             'add' => [
                 "ALTER TABLE {{{$tableName}}} ADD CONSTRAINT [[$name]] PRIMARY KEY ([[C_id_1]])",
-                static function (QueryBuilder $qb) use ($tableName, $name) {
+                static function(QueryBuilder $qb) use ($tableName, $name) {
                     return $qb->addPrimaryKey($name, $tableName, 'C_id_1');
                 },
             ],
             'add (2 columns)' => [
                 "ALTER TABLE {{{$tableName}}} ADD CONSTRAINT [[$name]] PRIMARY KEY ([[C_id_1]], [[C_id_2]])",
-                static function (QueryBuilder $qb) use ($tableName, $name) {
+                static function(QueryBuilder $qb) use ($tableName, $name) {
                     return $qb->addPrimaryKey($name, $tableName, 'C_id_1, C_id_2');
                 },
             ],
@@ -1658,19 +1658,19 @@ 
         return [
             'drop' => [
                 "ALTER TABLE {{{$tableName1}}} DROP CONSTRAINT [[$name1]]",
-                static function (QueryBuilder $qb) use ($tableName1, $name1) {
+                static function(QueryBuilder $qb) use ($tableName1, $name1) {
                     return $qb->dropUnique($name1, $tableName1);
                 },
             ],
             'add' => [
                 "ALTER TABLE {{{$tableName1}}} ADD CONSTRAINT [[$name1]] UNIQUE ([[C_unique]])",
-                static function (QueryBuilder $qb) use ($tableName1, $name1) {
+                static function(QueryBuilder $qb) use ($tableName1, $name1) {
                     return $qb->addUnique($name1, $tableName1, 'C_unique');
                 },
             ],
             'add (2 columns)' => [
                 "ALTER TABLE {{{$tableName2}}} ADD CONSTRAINT [[$name2]] UNIQUE ([[C_index_2_1]], [[C_index_2_2]])",
-                static function (QueryBuilder $qb) use ($tableName2, $name2) {
+                static function(QueryBuilder $qb) use ($tableName2, $name2) {
                     return $qb->addUnique($name2, $tableName2, 'C_index_2_1, C_index_2_2');
                 },
             ],
@@ -2348,31 +2348,31 @@ 
         return [
             'drop' => [
                 "DROP INDEX [[$name1]] ON {{{$tableName}}}",
-                static function (QueryBuilder $qb) use ($tableName, $name1) {
+                static function(QueryBuilder $qb) use ($tableName, $name1) {
                     return $qb->dropIndex($name1, $tableName);
                 },
             ],
             'create' => [
                 "CREATE INDEX [[$name1]] ON {{{$tableName}}} ([[C_index_1]])",
-                static function (QueryBuilder $qb) use ($tableName, $name1) {
+                static function(QueryBuilder $qb) use ($tableName, $name1) {
                     return $qb->createIndex($name1, $tableName, 'C_index_1');
                 },
             ],
             'create (2 columns)' => [
                 "CREATE INDEX [[$name2]] ON {{{$tableName}}} ([[C_index_2_1]], [[C_index_2_2]])",
-                static function (QueryBuilder $qb) use ($tableName, $name2) {
+                static function(QueryBuilder $qb) use ($tableName, $name2) {
                     return $qb->createIndex($name2, $tableName, 'C_index_2_1, C_index_2_2');
                 },
             ],
             'create unique' => [
                 "CREATE UNIQUE INDEX [[$name1]] ON {{{$tableName}}} ([[C_index_1]])",
-                static function (QueryBuilder $qb) use ($tableName, $name1) {
+                static function(QueryBuilder $qb) use ($tableName, $name1) {
                     return $qb->createIndex($name1, $tableName, 'C_index_1', true);
                 },
             ],
             'create unique (2 columns)' => [
                 "CREATE UNIQUE INDEX [[$name2]] ON {{{$tableName}}} ([[C_index_2_1]], [[C_index_2_2]])",
-                static function (QueryBuilder $qb) use ($tableName, $name2) {
+                static function(QueryBuilder $qb) use ($tableName, $name2) {
                     return $qb->createIndex($name2, $tableName, 'C_index_2_1, C_index_2_2', true);
                 },
             ],

src/TestUtility/TestConnectionTrait.php

Spacing +6 added lines, -6 removed lines

@@ -95,7 +95,7 @@ 
 
         $this->expectException(Exception::class);
 
-        $db->transaction(function () use ($db) {
+        $db->transaction(function() use ($db) {
             $db->createCommand()->insert('profile', ['description' => 'test transaction shortcut'])->execute();
             throw new Exception('Exception in transaction shortcut');
         });
@@ -109,7 +109,7 @@ 
     {
         $db = $this->getConnection(true);
 
-        $result = $db->transaction(static function () use ($db) {
+        $result = $db->transaction(static function() use ($db) {
             $db->createCommand()->insert('profile', ['description' => 'test transaction shortcut'])->execute();
             return true;
         });
@@ -127,7 +127,7 @@ 
     {
         $db = $this->getConnection(true);
 
-        $result = $db->transaction(static function (ConnectionInterface $db) {
+        $result = $db->transaction(static function(ConnectionInterface $db) {
             $db->createCommand()->insert('profile', ['description' => 'test transaction shortcut'])->execute();
             return true;
         }, Transaction::READ_UNCOMMITTED);
@@ -150,10 +150,10 @@ 
     {
         $db = $this->getConnection();
 
-        $db->transaction(function (ConnectionInterface $db) {
+        $db->transaction(function(ConnectionInterface $db) {
             $this->assertNotNull($db->getTransaction());
 
-            $db->transaction(function (ConnectionInterface $db) {
+            $db->transaction(function(ConnectionInterface $db) {
                 $this->assertNotNull($db->getTransaction());
                 $db->getTransaction()->rollBack();
             });
@@ -168,7 +168,7 @@ 
 
         $db->setEnableSavepoint(false);
 
-        $db->transaction(function (ConnectionInterface $db) {
+        $db->transaction(function(ConnectionInterface $db) {
             $this->assertNotNull($db->getTransaction());
             $this->expectException(NotSupportedException::class);
             $db->beginTransaction();