ExtensionManagerTables.php

Go to the documentation of this file.

<?php
namespace TYPO3\CMS\Install\Updates;

class ExtensionManagerTables extends AbstractUpdate {

    protected $title = 'Add the default Extension Manager database tables';

    protected $installToolSqlParser = NULL;

    protected function getInstallToolSqlParser() {
        if ($this->installToolSqlParser === NULL) {
            $this->installToolSqlParser = \TYPO3\CMS\Core\Utility\GeneralUtility::makeInstance('TYPO3\\CMS\\Install\\Service\\SqlSchemaMigrationService');
        }

        return $this->installToolSqlParser;
    }

    protected function getUpdateStatements() {
        $updateStatements = array();

        // Get all necessary statements for ext_tables.sql file
        $rawDefinitions = \TYPO3\CMS\Core\Utility\GeneralUtility::getUrl(\TYPO3\CMS\Core\Utility\ExtensionManagementUtility::extPath('extensionmanager') . '/ext_tables.sql');
        $fieldDefinitionsFromFile = $this->getInstallToolSqlParser()->getFieldDefinitions_fileContent($rawDefinitions);
        if (count($fieldDefinitionsFromFile)) {
            $fieldDefinitionsFromCurrentDatabase = $this->getInstallToolSqlParser()->getFieldDefinitions_database();
            $diff = $this->getInstallToolSqlParser()->getDatabaseExtra($fieldDefinitionsFromFile, $fieldDefinitionsFromCurrentDatabase);
            $updateStatements = $this->getInstallToolSqlParser()->getUpdateSuggestions($diff);
        }

        return $updateStatements;
    }

    public function checkForUpdate(&$description) {
        $result = FALSE;
        $description = 'Creates necessary database tables and adds static tables for the new Extension Manager.';

        // First check necessary database update
        $updateStatements = $this->getUpdateStatements();
        if (empty($updateStatements)) {
            // Check for repository database table
            $databaseTables = $GLOBALS['TYPO3_DB']->admin_get_tables();
            if (!isset($databaseTables['tx_extensionmanager_domain_model_repository'])) {
                $result = TRUE;
            } else {
                // Get count of rows in repository database table
                $count = $GLOBALS['TYPO3_DB']->exec_SELECTcountRows('*', 'tx_extensionmanager_domain_model_repository');
                if ($count === 0) {
                    $result = TRUE;
                }
            }
        } else {
            $result = TRUE;
        }

        return $result;
    }

    protected function hasError(&$customMessages) {
        $result = FALSE;
        if ($GLOBALS['TYPO3_DB']->sql_error()) {
            $customMessages .= '<br /><br />SQL-ERROR: ' . htmlspecialchars($GLOBALS['TYPO3_DB']->sql_error());
            $result = TRUE;
        }

        return $result;
    }

    public function performUpdate(array &$dbQueries, &$customMessages) {
        $result = FALSE;

        // First perform all create, add and change queries
        $updateStatements = $this->getUpdateStatements();
        foreach ((array) $updateStatements['add'] as $string) {
            $GLOBALS['TYPO3_DB']->admin_query($string);
            $dbQueries[] = $string;
            $result = ($result || $this->hasError($customMessages));
        }
        foreach ((array) $updateStatements['change'] as $string) {
            $GLOBALS['TYPO3_DB']->admin_query($string);
            $dbQueries[] = $string;
            $result = ($result || $this->hasError($customMessages));
        }
        foreach ((array) $updateStatements['create_table'] as $string) {
            $GLOBALS['TYPO3_DB']->admin_query($string);
            $dbQueries[] = $string;
            $result = ($result || $this->hasError($customMessages));
        }

        // Perform statis import anyway
        $rawDefinitions = \TYPO3\CMS\Core\Utility\GeneralUtility::getUrl(\TYPO3\CMS\Core\Utility\ExtensionManagementUtility::extPath('extensionmanager') . 'ext_tables_static+adt.sql');
        $statements = $this->getInstallToolSqlParser()->getStatementarray($rawDefinitions, 1);
        foreach ($statements as $statement) {
            if (trim($statement) !== '') {
                $GLOBALS['TYPO3_DB']->admin_query($statement);
                $dbQueries[] = $statement;
                $result = ($result || $this->hasError($customMessages));
            }
        }

        return !$result;
    }

}