ilECSUpdateSteps9.php

Go to the documentation of this file.

<?php

declare(strict_types=1);

class ilECSUpdateSteps9 implements ilDatabaseUpdateSteps
{
    protected ilDBInterface $db;

    private function ensure_index_exists(string $table, array $fields, string $name): void
    {
        if (!$this->db->indexExistsByFields($table, $fields)) {
            $this->db->addIndex($table, $fields, $name);
        }
    }

    private function ensure_indices_exist(): void
    {
        $this->ensure_index_exists('ecs_course_assignments', ['obj_id'], 'i1');
        $this->ensure_index_exists('ecs_import', ['obj_id'], 'i1');
        $this->ensure_index_exists('ecs_import', ['sub_id'], 'i2');
    }

    private function fix_duplicate_import_types(string $types): string
    {
        $pattern = '/^(a:\d+:\{.*\})\1+$/s';
        return (preg_match($pattern, $types, $matches)) ? $matches[1] : $types;
    }

    public function prepare(ilDBInterface $db): void
    {
        $this->db = $db;
    }

    public function step_1(): void
    {
        $this->ensure_indices_exist();
        $this->db->manipulate('UPDATE `ecs_course_assignments` inner join ecs_import on ecs_course_assignments.obj_id = ecs_import.obj_id SET ecs_course_assignments.`cms_sub_id`=ecs_import.sub_id WHERE ecs_import.sub_id is null;');
    }

    public function step_2(): void
    {
        $this->ensure_indices_exist();
    }

    public function step_3(): void
    {
        $query = 'SELECT sid, mid, import_types FROM ecs_part_settings';
        $rows = $this->db->query($query);
        while ($row = $rows->fetchRow(ilDBConstants::FETCHMODE_OBJECT)) {
            $fixed = $this->fix_duplicate_import_types($row->import_types);
            if ($row->import_types !== $fixed) {
                $update_query = 'UPDATE ecs_part_settings SET ' .
                    'import_types = ' . $this->db->quote($fixed, ilDBConstants::T_TEXT) . ' ' .
                    'WHERE sid = ' . $row->sid . ' ' .
                    'AND mid  = ' . $row->mid;
                $this->db->manipulate($update_query);
            }
        }
    }
}