import.php

   1 <?php
   2 /* vim: set expandtab sw=4 ts=4 sts=4: */
   3 /**
   4  * Core script for import, this is just the glue around all other stuff
   5  *
   6  * @package PhpMyAdmin
   7  */
   8
   9 /**
  10  * Get the variables sent or posted to this script and a core script
  11  */
  12 require_once 'libraries/common.inc.php';
  13 require_once 'libraries/sql.lib.php';
  14 require_once 'libraries/bookmark.lib.php';
  15 require_once 'libraries/Console.class.php';
  16 //require_once 'libraries/display_import_functions.lib.php';
  17
  18 if (isset($_REQUEST['show_as_php'])) {
  19     $GLOBALS['show_as_php'] = $_REQUEST['show_as_php'];
  20 }
  21
  22 // Import functions.
  23 require_once 'libraries/import.lib.php';
  24
  25 // If there is a request to 'Simulate DML'.
  26 if (isset($_REQUEST['simulate_dml'])) {
  27     PMA_handleSimulateDMLRequest();
  28     exit;
  29 }
  30
  31 // If it's a refresh console bookmarks request
  32 if (isset($_REQUEST['console_bookmark_refresh'])) {
  33     $response = PMA_Response::getInstance();
  34     $response->addJSON(
  35         'console_message_bookmark', PMA_Console::getBookmarkContent()
  36     );
  37     exit;
  38 }
  39 // If it's a console bookmark add request
  40 if (isset($_REQUEST['console_bookmark_add'])) {
  41     $response = PMA_Response::getInstance();
  42     if (isset($_REQUEST['label']) && isset($_REQUEST['db'])
  43         && isset($_REQUEST['bookmark_query']) && isset($_REQUEST['shared'])
  44     ) {
  45         $cfgBookmark = PMA_Bookmark_getParams();
  46         $bookmarkFields = array(
  47             'bkm_database' => $_REQUEST['db'],
  48             'bkm_user'  => $cfgBookmark['user'],
  49             'bkm_sql_query' => urlencode($_REQUEST['bookmark_query']),
  50             'bkm_label' => $_REQUEST['label']
  51         );
  52         $isShared = ($_REQUEST['shared'] == 'true' ? true : false);
  53         if (PMA_Bookmark_save($bookmarkFields, $isShared)) {
  54             $response->addJSON('message', __('Succeeded'));
  55             $response->addJSON('data', $bookmarkFields);
  56             $response->addJSON('isShared', $isShared);
  57         } else {
  58             $response->addJSON('message', __('Failed'));
  59         }
  60         die();
  61     } else {
  62         $response->addJSON('message', __('Incomplete params'));
  63         die();
  64     }
  65 }
  66
  67 /**
  68  * Sets globals from $_POST
  69  */
  70 $post_params = array(
  71     'bkm_label',
  72     'charset_of_file',
  73     'format',
  74     'import_type',
  75     'is_js_confirmed',
  76     'MAX_FILE_SIZE',
  77     'message_to_show',
  78     'noplugin',
  79     'skip',
  80     'skip_queries',
  81     'local_import_file'
  82 );
  83
  84 // TODO: adapt full list of allowed parameters, as in export.php
  85 foreach ($post_params as $one_post_param) {
  86     if (isset($_POST[$one_post_param])) {
  87         $GLOBALS[$one_post_param] = $_POST[$one_post_param];
  88     }
  89 }
  90
  91 // reset import messages for ajax request
  92 $_SESSION['Import_message']['message'] = null;
  93 $_SESSION['Import_message']['go_back_url'] = null;
  94 // default values
  95 $GLOBALS['reload'] = false;
  96
  97 // Use to identify current cycle is executing
  98 // a multiquery statement or stored routine
  99 if (!isset($_SESSION['is_multi_query'])) {
 100     $_SESSION['is_multi_query'] = false;
 101 }
 102
 103 $ajax_reload = array();
 104 // Are we just executing plain query or sql file?
 105 // (eg. non import, but query box/window run)
 106 if (! empty($sql_query)) {
 107
 108     // apply values for parameters
 109     if (! empty($_REQUEST['parameterized'])) {
 110         $parameters = $_REQUEST['parameters'];
 111         foreach ($parameters as $parameter => $replacement) {
 112             $quoted = preg_quote($parameter);
 113             // making sure that :param does not apply values to :param1
 114             $sql_query = preg_replace(
 115                 '/' . $quoted . '([^a-zA-Z0-9_])/',
 116                 PMA_Util::sqlAddSlashes($replacement) . '${1}',
 117                 $sql_query
 118             );
 119             // for parameters the appear at the end of the string
 120             $sql_query = preg_replace(
 121                 '/' . $quoted . '$/',
 122                 PMA_Util::sqlAddSlashes($replacement),
 123                 $sql_query
 124             );
 125         }
 126     }
 127
 128     // run SQL query
 129     $import_text = $sql_query;
 130     $import_type = 'query';
 131     $format = 'sql';
 132     $_SESSION['sql_from_query_box'] = true;
 133
 134     // If there is a request to ROLLBACK when finished.
 135     if (isset($_REQUEST['rollback_query'])) {
 136         PMA_handleRollbackRequest($import_text);
 137     }
 138
 139     // refresh navigation and main panels
 140     if (preg_match('/^(DROP)\s+(VIEW|TABLE|DATABASE|SCHEMA)\s+/i', $sql_query)) {
 141         $GLOBALS['reload'] = true;
 142         $ajax_reload['reload'] = true;
 143     }
 144
 145     // refresh navigation panel only
 146     if (preg_match(
 147         '/^(CREATE|ALTER)\s+(VIEW|TABLE|DATABASE|SCHEMA)\s+/i',
 148         $sql_query
 149     )) {
 150         $ajax_reload['reload'] = true;
 151     }
 152
 153     // do a dynamic reload if table is RENAMED
 154     // (by sending the instruction to the AJAX response handler)
 155     if (preg_match(
 156         '/^RENAME\s+TABLE\s+(.*?)\s+TO\s+(.*?)($|;|\s)/i',
 157         $sql_query,
 158         $rename_table_names
 159     )) {
 160         $ajax_reload['reload'] = true;
 161         $ajax_reload['table_name'] = PMA_Util::unQuote($rename_table_names[2]);
 162     }
 163
 164     $sql_query = '';
 165 } elseif (! empty($sql_localfile)) {
 166     // run SQL file on server
 167     $local_import_file = $sql_localfile;
 168     $import_type = 'queryfile';
 169     $format = 'sql';
 170     unset($sql_localfile);
 171 } elseif (! empty($sql_file)) {
 172     // run uploaded SQL file
 173     $import_file = $sql_file;
 174     $import_type = 'queryfile';
 175     $format = 'sql';
 176     unset($sql_file);
 177 } elseif (! empty($_REQUEST['id_bookmark'])) {
 178     // run bookmark
 179     $import_type = 'query';
 180     $format = 'sql';
 181 }
 182
 183 // If we didn't get any parameters, either user called this directly, or
 184 // upload limit has been reached, let's assume the second possibility.
 185 if ($_POST == array() && $_GET == array()) {
 186     $message = PMA_Message::error(
 187         __('You probably tried to upload a file that is too large. Please refer to %sdocumentation%s for a workaround for this limit.')
 188     );
 189     $message->addParam('[doc@faq1-16]');
 190     $message->addParam('[/doc]');
 191
 192     // so we can obtain the message
 193     $_SESSION['Import_message']['message'] = $message->getDisplay();
 194     $_SESSION['Import_message']['go_back_url'] = $GLOBALS['goto'];
 195
 196     $message->display();
 197     exit; // the footer is displayed automatically
 198 }
 199
 200 // Add console message id to response output
 201 if (isset($_POST['console_message_id'])) {
 202     $response = PMA_Response::getInstance();
 203     $response->addJSON('console_message_id', $_POST['console_message_id']);
 204 }
 205
 206 /**
 207  * Sets globals from $_POST patterns, for import plugins
 208  * We only need to load the selected plugin
 209  */
 210
 211 if (! in_array(
 212     $format,
 213     array(
 214         'csv',
 215         'ldi',
 216         'mediawiki',
 217         'ods',
 218         'shp',
 219         'sql',
 220         'xml'
 221     )
 222 )
 223 ) {
 224     // this should not happen for a normal user
 225     // but only during an attack
 226     PMA_fatalError('Incorrect format parameter');
 227 }
 228
 229 $post_patterns = array(
 230     '/^force_file_/',
 231     '/^' . $format . '_/'
 232 );
 233
 234 PMA_setPostAsGlobal($post_patterns);
 235
 236 // Check needed parameters
 237 PMA_Util::checkParameters(array('import_type', 'format'));
 238
 239 // We don't want anything special in format
 240 $format = PMA_securePath($format);
 241 /** @var PMA_String $pmaString */
 242 $pmaString = $GLOBALS['PMA_String'];
 243
 244 // Create error and goto url
 245 if ($import_type == 'table') {
 246     $err_url = 'tbl_import.php' . PMA_URL_getCommon(
 247         array(
 248             'db' => $db, 'table' => $table
 249         )
 250     );
 251     $_SESSION['Import_message']['go_back_url'] = $err_url;
 252     $goto = 'tbl_import.php';
 253 } elseif ($import_type == 'database') {
 254     $err_url = 'db_import.php' . PMA_URL_getCommon(array('db' => $db));
 255     $_SESSION['Import_message']['go_back_url'] = $err_url;
 256     $goto = 'db_import.php';
 257 } elseif ($import_type == 'server') {
 258     $err_url = 'server_import.php' . PMA_URL_getCommon();
 259     $_SESSION['Import_message']['go_back_url'] = $err_url;
 260     $goto = 'server_import.php';
 261 } else {
 262     if (empty($goto) || !preg_match('@^(server|db|tbl)(_[a-z]*)*\.php$@i', $goto)) {
 263         if (/*overload*/mb_strlen($table) && /*overload*/mb_strlen($db)) {
 264             $goto = 'tbl_structure.php';
 265         } elseif (/*overload*/mb_strlen($db)) {
 266             $goto = 'db_structure.php';
 267         } else {
 268             $goto = 'server_sql.php';
 269         }
 270     }
 271     if (/*overload*/mb_strlen($table) && /*overload*/mb_strlen($db)) {
 272         $common = PMA_URL_getCommon(array('db' => $db, 'table' => $table));
 273     } elseif (/*overload*/mb_strlen($db)) {
 274         $common = PMA_URL_getCommon(array('db' => $db));
 275     } else {
 276         $common = PMA_URL_getCommon();
 277     }
 278     $err_url  = $goto . $common
 279         . (preg_match('@^tbl_[a-z]*\.php$@', $goto)
 280             ? '&amp;table=' . htmlspecialchars($table)
 281             : '');
 282     $_SESSION['Import_message']['go_back_url'] = $err_url;
 283 }
 284 // Avoid setting selflink to 'import.php'
 285 // problem similar to bug 4276
 286 if (basename($_SERVER['SCRIPT_NAME']) === 'import.php') {
 287     $_SERVER['SCRIPT_NAME'] = $goto;
 288 }
 289
 290
 291 if (/*overload*/mb_strlen($db)) {
 292     $GLOBALS['dbi']->selectDb($db);
 293 }
 294
 295 @set_time_limit($cfg['ExecTimeLimit']);
 296 if (! empty($cfg['MemoryLimit'])) {
 297     @ini_set('memory_limit', $cfg['MemoryLimit']);
 298 }
 299
 300 $timestamp = time();
 301 if (isset($_REQUEST['allow_interrupt'])) {
 302     $maximum_time = ini_get('max_execution_time');
 303 } else {
 304     $maximum_time = 0;
 305 }
 306
 307 // set default values
 308 $timeout_passed = false;
 309 $error = false;
 310 $read_multiply = 1;
 311 $finished = false;
 312 $offset = 0;
 313 $max_sql_len = 0;
 314 $file_to_unlink = '';
 315 $sql_query = '';
 316 $sql_query_disabled = false;
 317 $go_sql = false;
 318 $executed_queries = 0;
 319 $run_query = true;
 320 $charset_conversion = false;
 321 $reset_charset = false;
 322 $bookmark_created = false;
 323
 324 // Bookmark Support: get a query back from bookmark if required
 325 if (! empty($_REQUEST['id_bookmark'])) {
 326     $id_bookmark = (int)$_REQUEST['id_bookmark'];
 327     include_once 'libraries/bookmark.lib.php';
 328     switch ($_REQUEST['action_bookmark']) {
 329     case 0: // bookmarked query that have to be run
 330         $import_text = PMA_Bookmark_get(
 331             $db,
 332             $id_bookmark,
 333             'id',
 334             isset($_REQUEST['action_bookmark_all'])
 335         );
 336         if (! empty($_REQUEST['bookmark_variable'])) {
 337             $import_text = PMA_Bookmark_applyVariables(
 338                 $import_text
 339             );
 340         }
 341
 342         // refresh navigation and main panels
 343         if (preg_match(
 344             '/^(DROP)\s+(VIEW|TABLE|DATABASE|SCHEMA)\s+/i',
 345             $import_text
 346         )) {
 347             $GLOBALS['reload'] = true;
 348             $ajax_reload['reload'] = true;
 349         }
 350
 351         // refresh navigation panel only
 352         if (preg_match(
 353             '/^(CREATE|ALTER)\s+(VIEW|TABLE|DATABASE|SCHEMA)\s+/i',
 354             $import_text
 355         )
 356         ) {
 357             $ajax_reload['reload'] = true;
 358         }
 359         break;
 360     case 1: // bookmarked query that have to be displayed
 361         $import_text = PMA_Bookmark_get($db, $id_bookmark);
 362         if ($GLOBALS['is_ajax_request'] == true) {
 363             $message = PMA_Message::success(__('Showing bookmark'));
 364             $response = PMA_Response::getInstance();
 365             $response->isSuccess($message->isSuccess());
 366             $response->addJSON('message', $message);
 367             $response->addJSON('sql_query', $import_text);
 368             $response->addJSON('action_bookmark', $_REQUEST['action_bookmark']);
 369             exit;
 370         } else {
 371             $run_query = false;
 372         }
 373         break;
 374     case 2: // bookmarked query that have to be deleted
 375         $import_text = PMA_Bookmark_get($db, $id_bookmark);
 376         PMA_Bookmark_delete($id_bookmark);
 377         if ($GLOBALS['is_ajax_request'] == true) {
 378             $message = PMA_Message::success(__('The bookmark has been deleted.'));
 379             $response = PMA_Response::getInstance();
 380             $response->isSuccess($message->isSuccess());
 381             $response->addJSON('message', $message);
 382             $response->addJSON('action_bookmark', $_REQUEST['action_bookmark']);
 383             $response->addJSON('id_bookmark', $id_bookmark);
 384             exit;
 385         } else {
 386             $run_query = false;
 387             $error = true; // this is kind of hack to skip processing the query
 388         }
 389         break;
 390     }
 391 } // end bookmarks reading
 392
 393 // Do no run query if we show PHP code
 394 if (isset($GLOBALS['show_as_php'])) {
 395     $run_query = false;
 396     $go_sql = true;
 397 }
 398
 399 // We can not read all at once, otherwise we can run out of memory
 400 $memory_limit = trim(@ini_get('memory_limit'));
 401 // 2 MB as default
 402 if (empty($memory_limit)) {
 403     $memory_limit = 2 * 1024 * 1024;
 404 }
 405 // In case no memory limit we work on 10MB chunks
 406 if ($memory_limit == -1) {
 407     $memory_limit = 10 * 1024 * 1024;
 408 }
 409
 410 // Calculate value of the limit
 411 $memoryUnit = /*overload*/mb_strtolower(substr($memory_limit, -1));
 412 if ('m' == $memoryUnit) {
 413     $memory_limit = (int)substr($memory_limit, 0, -1) * 1024 * 1024;
 414 } elseif ('k' == $memoryUnit) {
 415     $memory_limit = (int)substr($memory_limit, 0, -1) * 1024;
 416 } elseif ('g' == $memoryUnit) {
 417     $memory_limit = (int)substr($memory_limit, 0, -1) * 1024 * 1024 * 1024;
 418 } else {
 419     $memory_limit = (int)$memory_limit;
 420 }
 421
 422 // Just to be sure, there might be lot of memory needed for uncompression
 423 $read_limit = $memory_limit / 8;
 424
 425 // handle filenames
 426 if (isset($_FILES['import_file'])) {
 427     $import_file = $_FILES['import_file']['tmp_name'];
 428 }
 429 if (! empty($local_import_file) && ! empty($cfg['UploadDir'])) {
 430
 431     // sanitize $local_import_file as it comes from a POST
 432     $local_import_file = PMA_securePath($local_import_file);
 433
 434     $import_file = PMA_Util::userDir($cfg['UploadDir'])
 435         . $local_import_file;
 436
 437 } elseif (empty($import_file) || ! is_uploaded_file($import_file)) {
 438     $import_file  = 'none';
 439 }
 440
 441 // Do we have file to import?
 442
 443 if ($import_file != 'none' && ! $error) {
 444     // work around open_basedir and other limitations
 445     $open_basedir = @ini_get('open_basedir');
 446
 447     // If we are on a server with open_basedir, we must move the file
 448     // before opening it.
 449
 450     if (! empty($open_basedir)) {
 451         $tmp_subdir = ini_get('upload_tmp_dir');
 452         if (empty($tmp_subdir)) {
 453             $tmp_subdir = sys_get_temp_dir();
 454         }
 455         $tmp_subdir = rtrim($tmp_subdir, DIRECTORY_SEPARATOR);
 456         if (is_writable($tmp_subdir)) {
 457             $import_file_new = $tmp_subdir . DIRECTORY_SEPARATOR
 458                 . basename($import_file) . uniqid();
 459             if (move_uploaded_file($import_file, $import_file_new)) {
 460                 $import_file = $import_file_new;
 461                 $file_to_unlink = $import_file_new;
 462             }
 463
 464             $size = filesize($import_file);
 465         } else {
 466
 467             // If the php.ini is misconfigured (eg. there is no /tmp access defined
 468             // with open_basedir), $tmp_subdir won't be writable and the user gets
 469             // a 'File could not be read!' error (at PMA_detectCompression), which
 470             // is not too meaningful. Show a meaningful error message to the user
 471             // instead.
 472
 473             $message = PMA_Message::error(
 474                 __('Uploaded file cannot be moved, because the server has open_basedir enabled without access to the %s directory (for temporary files).')
 475             );
 476             $message->addParam($tmp_subdir);
 477             PMA_stopImport($message);
 478         }
 479     }
 480
 481     /**
 482      *  Handle file compression
 483      * @todo duplicate code exists in File.class.php
 484      */
 485     $compression = PMA_detectCompression($import_file);
 486     if ($compression === false) {
 487         $message = PMA_Message::error(__('File could not be read!'));
 488         PMA_stopImport($message); //Contains an 'exit'
 489     }
 490
 491     switch ($compression) {
 492     case 'application/bzip2':
 493         if ($cfg['BZipDump'] && @function_exists('bzopen')) {
 494             $import_handle = @bzopen($import_file, 'r');
 495         } else {
 496             $message = PMA_Message::error(
 497                 __('You attempted to load file with unsupported compression (%s). Either support for it is not implemented or disabled by your configuration.')
 498             );
 499             $message->addParam($compression);
 500             PMA_stopImport($message);
 501         }
 502         break;
 503     case 'application/gzip':
 504         if ($cfg['GZipDump'] && @function_exists('gzopen')) {
 505             $import_handle = @gzopen($import_file, 'r');
 506         } else {
 507             $message = PMA_Message::error(
 508                 __('You attempted to load file with unsupported compression (%s). Either support for it is not implemented or disabled by your configuration.')
 509             );
 510             $message->addParam($compression);
 511             PMA_stopImport($message);
 512         }
 513         break;
 514     case 'application/zip':
 515         if ($cfg['ZipDump'] && @function_exists('zip_open')) {
 516             /**
 517              * Load interface for zip extension.
 518              */
 519             include_once 'libraries/zip_extension.lib.php';
 520             $zipResult = PMA_getZipContents($import_file);
 521             if (! empty($zipResult['error'])) {
 522                 $message = PMA_Message::rawError($zipResult['error']);
 523                 PMA_stopImport($message);
 524             } else {
 525                 $import_text = $zipResult['data'];
 526             }
 527         } else {
 528             $message = PMA_Message::error(
 529                 __('You attempted to load file with unsupported compression (%s). Either support for it is not implemented or disabled by your configuration.')
 530             );
 531             $message->addParam($compression);
 532             PMA_stopImport($message);
 533         }
 534         break;
 535     case 'none':
 536         $import_handle = @fopen($import_file, 'r');
 537         break;
 538     default:
 539         $message = PMA_Message::error(
 540             __('You attempted to load file with unsupported compression (%s). Either support for it is not implemented or disabled by your configuration.')
 541         );
 542         $message->addParam($compression);
 543         PMA_stopImport($message);
 544         break;
 545     }
 546     // use isset() because zip compression type does not use a handle
 547     if (! $error && isset($import_handle) && $import_handle === false) {
 548         $message = PMA_Message::error(__('File could not be read!'));
 549         PMA_stopImport($message);
 550     }
 551 } elseif (! $error) {
 552     if (! isset($import_text) || empty($import_text)) {
 553         $message = PMA_Message::error(
 554             __('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].')
 555         );
 556         PMA_stopImport($message);
 557     }
 558 }
 559
 560 // so we can obtain the message
 561 //$_SESSION['Import_message'] = $message->getDisplay();
 562
 563 // Convert the file's charset if necessary
 564 if ($GLOBALS['PMA_recoding_engine'] != PMA_CHARSET_NONE && isset($charset_of_file)) {
 565     if ($charset_of_file != 'utf-8') {
 566         $charset_conversion = true;
 567     }
 568 } elseif (isset($charset_of_file) && $charset_of_file != 'utf-8') {
 569     if (PMA_DRIZZLE) {
 570         // Drizzle doesn't support other character sets,
 571         // so we can't fallback to SET NAMES - throw an error
 572         $message = PMA_Message::error(
 573             __(
 574                 'Cannot convert file\'s character'
 575                 . ' set without character set conversion library!'
 576             )
 577         );
 578         PMA_stopImport($message);
 579     } else {
 580         $GLOBALS['dbi']->query('SET NAMES \'' . $charset_of_file . '\'');
 581         // We can not show query in this case, it is in different charset
 582         $sql_query_disabled = true;
 583         $reset_charset = true;
 584     }
 585 }
 586
 587 // Something to skip?
 588 if (! $error && isset($skip)) {
 589     $original_skip = $skip;
 590     while ($skip > 0) {
 591         PMA_importGetNextChunk($skip < $read_limit ? $skip : $read_limit);
 592         // Disable read progressivity, otherwise we eat all memory!
 593         $read_multiply = 1;
 594         $skip -= $read_limit;
 595     }
 596     unset($skip);
 597 }
 598
 599 // This array contain the data like numberof valid sql queries in the statement
 600 // and complete valid sql statement (which affected for rows)
 601 $sql_data = array('valid_sql' => array(), 'valid_queries' => 0);
 602
 603 if (! $error) {
 604     // Check for file existence
 605     include_once "libraries/plugin_interface.lib.php";
 606     $import_plugin = PMA_getPlugin(
 607         "import",
 608         $format,
 609         'libraries/plugins/import/',
 610         $import_type
 611     );
 612     if ($import_plugin == null) {
 613         $message = PMA_Message::error(
 614             __('Could not load import plugins, please check your installation!')
 615         );
 616         PMA_stopImport($message);
 617     } else {
 618         // Do the real import
 619         try {
 620             $default_fk_check = PMA_Util::handleDisableFKCheckInit();
 621             $import_plugin->doImport($sql_data);
 622             PMA_Util::handleDisableFKCheckCleanup($default_fk_check);
 623         } catch (Exception $e) {
 624             PMA_Util::handleDisableFKCheckCleanup($default_fk_check);
 625             throw $e;
 626         }
 627     }
 628 }
 629
 630 if (! empty($import_handle)) {
 631     fclose($import_handle);
 632 }
 633
 634 // Cleanup temporary file
 635 if ($file_to_unlink != '') {
 636     unlink($file_to_unlink);
 637 }
 638
 639 // Reset charset back, if we did some changes
 640 if ($reset_charset) {
 641     $GLOBALS['dbi']->query('SET CHARACTER SET utf8');
 642     $GLOBALS['dbi']->query(
 643         'SET SESSION collation_connection =\'' . $collation_connection . '\''
 644     );
 645 }
 646
 647 // Show correct message
 648 if (! empty($id_bookmark) && $_REQUEST['action_bookmark'] == 2) {
 649     $message = PMA_Message::success(__('The bookmark has been deleted.'));
 650     $display_query = $import_text;
 651     $error = false; // unset error marker, it was used just to skip processing
 652 } elseif (! empty($id_bookmark) && $_REQUEST['action_bookmark'] == 1) {
 653     $message = PMA_Message::notice(__('Showing bookmark'));
 654 } elseif ($bookmark_created) {
 655     $special_message = '[br]'  . sprintf(
 656         __('Bookmark %s has been created.'),
 657         htmlspecialchars($bkm_label)
 658     );
 659 } elseif ($finished && ! $error) {
 660     if ($import_type == 'query') {
 661         $message = PMA_Message::success();
 662     } else {
 663         $message = PMA_Message::success(
 664             '<em>'
 665             . __('Import has been successfully finished, %d queries executed.')
 666             . '</em>'
 667         );
 668         $message->addParam($executed_queries);
 669
 670         if ($import_notice) {
 671             $message->addString($import_notice);
 672         }
 673         if (isset($local_import_file)) {
 674             $message->addString('(' . htmlspecialchars($local_import_file) . ')');
 675         } else {
 676             $message->addString(
 677                 '(' . htmlspecialchars($_FILES['import_file']['name']) . ')'
 678             );
 679         }
 680     }
 681 }
 682
 683 // Did we hit timeout? Tell it user.
 684 if ($timeout_passed) {
 685     $importUrl = $err_url .= '&timeout_passed=1&offset=' . urlencode($GLOBALS['offset']);
 686     if (isset($local_import_file)) {
 687         $importUrl .= '&local_import_file=' . urlencode($local_import_file);
 688     }
 689     $message = PMA_Message::error(
 690         __(
 691             'Script timeout passed, if you want to finish import,'
 692             . ' please %sresubmit the same file%s and import will resume.'
 693         )
 694     );
 695     $message->addParam('<a href="' . $importUrl . '">', false);
 696     $message->addParam('</a>', false);
 697
 698     if ($offset == 0 || (isset($original_skip) && $original_skip == $offset)) {
 699         $message->addString(
 700             __(
 701                 'However on last run no data has been parsed,'
 702                 . ' this usually means phpMyAdmin won\'t be able to'
 703                 . ' finish this import unless you increase php time limits.'
 704             )
 705         );
 706     }
 707 }
 708
 709 // if there is any message, copy it into $_SESSION as well,
 710 // so we can obtain it by AJAX call
 711 if (isset($message)) {
 712     $_SESSION['Import_message']['message'] = $message->getDisplay();
 713 }
 714 // Parse and analyze the query, for correct db and table name
 715 // in case of a query typed in the query window
 716 // (but if the query is too large, in case of an imported file, the parser
 717 //  can choke on it so avoid parsing)
 718 $sqlLength = /*overload*/mb_strlen($sql_query);
 719 if ($sqlLength <= $GLOBALS['cfg']['MaxCharactersInDisplayedSQL']) {
 720     include_once 'libraries/parse_analyze.inc.php';
 721 }
 722
 723 // There was an error?
 724 if (isset($my_die)) {
 725     foreach ($my_die as $key => $die) {
 726         PMA_Util::mysqlDie(
 727             $die['error'], $die['sql'], false, $err_url, $error
 728         );
 729     }
 730 }
 731
 732 if ($go_sql) {
 733
 734     if (! empty($sql_data) && ($sql_data['valid_queries'] > 1)) {
 735         $_SESSION['is_multi_query'] = true;
 736         $sql_queries = $sql_data['valid_sql'];
 737     } else {
 738         $sql_queries = array($sql_query);
 739     }
 740
 741     $html_output = '';
 742     foreach ($sql_queries as $sql_query) {
 743         // parse sql query
 744         include 'libraries/parse_analyze.inc.php';
 745
 746         $html_output .= PMA_executeQueryAndGetQueryResponse(
 747             $analyzed_sql_results, false, $db, $table, null,
 748             $sql_query, null, $analyzed_sql_results['is_affected'],
 749             null, null, null, $goto, $pmaThemeImage,
 750             null, null, null, $sql_query, null, null
 751         );
 752     }
 753
 754     $response = PMA_Response::getInstance();
 755     $response->addJSON('ajax_reload', $ajax_reload);
 756     $response->addHTML($html_output);
 757     exit();
 758
 759 } else if ($result) {
 760     // Save a Bookmark with more than one queries (if Bookmark label given).
 761     if (! empty($_POST['bkm_label']) && ! empty($import_text)) {
 762         $cfgBookmark = PMA_Bookmark_getParams();
 763         PMA_storeTheQueryAsBookmark(
 764             $db, $cfgBookmark['user'],
 765             $_REQUEST['sql_query'], $_POST['bkm_label'],
 766             isset($_POST['bkm_replace']) ? $_POST['bkm_replace'] : null
 767         );
 768     }
 769
 770     $response = PMA_Response::getInstance();
 771     $response->isSuccess(true);
 772     $response->addJSON('message', PMA_Message::success($msg));
 773     $response->addJSON(
 774         'sql_query',
 775         PMA_Util::getMessage($msg, $sql_query, 'success')
 776     );
 777 } else if ($result == false) {
 778     $response = PMA_Response::getInstance();
 779     $response->isSuccess(false);
 780     $response->addJSON('message', PMA_Message::error($msg));
 781 } else {
 782     $active_page = $goto;
 783     include '' . $goto;
 784 }
 785
 786 // If there is request for ROLLBACK in the end.
 787 if (isset($_REQUEST['rollback_query'])) {
 788     $GLOBALS['dbi']->query('ROLLBACK');
 789 }