lang['Backup_explain']; ?>
"; $message = ( empty($store_path) ) ? $user->lang['Backup_download'] : $user->lang['Backup_writing']; page_header($user->lang['DB_Backup'], $meta); page_message($user->lang['DB_Backup'], $message); 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->addFile(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_admin_log('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); message_die(MESSAGE, $user->lang['Backup_success']); } exit; break; case 'restore': 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($HTTP_POST_FILES['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) ) { message_die(MESSAGE, $user->lang['Restore_Error_no_file']); } $ext = substr($filename, strrpos($filename, '.') + 1); if ( !preg_match('/^(sql|gz|bz2)$/', $ext) ) { message_die(MESSAGE, $user->lang['Restore_Error_filename']); } if ( ( !extension_loaded('zlib') && $ext == 'gz' ) || ( !extension_loaded('zip') && $ext == 'zip' ) || ( $ext == 'bz2' && !extension_loaded('bz2') ) ) { message_die(MESSAGE, $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; default; $sql_query = fread(fopen($file_tmpname, 'r'), filesize($file_tmpname)); } if ( $sql_query != '' ) { // Strip out sql comments... $sql_query = 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_admin_log('log_db_restore'); message_die(MESSAGE, $user->lang['Restore_success']); } // // Restore page // page_header($user->lang['DB_Restore']); ?>lang['Restore_explain']; ?>
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); if(!result) { message_die(GENERAL_ERROR, "Failed in get_table_def (show fields)", "", __LINE__, __FILE__, $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']; } while(list($x, $columns) = @each($index)) { $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 (eregi("char|text|bool", $aryType[$i])) { $strQuote = "'"; $strEmpty = ""; $strVal = addslashes($strVal); } elseif (eregi("date|timestamp", $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 = ereg_replace(",$", "", $schema_vals); $schema_vals = ereg_replace("^ ", "", $schema_vals); $schema_fields = ereg_replace(",$", "", $schema_fields); $schema_fields = ereg_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 = ereg_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 = ereg_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; } // // Zip creation class from phpMyAdmin 2.3.0 (c) Tobias Ratschiller, Olivier Mller, Loc Chapeaux, Marc Delisle // http://www.phpmyadmin.net/ // // Based on work by Eric Mueller and Denis125 // Official ZIP file format: http://www.pkware.com/appnote.txt // class zipfile { var $datasec = array(); var $ctrl_dir = array(); var $eof_ctrl_dir = "\x50\x4b\x05\x06\x00\x00\x00\x00"; var $old_offset = 0; function unix2DosTime($unixtime = 0) { $timearray = ( $unixtime == 0 ) ? getdate() : getdate($unixtime); if ($timearray['year'] < 1980) { $timearray['year'] = 1980; $timearray['mon'] = 1; $timearray['mday'] = 1; $timearray['hours'] = 0; $timearray['minutes'] = 0; $timearray['seconds'] = 0; } return ( ( $timearray['year'] - 1980) << 25 ) | ( $timearray['mon'] << 21 ) | ( $timearray['mday'] << 16 ) | ( $timearray['hours'] << 11 ) | ( $timearray['minutes'] << 5 ) | ( $timearray['seconds'] >> 1 ); } function addFile($data, $name, $time = 0) { $name = str_replace('\\', '/', $name); $dtime = dechex($this->unix2DosTime($time)); $hexdtime = '\x' . $dtime[6] . $dtime[7] . '\x' . $dtime[4] . $dtime[5] . '\x' . $dtime[2] . $dtime[3] . '\x' . $dtime[0] . $dtime[1]; eval('$hexdtime = "' . $hexdtime . '";'); $fr = "\x50\x4b\x03\x04"; $fr .= "\x14\x00"; // ver needed to extract $fr .= "\x00\x00"; // gen purpose bit flag $fr .= "\x08\x00"; // compression method $fr .= $hexdtime; // last mod time and date $unc_len = strlen($data); $crc = crc32($data); $zdata = gzcompress($data); $zdata = substr(substr($zdata, 0, strlen($zdata) - 4), 2); // fix crc bug $c_len = strlen($zdata); $fr .= pack('V', $crc); // crc32 $fr .= pack('V', $c_len); // compressed filesize $fr .= pack('V', $unc_len); // uncompressed filesize $fr .= pack('v', strlen($name)); // length of filename $fr .= pack('v', 0); // extra field length $fr .= $name; // "file data" segment $fr .= $zdata; // "data descriptor" segment (optional but necessary if archive is not // served as file) $fr .= pack('V', $crc); // crc32 $fr .= pack('V', $c_len); // compressed filesize $fr .= pack('V', $unc_len); // uncompressed filesize // add this entry to array $this -> datasec[] = $fr; $new_offset = strlen(implode('', $this->datasec)); // now add to central directory record $cdrec = "\x50\x4b\x01\x02"; $cdrec .= "\x00\x00"; // version made by $cdrec .= "\x14\x00"; // version needed to extract $cdrec .= "\x00\x00"; // gen purpose bit flag $cdrec .= "\x08\x00"; // compression method $cdrec .= $hexdtime; // last mod time & date $cdrec .= pack('V', $crc); // crc32 $cdrec .= pack('V', $c_len); // compressed filesize $cdrec .= pack('V', $unc_len); // uncompressed filesize $cdrec .= pack('v', strlen($name) ); // length of filename $cdrec .= pack('v', 0 ); // extra field length $cdrec .= pack('v', 0 ); // file comment length $cdrec .= pack('v', 0 ); // disk number start $cdrec .= pack('v', 0 ); // internal file attributes $cdrec .= pack('V', 32 ); // external file attributes - 'archive' bit set $cdrec .= pack('V', $this -> old_offset ); // relative offset of local header $this -> old_offset = $new_offset; $cdrec .= $name; // optional extra field, file comment goes here // save to central directory $this -> ctrl_dir[] = $cdrec; } function file() { $data = implode('', $this -> datasec); $ctrldir = implode('', $this -> ctrl_dir); return $data . $ctrldir . $this -> eof_ctrl_dir . pack('v', sizeof($this -> ctrl_dir)) . // total # of entries "on this disk" pack('v', sizeof($this -> ctrl_dir)) . // total # of entries overall pack('V', strlen($ctrldir)) . // size of central dir pack('V', strlen($data)) . // offset to start of central dir "\x00\x00"; // .zip file comment length } } // // End Functions // ----------------------------------------------- ?>BѠw ~Iɘ`%c..=*PXbw "x8$#d8<^۠`S֓q"wF[ <y %G#'x$K:iw?Ir@ZdƎ;y-gr ga+Y2%3ܜ:oMZ2PL vXHM*0Po#fG"+!:uitՏ3ݱ$*ٷV Z5'9Hpf~ }p= 9\ }֤üfp )sQyd"ȦTj ,ELf6A)֬-3ѪK>Q4 G?`w# ͲAd T!fFs&9wP8'(mݡ!uIq0v8O_ tV+x TK:@]L&MK1zyȍ&pe1s8gK,NN yfZ%~o5Ln-}g kiKOj(BtǛ:E vloyej->znﰂIJwV xC0i2H9yQj!҆3+vfijC ^W9C:jmG>xMS*3*alÝy*[';r <@[a cJS-Ӷ;b%>lrYFpaA**hq@% 0 Bt旡s7i%ճMrdp +%c ~ S(5U̢ݔD[ ϒS 1 &҈YIKk*<4NfR{ƜJ:z#yL|XDkfL+]yPR8AC ^x<_sjjRu5|b' ^J ॶ;孛,^Őُ͠\ُ(Ș F/ ]Sώi1ٞTx/0\@w6b_(!U3]M]m]ߏaY4b {d`QNOu>YYL gNQVB%ιSz,,DYm7{J*(}7 IԎ`bp+@RJ=O91{T {iw> 3_p&-