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