InitialDatabaseSchemaUpdate.php

Go to the documentation of this file.

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

class InitialDatabaseSchemaUpdate extends AbstractDatabaseSchemaUpdate {

    public function __construct() {
        parent::__construct();
        $this->title = 'Update database schema: Create tables and fields';
    }

    public function checkForUpdate(&$description) {
        $description = 'There are tables or fields in the database which need to be created.<br /><br />' .
        'You have to run this update wizard before you can run any other update wizard to make sure all needed tables and fields are present.';

        $databaseDifferences = $this->getDatabaseDifferences();
        $updateSuggestions = $this->schemaMigrationService->getUpdateSuggestions($databaseDifferences);

        return isset($updateSuggestions['create_table']) || isset($updateSuggestions['add']);
    }

    public function getUserInput($inputPrefix) {
        $result = '';

        $databaseDifferences = $this->getDatabaseDifferences();
        $updateSuggestions = $this->schemaMigrationService->getUpdateSuggestions($databaseDifferences);

        if (isset($updateSuggestions['create_table'])) {
            $list = '
                <p>
                    Add the following tables:
                </p>
                <fieldset>
                    <ol class="t3-install-form-label-after">%s</ol>
                </fieldset>';
            $item = '
                <li class="labelAfter">
                    <label><strong>%1$s</strong></label>
                </li>';

            $items = array();
            foreach ($databaseDifferences['extra'] as $tableName => $difference) {
                if ($difference['whole_table'] == 1) {
                    $items[] = sprintf($item, $tableName);
                }
            }
            $result .= sprintf($list, implode('', $items));
        }

        if (isset($updateSuggestions['add'])) {
            $fieldsList = '
                <p>
                    Add the following fields to tables:
                </p>
                <fieldset>
                    <ol class="t3-install-form-label-after">%s</ol>
                </fieldset>';
            $keysList = '
                <p>
                    Add the following keys to tables:
                </p>
                <fieldset>
                    <ol class="t3-install-form-label-after">%s</ol>
                </fieldset>';
            $item = '
                <li class="labelAfter">
                    <label><strong>%1$s</strong>: %2$s</label>
                </li>';

            $fieldItems = array();
            $keyItems = array();
            foreach ($databaseDifferences['extra'] as $tableName => $difference) {
                if ($difference['whole_table'] != 1) {
                    if ($difference['fields']) {
                        $fieldNames = array();
                        foreach ($difference['fields'] as $fieldName => $sql) {
                            $fieldNames[] = $fieldName;
                        }
                        $fieldItems[] = sprintf($item, $tableName, implode(', ', $fieldNames));
                    }
                    if ($difference['keys']) {
                        $keyNames = array();
                        foreach ($difference['keys'] as $keyName => $sql) {
                            $keyNames[] = $keyName;
                        }
                        $keyItems[] = sprintf($item, $tableName, implode(', ', $keyNames));
                    }
                }
            }
            if (!empty($fieldItems)) {
                $result .= sprintf($fieldsList, implode('', $fieldItems));
            }
            if (!empty($keyItems)) {
                $result .= sprintf($keysList, implode('', $keyItems));
            }
        }

        return $result;
    }


    public function performUpdate(array &$dbQueries, &$customMessages) {

        // First perform all add update statements to database
        $databaseDifferences = $this->getDatabaseDifferences();
        $updateStatements = $this->schemaMigrationService->getUpdateSuggestions($databaseDifferences);

        foreach ((array)$updateStatements['create_table'] as $query) {
            $GLOBALS['TYPO3_DB']->admin_query($query);
            $dbQueries[] = $query;
            if ($GLOBALS['TYPO3_DB']->sql_error()) {
                $customMessages = 'SQL-ERROR: ' . htmlspecialchars($GLOBALS['TYPO3_DB']->sql_error());
                return FALSE;
            }
        }

        foreach ((array)$updateStatements['add'] as $query) {
            $GLOBALS['TYPO3_DB']->admin_query($query);
            $dbQueries[] = $query;
            if ($GLOBALS['TYPO3_DB']->sql_error()) {
                $customMessages = 'SQL-ERROR: ' . htmlspecialchars($GLOBALS['TYPO3_DB']->sql_error());
                return FALSE;
            }
        }

        return TRUE;
    }
}