Default page

Edit File: Export.php

<?php
/* vim: set expandtab sw=4 ts=4 sts=4: */
/**
 * function for the main export logic
 *
 * @package PhpMyAdmin
 */
namespace PhpMyAdmin;

use PhpMyAdmin\Core;
use PhpMyAdmin\Encoding;
use PhpMyAdmin\Message;
use PhpMyAdmin\Plugins;
use PhpMyAdmin\Plugins\ExportPlugin;
use PhpMyAdmin\Sanitize;
use PhpMyAdmin\Table;
use PhpMyAdmin\Url;
use PhpMyAdmin\Util;
use PhpMyAdmin\ZipExtension;

/**
 * PhpMyAdmin\Export class
 *
 * @package PhpMyAdmin
 */
class Export
{
    /**
     * Sets a session variable upon a possible fatal error during export
     *
     * @return void
     */
    public static function shutdown()
    {
        $error = error_get_last();
        if ($error != null && mb_strpos($error['message'], "execution time")) {
            //set session variable to check if there was error while exporting
            $_SESSION['pma_export_error'] = $error['message'];
        }
    }

/**
     * Detect ob_gzhandler
     *
     * @return bool
     */
    public static function isGzHandlerEnabled()
    {
        return in_array('ob_gzhandler', ob_list_handlers());
    }

/**
     * Detect whether gzencode is needed; it might not be needed if
     * the server is already compressing by itself
     *
     * @return bool Whether gzencode is needed
     */
    public static function gzencodeNeeded()
    {
        /*
         * We should gzencode only if the function exists
         * but we don't want to compress twice, therefore
         * gzencode only if transparent compression is not enabled
         * and gz compression was not asked via $cfg['OBGzip']
         * but transparent compression does not apply when saving to server
         */
        $chromeAndGreaterThan43 = PMA_USR_BROWSER_AGENT == 'CHROME'
            && PMA_USR_BROWSER_VER >= 43; // see bug #4942

if (function_exists('gzencode')
            && ((! ini_get('zlib.output_compression')
            && ! self::isGzHandlerEnabled())
            || $GLOBALS['save_on_server']
            || $chromeAndGreaterThan43)
        ) {
            return true;
        }

return false;
    }

/**
     * Output handler for all exports, if needed buffering, it stores data into
     * $dump_buffer, otherwise it prints them out.
     *
     * @param string $line the insert statement
     *
     * @return bool Whether output succeeded
     */
    public static function outputHandler($line)
    {
        global $time_start, $dump_buffer, $dump_buffer_len, $save_filename;

// Kanji encoding convert feature
        if ($GLOBALS['output_kanji_conversion']) {
            $line = Encoding::kanjiStrConv(
                $line,
                $GLOBALS['knjenc'],
                isset($GLOBALS['xkana']) ? $GLOBALS['xkana'] : ''
            );
        }

// If we have to buffer data, we will perform everything at once at the end
        if ($GLOBALS['buffer_needed']) {

$dump_buffer .= $line;
            if ($GLOBALS['onfly_compression']) {

$dump_buffer_len += strlen($line);

if ($dump_buffer_len > $GLOBALS['memory_limit']) {
                    if ($GLOBALS['output_charset_conversion']) {
                        $dump_buffer = Encoding::convertString(
                            'utf-8',
                            $GLOBALS['charset'],
                            $dump_buffer
                        );
                    }
                    if ($GLOBALS['compression'] == 'gzip'
                        && self::gzencodeNeeded()
                    ) {
                        // as a gzipped file
                        // without the optional parameter level because it bugs
                        $dump_buffer = gzencode($dump_buffer);
                    }
                    if ($GLOBALS['save_on_server']) {
                        $write_result = @fwrite($GLOBALS['file_handle'], $dump_buffer);
                        // Here, use strlen rather than mb_strlen to get the length
                        // in bytes to compare against the number of bytes written.
                        if ($write_result != strlen($dump_buffer)) {
                            $GLOBALS['message'] = Message::error(
                                __('Insufficient space to save the file %s.')
                            );
                            $GLOBALS['message']->addParam($save_filename);
                            return false;
                        }
                    } else {
                        echo $dump_buffer;
                    }
                    $dump_buffer = '';
                    $dump_buffer_len = 0;
                }
            } else {
                $time_now = time();
                if ($time_start >= $time_now + 30) {
                    $time_start = $time_now;
                    header('X-pmaPing: Pong');
                } // end if
            }
        } else {
            if ($GLOBALS['asfile']) {
                if ($GLOBALS['output_charset_conversion']) {
                    $line = Encoding::convertString(
                        'utf-8',
                        $GLOBALS['charset'],
                        $line
                    );
                }
                if ($GLOBALS['save_on_server'] && mb_strlen($line) > 0) {
                    $write_result = @fwrite($GLOBALS['file_handle'], $line);
                    // Here, use strlen rather than mb_strlen to get the length
                    // in bytes to compare against the number of bytes written.
                    if (! $write_result
                        || $write_result != strlen($line)
                    ) {
                        $GLOBALS['message'] = Message::error(
                            __('Insufficient space to save the file %s.')
                        );
                        $GLOBALS['message']->addParam($save_filename);
                        return false;
                    }
                    $time_now = time();
                    if ($time_start >= $time_now + 30) {
                        $time_start = $time_now;
                        header('X-pmaPing: Pong');
                    } // end if
                } else {
                    // We export as file - output normally
                    echo $line;
                }
            } else {
                // We export as html - replace special chars
                echo htmlspecialchars($line);
            }
        }
        return true;
    } // end of the 'self::outputHandler()' function

/**
     * Returns HTML containing the footer for a displayed export
     *
     * @param string $back_button   the link for going Back
     * @param string $refreshButton the link for refreshing page
     *
     * @return string $html the HTML output
     */
    public static function getHtmlForDisplayedExportFooter($back_button, $refreshButton)
    {
        /**
         * Close the html tags and add the footers for on-screen export
         */
        $html = '

' . '

' . '
' // bottom back button . $back_button . $refreshButton . '

'; /** * Displays a back button with all the $_POST data in the URL * (store in a variable to also display after the textarea) */ $back_button = '

[ ' . __('Back') . ' ]

'; $html .= '
'; $html .= $back_button; $refreshButton = ''; $html .= $refreshButton . '
' . '

' . '

return array($html, $back_button, $refreshButton);
    }

/**
     * Export at the server level
     *
     * @param string       $db_select       the selected databases to export
     * @param string       $whatStrucOrData structure or data or both
     * @param ExportPlugin $export_plugin   the selected export plugin
     * @param string       $crlf            end of line character(s)
     * @param string       $err_url         the URL in case of error
     * @param string       $export_type     the export type
     * @param bool         $do_relation     whether to export relation info
     * @param bool         $do_comments     whether to add comments
     * @param bool         $do_mime         whether to add MIME info
     * @param bool         $do_dates        whether to add dates
     * @param array        $aliases         alias information for db/table/column
     * @param string       $separate_files  whether it is a separate-files export
     *
     * @return void
     */
    public static function exportServer(
        $db_select, $whatStrucOrData, $export_plugin, $crlf, $err_url,
        $export_type, $do_relation, $do_comments, $do_mime, $do_dates,
        array $aliases, $separate_files
    ) {
        if (! empty($db_select)) {
            $tmp_select = implode($db_select, '|');
            $tmp_select = '|' . $tmp_select . '|';
        }
        // Walk over databases
        foreach ($GLOBALS['dblist']->databases as $current_db) {
            if (isset($tmp_select)
                && mb_strpos(' ' . $tmp_select, '|' . $current_db . '|')
            ) {
                $tables = $GLOBALS['dbi']->getTables($current_db);
                self::exportDatabase(
                    $current_db, $tables, $whatStrucOrData, $tables, $tables,
                    $export_plugin, $crlf, $err_url, $export_type, $do_relation,
                    $do_comments, $do_mime, $do_dates, $aliases,
                    $separate_files == 'database' ? $separate_files : ''
                );
                if ($separate_files == 'server') {
                    self::saveObjectInBuffer($current_db);
                }
            }
        } // end foreach database
    }

/**
     * Export at the database level
     *
     * @param string       $db              the database to export
     * @param array        $tables          the tables to export
     * @param string       $whatStrucOrData structure or data or both
     * @param array        $table_structure whether to export structure for each table
     * @param array        $table_data      whether to export data for each table
     * @param ExportPlugin $export_plugin   the selected export plugin
     * @param string       $crlf            end of line character(s)
     * @param string       $err_url         the URL in case of error
     * @param string       $export_type     the export type
     * @param bool         $do_relation     whether to export relation info
     * @param bool         $do_comments     whether to add comments
     * @param bool         $do_mime         whether to add MIME info
     * @param bool         $do_dates        whether to add dates
     * @param array        $aliases         Alias information for db/table/column
     * @param string       $separate_files  whether it is a separate-files export
     *
     * @return void
     */
    public static function exportDatabase(
        $db, array $tables, $whatStrucOrData, array $table_structure, array $table_data,
        $export_plugin, $crlf, $err_url, $export_type, $do_relation,
        $do_comments, $do_mime, $do_dates, array $aliases, $separate_files
    ) {
        $db_alias = !empty($aliases[$db]['alias'])
            ? $aliases[$db]['alias'] : '';

if (! $export_plugin->exportDBHeader($db, $db_alias)) {
            return;
        }
        if (! $export_plugin->exportDBCreate($db, $export_type, $db_alias)) {
            return;
        }
        if ($separate_files == 'database') {
            self::saveObjectInBuffer('database', true);
        }

if (($GLOBALS['sql_structure_or_data'] == 'structure'
            || $GLOBALS['sql_structure_or_data'] == 'structure_and_data')
            && isset($GLOBALS['sql_procedure_function'])
        ) {
            $export_plugin->exportRoutines($db, $aliases);

if ($separate_files == 'database') {
                self::saveObjectInBuffer('routines');
            }
        }

$views = array();

foreach ($tables as $table) {
            $_table = new Table($table, $db);
            // if this is a view, collect it for later;
            // views must be exported after the tables
            $is_view = $_table->isView();
            if ($is_view) {
                $views[] = $table;
            }
            if (($whatStrucOrData == 'structure'
                || $whatStrucOrData == 'structure_and_data')
                && in_array($table, $table_structure)
            ) {
                // for a view, export a stand-in definition of the table
                // to resolve view dependencies (only when it's a single-file export)
                if ($is_view) {
                    if ($separate_files == ''
                        && isset($GLOBALS['sql_create_view'])
                        && ! $export_plugin->exportStructure(
                            $db, $table, $crlf, $err_url, 'stand_in',
                            $export_type, $do_relation, $do_comments,
                            $do_mime, $do_dates, $aliases
                        )
                    ) {
                        break;
                    }
                } elseif (isset($GLOBALS['sql_create_table'])) {

$table_size = $GLOBALS['maxsize'];
                    // Checking if the maximum table size constrain has been set
                    // And if that constrain is a valid number or not
                    if ($table_size !== '' && is_numeric($table_size)) {
                        // This obtains the current table's size
                        $query = 'SELECT data_length + index_length
                              from information_schema.TABLES
                              WHERE table_schema = "' . $GLOBALS['dbi']->escapeString($db) . '"
                              AND table_name = "' . $GLOBALS['dbi']->escapeString($table) . '"';

$size = $GLOBALS['dbi']->fetchValue($query);
                        //Converting the size to MB
                        $size = ($size / 1024) / 1024;
                        if ($size > $table_size) {
                            continue;
                        }
                    }

if (! $export_plugin->exportStructure(
                        $db, $table, $crlf, $err_url, 'create_table',
                        $export_type, $do_relation, $do_comments,
                        $do_mime, $do_dates, $aliases
                    )) {
                        break;
                    }

}

}
            // if this is a view or a merge table, don't export data
            if (($whatStrucOrData == 'data' || $whatStrucOrData == 'structure_and_data')
                && in_array($table, $table_data)
                && ! ($is_view)
            ) {
                $tableObj = new Table($table, $db);
                $nonGeneratedCols = $tableObj->getNonGeneratedColumns(true);

$local_query  = 'SELECT ' . implode(', ', $nonGeneratedCols)
                    .  ' FROM ' . Util::backquote($db)
                    . '.' . Util::backquote($table);

if (! $export_plugin->exportData(
                    $db, $table, $crlf, $err_url, $local_query, $aliases
                )) {
                    break;
                }
            }

// this buffer was filled, we save it and go to the next one
            if ($separate_files == 'database') {
                self::saveObjectInBuffer('table_' . $table);
            }

// now export the triggers (needs to be done after the data because
            // triggers can modify already imported tables)
            if (isset($GLOBALS['sql_create_trigger']) && ($whatStrucOrData == 'structure'
                || $whatStrucOrData == 'structure_and_data')
                && in_array($table, $table_structure)
            ) {
                if (! $export_plugin->exportStructure(
                    $db, $table, $crlf, $err_url, 'triggers',
                    $export_type, $do_relation, $do_comments,
                    $do_mime, $do_dates, $aliases
                )) {
                    break;
                }

if ($separate_files == 'database') {
                    self::saveObjectInBuffer('table_' . $table, true);
                }
            }

}

if (isset($GLOBALS['sql_create_view'])) {

foreach ($views as $view) {
                // no data export for a view
                if ($whatStrucOrData == 'structure'
                    || $whatStrucOrData == 'structure_and_data'
                ) {
                    if (! $export_plugin->exportStructure(
                        $db, $view, $crlf, $err_url, 'create_view',
                        $export_type, $do_relation, $do_comments,
                        $do_mime, $do_dates, $aliases
                    )) {
                        break;
                    }

if ($separate_files == 'database') {
                        self::saveObjectInBuffer('view_' . $view);
                    }
                }
            }

}

if (! $export_plugin->exportDBFooter($db)) {
            return;
        }

// export metadata related to this db
        if (isset($GLOBALS['sql_metadata'])) {
            // Types of metadata to export.
            // In the future these can be allowed to be selected by the user
            $metadataTypes = self::getMetadataTypes();
            $export_plugin->exportMetadata($db, $tables, $metadataTypes);

if ($separate_files == 'database') {
                self::saveObjectInBuffer('metadata');
            }
        }

if ($separate_files == 'database') {
            self::saveObjectInBuffer('extra');
        }

if ($separate_files == 'database') {
                self::saveObjectInBuffer('events');
            }
        }
    }

/**
     * Export at the table level
     *
     * @param string       $db              the database to export
     * @param string       $table           the table to export
     * @param string       $whatStrucOrData structure or data or both
     * @param ExportPlugin $export_plugin   the selected export plugin
     * @param string       $crlf            end of line character(s)
     * @param string       $err_url         the URL in case of error
     * @param string       $export_type     the export type
     * @param bool         $do_relation     whether to export relation info
     * @param bool         $do_comments     whether to add comments
     * @param bool         $do_mime         whether to add MIME info
     * @param bool         $do_dates        whether to add dates
     * @param string       $allrows         whether "dump all rows" was ticked
     * @param string       $limit_to        upper limit
     * @param string       $limit_from      starting limit
     * @param string       $sql_query       query for which exporting is requested
     * @param array        $aliases         Alias information for db/table/column
     *
     * @return void
     */
    public static function exportTable(
        $db, $table, $whatStrucOrData, $export_plugin, $crlf, $err_url,
        $export_type, $do_relation, $do_comments, $do_mime, $do_dates,
        $allrows, $limit_to, $limit_from, $sql_query, array $aliases
    ) {
        $db_alias = !empty($aliases[$db]['alias'])
            ? $aliases[$db]['alias'] : '';
        if (! $export_plugin->exportDBHeader($db, $db_alias)) {
            return;
        }
        if (isset($allrows)
            && $allrows == '0'
            && $limit_to > 0
            && $limit_from >= 0
        ) {
            $add_query  = ' LIMIT '
                        . (($limit_from > 0) ? $limit_from . ', ' : '')
                        . $limit_to;
        } else {
            $add_query  = '';
        }

$_table = new Table($table, $db);
        $is_view = $_table->isView();
        if ($whatStrucOrData == 'structure'
            || $whatStrucOrData == 'structure_and_data'
        ) {

if ($is_view) {

if (isset($GLOBALS['sql_create_view'])) {
                    if (! $export_plugin->exportStructure(
                        $db, $table, $crlf, $err_url, 'create_view',
                        $export_type, $do_relation, $do_comments,
                        $do_mime, $do_dates, $aliases
                    )) {
                        return;
                    }
                }

} elseif (isset($GLOBALS['sql_create_table'])) {

if (! $export_plugin->exportStructure(
                    $db, $table, $crlf, $err_url, 'create_table',
                    $export_type, $do_relation, $do_comments,
                    $do_mime, $do_dates, $aliases
                )) {
                    return;
                }

}

}
        // If this is an export of a single view, we have to export data;
        // for example, a PDF report
        // if it is a merge table, no data is exported
        if ($whatStrucOrData == 'data'
            || $whatStrucOrData == 'structure_and_data'
        ) {
            if (! empty($sql_query)) {
                // only preg_replace if needed
                if (! empty($add_query)) {
                    // remove trailing semicolon before adding a LIMIT
                    $sql_query = preg_replace('%;\s*$%', '', $sql_query);
                }
                $local_query = $sql_query . $add_query;
                $GLOBALS['dbi']->selectDb($db);
            } else {
                // Data is exported only for Non-generated columns
                $tableObj = new Table($table, $db);
                $nonGeneratedCols = $tableObj->getNonGeneratedColumns(true);

$local_query  = 'SELECT ' . implode(', ', $nonGeneratedCols)
                    .  ' FROM ' . Util::backquote($db)
                    . '.' . Util::backquote($table) . $add_query;
            }
            if (! $export_plugin->exportData(
                $db, $table, $crlf, $err_url, $local_query, $aliases
            )) {
                return;
            }
        }
        // now export the triggers (needs to be done after the data because
        // triggers can modify already imported tables)
        if (isset($GLOBALS['sql_create_trigger']) && ($whatStrucOrData == 'structure'
            || $whatStrucOrData == 'structure_and_data')
        ) {
            if (! $export_plugin->exportStructure(
                $db, $table, $crlf, $err_url, 'triggers',
                $export_type, $do_relation, $do_comments,
                $do_mime, $do_dates, $aliases
            )) {
                return;
            }
        }
        if (! $export_plugin->exportDBFooter($db)) {
            return;
        }

if (isset($GLOBALS['sql_metadata'])) {
            // Types of metadata to export.
            // In the future these can be allowed to be selected by the user
            $metadataTypes = self::getMetadataTypes();
            $export_plugin->exportMetadata($db, $table, $metadataTypes);
        }
    }

/**
     * Loads correct page after doing export
     *
     * @param string $db          the database name
     * @param string $table       the table name
     * @param string $export_type Export type
     *
     * @return void
     */
    public static function showPage($db, $table, $export_type)
    {
        global $cfg;
        if ($export_type == 'server') {
            $active_page = 'server_export.php';
            include_once 'server_export.php';
        } elseif ($export_type == 'database') {
            $active_page = 'db_export.php';
            include_once 'db_export.php';
        } else {
            $active_page = 'tbl_export.php';
            include_once 'tbl_export.php';
        }
        exit();
    }

/**
     * Merge two alias arrays, if array1 and array2 have
     * conflicting alias then array2 value is used if it
     * is non empty otherwise array1 value.
     *
     * @param array $aliases1 first array of aliases
     * @param array $aliases2 second array of aliases
     *
     * @return array resultant merged aliases info
     */
    public static function mergeAliases(array $aliases1, array $aliases2)
    {
        // First do a recursive array merge
        // on aliases arrays.
        $aliases = array_merge_recursive($aliases1, $aliases2);
        // Now, resolve conflicts in aliases, if any
        foreach ($aliases as $db_name => $db) {
            // If alias key is an array then
            // it is a merge conflict.
            if (isset($db['alias']) && is_array($db['alias'])) {
                $val1 = $db['alias'][0];
                $val2 = $db['alias'][1];
                // Use aliases2 alias if non empty
                $aliases[$db_name]['alias']
                    = empty($val2) ? $val1 : $val2;
            }
            if (!isset($db['tables'])) {
                continue;
            }
            foreach ($db['tables'] as $tbl_name => $tbl) {
                if (isset($tbl['alias']) && is_array($tbl['alias'])) {
                    $val1 = $tbl['alias'][0];
                    $val2 = $tbl['alias'][1];
                    // Use aliases2 alias if non empty
                    $aliases[$db_name]['tables'][$tbl_name]['alias']
                        = empty($val2) ? $val1 : $val2;
                }
                if (!isset($tbl['columns'])) {
                    continue;
                }
                foreach ($tbl['columns'] as  $col => $col_as) {
                    if (isset($col_as) && is_array($col_as)) {
                        $val1 = $col_as[0];
                        $val2 = $col_as[1];
                        // Use aliases2 alias if non empty
                        $aliases[$db_name]['tables'][$tbl_name]['columns'][$col]
                            = empty($val2) ? $val1 : $val2;
                    }
                };
            };
        }
        return $aliases;
    }

/**
     * Locks tables
     *
     * @param string $db       database name
     * @param array  $tables   list of table names
     * @param string $lockType lock type; "[LOW_PRIORITY] WRITE" or "READ [LOCAL]"
     *
     * @return mixed result of the query
     */
    public static function lockTables($db, array $tables, $lockType = "WRITE")
    {
        $locks = array();
        foreach ($tables as $table) {
            $locks[] = Util::backquote($db) . "."
                . Util::backquote($table) . " " . $lockType;
        }

$sql = "LOCK TABLES " . implode(", ", $locks);
        return $GLOBALS['dbi']->tryQuery($sql);
    }

/**
     * Releases table locks
     *
     * @return mixed result of the query
     */
    public static function unlockTables()
    {
        return $GLOBALS['dbi']->tryQuery("UNLOCK TABLES");
    }

/**
     * Returns all the metadata types that can be exported with a database or a table
     *
     * @return string[] metadata types.
     */
    public static function getMetadataTypes()
    {
        return array(
            'column_info',
            'table_uiprefs',
            'tracking',
            'bookmark',
            'relation',
            'table_coords',
            'pdf_pages',
            'savedsearches',
            'central_columns',
            'export_templates',
        );
    }

/**
     * Returns the checked clause, depending on the presence of key in array
     *
     * @param string $key   the key to look for
     * @param array  $array array to verify
     *
     * @return string the checked clause
     */
    public static function getCheckedClause($key, array $array)
    {
        if (in_array($key, $array)) {
            return ' checked="checked"';
        }

return '';
    }

/**
     * get all the export options and verify
     * call and include the appropriate Schema Class depending on $export_type
     *
     * @param string $export_type format of the export
     *
     * @return void
     */
    public static function processExportSchema($export_type)
    {
        /**
         * default is PDF, otherwise validate it's only letters a-z
         */
        if (! isset($export_type) || ! preg_match('/^[a-zA-Z]+$/', $export_type)) {
            $export_type = 'pdf';
        }

// sanitize this parameter which will be used below in a file inclusion
        $export_type = Core::securePath($export_type);

// get the specific plugin
        /* @var $export_plugin SchemaPlugin */
        $export_plugin = Plugins::getPlugin(
            "schema",
            $export_type,
            'libraries/classes/Plugins/Schema/'
        );

// Check schema export type
        if (! isset($export_plugin)) {
            Core::fatalError(__('Bad type!'));
        }

$GLOBALS['dbi']->selectDb($_POST['db']);
        $export_plugin->exportSchema($_POST['db']);
    }
}