@noinspection AutoloadingIssuesInspection More...

Inheritance diagram for ilDataCollectionStorageMigration:

Collaboration diagram for ilDataCollectionStorageMigration:

Public Member Functions
	getLabel ()
	@inheritDoc More...

	getDefaultAmountOfStepsPerRun ()
	@inheritDoc More...

	getPreconditions (\ILIAS\Setup\Environment $environment)
	@inheritDoc More...

	prepare (\ILIAS\Setup\Environment $environment)
	@inheritDoc More...

	step (\ILIAS\Setup\Environment $environment)
	@inheritDoc More...

	getRemainingAmountOfSteps ()
	@inheritDoc More...

Public Member Functions inherited from ILIAS\Setup\Migration
	getLabel ()

	getDefaultAmountOfStepsPerRun ()
	Tell the default amount of steps to be executed for one run of the migration. More...

	getPreconditions (Environment $environment)
	Objectives the migration depend on. More...

	prepare (Environment $environment)
	Prepare the migration by means of some environment. More...

	step (Environment $environment)
	Run one step of the migration. More...

	getRemainingAmountOfSteps ()
	Count up how many "things" need to be migrated. More...

Data Fields
const	DEFAULT_AMOUNT_OF_STEPS = 10000

Data Fields inherited from ILIAS\Setup\Migration
const	INFINITE = -1

Protected Attributes
ilResourceStorageMigrationHelper	$helper

Detailed Description

@noinspection AutoloadingIssuesInspection

Definition at line 26 of file class.ilDataCollectionStorageMigration.php.

Member Function Documentation

◆ getDefaultAmountOfStepsPerRun()

ilDataCollectionStorageMigration::getDefaultAmountOfStepsPerRun ( )

@inheritDoc

Implements ILIAS\Setup\Migration.

Definition at line 43 of file class.ilDataCollectionStorageMigration.php.

                                                   : int
    {
        return self::DEFAULT_AMOUNT_OF_STEPS;
    }

References DEFAULT_AMOUNT_OF_STEPS.

◆ getLabel()

ilDataCollectionStorageMigration::getLabel ( )

@inheritDoc

Implements ILIAS\Setup\Migration.

Definition at line 35 of file class.ilDataCollectionStorageMigration.php.

                              : string
    {
        return "Migration of DataCollection files to the Resource Storage Service.";
    }

◆ getPreconditions()

ilDataCollectionStorageMigration::getPreconditions ( \ILIAS\Setup\Environment $environment )

@inheritDoc

Definition at line 51 of file class.ilDataCollectionStorageMigration.php.

                                                                           : array
    {
        return ilResourceStorageMigrationHelper::getPreconditions();
    }

References ilResourceStorageMigrationHelper\getPreconditions().

Here is the call graph for this function:

◆ getRemainingAmountOfSteps()

ilDataCollectionStorageMigration::getRemainingAmountOfSteps ( )

@inheritDoc

Implements ILIAS\Setup\Migration.

Definition at line 162 of file class.ilDataCollectionStorageMigration.php.

                                               : int
    {
        $legacy_file_field_amount = $this->helper->getDatabase()->fetchObject(
            $this->helper->getDatabase()->query(
                "SELECT COUNT(field.id) AS amount FROM il_dcl_field AS field WHERE field.datatype_id = 6;"
            )
        );
 
        return (int) $legacy_file_field_amount?->amount;
    }

◆ prepare()

ilDataCollectionStorageMigration::prepare ( \ILIAS\Setup\Environment $environment )

@inheritDoc

Definition at line 59 of file class.ilDataCollectionStorageMigration.php.

                                                                  : void
    {
        $this->helper = new ilResourceStorageMigrationHelper(
            new ilDataCollectionStakeholder(),
            $environment
        );
    }

◆ step()

ilDataCollectionStorageMigration::step ( \ILIAS\Setup\Environment $environment )

@inheritDoc

Definition at line 70 of file class.ilDataCollectionStorageMigration.php.

                                                               : void
    {
        $integer_storage = "il_dcl_stloc2_value";
        $string_storage = "il_dcl_stloc1_value";
        $db = $this->helper->getDatabase();
 
        // Find next field with a fileupload datatype.
 
        $legacy_file_field = $db->fetchObject(
            $db->query(
                "SELECT * FROM il_dcl_field AS field WHERE datatype_id = 6 LIMIT 1;"
            )
        );
 
        // Loop through all records of the field.
        $legacy_file_records = $db->queryF(
            "SELECT * FROM il_dcl_record_field AS record_field WHERE record_field.field_id = %s;",
            ['integer'],
            [$legacy_file_field->id]
        );
        while ($record = $db->fetchObject($legacy_file_records)) {
            // Get the file id from the storage.
            $legacy_file_record = $db->fetchObject(
                $db->queryF(
                    "SELECT id, rid, file_id, record_field_id 
                    FROM $integer_storage AS storage 
                    JOIN file_data AS file ON file.file_id = storage.value
                    WHERE storage.record_field_id = %s;",
                    ['integer'],
                    [$record->id]
                )
            );
            if ($legacy_file_record === null) {
                continue;
            }
            // Store RID as new value in string storage.
            $rid = $legacy_file_record->rid ?? null;
 
            $db->insert($string_storage, [
                'id' => ['integer', $db->nextId($string_storage)],
                'record_field_id' => ['integer', (int) $legacy_file_record->record_field_id],
                'value' => ['text', $rid],
            ]);
 
            // Remove file_id from integer storage.
            $db->manipulateF(
                "DELETE FROM $integer_storage WHERE id = %s;",
                ['integer'],
                [(int) $legacy_file_record->id]
            );
 
            // Switch Stakeholder
            $this->helper->moveResourceToNewStakeholderAndOwner(
                new ResourceIdentification($rid),
                new ilObjFileStakeholder(),
                $this->helper->getStakeholder()
            );
 
            // Delete File-object
            try {
                $file_id = (int) $legacy_file_record->file_id;
                $db->manipulateF(
                    "DELETE FROM file_data WHERE file_id = %s",
                    ['integer'],
                    [$file_id]
                );
                $db->manipulateF(
                    "DELETE FROM history WHERE obj_id = %s",
                    ['integer'],
                    [(int) $legacy_file_record->id]
                );
                $db->manipulateF(
                    "DELETE FROM object_data WHERE obj_id = %s AND type = %s",
                    ['integer', 'text'],
                    [(int) $legacy_file_record->id, 'file']
                );
            } catch (Exception) {
                continue;
            }
        }
 
        // update datatype of legacy entry, so it now reads from string-storage.
        $db->update("il_dcl_field", [
            'datatype_id' => ['integer', ilDclDatatype::INPUTFORMAT_FILE],
        ], [
            'id' => ['integer', (int) $legacy_file_field->id],
        ]);
    }