-<?php

-/**

-*

-* @package acp

-* @version $Id$

-* @copyright (c) 2005 phpBB Group

-* @license http://opensource.org/licenses/gpl-license.php GNU Public License

-*

-*/

-

-/**

-*/

-if (!empty($setmodules))

-{

- $filename = basename(__FILE__);

- $module['DB']['DB_BACKUP'] = ($auth->acl_get('a_backup')) ? $filename . "$SID&amp;mode=backup" : '';

-

- $file_uploads = @ini_get('file_uploads');

- if (!empty($file_uploads) && $file_uploads !== 0 && strtolower($file_uploads) != 'off' && $auth->acl_get('a_restore'))

- {

- $module['DB']['DB_RESTORE'] = "$filename$SID&amp;mode=restore";

- }

-

- return;

-}

-

-define('IN_PHPBB', 1);

-// Load default header

-$phpbb_root_path = '../';

-$phpEx = substr(strrchr(__FILE__, '.'), 1);

-require('pagestart.' . $phpEx);

-include($phpbb_root_path . 'includes/functions_compress.'.$phpEx);

-

-@set_time_limit(1200);

-

-

-// Get some vars

-$mode = (isset($_GET['mode'])) ? htmlspecialchars($_GET['mode']) : '';

-$action = (isset($_REQUEST['action'])) ? htmlspecialchars($_REQUEST['action']) : '';

-

-

-// --------------------

-// Begin program proper

-// --------------------

-switch($mode)

-{

- case 'backup':

- if (!$auth->acl_get('a_backup'))

- {

- trigger_error($user->lang['NO_ADMIN']);

- }

-

- $db_type = '';

- switch (SQL_LAYER)

- {

- case 'oracle':

- $db_type = 'Oracle';

- break;

- case 'odbc':

- $db_type = 'ODBC';

- break;

- case 'mssql':

- $db_type = 'MSSQL';

- break;

- }

-

- if ($db_type)

- {

- trigger_error($user->lang['Backups_not_supported']);

- }

-

- $additional_tables = (isset($_REQUEST['tables'])) ? htmlspecialchars($_REQUEST['tables']) : '';

- $backup_type = (isset($_REQUEST['type'])) ? intval($_REQUEST['type']) : false;

- $search = (!empty($_REQUEST['search'])) ? true : false;

- $store = (!empty($_REQUEST['store'])) ? true : false;

- $compress = (isset($_REQUEST['compress'])) ? htmlspecialchars($_REQUEST['compress']) : '';

-

- if (!isset($_POST['backupstart']) && !isset($_GET['backupstart']))

- {

- adm_page_header($user->lang['DB_BACKUP']);

-

-?>

-

-<h1><?php echo $user->lang['DB_BACKUP']; ?></h1>

-

-<p><?php echo $user->lang['Backup_explain']; ?></p>

-

-<form method="post" action="<?php echo "admin_database.$phpEx$SID&amp;mode=$mode"; ?>"><table class="bg" width="95%" cellspacing="1" cellpadding="4" border="0" align="center">

- <tr>

- <th colspan="2"><?php echo $user->lang['Backup_options']; ?></th>

- </tr>

- <tr>

- <td class="row1" width="40%"><b><?php echo $user->lang['Backup_type']; ?>: </b></td>

- <td class="row2"><input type="radio" name="type" value="full" checked="checked" /> <?php echo $user->lang['Full_backup']; ?>&nbsp;&nbsp;<input type="radio" name="type" value="structure" /> <?php echo $user->lang['Structure_only']; ?>&nbsp;&nbsp;<input type="radio" name="type" value="data" /> <?php echo $user->lang['Data_only']; ?></td>

- </tr>

- <tr>

- <td class="row1"><b><?php echo $user->lang['Additional_tables']; ?>: </b><br /><span class="gensmall"><?php echo $user->lang['Additional_tables_explain']; ?></span></td>

- <td class="row2"><input class="post" type="text" name="tables" maxlength="255" size="40" /></td>

- </tr>

- <tr>

- <td class="row1"><b><?php echo $user->lang['INC_SEARCH_INDEX']; ?>: </b><br /><span class="gensmall"><?php echo $user->lang['INC_SEARCH_INDEX_EXPLAIN']; ?></span></td>

- <td class="row2"><input type="radio" name="search" value="1" checked="checked" /> <?php echo $user->lang['YES']; ?>&nbsp;&nbsp;<input type="radio" name="search" value="0" /> <?php echo $user->lang['NO']; ?></td>

- </tr>

- <tr>

- <td class="row1"><b><?php echo $user->lang['DOWNLOAD_STORE']; ?>: </b><br /><span class="gensmall"><?php echo $user->lang['DOWNLOAD_STORE_EXPLAIN']; ?></span></td>

- <td class="row2"><input type="radio" name="store" value="0" checked="checked" /> <?php echo $user->lang['EXPORT_DOWNLOAD']; ?>&nbsp;&nbsp;<input type="radio" name="store" value="1" /> <?php echo $user->lang['EXPORT_STORE']; ?></td>

- </tr>

-<?php

-

- if (@extension_loaded('zlib') || extension_loaded('bz2'))

- {

-

-?>

- <tr>

- <td class="row1"><b><?php echo $user->lang['Compress_file']; ?>: </b></td>

- <td class="row2"><input type="radio" name="compress" value="none" checked="checked" /> <?php echo $user->lang['NONE']; ?><?php

-

- if (extension_loaded('zlib'))

- {

-

-

-?>&nbsp;&nbsp;<input type="radio" name="compress" value="gzip" />.gz&nbsp;&nbsp;<input type="radio" name="compress" value="zip" />.zip<?php

-

- }

-

- if (extension_loaded('bz2'))

- {

-

-?>&nbsp;&nbsp;<input type="radio" name="compress" value="bzip" />.bz2<?php

-

- }

-

-?></td>

- </tr>

-<?php

-

- }

-

-?>

- <tr>

- <td class="cat" colspan="2" align="center"><input type="submit" name="backupstart" value="<?php echo $user->lang['Start_backup']; ?>" class="btnmain" /></td>

- </tr>

-</table></form>

-

-<?php

-

- break;

- }

- else if (!isset($_POST['startdownload']) && !isset($_GET['startdownload']))

- {

- $meta = "<meta http-equiv=\"refresh\" content=\"0;url=admin_database.$phpEx?mode=backup&amp;type=$backup_type&amp;tables=" . quotemeta($additional_tables) . "&amp;search=$search&amp;store=" . quotemeta($store_path) . "&amp;compress=$compress&amp;backupstart=1&amp;startdownload=1\">";

-

- $message = (empty($store_path)) ? $user->lang['Backup_download'] : $user->lang['Backup_writing'];

-

- adm_page_header($user->lang['DB_Backup'], $meta);

- page_message($user->lang['DB_Backup'], $message);

- adm_page_footer();

- }

-

- $tables = (SQL_LAYER != 'postgresql') ? mysql_get_tables() : pg_get_tables();

- @sort($tables);

-

- if (!empty($additional_tables))

- {

- $additional_tables = explode(',', $additional_tables);

-

- for($i = 0; $i < count($additional_tables); $i++)

- {

- $tables[] = trim($additional_tables[$i]);

- }

- unset($additional_tables);

- }

-

- // Enable output buffering

- @ob_start();

- @ob_implicit_flush(0);

-

- // Build the sql script file...

- echo "#\n";

- echo "# phpBB Backup Script\n";

- echo "# Dump of tables for $dbname\n";

- echo "#\n# DATE : " . gmdate("d-m-Y H:i:s", time()) . " GMT\n";

- echo "#\n";

-

- if (SQL_LAYER == 'postgresql')

- {

- echo "\n" . pg_get_sequences("\n", $backup_type);

- }

-

- for($i = 0; $i < count($tables); $i++)

- {

- $table_name = $tables[$i];

-

- if (SQL_LAYER != 'mysql4')

- {

- $table_def_function = "get_table_def_" . SQL_LAYER;

- $table_content_function = "get_table_content_" . SQL_LAYER;

- }

- else

- {

- $table_def_function = "get_table_def_mysql";

- $table_content_function = "get_table_content_mysql";

- }

-

- if ($backup_type != 'data')

- {

- echo "#\n# TABLE: " . $table_name . "\n#\n";

- echo $table_def_function($table_name, "\n") . "\n";

- }

-

- if ($backup_type != 'structure')

- {

- //

- // Skip search table data?

- //

- if ($search || (!$search && !preg_match('/search_word/', $table_name)))

- {

- $table_content_function($table_name, "output_table_content");

- }

- }

- }

-

- // Flush the buffer, send the file

- switch ($compress)

- {/*

- case 'gzip':

- $extension = 'sql.gz';

- $contents = gzencode(ob_get_contents());

- ob_end_clean();

- break;

-

- case 'zip':

- $extension = 'zip';

- $zip = new zipfile;

- $zip->add_file(ob_get_contents(), "phpbb_db_backup.sql", time());

- ob_end_clean();

- $contents = $zip->file();

- break;

-

- case 'bzip':

- $extension = 'bz2';

- $contents = bzcompress(ob_get_contents());

- ob_end_clean();

- break;*/

-

- default:

- $extension = 'sql';

- $contents = ob_get_contents();

- ob_end_clean();

- }

-

- add_log('admin', 'log_db_backup');

-

- if (empty($store_path))

- {

- header("Pragma: no-cache");

- header("Content-Type: text/x-delimtext; name=\"phpbb_db_backup.$extension\"");

- header("Content-disposition: attachment; filename=phpbb_db_backup.$extension");

-

- echo $contents;

- unset($contents);

- }

- else

- {

- if (!($fp = fopen('./../' . $store_path . "/phpbb_db_backup.$extension", 'wb')))

- {

- message_die(ERROR, 'Could not open backup file');

- }

-

- if (!fwrite($fp, $contents))

- {

- message_die(ERROR, 'Could not write backup file content');

- }

-

- fclose($fp);

- unset($contents);

-

- trigger_error($user->lang['Backup_success']);

- }

-

- exit;

- break;

-

- case 'restore':

- if (!$auth->acl_get('a_restore'))

- {

- trigger_error($user->lang['NO_ADMIN']);

- }

-

- if (isset($_POST['restorestart']))

- {

- // Handle the file upload ....

- // If no file was uploaded report an error...

- if (!empty($_POST['local']))

- {

- $file_tmpname = './../' . str_replace('\\\\', '/', $_POST['local']);

- $filename = substr($file_tmpname, strrpos($file_tmpname, '/'));

- }

- else

- {

- $filename = (!empty($_POST['backup_file']['name'])) ? $HTTP_POST_FILES['backup_file']['name'] : '';

- $file_tmpname = ($HTTP_POST_FILES['backup_file']['tmp_name'] != 'none') ? $HTTP_POST_FILES['backup_file']['tmp_name'] : '';

- }

-

- if ($file_tmpname == '' || $filename == '' || !file_exists($file_tmpname))

- {

- trigger_error($user->lang['Restore_Error_no_file']);

- }

-

- $ext = substr($filename, strrpos($filename, '.') + 1);

-

- if (!preg_match('/^(sql|gz|bz2)$/', $ext))

- {

- trigger_error($user->lang['Restore_Error_filename']);

- }

-

- if ((!extension_loaded('zlib') && $ext == 'gz') || (!extension_loaded('zip') && $ext == 'zip') || ($ext == 'bz2' && !extension_loaded('bz2')))

- {

- trigger_error($user->lang['Compress_unsupported']);

- }

-

- $sql_query = '';

- switch ($ext)

- {

- case 'gz':

- $fp = gzopen($file_tmpname, 'rb');

- while (!gzeof($fp))

- {

- $sql_query .= gzgets($fp, 100000);

- }

- gzclose($fp);

- break;

-

- case 'bz2':

- $sql_query = bzdecompress(fread(fopen($file_tmpname, 'rb'), filesize($file_tmpname)));

- break;

-

- case 'zip':

-

-

- default;

- $sql_query = fread(fopen($file_tmpname, 'r'), filesize($file_tmpname));

- }

-

- if ($sql_query != '')

- {

- // Strip out sql comments...

- remove_remarks($sql_query);

- $pieces = split_sql_file($sql_query, ';');

-

- $sql_count = count($pieces);

- for($i = 0; $i < $sql_count; $i++)

- {

- $sql = trim($pieces[$i]);

-

- if (!empty($sql) && $sql[0] != '#')

- {

- $db->sql_query($sql);

- }

- }

- }

-

- add_log('admin', 'log_db_restore');

-

- trigger_error($user->lang['Restore_success']);

- }

-

- //

- // Restore page

- //

- adm_page_header($user->lang['DB_RESTORE']);

-

-?>

-

-<h1><?php echo $user->lang['DB_RESTORE']; ?></h1>

-

-<p><?php echo $user->lang['Restore_explain']; ?></p>

-

-<form enctype="multipart/form-data" method="post" action="<?php echo "admin_database.$phpEx$SID&amp;mode=$mode"; ?>"><table class="bg" width="80%" cellspacing="1" cellpadding="4" border="0" align="center">

- <th colspan="2"><?php echo $user->lang['Select_file']; ?></th>

- </tr>

- <tr>

- <td class="row1"><?php echo $user->lang['Upload_file']; ?>: <br /><span class="gensmall"><?php

-

- echo $user->lang['Supported_extensions'];

-

- $types = ': <u>sql</u>';

- if (extension_loaded('zlib'))

- {

- $types .= ', <u>sql.gz</u>';

- }

- if (extension_loaded('bz2'))

- {

- $types .= ', <u>bz2</u>';

- }

-

- echo $types;

-

-?></span></td>

- <td class="row2"><input type="file" name="backup_file" /></td>

- </tr>

- <tr>

- <td class="row1"><?php echo $user->lang['Local_backup_file']; ?>: <br /><span class="gensmall"><?php echo $user->lang['Local_backup_file_explain']; ?></span></td>

- <td class="row2"><input type="text" name="local" size="40" /></td>

- </tr>

- <tr>

- <td class="cat" colspan="2" align="center"><input type="submit" name="restorestart" value="<?php echo $user->lang['Start_Restore']; ?>" class="btnmain" /></td>

- </tr>

-</table></form>

-

-<?php

-

- break;

-

- default:

- trigger_error($user->lang['No_admin']);

- exit;

-

-}

-

-adm_page_footer();

-

-// -----------------------------------------------

-// Begin Functions

-//

-

-//

-// Table defns (not from phpMyAdmin)

-//

-function mysql_get_tables()

-{

- global $db, $table_prefix;

-

- $tables = array();

-

- $result = mysql_list_tables($db->dbname, $db->db_connect_id);

- if ($row = $db->sql_fetchrow($result))

- {

- do

- {

- if (preg_match('/^' . $table_prefix . '/', $row[0]))

- {

- $tables[] = $row[0];

- }

- }

- while ($row = $db->sql_fetchrow($result));

- }

-

- return $tables;

-}

-

-//

-// The following functions are adapted from phpMyAdmin and upgrade_20.php

-//

-// This function is used for grabbing the sequences for postgres...

-//

-function pg_get_sequences($crlf, $backup_type)

-{

- global $db;

-

- $get_seq_sql = "SELECT relname FROM pg_class WHERE NOT relname ~ 'pg_.*'

- AND relkind = 'S' ORDER BY relname";

-

- $seq = $db->sql_query($get_seq_sql);

-

- if (!$num_seq = $db->sql_numrows($seq))

- {

-

- $return_val = "# No Sequences Found $crlf";

-

- }

- else

- {

- $return_val = "# Sequences $crlf";

- $i_seq = 0;

-

- while($i_seq < $num_seq)

- {

- $row = $db->sql_fetchrow($seq);

- $sequence = $row['relname'];

-

- $get_props_sql = "SELECT * FROM $sequence";

- $seq_props = $db->sql_query($get_props_sql);

-

- if ($db->sql_numrows($seq_props) > 0)

- {

- $row1 = $db->sql_fetchrow($seq_props);

-

- if ($backup_type == 'structure')

- {

- $row['last_value'] = 1;

- }

-

- $return_val .= "CREATE SEQUENCE $sequence start " . $row['last_value'] . ' increment ' . $row['increment_by'] . ' maxvalue ' . $row['max_value'] . ' minvalue ' . $row['min_value'] . ' cache ' . $row['cache_value'] . "; $crlf";

-

- } // End if numrows > 0

-

- if (($row['last_value'] > 1) && ($backup_type != 'structure'))

- {

- $return_val .= "SELECT NEXTVALE('$sequence'); $crlf";

- unset($row['last_value']);

- }

-

- $i_seq++;

-

- } // End while..

-

- } // End else...

-

- return $returnval;

-

-} // End function...

-

-//

-// The following functions will return the "CREATE TABLE syntax for the

-// varying DBMS's

-//

-// This function returns, will return the table def's for postgres...

-//

-function get_table_def_postgresql($table, $crlf)

-{

- global $db;

-

- $schema_create = "";

- //

- // Get a listing of the fields, with their associated types, etc.

- //

-

- $field_query = "SELECT a.attnum, a.attname AS field, t.typname as type, a.attlen AS length, a.atttypmod as lengthvar, a.attnotnull as notnull

- FROM pg_class c, pg_attribute a, pg_type t

- WHERE c.relname = '$table'

- AND a.attnum > 0

- AND a.attrelid = c.oid

- AND a.atttypid = t.oid

- ORDER BY a.attnum";

- $result = $db->sql_query($field_query);

-

- if (!$result)

- {

- message_die(GENERAL_ERROR, "Failed in get_table_def (show fields)", "", __LINE__, __FILE__, $field_query);

- } // end if..

-

- $schema_create .= "DROP TABLE $table;$crlf";

-

- //

- // Ok now we actually start building the SQL statements to restore the tables

- //

-

- $schema_create .= "CREATE TABLE $table($crlf";

-

- while ($row = $db->sql_fetchrow($result))

- {

- //

- // Get the data from the table

- //

- $sql_get_default = "SELECT d.adsrc AS rowdefault

- FROM pg_attrdef d, pg_class c

- WHERE (c.relname = '$table')

- AND (c.oid = d.adrelid)

- AND d.adnum = " . $row['attnum'];

- $def_res = $db->sql_query($sql_get_default);

-

- if (!$def_res)

- {

- unset($row['rowdefault']);

- }

- else

- {

- $row['rowdefault'] = @pg_result($def_res, 0, 'rowdefault');

- }

-

- if ($row['type'] == 'bpchar')

- {

- // Internally stored as bpchar, but isn't accepted in a CREATE TABLE statement.

- $row['type'] = 'char';

- }

-

- $schema_create .= ' ' . $row['field'] . ' ' . $row['type'];

-

- if (eregi('char', $row['type']))

- {

- if ($row['lengthvar'] > 0)

- {

- $schema_create .= '(' . ($row['lengthvar'] -4) . ')';

- }

- }

-

- if (eregi('numeric', $row['type']))

- {

- $schema_create .= '(';

- $schema_create .= sprintf("%s,%s", (($row['lengthvar'] >> 16) & 0xffff), (($row['lengthvar'] - 4) & 0xffff));

- $schema_create .= ')';

- }

-

- if (!empty($row['rowdefault']))

- {

- $schema_create .= ' DEFAULT ' . $row['rowdefault'];

- }

-

- if ($row['notnull'] == 't')

- {

- $schema_create .= ' NOT NULL';

- }

-

- $schema_create .= ",$crlf";

-

- }

- //

- // Get the listing of primary keys.

- //

-

- $sql_pri_keys = "SELECT ic.relname AS index_name, bc.relname AS tab_name, ta.attname AS column_name, i.indisunique AS unique_key, i.indisprimary AS primary_key

- FROM pg_class bc, pg_class ic, pg_index i, pg_attribute ta, pg_attribute ia

- WHERE (bc.oid = i.indrelid)

- AND (ic.oid = i.indexrelid)

- AND (ia.attrelid = i.indexrelid)

- AND (ta.attrelid = bc.oid)

- AND (bc.relname = '$table')

- AND (ta.attrelid = i.indrelid)

- AND (ta.attnum = i.indkey[ia.attnum-1])

- ORDER BY index_name, tab_name, column_name ";

- $result = $db->sql_query($sql_pri_keys);

-

- if (!$result)

- {

- message_die(GENERAL_ERROR, "Failed in get_table_def (show fields)", "", __LINE__, __FILE__, $sql_pri_keys);

- }

-

- while ($row = $db->sql_fetchrow($result))

- {

- if ($row['primary_key'] == 't')

- {

- if (!empty($primary_key))

- {

- $primary_key .= ', ';

- }

-

- $primary_key .= $row['column_name'];

- $primary_key_name = $row['index_name'];

-

- }

- else

- {

- //

- // We have to store this all this info because it is possible to have a multi-column key...

- // we can loop through it again and build the statement

- //

- $index_rows[$row['index_name']]['table'] = $table;

- $index_rows[$row['index_name']]['unique'] = ($row['unique_key'] == 't') ? ' UNIQUE ' : '';

- $index_rows[$row['index_name']]['column_names'] .= $row['column_name'] . ', ';

- }

- }

-

- if (!empty($index_rows))

- {

- while(list($idx_name, $props) = each($index_rows))

- {

- $props['column_names'] = ereg_replace(", $", "" , $props['column_names']);

- $index_create .= 'CREATE ' . $props['unique'] . " INDEX $idx_name ON $table (" . $props['column_names'] . ");$crlf";

- }

- }

-

- if (!empty($primary_key))

- {

- $schema_create .= " CONSTRAINT $primary_key_name PRIMARY KEY ($primary_key),$crlf";

- }

-

- //

- // Generate constraint clauses for CHECK constraints

- //

- $sql_checks = "SELECT rcname as index_name, rcsrc

- FROM pg_relcheck, pg_class bc

- WHERE rcrelid = bc.oid

- AND bc.relname = '$table'

- AND NOT EXISTS (

- SELECT *

- FROM pg_relcheck as c, pg_inherits as i

- WHERE i.inhrelid = pg_relcheck.rcrelid

- AND c.rcname = pg_relcheck.rcname

- AND c.rcsrc = pg_relcheck.rcsrc

- AND c.rcrelid = i.inhparent

- )";

- $result = $db->sql_query($sql_checks);

-

- if (!$result)

- {

- message_die(GENERAL_ERROR, "Failed in get_table_def (show fields)", "", __LINE__, __FILE__, $sql_checks);

- }

-

- //

- // Add the constraints to the sql file.

- //

- while ($row = $db->sql_fetchrow($result))

- {

- $schema_create .= ' CONSTRAINT ' . $row['index_name'] . ' CHECK ' . $row['rcsrc'] . ",$crlf";

- }

-

- $schema_create = ereg_replace(',' . $crlf . '$', '', $schema_create);

- $index_create = ereg_replace(',' . $crlf . '$', '', $index_create);

-

- $schema_create .= "$crlf);$crlf";

-

- if (!empty($index_create))

- {

- $schema_create .= $index_create;

- }

-

- //

- // Ok now we've built all the sql return it to the calling function.

- //

- return (stripslashes($schema_create));

-

-}

-

-//

-// This function returns the "CREATE TABLE" syntax for mysql dbms...

-//

-function get_table_def_mysql($table, $crlf)

-{

- global $db;

-

- $schema_create = "";

- $field_query = "SHOW FIELDS FROM $table";

- $key_query = "SHOW KEYS FROM $table";

-

- // If the user has selected to drop existing tables when doing a restore.

- // Then we add the statement to drop the tables....

- $schema_create .= "DROP TABLE IF EXISTS $table;$crlf";

- $schema_create .= "CREATE TABLE $table($crlf";

-

- // Ok lets grab the fields...

- $result = $db->sql_query($field_query);

-

- while ($row = $db->sql_fetchrow($result))

- {

- $schema_create .= ' ' . $row['Field'] . ' ' . $row['Type'];

-

- if (!empty($row['Default']))

- {

- $schema_create .= ' DEFAULT \'' . $row['Default'] . '\'';

- }

-

- if ($row['Null'] != "YES")

- {

- $schema_create .= ' NOT NULL';

- }

-

- if ($row['Extra'] != "")

- {

- $schema_create .= ' ' . $row['Extra'];

- }

-

- $schema_create .= ",$crlf";

- }

- //

- // Drop the last ',$crlf' off ;)

- //

- $schema_create = ereg_replace(',' . $crlf . '$', "", $schema_create);

-

- //

- // Get any Indexed fields from the database...

- //

- $result = $db->sql_query($key_query);

-

- while($row = $db->sql_fetchrow($result))

- {

- $kname = $row['Key_name'];

-

- if (($kname != 'PRIMARY') && ($row['Non_unique'] == 0))

- {

- $kname = "UNIQUE|$kname";

- }

-

- if (!is_array($index[$kname]))

- {

- $index[$kname] = array();

- }

-

- $index[$kname][] = $row['Column_name'];

- }

-

- foreach ($index as $x => $columns)

- {

- $schema_create .= ", $crlf";

-

- if ($x == 'PRIMARY')

- {

- $schema_create .= ' PRIMARY KEY (' . implode($columns, ', ') . ')';

- }

- elseif (substr($x,0,6) == 'UNIQUE')

- {

- $schema_create .= ' UNIQUE ' . substr($x,7) . ' (' . implode($columns, ', ') . ')';

- }

- else

- {

- $schema_create .= " KEY $x (" . implode($columns, ', ') . ')';

- }

- }

-

- $schema_create .= "$crlf);";

-

- if (get_magic_quotes_runtime())

- {

- return stripslashes($schema_create);

- }

- else

- {

- return $schema_create;

- }

-

-} // End get_table_def_mysql

-

-

-//

-// This fuction will return a tables create definition to be used as an sql

-// statement.

-//

-//

-// The following functions Get the data from the tables and format it as a

-// series of INSERT statements, for each different DBMS...

-// After every row a custom callback function $handler gets called.

-// $handler must accept one parameter ($sql_insert);

-//

-//

-// Here is the function for postgres...

-//

-function get_table_content_postgresql($table, $handler)

-{

- global $db;

-

- // Grab all of the data from current table.

- $result = $db->sql_query("SELECT * FROM $table");

-

- $i_num_fields = $db->sql_numfields($result);

-

- for ($i = 0; $i < $i_num_fields; $i++)

- {

- $aryType[] = $db->sql_fieldtype($i, $result);

- $aryName[] = $db->sql_fieldname($i, $result);

- }

-

- $iRec = 0;

-

- while ($row = $db->sql_fetchrow($result))

- {

- unset($schema_vals);

- unset($schema_fields);

- unset($schema_insert);

-

- // Build the SQL statement to recreate the data.

- for($i = 0; $i < $i_num_fields; $i++)

- {

- $strVal = $row[$aryName[$i]];

- if (preg_match('#char|text|bool#i', $aryType[$i]))

- {

- $strQuote = "'";

- $strEmpty = "";

- $strVal = addslashes($strVal);

- }

- elseif (preg_match('#date|timestamp#i', $aryType[$i]))

- {

- if ($empty($strVal))

- {

- $strQuote = "";

- }

- else

- {

- $strQuote = "'";

- }

- }

- else

- {

- $strQuote = "";

- $strEmpty = "NULL";

- }

-

- if (empty($strVal) && $strVal != "0")

- {

- $strVal = $strEmpty;

- }

-

- $schema_vals .= " $strQuote$strVal$strQuote,";

- $schema_fields .= " $aryName[$i],";

- }

-

- $schema_vals = preg_replace('#,$#', '', $schema_vals);

- $schema_vals = preg_replace('#^ #', '', $schema_vals);

- $schema_fields = preg_replace('#,$#', '', $schema_fields);

- $schema_fields = preg_replace('#^ #', '', $schema_fields);

-

- // Take the ordered fields and their associated data and build it

- // into a valid sql statement to recreate that field in the data.

- $schema_insert = "INSERT INTO $table ($schema_fields) VALUES($schema_vals);";

-

- $handler(trim($schema_insert));

- }

-

- return(true);

-

-}// end function get_table_content_postgres...

-

-//

-// This function is for getting the data from a mysql table.

-//

-

-function get_table_content_mysql($table, $handler)

-{

- global $db;

-

- // Grab the data from the table.

- $result = $db->sql_query("SELECT * FROM $table");

-

- // Loop through the resulting rows and build the sql statement.

- $schema_insert = "";

- if ($row = $db->sql_fetchrow($result))

- {

- $schema_insert = "\n#\n# Table Data for $table\n#\n";

-

- $handler($schema_insert);

-

- do

- {

- $table_list = '(';

- $num_fields = $db->sql_numfields($result);

- //

- // Grab the list of field names.

- //

- for ($j = 0; $j < $num_fields; $j++)

- {

- $table_list .= $db->sql_fieldname($j, $result) . ', ';

- }

- //

- // Get rid of the last comma

- //

- $table_list = preg_replace('#, $#', '', $table_list);

- $table_list .= ')';

- //

- // Start building the SQL statement.

- //

- $schema_insert = "INSERT INTO $table $table_list VALUES(";

- //

- // Loop through the rows and fill in data for each column

- //

- for ($j = 0; $j < $num_fields; $j++)

- {

- if (!isset($row[$j]))

- {

- //

- // If there is no data for the column set it to null.

- // There was a problem here with an extra space causing the

- // sql file not to reimport if the last column was null in

- // any table. Should be fixed now :) JLH

- //

- $schema_insert .= ' NULL,';

- }

- elseif ($row[$j] != '')

- {

- $schema_insert .= ' \'' . addslashes($row[$j]) . '\',';

- }

- else

- {

- $schema_insert .= '\'\',';

- }

- }

- //

- // Get rid of the the last comma.

- //

- $schema_insert = preg_replace('#,$#', '', $schema_insert);

- $schema_insert .= ');';

- //

- // Go ahead and send the insert statement to the handler function.

- //

- $handler(trim($schema_insert));

- }

- while ($row = $db->sql_fetchrow($result));

- }

-

- return true;

-}

-

-function output_table_content($content)

-{

- global $tempfile;

-

- //fwrite($tempfile, $content . "\n");

- //$backup_sql .= $content . "\n";

- echo $content ."\n";

- return;

-}

-//

-// End Functions

-// -----------------------------------------------

-

-?> \ No newline at end of file