Update QueryBuilder methods

supseven-at · Nov 13, 2024 · 115a71d · 115a71d
1 parent 250f564
commit 115a71d
Show file tree

Hide file tree

Showing 3 changed files with 7 additions and 7 deletions.
diff --git a/Classes/Command/AbstractTableCommand.php b/Classes/Command/AbstractTableCommand.php
@@ -83,16 +83,16 @@ protected function getColumnNames(): array
         $result = $this->queryBuilderForTable($table)
             ->select('*')
             ->from($table)
-            ->execute()
-            ->fetch();
+            ->executeQuery()
+            ->fetchAssociative();
         if ($result) {
             $columnNames = \array_keys($result);
             $this->tableColumnCache[$table] = $columnNames;
         } else {
             $result = GeneralUtility::makeInstance(ConnectionPool::class)->getConnectionForTable($table);
-            $result = $result->getSchemaManager()->listTableColumns($table);
-            foreach ($result as $columnName => $columnProperties) {
-                $columnNames[] = $columnName;
+            $result = $result->getSchemaInformation()->introspectTable($table)->getColumns();
+            foreach ($result as $columnProperties) {
+                $columnNames[] = $columnProperties->getName();
             }
             $this->tableColumnCache[$table] = $columnNames;
         }

diff --git a/Classes/Command/ExportTableCommand.php b/Classes/Command/ExportTableCommand.php
@@ -271,7 +271,7 @@ protected function exportTable(SymfonyStyle $io): void
                                         )
                                     )
                             )
-                            ->execute();
+                            ->executeQuery();
                         $usergroupsTitles = [];
                         foreach ($usergroups as $singleUserGroup) {
                             $usergroupsTitles[] = $singleUserGroup['title'];

diff --git a/Classes/Command/ImportTableCommand.php b/Classes/Command/ImportTableCommand.php
@@ -146,7 +146,7 @@ protected function importData(SymfonyStyle $io): void
                             )
                         );
                     }
-                    $row = $row->where(...$whereClause)->execute()->fetch();
+                    $row = $row->where(...$whereClause)->executeQuery()->fetchAssociative();
                 }
                 if ($row) {
                     // Update row as the matched row exists in the table