DatabaseSelect.php

Go to the documentation of this file.

<?php
namespace TYPO3\CMS\Install\Controller\Action\Step;

class DatabaseSelect extends AbstractStepAction {

    protected $databaseConnection = NULL;

    public function execute() {
        $result = array();
        $this->initializeDatabaseConnection();
        $postValues = $this->postValues['values'];
        $localConfigurationPathValuePairs = array();
        $configurationManager = $this->objectManager->get('TYPO3\\CMS\\Core\\Configuration\\ConfigurationManager');
        if ($postValues['type'] === 'new') {
            $newDatabaseName = $postValues['new'];
            if (strlen($newDatabaseName) <= 50) {
                $createDatabaseResult = $this->databaseConnection->admin_query('CREATE DATABASE ' . $newDatabaseName . ' CHARACTER SET utf8');
                if ($createDatabaseResult) {
                    $localConfigurationPathValuePairs['DB/database'] = $newDatabaseName;
                } else {
                    $errorStatus = $this->objectManager->get('TYPO3\\CMS\\Install\\Status\\ErrorStatus');
                    $errorStatus->setTitle('Unable to create database');
                    $errorStatus->setMessage(
                        'Database with name ' . $newDatabaseName . ' could not be created.' .
                        ' Either your database name contains special chars (only alphanumeric characters are allowed)' .
                        ' or your database user probably does not have sufficient permissions to create it.' .
                        ' Please choose an existing (empty) database or contact administration.'
                    );
                    $result[] = $errorStatus;
                }
            } else {
                $errorStatus = $this->objectManager->get('TYPO3\\CMS\\Install\\Status\\ErrorStatus');
                $errorStatus->setTitle('Database name not valid');
                $errorStatus->setMessage('Given database name must be shorter than fifty characters.');
                $result[] = $errorStatus;
            }
        } elseif ($postValues['type'] === 'existing' && !empty($postValues['existing'])) {
            // Only store database information when it's empty
            $this->databaseConnection->setDatabaseName($postValues['existing']);
            $this->databaseConnection->sql_select_db();
            $existingTables = $this->databaseConnection->admin_get_tables();
            $isInitialInstallation = $configurationManager->getConfigurationValueByPath('SYS/isInitialInstallationInProgress');
            if (!$isInitialInstallation || count($existingTables) === 0) {
                $localConfigurationPathValuePairs['DB/database'] = $postValues['existing'];
            }
        } else {
            $errorStatus = $this->objectManager->get('TYPO3\\CMS\\Install\\Status\\ErrorStatus');
            $errorStatus->setTitle('No Database selected');
            $errorStatus->setMessage('You must select a database.');
            $result[] = $errorStatus;
        }

        if (!empty($localConfigurationPathValuePairs)) {
            $configurationManager->setLocalConfigurationValuesByPathValuePairs($localConfigurationPathValuePairs);
        }

        return $result;
    }

    public function needsExecution() {
        $this->initializeDatabaseConnection();
        $result = TRUE;
        if (strlen($GLOBALS['TYPO3_CONF_VARS']['DB']['database']) > 0) {
            $this->databaseConnection->setDatabaseName($GLOBALS['TYPO3_CONF_VARS']['DB']['database']);
            try {
                $selectResult = $this->databaseConnection->sql_select_db();
                if ($selectResult === TRUE) {
                    $result = FALSE;
                }
            } catch (\RuntimeException $e) {
            }
        }
        return $result;
    }

    protected function executeAction() {
        $configurationManager = $this->objectManager->get('TYPO3\\CMS\\Core\\Configuration\\ConfigurationManager');
        $isInitialInstallationInProgress = $configurationManager->getConfigurationValueByPath('SYS/isInitialInstallationInProgress');
        $this->view->assign('databaseList', $this->getDatabaseList($isInitialInstallationInProgress));
        $this->view->assign('isInitialInstallationInProgress', $isInitialInstallationInProgress);
        $this->assignSteps();
        return $this->view->render();
    }

    protected function getDatabaseList($initialInstallation) {
        $this->initializeDatabaseConnection();
        $databaseArray = $this->databaseConnection->admin_get_dbs();
        // Remove mysql organizational tables from database list
        $reservedDatabaseNames = array('mysql', 'information_schema', 'performance_schema');
        $allPossibleDatabases = array_diff($databaseArray, $reservedDatabaseNames);

        // If we are upgrading we show *all* databases the user has access to
        if ($initialInstallation === FALSE) {
            return $allPossibleDatabases;
        } else {
            // In first installation we show all databases but disable not empty ones (with tables)
            $databases = array();
            foreach ($allPossibleDatabases as $database) {
                $this->databaseConnection->setDatabaseName($database);
                $this->databaseConnection->sql_select_db();
                $existingTables = $this->databaseConnection->admin_get_tables();
                $databases[] = array(
                    'name' => $database,
                    'tables' => count($existingTables),
                );
            }
            return $databases;
        }
    }

    protected function initializeDatabaseConnection() {
        $this->databaseConnection = $this->objectManager->get('TYPO3\\CMS\\Core\\Database\\DatabaseConnection');
        $this->databaseConnection->setDatabaseUsername($GLOBALS['TYPO3_CONF_VARS']['DB']['username']);
        $this->databaseConnection->setDatabasePassword($GLOBALS['TYPO3_CONF_VARS']['DB']['password']);
        $this->databaseConnection->setDatabaseHost($GLOBALS['TYPO3_CONF_VARS']['DB']['host']);
        $this->databaseConnection->setDatabasePort($GLOBALS['TYPO3_CONF_VARS']['DB']['port']);
        $this->databaseConnection->setDatabaseSocket($GLOBALS['TYPO3_CONF_VARS']['DB']['socket']);
        $this->databaseConnection->sql_pconnect();
    }
}