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