9.5/_extension_manager_tables_8php_source.html

<?php

namespace ‪TYPO3\CMS\Install\Updates;


/*

 * This file is part of the TYPO3 CMS project.

 *

 * It is free software; you can redistribute it and/or modify it under

 * the terms of the GNU General Public License, either version 2

 * of the License, or any later version.

 *

 * For the full copyright and license information, please read the

 * LICENSE.txt file that was distributed with this source code.

 *

 * The TYPO3 project - inspiring people to share!

 */


use ‪TYPO3\CMS\Core\Database\ConnectionPool;

use ‪TYPO3\CMS\Core\Database\Schema\SchemaMigrator;

use ‪TYPO3\CMS\Core\Database\Schema\SqlReader;

use ‪TYPO3\CMS\Core\Utility\ExtensionManagementUtility;

use ‪TYPO3\CMS\Core\Utility\GeneralUtility;


class ‪ExtensionManagerTables implements ‪UpgradeWizardInterface, ‪RepeatableInterface

{

    public function ‪getIdentifier(): string

    {

        return 'extensionManagerTables';

    }


    public function ‪getTitle(): string

    {

        return 'Add the default Extension Manager database tables';

    }


    public function ‪getDescription(): string

    {

        return 'Creates necessary database tables and adds static data for the Extension Manager.';

    }


    public function ‪updateNecessary(): bool

    {

        $result = false;

        // First check necessary database update

        $updateStatements = array_filter($this->‪getUpdateStatements());

        if (count($updateStatements) === 0) {

            // Get count of rows in repository database table

            $count = GeneralUtility::makeInstance(ConnectionPool::class)

                ->getConnectionForTable('tx_extensionmanager_domain_model_repository')

                ->count('*', 'tx_extensionmanager_domain_model_repository', []);


            if ($count === 0) {

                $result = true;

            }

        } else {

            $result = true;

        }

        return $result;

    }


    public function ‪getPrerequisites(): array

    {

        return [

            DatabaseUpdatedPrerequisite::class

        ];

    }


    public function ‪executeUpdate(): bool

    {

        $result = true;


        $sqlReader = GeneralUtility::makeInstance(SqlReader::class);

        $createTableStatements = $this->‪getTableStatements();


        // First perform all create, add and change queries

        $schemaMigrationService = GeneralUtility::makeInstance(SchemaMigrator::class);

        $schemaMigrationService->install($createTableStatements);


        // Perform import of static data

        $rawDefinitions = file_get_contents(

            ‪ExtensionManagementUtility::extPath('extensionmanager', 'ext_tables_static+adt.sql')

        );


        $insertStatements = $sqlReader->getInsertStatementArray($rawDefinitions);

        $schemaMigrationService->importStaticData($insertStatements);


        return $result;

    }


    protected function ‪getUpdateStatements()

    {

        $updateStatements = [];

        $emTableStatements = $this->‪getTableStatements();

        if (count($emTableStatements)) {

            $schemaMigrationService = GeneralUtility::makeInstance(SchemaMigrator::class);

            $updateSuggestions = $schemaMigrationService->getUpdateSuggestions($emTableStatements);

            $updateStatements = array_merge_recursive(...array_values($updateSuggestions));

        }

        return $updateStatements;

    }


    protected function ‪getTableStatements(): array

    {

        $rawDefinitions = file_get_contents(‪ExtensionManagementUtility::extPath('extensionmanager', 'ext_tables.sql'));

        $sqlReader = GeneralUtility::makeInstance(SqlReader::class);

        return $sqlReader->getCreateTableStatementArray($rawDefinitions);

    }

}