path: root/libraries/classes/Controllers/Import/ImportController.php

<?php

declare(strict_types=1);

namespace PhpMyAdmin\Controllers\Import;

use PhpMyAdmin\Bookmark;
use PhpMyAdmin\ConfigStorage\Relation;
use PhpMyAdmin\Controllers\AbstractController;
use PhpMyAdmin\Core;
use PhpMyAdmin\DatabaseInterface;
use PhpMyAdmin\Dbal\DatabaseName;
use PhpMyAdmin\Encoding;
use PhpMyAdmin\File;
use PhpMyAdmin\Html\Generator;
use PhpMyAdmin\Http\ServerRequest;
use PhpMyAdmin\Import;
use PhpMyAdmin\Message;
use PhpMyAdmin\ParseAnalyze;
use PhpMyAdmin\Plugins;
use PhpMyAdmin\Plugins\ImportPlugin;
use PhpMyAdmin\ResponseRenderer;
use PhpMyAdmin\Sql;
use PhpMyAdmin\Template;
use PhpMyAdmin\Url;
use PhpMyAdmin\Util;
use PhpMyAdmin\Utils\ForeignKey;
use Throwable;

use function __;
use function _ngettext;
use function in_array;
use function ini_get;
use function ini_set;
use function intval;
use function is_array;
use function is_link;
use function is_numeric;
use function is_string;
use function is_uploaded_file;
use function mb_strlen;
use function mb_strtolower;
use function preg_match;
use function preg_quote;
use function preg_replace;
use function strlen;
use function substr;
use function time;
use function trim;

final class ImportController extends AbstractController
{
    /** @var Import */
    private $import;

    /** @var Sql */
    private $sql;

    /** @var DatabaseInterface */
    private $dbi;

    public function __construct(
        ResponseRenderer $response,
        Template $template,
        Import $import,
        Sql $sql,
        DatabaseInterface $dbi
    ) {
        parent::__construct($response, $template);
        $this->import = $import;
        $this->sql = $sql;
        $this->dbi = $dbi;
    }

    public function __invoke(ServerRequest $request): void
    {
        $GLOBALS['collation_connection'] = $GLOBALS['collation_connection'] ?? null;
        $GLOBALS['goto'] = $GLOBALS['goto'] ?? null;
        $GLOBALS['display_query'] = $GLOBALS['display_query'] ?? null;
        $GLOBALS['ajax_reload'] = $GLOBALS['ajax_reload'] ?? null;
        $GLOBALS['import_text'] = $GLOBALS['import_text'] ?? null;
        $GLOBALS['message'] = $GLOBALS['message'] ?? null;
        $GLOBALS['errorUrl'] = $GLOBALS['errorUrl'] ?? null;
        $GLOBALS['urlParams'] = $GLOBALS['urlParams'] ?? null;
        $GLOBALS['memory_limit'] = $GLOBALS['memory_limit'] ?? null;
        $GLOBALS['read_limit'] = $GLOBALS['read_limit'] ?? null;
        $GLOBALS['finished'] = $GLOBALS['finished'] ?? null;
        $GLOBALS['offset'] = $GLOBALS['offset'] ?? null;
        $GLOBALS['charset_conversion'] = $GLOBALS['charset_conversion'] ?? null;
        $GLOBALS['timestamp'] = $GLOBALS['timestamp'] ?? null;
        $GLOBALS['maximum_time'] = $GLOBALS['maximum_time'] ?? null;
        $GLOBALS['timeout_passed'] = $GLOBALS['timeout_passed'] ?? null;
        $GLOBALS['import_file'] = $GLOBALS['import_file'] ?? null;
        $GLOBALS['go_sql'] = $GLOBALS['go_sql'] ?? null;
        $GLOBALS['sql_file'] = $GLOBALS['sql_file'] ?? null;
        $GLOBALS['error'] = $GLOBALS['error'] ?? null;
        $GLOBALS['max_sql_len'] = $GLOBALS['max_sql_len'] ?? null;
        $GLOBALS['msg'] = $GLOBALS['msg'] ?? null;
        $GLOBALS['sql_query_disabled'] = $GLOBALS['sql_query_disabled'] ?? null;
        $GLOBALS['executed_queries'] = $GLOBALS['executed_queries'] ?? null;
        $GLOBALS['run_query'] = $GLOBALS['run_query'] ?? null;
        $GLOBALS['reset_charset'] = $GLOBALS['reset_charset'] ?? null;
        $GLOBALS['result'] = $GLOBALS['result'] ?? null;
        $GLOBALS['import_file_name'] = $GLOBALS['import_file_name'] ?? null;
        $GLOBALS['import_notice'] = $GLOBALS['import_notice'] ?? null;
        $GLOBALS['read_multiply'] = $GLOBALS['read_multiply'] ?? null;
        $GLOBALS['my_die'] = $GLOBALS['my_die'] ?? null;
        $GLOBALS['active_page'] = $GLOBALS['active_page'] ?? null;
        $GLOBALS['reload'] = $GLOBALS['reload'] ?? null;
        $GLOBALS['charset_connection'] = $GLOBALS['charset_connection'] ?? null;

        $GLOBALS['charset_of_file'] = $_POST['charset_of_file'] ?? null;
        $GLOBALS['format'] = $_POST['format'] ?? '';
        $GLOBALS['import_type'] = $_POST['import_type'] ?? null;
        $GLOBALS['is_js_confirmed'] = $_POST['is_js_confirmed'] ?? null;
        $GLOBALS['MAX_FILE_SIZE'] = $_POST['MAX_FILE_SIZE'] ?? null;
        $GLOBALS['message_to_show'] = $_POST['message_to_show'] ?? null;
        $GLOBALS['noplugin'] = $_POST['noplugin'] ?? null;
        $GLOBALS['skip_queries'] = $_POST['skip_queries'] ?? null;
        $GLOBALS['local_import_file'] = $_POST['local_import_file'] ?? null;
        $GLOBALS['show_as_php'] = $_POST['show_as_php'] ?? null;

        // reset import messages for ajax request
        $_SESSION['Import_message']['message'] = null;
        $_SESSION['Import_message']['go_back_url'] = null;
        // default values
        $GLOBALS['reload'] = false;

        // Use to identify current cycle is executing
        // a multiquery statement or stored routine
        if (! isset($_SESSION['is_multi_query'])) {
            $_SESSION['is_multi_query'] = false;
        }

        $GLOBALS['ajax_reload'] = [];
        $GLOBALS['import_text'] = '';
        // Are we just executing plain query or sql file?
        // (eg. non import, but query box/window run)
        if (! empty($GLOBALS['sql_query'])) {
            // apply values for parameters
            if (! empty($_POST['parameterized']) && ! empty($_POST['parameters']) && is_array($_POST['parameters'])) {
                $parameters = $_POST['parameters'];
                foreach ($parameters as $parameter => $replacement) {
                    $replacementValue = $this->dbi->escapeString($replacement);
                    if (! is_numeric($replacementValue)) {
                        $replacementValue = '\'' . $replacementValue . '\'';
                    }

                    $quoted = preg_quote($parameter, '/');
                    // making sure that :param does not apply values to :param1
                    $GLOBALS['sql_query'] = preg_replace(
                        '/' . $quoted . '([^a-zA-Z0-9_])/',
                        $replacementValue . '${1}',
                        $GLOBALS['sql_query']
                    );
                    // for parameters the appear at the end of the string
                    $GLOBALS['sql_query'] = preg_replace(
                        '/' . $quoted . '$/',
                        $replacementValue,
                        $GLOBALS['sql_query']
                    );
                }
            }

            // run SQL query
            $GLOBALS['import_text'] = $GLOBALS['sql_query'];
            $GLOBALS['import_type'] = 'query';
            $GLOBALS['format'] = 'sql';
            $_SESSION['sql_from_query_box'] = true;

            // If there is a request to ROLLBACK when finished.
            if (isset($_POST['rollback_query'])) {
                $this->import->handleRollbackRequest($GLOBALS['import_text']);
            }

            // refresh navigation and main panels
            if (preg_match('/^(DROP)\s+(VIEW|TABLE|DATABASE|SCHEMA)\s+/i', $GLOBALS['sql_query'])) {
                $GLOBALS['reload'] = true;
                $GLOBALS['ajax_reload']['reload'] = true;
            }

            // refresh navigation panel only
            if (preg_match('/^(CREATE|ALTER)\s+(VIEW|TABLE|DATABASE|SCHEMA)\s+/i', $GLOBALS['sql_query'])) {
                $GLOBALS['ajax_reload']['reload'] = true;
            }

            // do a dynamic reload if table is RENAMED
            // (by sending the instruction to the AJAX response handler)
            if (
                preg_match(
                    '/^RENAME\s+TABLE\s+(.*?)\s+TO\s+(.*?)($|;|\s)/i',
                    $GLOBALS['sql_query'],
                    $rename_table_names
                )
            ) {
                $GLOBALS['ajax_reload']['reload'] = true;
                $GLOBALS['ajax_reload']['table_name'] = Util::unQuote($rename_table_names[2]);
            }

            $GLOBALS['sql_query'] = '';
        } elseif (! empty($GLOBALS['sql_file'])) {
            // run uploaded SQL file
            $GLOBALS['import_file'] = $GLOBALS['sql_file'];
            $GLOBALS['import_type'] = 'queryfile';
            $GLOBALS['format'] = 'sql';
            unset($GLOBALS['sql_file']);
        } elseif (! empty($_POST['id_bookmark'])) {
            // run bookmark
            $GLOBALS['import_type'] = 'query';
            $GLOBALS['format'] = 'sql';
        }

        // If we didn't get any parameters, either user called this directly, or
        // upload limit has been reached, let's assume the second possibility.
        if ($_POST == [] && $_GET == []) {
            $GLOBALS['message'] = Message::error(
                __(
                    'You probably tried to upload a file that is too large. Please refer ' .
                    'to %sdocumentation%s for a workaround for this limit.'
                )
            );
            $GLOBALS['message']->addParam('[doc@faq1-16]');
            $GLOBALS['message']->addParam('[/doc]');

            // so we can obtain the message
            $_SESSION['Import_message']['message'] = $GLOBALS['message']->getDisplay();
            $_SESSION['Import_message']['go_back_url'] = $GLOBALS['goto'];

            $this->response->setRequestStatus(false);
            $this->response->addJSON('message', $GLOBALS['message']);

            return; // the footer is displayed automatically
        }

        // Add console message id to response output
        if (isset($_POST['console_message_id'])) {
            $this->response->addJSON('console_message_id', $_POST['console_message_id']);
        }

        /**
         * Sets globals from $_POST patterns, for import plugins
         * We only need to load the selected plugin
         */

        if (! in_array($GLOBALS['format'], ['csv', 'ldi', 'mediawiki', 'ods', 'shp', 'sql', 'xml'])) {
            // this should not happen for a normal user
            // but only during an attack
            $this->response->setRequestStatus(false);
            $this->response->addHTML(Message::error(__('Incorrect format parameter'))->getDisplay());

            return;
        }

        $post_patterns = [
            '/^force_file_/',
            '/^' . $GLOBALS['format'] . '_/',
        ];

        Core::setPostAsGlobal($post_patterns);

        $this->checkParameters(['import_type', 'format']);

        // We don't want anything special in format
        $GLOBALS['format'] = Core::securePath($GLOBALS['format']);

        if (strlen($GLOBALS['table']) > 0 && strlen($GLOBALS['db']) > 0) {
            $GLOBALS['urlParams'] = [
                'db' => $GLOBALS['db'],
                'table' => $GLOBALS['table'],
            ];
        } elseif (strlen($GLOBALS['db']) > 0) {
            $GLOBALS['urlParams'] = ['db' => $GLOBALS['db']];
        } else {
            $GLOBALS['urlParams'] = [];
        }

        // Create error and goto url
        if ($GLOBALS['import_type'] === 'table') {
            $GLOBALS['goto'] = Url::getFromRoute('/table/import');
        } elseif ($GLOBALS['import_type'] === 'database') {
            $GLOBALS['goto'] = Url::getFromRoute('/database/import');
        } elseif ($GLOBALS['import_type'] === 'server') {
            $GLOBALS['goto'] = Url::getFromRoute('/server/import');
        } elseif (empty($GLOBALS['goto']) || ! preg_match('@^index\.php$@i', $GLOBALS['goto'])) {
            if (strlen($GLOBALS['table']) > 0 && strlen($GLOBALS['db']) > 0) {
                $GLOBALS['goto'] = Url::getFromRoute('/table/structure');
            } elseif (strlen($GLOBALS['db']) > 0) {
                $GLOBALS['goto'] = Url::getFromRoute('/database/structure');
            } else {
                $GLOBALS['goto'] = Url::getFromRoute('/server/sql');
            }
        }

        $GLOBALS['errorUrl'] = $GLOBALS['goto'] . Url::getCommon($GLOBALS['urlParams'], '&');
        $_SESSION['Import_message']['go_back_url'] = $GLOBALS['errorUrl'];

        if (strlen($GLOBALS['db']) > 0) {
            $this->dbi->selectDb($GLOBALS['db']);
        }

        Util::setTimeLimit();
        if (! empty($GLOBALS['cfg']['MemoryLimit'])) {
            ini_set('memory_limit', $GLOBALS['cfg']['MemoryLimit']);
        }

        $GLOBALS['timestamp'] = time();
        if (isset($_POST['allow_interrupt'])) {
            $GLOBALS['maximum_time'] = ini_get('max_execution_time');
        } else {
            $GLOBALS['maximum_time'] = 0;
        }

        // set default values
        $GLOBALS['timeout_passed'] = false;
        $GLOBALS['error'] = false;
        $GLOBALS['read_multiply'] = 1;
        $GLOBALS['finished'] = false;
        $GLOBALS['offset'] = 0;
        $GLOBALS['max_sql_len'] = 0;
        $GLOBALS['sql_query'] = '';
        $GLOBALS['sql_query_disabled'] = false;
        $GLOBALS['go_sql'] = false;
        $GLOBALS['executed_queries'] = 0;
        $GLOBALS['run_query'] = true;
        $GLOBALS['charset_conversion'] = false;
        $GLOBALS['reset_charset'] = false;
        $GLOBALS['msg'] = 'Sorry an unexpected error happened!';

        $GLOBALS['result'] = false;

        // Bookmark Support: get a query back from bookmark if required
        if (! empty($_POST['id_bookmark'])) {
            $id_bookmark = (int) $_POST['id_bookmark'];
            switch ($_POST['action_bookmark']) {
                case 0: // bookmarked query that have to be run
                    $bookmark = Bookmark::get(
                        $this->dbi,
                        $GLOBALS['cfg']['Server']['user'],
                        DatabaseName::fromValue($GLOBALS['db']),
                        $id_bookmark,
                        'id',
                        isset($_POST['action_bookmark_all'])
                    );
                    if (! $bookmark instanceof Bookmark) {
                        break;
                    }

                    if (! empty($_POST['bookmark_variable'])) {
                        $GLOBALS['import_text'] = $bookmark->applyVariables($_POST['bookmark_variable']);
                    } else {
                        $GLOBALS['import_text'] = $bookmark->getQuery();
                    }

                    // refresh navigation and main panels
                    if (preg_match('/^(DROP)\s+(VIEW|TABLE|DATABASE|SCHEMA)\s+/i', $GLOBALS['import_text'])) {
                        $GLOBALS['reload'] = true;
                        $GLOBALS['ajax_reload']['reload'] = true;
                    }

                    // refresh navigation panel only
                    if (preg_match('/^(CREATE|ALTER)\s+(VIEW|TABLE|DATABASE|SCHEMA)\s+/i', $GLOBALS['import_text'])) {
                        $GLOBALS['ajax_reload']['reload'] = true;
                    }

                    break;
                case 1: // bookmarked query that have to be displayed
                    $bookmark = Bookmark::get(
                        $this->dbi,
                        $GLOBALS['cfg']['Server']['user'],
                        DatabaseName::fromValue($GLOBALS['db']),
                        $id_bookmark
                    );
                    if (! $bookmark instanceof Bookmark) {
                        break;
                    }

                    $GLOBALS['import_text'] = $bookmark->getQuery();
                    if ($this->response->isAjax()) {
                        $GLOBALS['message'] = Message::success(__('Showing bookmark'));
                        $this->response->setRequestStatus($GLOBALS['message']->isSuccess());
                        $this->response->addJSON('message', $GLOBALS['message']);
                        $this->response->addJSON('sql_query', $GLOBALS['import_text']);
                        $this->response->addJSON('action_bookmark', $_POST['action_bookmark']);

                        return;
                    } else {
                        $GLOBALS['run_query'] = false;
                    }

                    break;
                case 2: // bookmarked query that have to be deleted
                    $bookmark = Bookmark::get(
                        $this->dbi,
                        $GLOBALS['cfg']['Server']['user'],
                        DatabaseName::fromValue($GLOBALS['db']),
                        $id_bookmark
                    );
                    if (! $bookmark instanceof Bookmark) {
                        break;
                    }

                    $bookmark->delete();
                    if ($this->response->isAjax()) {
                        $GLOBALS['message'] = Message::success(
                            __('The bookmark has been deleted.')
                        );
                        $this->response->setRequestStatus($GLOBALS['message']->isSuccess());
                        $this->response->addJSON('message', $GLOBALS['message']);
                        $this->response->addJSON('action_bookmark', $_POST['action_bookmark']);
                        $this->response->addJSON('id_bookmark', $id_bookmark);

                        return;
                    } else {
                        $GLOBALS['run_query'] = false;
                        $GLOBALS['error'] = true; // this is kind of hack to skip processing the query
                    }

                    break;
            }
        }

        // Do no run query if we show PHP code
        if (isset($GLOBALS['show_as_php'])) {
            $GLOBALS['run_query'] = false;
            $GLOBALS['go_sql'] = true;
        }

        // We can not read all at once, otherwise we can run out of memory
        $GLOBALS['memory_limit'] = trim((string) ini_get('memory_limit'));
        // 2 MB as default
        if (empty($GLOBALS['memory_limit'])) {
            $GLOBALS['memory_limit'] = 2 * 1024 * 1024;
        }

        // In case no memory limit we work on 10MB chunks
        if ($GLOBALS['memory_limit'] === '-1') {
            $GLOBALS['memory_limit'] = 10 * 1024 * 1024;
        }

        // Calculate value of the limit
        $memoryUnit = mb_strtolower(substr((string) $GLOBALS['memory_limit'], -1));
        if ($memoryUnit === 'm') {
            $GLOBALS['memory_limit'] = (int) substr((string) $GLOBALS['memory_limit'], 0, -1) * 1024 * 1024;
        } elseif ($memoryUnit === 'k') {
            $GLOBALS['memory_limit'] = (int) substr((string) $GLOBALS['memory_limit'], 0, -1) * 1024;
        } elseif ($memoryUnit === 'g') {
            $GLOBALS['memory_limit'] = (int) substr((string) $GLOBALS['memory_limit'], 0, -1) * 1024 * 1024 * 1024;
        } else {
            $GLOBALS['memory_limit'] = (int) $GLOBALS['memory_limit'];
        }

        // Just to be sure, there might be lot of memory needed for uncompression
        $GLOBALS['read_limit'] = $GLOBALS['memory_limit'] / 8;

        // handle filenames
        if (
            isset($_FILES['import_file'])
            && is_array($_FILES['import_file'])
            && isset($_FILES['import_file']['name'], $_FILES['import_file']['tmp_name'])
            && is_string($_FILES['import_file']['name'])
            && is_string($_FILES['import_file']['tmp_name'])
        ) {
            $GLOBALS['import_file'] = $_FILES['import_file']['tmp_name'];
            $GLOBALS['import_file_name'] = $_FILES['import_file']['name'];
        }

        if (! empty($GLOBALS['local_import_file']) && ! empty($GLOBALS['cfg']['UploadDir'])) {
            // sanitize $local_import_file as it comes from a POST
            $GLOBALS['local_import_file'] = Core::securePath($GLOBALS['local_import_file']);

            $GLOBALS['import_file'] = Util::userDir((string) $GLOBALS['cfg']['UploadDir'])
                . $GLOBALS['local_import_file'];

            /**
             * Do not allow symlinks to avoid security issues
             * (user can create symlink to file they can not access,
             * but phpMyAdmin can).
             */
            if (@is_link($GLOBALS['import_file'])) {
                $GLOBALS['import_file'] = 'none';
            }
        } elseif (empty($GLOBALS['import_file']) || ! is_uploaded_file($GLOBALS['import_file'])) {
            $GLOBALS['import_file'] = 'none';
        }

        // Do we have file to import?

        if ($GLOBALS['import_file'] !== 'none' && ! $GLOBALS['error']) {
            /**
             *  Handle file compression
             */
            $importHandle = new File($GLOBALS['import_file']);
            $importHandle->checkUploadedFile();
            if ($importHandle->isError()) {
                /** @var Message $errorMessage */
                $errorMessage = $importHandle->getError();

                $importHandle->close();

                $_SESSION['Import_message']['message'] = $errorMessage->getDisplay();

                $this->response->setRequestStatus(false);
                $this->response->addJSON('message', $errorMessage->getDisplay());
                $this->response->addHTML($errorMessage->getDisplay());

                return;
            }

            $importHandle->setDecompressContent(true);
            $importHandle->open();
            if ($importHandle->isError()) {
                /** @var Message $errorMessage */
                $errorMessage = $importHandle->getError();

                $importHandle->close();

                $_SESSION['Import_message']['message'] = $errorMessage->getDisplay();

                $this->response->setRequestStatus(false);
                $this->response->addJSON('message', $errorMessage->getDisplay());
                $this->response->addHTML($errorMessage->getDisplay());

                return;
            }
        } elseif (! $GLOBALS['error'] && (! isset($GLOBALS['import_text']) || empty($GLOBALS['import_text']))) {
            $GLOBALS['message'] = Message::error(
                __(
                    'No data was received to import. Either no file name was ' .
                    'submitted, or the file size exceeded the maximum size permitted ' .
                    'by your PHP configuration. See [doc@faq1-16]FAQ 1.16[/doc].'
                )
            );

            $_SESSION['Import_message']['message'] = $GLOBALS['message']->getDisplay();

            $this->response->setRequestStatus(false);
            $this->response->addJSON('message', $GLOBALS['message']->getDisplay());
            $this->response->addHTML($GLOBALS['message']->getDisplay());

            return;
        }

        // Convert the file's charset if necessary
        if (Encoding::isSupported() && isset($GLOBALS['charset_of_file'])) {
            if ($GLOBALS['charset_of_file'] !== 'utf-8') {
                $GLOBALS['charset_conversion'] = true;
            }
        } elseif (isset($GLOBALS['charset_of_file']) && $GLOBALS['charset_of_file'] !== 'utf-8') {
            $this->dbi->query('SET NAMES \'' . $GLOBALS['charset_of_file'] . '\'');
            // We can not show query in this case, it is in different charset
            $GLOBALS['sql_query_disabled'] = true;
            $GLOBALS['reset_charset'] = true;
        }

        // Something to skip? (because timeout has passed)
        if (! $GLOBALS['error'] && isset($_POST['skip'])) {
            $original_skip = $skip = intval($_POST['skip']);
            while ($skip > 0 && ! $GLOBALS['finished']) {
                $this->import->getNextChunk(
                    $importHandle ?? null,
                    $skip < $GLOBALS['read_limit'] ? $skip : $GLOBALS['read_limit']
                );
                // Disable read progressivity, otherwise we eat all memory!
                $GLOBALS['read_multiply'] = 1;
                $skip -= $GLOBALS['read_limit'];
            }

            unset($skip);
        }

        // This array contain the data like number of valid sql queries in the statement
        // and complete valid sql statement (which affected for rows)
        $queriesToBeExecuted = [];

        if (! $GLOBALS['error']) {
            /**
             * @var ImportPlugin $import_plugin
             */
            $import_plugin = Plugins::getPlugin('import', $GLOBALS['format'], $GLOBALS['import_type']);
            if ($import_plugin == null) {
                $GLOBALS['message'] = Message::error(
                    __('Could not load import plugins, please check your installation!')
                );

                $_SESSION['Import_message']['message'] = $GLOBALS['message']->getDisplay();

                $this->response->setRequestStatus(false);
                $this->response->addJSON('message', $GLOBALS['message']->getDisplay());
                $this->response->addHTML($GLOBALS['message']->getDisplay());

                return;
            }

            // Do the real import
            $default_fk_check = ForeignKey::handleDisableCheckInit();
            try {
                $queriesToBeExecuted = $import_plugin->doImport($importHandle ?? null);
                ForeignKey::handleDisableCheckCleanup($default_fk_check);
            } catch (Throwable $e) {
                ForeignKey::handleDisableCheckCleanup($default_fk_check);

                throw $e;
            }
        }

        if (isset($importHandle)) {
            $importHandle->close();
        }

        // Reset charset back, if we did some changes
        if ($GLOBALS['reset_charset']) {
            $this->dbi->query('SET CHARACTER SET ' . $GLOBALS['charset_connection']);
            $this->dbi->setCollation($GLOBALS['collation_connection']);
        }

        // Show correct message
        if (! empty($id_bookmark) && $_POST['action_bookmark'] == 2) {
            $GLOBALS['message'] = Message::success(__('The bookmark has been deleted.'));
            $GLOBALS['display_query'] = $GLOBALS['import_text'];
            $GLOBALS['error'] = false; // unset error marker, it was used just to skip processing
        } elseif (! empty($id_bookmark) && $_POST['action_bookmark'] == 1) {
            $GLOBALS['message'] = Message::notice(__('Showing bookmark'));
        } elseif ($GLOBALS['finished'] && ! $GLOBALS['error']) {
            // Do not display the query with message, we do it separately
            $GLOBALS['display_query'] = ';';
            if ($GLOBALS['import_type'] !== 'query') {
                $GLOBALS['message'] = Message::success(
                    '<em>'
                    . _ngettext(
                        'Import has been successfully finished, %d query executed.',
                        'Import has been successfully finished, %d queries executed.',
                        $GLOBALS['executed_queries']
                    )
                    . '</em>'
                );
                $GLOBALS['message']->addParam($GLOBALS['executed_queries']);

                if (! empty($GLOBALS['import_notice'])) {
                    $GLOBALS['message']->addHtml($GLOBALS['import_notice']);
                }

                if (! empty($GLOBALS['local_import_file'])) {
                    $GLOBALS['message']->addText('(' . $GLOBALS['local_import_file'] . ')');
                } elseif (
                    isset($_FILES['import_file'])
                    && is_array($_FILES['import_file'])
                    && isset($_FILES['import_file']['name'])
                    && is_string($_FILES['import_file']['name'])
                ) {
                    $GLOBALS['message']->addText('(' . $_FILES['import_file']['name'] . ')');
                }
            }
        }

        // Did we hit timeout? Tell it user.
        if ($GLOBALS['timeout_passed']) {
            $GLOBALS['urlParams']['timeout_passed'] = '1';
            $GLOBALS['urlParams']['offset'] = $GLOBALS['offset'];
            if (isset($GLOBALS['local_import_file'])) {
                $GLOBALS['urlParams']['local_import_file'] = $GLOBALS['local_import_file'];
            }

            $importUrl = $GLOBALS['errorUrl'] = $GLOBALS['goto'] . Url::getCommon($GLOBALS['urlParams'], '&');

            $GLOBALS['message'] = Message::error(
                __(
                    'Script timeout passed, if you want to finish import,'
                    . ' please %sresubmit the same file%s and import will resume.'
                )
            );
            $GLOBALS['message']->addParamHtml('<a href="' . $importUrl . '">');
            $GLOBALS['message']->addParamHtml('</a>');

            if ($GLOBALS['offset'] == 0 || (isset($original_skip) && $original_skip == $GLOBALS['offset'])) {
                $GLOBALS['message']->addText(
                    __(
                        'However on last run no data has been parsed,'
                        . ' this usually means phpMyAdmin won\'t be able to'
                        . ' finish this import unless you increase php time limits.'
                    )
                );
            }
        }

        // if there is any message, copy it into $_SESSION as well,
        // so we can obtain it by AJAX call
        if (isset($GLOBALS['message'])) {
            $_SESSION['Import_message']['message'] = $GLOBALS['message']->getDisplay();
        }

        // Parse and analyze the query, for correct db and table name
        // in case of a query typed in the query window
        // (but if the query is too large, in case of an imported file, the parser
        //  can choke on it so avoid parsing)
        $sqlLength = mb_strlen($GLOBALS['sql_query']);
        if ($sqlLength <= $GLOBALS['cfg']['MaxCharactersInDisplayedSQL']) {
            [$statementInfo, $GLOBALS['db'], $table_from_sql] = ParseAnalyze::sqlQuery(
                $GLOBALS['sql_query'],
                $GLOBALS['db']
            );

            $GLOBALS['reload'] = $statementInfo->reload;
            $GLOBALS['offset'] = $statementInfo->offset;

            if ($GLOBALS['table'] != $table_from_sql && ! empty($table_from_sql)) {
                $GLOBALS['table'] = $table_from_sql;
            }
        }

        // There was an error?
        if (isset($GLOBALS['my_die'])) {
            foreach ($GLOBALS['my_die'] as $die) {
                Generator::mysqlDie($die['error'], $die['sql'], false, $GLOBALS['errorUrl'], $GLOBALS['error']);
            }
        }

        if ($GLOBALS['go_sql']) {
            if ($queriesToBeExecuted !== []) {
                $_SESSION['is_multi_query'] = true;
            } else {
                $queriesToBeExecuted = [$GLOBALS['sql_query']];
            }

            $html_output = '';

            foreach ($queriesToBeExecuted as $GLOBALS['sql_query']) {
                // parse sql query
                [$statementInfo, $GLOBALS['db'], $table_from_sql] = ParseAnalyze::sqlQuery(
                    $GLOBALS['sql_query'],
                    $GLOBALS['db']
                );

                $GLOBALS['offset'] = $statementInfo->offset;
                $GLOBALS['reload'] = $statementInfo->reload;

                // Check if User is allowed to issue a 'DROP DATABASE' Statement
                if (
                    $this->sql->hasNoRightsToDropDatabase(
                        $statementInfo,
                        $GLOBALS['cfg']['AllowUserDropDatabase'],
                        $this->dbi->isSuperUser()
                    )
                ) {
                    Generator::mysqlDie(
                        __('"DROP DATABASE" statements are disabled.'),
                        '',
                        false,
                        $_SESSION['Import_message']['go_back_url']
                    );

                    return;
                }

                if ($GLOBALS['table'] != $table_from_sql && ! empty($table_from_sql)) {
                    $GLOBALS['table'] = $table_from_sql;
                }

                $html_output .= $this->sql->executeQueryAndGetQueryResponse(
                    $statementInfo,
                    false, // is_gotofile
                    $GLOBALS['db'], // db
                    $GLOBALS['table'], // table
                    null, // find_real_end
                    null, // sql_query_for_bookmark - see below
                    null, // extra_data
                    null, // message_to_show
                    null, // sql_data
                    $GLOBALS['goto'], // goto
                    null, // disp_query
                    null, // disp_message
                    $GLOBALS['sql_query'], // sql_query
                    null // complete_query
                );
            }

            // sql_query_for_bookmark is not included in Sql::executeQueryAndGetQueryResponse
            // since only one bookmark has to be added for all the queries submitted through
            // the SQL tab
            if (! empty($_POST['bkm_label']) && ! empty($GLOBALS['import_text'])) {
                $relation = new Relation($this->dbi);

                $this->sql->storeTheQueryAsBookmark(
                    $relation->getRelationParameters()->bookmarkFeature,
                    $GLOBALS['db'],
                    $GLOBALS['cfg']['Server']['user'],
                    $_POST['sql_query'],
                    $_POST['bkm_label'],
                    isset($_POST['bkm_replace'])
                );
            }

            $this->response->addJSON('ajax_reload', $GLOBALS['ajax_reload']);
            $this->response->addHTML($html_output);

            return;
        }

        if ($GLOBALS['result']) {
            // Save a Bookmark with more than one queries (if Bookmark label given).
            if (! empty($_POST['bkm_label']) && ! empty($GLOBALS['import_text'])) {
                $relation = new Relation($this->dbi);

                $this->sql->storeTheQueryAsBookmark(
                    $relation->getRelationParameters()->bookmarkFeature,
                    $GLOBALS['db'],
                    $GLOBALS['cfg']['Server']['user'],
                    $_POST['sql_query'],
                    $_POST['bkm_label'],
                    isset($_POST['bkm_replace'])
                );
            }

            $this->response->setRequestStatus(true);
            $this->response->addJSON('message', Message::success($GLOBALS['msg']));
            $this->response->addJSON(
                'sql_query',
                Generator::getMessage($GLOBALS['msg'], $GLOBALS['sql_query'], 'success')
            );
        } elseif ($GLOBALS['result'] === false) {
            $this->response->setRequestStatus(false);
            $this->response->addJSON('message', Message::error($GLOBALS['msg']));
        } else {
            $GLOBALS['active_page'] = $GLOBALS['goto'];
            /** @psalm-suppress UnresolvableInclude */
            include ROOT_PATH . $GLOBALS['goto'];
        }

        // If there is request for ROLLBACK in the end.
        if (! isset($_POST['rollback_query'])) {
            return;
        }

        $this->dbi->query('ROLLBACK');
    }
}