dbi = $dbi; } /** * @param TableName[] $tables * * @return array|string> * @psalm-return array{array, string} */ public function getAnalyzeTableRows(DatabaseName $db, array $tables): array { $backQuotedTables = []; foreach ($tables as $table) { $backQuotedTables[] = Util::backquote($table->getName()); } $query = 'ANALYZE TABLE ' . implode(', ', $backQuotedTables) . ';'; $this->dbi->selectDb($db); /** @var array> $result */ $result = $this->dbi->fetchResult($query); $rows = []; foreach ($result as $row) { $message = Message::fromArray($row); $rows[$message->table][] = $message; } return [$rows, $query]; } /** * @param TableName[] $tables * * @return array|string> * @psalm-return array{array, string} */ public function getCheckTableRows(DatabaseName $db, array $tables): array { $backQuotedTables = []; foreach ($tables as $table) { $backQuotedTables[] = Util::backquote($table->getName()); } $query = 'CHECK TABLE ' . implode(', ', $backQuotedTables) . ';'; $this->dbi->selectDb($db); /** @var array> $result */ $result = $this->dbi->fetchResult($query); $rows = []; foreach ($result as $row) { $message = Message::fromArray($row); $rows[$message->table][] = $message; } return [$rows, $query]; } /** * @param TableName[] $tables * * @return array>>|string> * @psalm-return array{array>, string, Warning[]} */ public function getChecksumTableRows(DatabaseName $db, array $tables): array { $backQuotedTables = []; foreach ($tables as $table) { $backQuotedTables[] = Util::backquote($table->getName()); } $query = 'CHECKSUM TABLE ' . implode(', ', $backQuotedTables) . ';'; $this->dbi->selectDb($db); /** @var array> $rows */ $rows = $this->dbi->fetchResult($query); $warnings = $this->dbi->getWarnings(); return [$rows, $query, $warnings]; } /** * @param TableName[] $tables */ public function getIndexesProblems(DatabaseName $db, array $tables): string { $indexesProblems = ''; foreach ($tables as $table) { $check = Index::findDuplicates($table->getName(), $db->getName()); if (empty($check)) { continue; } $indexesProblems .= sprintf(__('Problems with indexes of table `%s`'), $table->getName()); $indexesProblems .= $check; } return $indexesProblems; } /** * @param TableName[] $tables * * @return array|string> * @psalm-return array{array, string} */ public function getOptimizeTableRows(DatabaseName $db, array $tables): array { $backQuotedTables = []; foreach ($tables as $table) { $backQuotedTables[] = Util::backquote($table->getName()); } $query = 'OPTIMIZE TABLE ' . implode(', ', $backQuotedTables) . ';'; $this->dbi->selectDb($db); /** @var array> $result */ $result = $this->dbi->fetchResult($query); $rows = []; foreach ($result as $row) { $message = Message::fromArray($row); $rows[$message->table][] = $message; } return [$rows, $query]; } /** * @param TableName[] $tables * * @return array|string> * @psalm-return array{array, string} */ public function getRepairTableRows(DatabaseName $db, array $tables): array { $backQuotedTables = []; foreach ($tables as $table) { $backQuotedTables[] = Util::backquote($table->getName()); } $query = 'REPAIR TABLE ' . implode(', ', $backQuotedTables) . ';'; $this->dbi->selectDb($db); /** @var array> $result */ $result = $this->dbi->fetchResult($query); $rows = []; foreach ($result as $row) { $message = Message::fromArray($row); $rows[$message->table][] = $message; } return [$rows, $query]; } }