<?php
// -------------------------------------------------------------
//
// $Id$
//
// FILENAME  : admin_database.php
// STARTED   : Thu May 31, 2001
// COPYRIGHT : © 2003 phpBB Group
// WWW       : http://www.phpbb.com/
// LICENCE   : GPL vs2.0 [ see /docs/COPYING ] 
// 
// -------------------------------------------------------------

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
// -----------------------------------------------

?>