class.ilMysqlMyIsamToInnoDbMigration.php

Go to the documentation of this file.

<?php
 
namespace ILIAS\Setup;
 
use ilDatabaseInitializedObjective;
use ilDatabaseUpdatedObjective;
use ilDBConstants;
use ilException;
use ilIniFilesLoadedObjective;
 
class ilMysqlMyIsamToInnoDbMigration implements Migration
{
    protected ?string $db_name = null;
    protected ?\ilDBInterface $database = null;
 
    public function getLabel(): string
    {
        return "Migration to convert tables from MyISAM to Innodb service";
    }
 
    public function getDefaultAmountOfStepsPerRun(): int
    {
        return 20;
    }
 
    public function getPreconditions(Environment $environment): array
    {
        return [
            new ilIniFilesLoadedObjective(),
            new ilDatabaseInitializedObjective(),
            new ilDatabaseUpdatedObjective()
        ];
    }
 
    public function prepare(Environment $environment): void
    {
        $this->database = $environment->getResource(Environment::RESOURCE_DATABASE);
        $client_ini = $environment->getResource(Environment::RESOURCE_CLIENT_INI);
        $this->db_name = $client_ini->readVariable('db', 'name');
    }
 
    public function step(Environment $environment): void
    {
        $rows = $this->getNonInnoDBTables();
        $table_name = array_pop($rows);
 
        if (is_string($table_name) && $table_name !== '') {
            try {
                $this->database->migrateTableToEngine($table_name);
            } catch (\ilDatabaseException $e) {
                throw new UnachievableException(
                    "The migration of the following tables did throw errors, " .
                    "please resolve the problem before you continue: \n" . $table_name . " -> " . $e->getMessage()
                );
            }
        }
    }
 
    public function getRemainingAmountOfSteps(): int
    {
        if ($this->db_name !== null) {
            $rows = $this->getNonInnoDBTables();
            return count($rows);
        }
        return 0;
    }
 
    protected function getNonInnoDBTables(): array
    {
        $tables = [];
        $set = $this->database->queryF("SELECT table_name
                FROM INFORMATION_SCHEMA.TABLES
                WHERE ENGINE != %s AND table_schema = %s;", ['text', 'text'], [
            ilDBConstants::MYSQL_ENGINE_INNODB,
            $this->db_name
        ]);
        while ($row = $this->database->fetchAssoc($set)) {
            $tables[] = $row['table_name'];
        }
        return $tables;
    }
}