home *** CD-ROM | disk | FTP | other *** search
<?php /*************************************************************************** * upgrade.php * ------------------- * begin : Wed Sep 05 2001 * copyright : (C) 2001 The phpBB Group * email : support@phpbb.com * * $Id: upgrade.php,v 1.1.2.10 2003/03/18 23:24:01 acydburn Exp $ * ****************************************************************************/ /*************************************************************************** * * This program is free software; you can redistribute it and/or modify * it under the terms of the GNU General Public License as published by * the Free Software Foundation; either version 2 of the License, or * (at your option) any later version. * ***************************************************************************/ define('IN_PHPBB', true); $phpbb_root_path = './../'; if ( !defined('INSTALLING') ) { error_reporting (E_ERROR | E_WARNING | E_PARSE); // This will NOT report uninitialized variables set_magic_quotes_runtime(0); // Disable magic_quotes_runtime // // If we are being called from the install script then we don't need these // as they are already included. // include($phpbb_root_path . 'extension.inc'); include($phpbb_root_path . 'config.'.$phpEx); include($phpbb_root_path . 'includes/constants.'.$phpEx); include($phpbb_root_path . 'includes/functions.'.$phpEx); if( defined("PHPBB_INSTALLED") ) { redirect("../index.$phpEx"); } } // // Force the DB type to be MySQL // $dbms = 'mysql'; include($phpbb_root_path . 'includes/db.'.$phpEx); include($phpbb_root_path . 'includes/bbcode.'.$phpEx); include($phpbb_root_path . 'includes/functions_search.'.$phpEx); set_time_limit(0); // Unlimited execution time $months = array( 'Jan' => 1, 'Feb' => 2, 'Mar' => 3, 'Apr' => 4, 'May' => 5, 'Jun' => 6, 'Jul' => 7, 'Aug' => 8, 'Sep' => 9, 'Sept' => 9, 'Oct' => 10, 'Nov' => 11, 'Dec' => 12 ); // --------------- // Begin functions // function common_header() { ?> <!DOCTYPE HTML PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN"> <html> <head> <meta http-equiv="Content-Type" content="text/html; charset=ISO-8859-1"> <meta http-equiv="Content-Style-Type" content="text/css"> <style type="text/css"> <!-- /* Specifiy background images for selected styles This can't be done within the external style sheet as NS4 sees image paths relative to the page which called the style sheet (i.e. this page in the root phpBB directory) whereas all other browsers see image paths relative to the style sheet. Stupid NS again! */ th { background-image: url('../templates/subSilver/images/cellpic3.gif') } td.cat { background-image: url('../templates/subSilver/images/cellpic1.gif') } td.rowpic { background-image: url('../templates/subSilver/images/cellpic2.jpg'); background-repeat: repeat-y } td.catHead,td.catSides,td.catLeft,td.catRight,td.catBottom { background-image: url('../templates/subSilver/images/cellpic1.gif') } font,th,td,p,body { font-family: Verdana, Arial, Helvetica, sans-serif; font-size: 11pt } a:link,a:active,a:visited { font-family: Verdana, Arial, Helvetica, sans-serif; color : #006699; font-size:11pt } a:hover { font-family: Verdana, Arial, Helvetica, sans-serif; text-decoration: underline; color : #DD6900; font-size:11pt } hr { height: 0px; border: solid #D1D7DC 0px; border-top-width: 1px;} .maintitle,h1,h2 {font-weight: bold; font-size: 22px; font-family: "Trebuchet MS",Verdana, Arial, Helvetica, sans-serif; text-decoration: none; line-height : 120%; color : #000000;} .ok {color:green} /* Import the fancy styles for IE only (NS4.x doesn't use the @import function) */ @import url("../templates/subSilver/formIE.css"); --> </style> </head> <body bgcolor="#FFFFFF" text="#000000" link="#006699" vlink="#5584AA"> <table width="100%" border="0" cellspacing="0" cellpadding="10" align="center"> <tr> <td><table width="100%" border="0" cellspacing="0" cellpadding="0"> <tr> <td><img src="../templates/subSilver/images/logo_phpBB.gif" border="0" alt="Forum Home" vspace="1" /></td> <td align="center" width="100%" valign="middle"><span class="maintitle">Upgrading to phpBB 2.0</span></td> </tr> </table></td> </tr> </table> <br clear="all" /> <? return; } function common_footer() { ?> <br clear="all" /> </body> </html> <? return; } function query($sql, $errormsg) { global $db; if ( !($result = $db->sql_query($sql)) ) { print "<br><font color=\"red\">\n"; print "$errormsg<br>"; $sql_error = $db->sql_error(); print $sql_error['code'] .": ". $sql_error['message']. "<br>\n"; print "<pre>$sql</pre>"; print "</font>\n"; return FALSE; } else { return $result; } } function smiley_replace($text = '') { global $db; static $search, $replace; // Did we get the smiley info in a previous call? if ( !is_array($search) ) { $sql = "SELECT code, smile_url FROM smiles"; $result = query($sql, "Unable to get list of smilies from the DB"); $smilies = $db->sql_fetchrowset($result); @usort($smilies, 'smiley_sort'); $search = array(); $replace = array(); for($i = 0; $i < count($smilies); $i++) { $search[] = '/<IMG SRC=".*?\/' . phpbb_preg_quote($smilies[$i]['smile_url'], '/') .'">/i'; $replace[] = $smilies[$i]['code']; } } return ( $text != '' ) ? preg_replace($search, $replace, $text) : ''; } function get_schema() { global $table_prefix; $schemafile = file('schemas/mysql_schema.sql'); $tabledata = 0; for($i=0; $i < count($schemafile); $i++) { $line = $schemafile[$i]; if ( preg_match('/^CREATE TABLE (\w+)/i', $line, $matches) ) { // Start of a new table definition, set some variables and go to the next line. $tabledata = 1; // Replace the 'phpbb_' prefix by the user defined prefix. $table = str_replace('phpbb_', $table_prefix, $matches[1]); $table_def[$table] = "CREATE TABLE $table (\n"; continue; } if ( preg_match('/^\);/', $line) ) { // End of the table definition // After this we will skip everything until the next 'CREATE' line $tabledata = 0; $table_def[$table] .= ')'; // We don't need the closing semicolon } if ( $tabledata == 1 ) { // We are inside a table definition, parse this line. // Add the current line to the complete table definition: $table_def[$table] .= $line; if ( preg_match('/^\s*(\w+)\s+(\w+)\(([\d,]+)\)(.*)$/', $line, $matches) ) { // This is a column definition $field = $matches[1]; $type = $matches[2]; $size = $matches[3]; preg_match('/DEFAULT (NULL|\'.*?\')[,\s](.*)$/i', $matches[4], $match); $default = $match[1]; $notnull = ( preg_match('/NOT NULL/i', $matches[4]) ) ? 1 : 0; $auto_increment = ( preg_match('/auto_increment/i', $matches[4]) ) ? 1 : 0; $field_def[$table][$field] = array( 'type' => $type, 'size' => $size, 'default' => $default, 'notnull' => $notnull, 'auto_increment' => $auto_increment ); } if ( preg_match('/\s*PRIMARY\s+KEY\s*\((.*)\).*/', $line, $matches) ) { // Primary key $key_def[$table]['PRIMARY'] = $matches[1]; } else if ( preg_match('/\s*KEY\s+(\w+)\s*\((.*)\)/', $line, $matches) ) { // Normal key $key_def[$table][$matches[1]] = $matches[2]; } else if ( preg_match('/^\s*(\w+)\s*(.*?),?\s*$/', $line, $matches) ) { // Column definition $create_def[$table][$matches[1]] = $matches[2]; } else { // It's a bird! It's a plane! It's something we didn't expect ;( } } } $schema['field_def'] = $field_def; $schema['table_def'] = $table_def; $schema['create_def'] = $create_def; $schema['key_def'] = $key_def; return $schema; } function get_inserts() { global $table_prefix; $insertfile = file('schemas/mysql_basic.sql'); for($i = 0; $i < count($insertfile); $i++) { if ( preg_match('/(INSERT INTO (\w+)\s.*);/i', str_replace('phpbb_', $table_prefix, $insertfile[$i]), $matches) ) { $returnvalue[$matches[2]][] = $matches[1]; } } return $returnvalue; } function lock_tables($state, $tables= '') { if ( $state == 1 ) { if ( is_array($tables) ) { $tables = join(' WRITE, ', $tables); } query("LOCK TABLES $tables WRITE", "Couldn't do: $sql"); } else { query("UNLOCK TABLES", "Couldn't unlock all tables"); } } function output_table_content($content) { echo $content . "\n"; return; } // // Nathan's bbcode2 conversion routines // function bbdecode($message) { // Undo [code] $code_start_html = '<!-- BBCode Start --><TABLE BORDER=0 ALIGN=CENTER WIDTH=85%><TR><TD><font size=-1>Code:</font><HR></TD></TR><TR><TD><FONT SIZE=-1><PRE>'; $code_end_html = '</PRE></FONT></TD></TR><TR><TD><HR></TD></TR></TABLE><!-- BBCode End -->'; $message = str_replace($code_start_html, '[code]', $message); $message = str_replace($code_end_html, '[/code]', $message); // Undo [quote] $quote_start_html = '<!-- BBCode Quote Start --><TABLE BORDER=0 ALIGN=CENTER WIDTH=85%><TR><TD><font size=-1>Quote:</font><HR></TD></TR><TR><TD><FONT SIZE=-1><BLOCKQUOTE>'; $quote_end_html = '</BLOCKQUOTE></FONT></TD></TR><TR><TD><HR></TD></TR></TABLE><!-- BBCode Quote End -->'; $message = str_replace($quote_start_html, '[quote]', $message); $message = str_replace($quote_end_html, '[/quote]', $message); // Undo [b] and [i] $message = preg_replace("#<!-- BBCode Start --><B>(.*?)</B><!-- BBCode End -->#s", "[b]\\1[/b]", $message); $message = preg_replace("#<!-- BBCode Start --><I>(.*?)</I><!-- BBCode End -->#s", "[i]\\1[/i]", $message); // Undo [url] (long form) $message = preg_replace("#<!-- BBCode u2 Start --><A HREF=\"([a-z]+?://)(.*?)\" TARGET=\"_blank\">(.*?)</A><!-- BBCode u2 End -->#s", "[url=\\1\\2]\\3[/url]", $message); // Undo [url] (short form) $message = preg_replace("#<!-- BBCode u1 Start --><A HREF=\"([a-z]+?://)(.*?)\" TARGET=\"_blank\">(.*?)</A><!-- BBCode u1 End -->#s", "[url]\\3[/url]", $message); // Undo [email] $message = preg_replace("#<!-- BBCode Start --><A HREF=\"mailto:(.*?)\">(.*?)</A><!-- BBCode End -->#s", "[email]\\1[/email]", $message); // Undo [img] $message = preg_replace("#<!-- BBCode Start --><IMG SRC=\"(.*?)\" BORDER=\"0\"><!-- BBCode End -->#s", "[img]\\1[/img]", $message); // Undo lists (unordered/ordered) // <li> tags: $message = str_replace('<!-- BBCode --><LI>', '[*]', $message); // [list] tags: $message = str_replace('<!-- BBCode ulist Start --><UL>', '[list]', $message); // [list=x] tags: $message = preg_replace('#<!-- BBCode olist Start --><OL TYPE=([A1])>#si', "[list=\\1]", $message); // [/list] tags: $message = str_replace('</UL><!-- BBCode ulist End -->', '[/list]', $message); $message = str_replace('</OL><!-- BBCode olist End -->', '[/list]', $message); return $message; } // // Alternative for in_array() which is only available in PHP4 // function inarray($needle, $haystack) { for( $i = 0 ; $i < sizeof($haystack) ; $i++ ) { if ( $haystack[$i] == $needle ) { return true; } } return false; } function end_step($next) { print "<hr /><a href=\"$PHP_SELF?next=$next\">Next step: <b>$next</b></a><br /><br />\n"; exit; } // // End functions // ------------- // // Start at the beginning if the user hasn't specified a specific starting point. // $next = ( isset($HTTP_GET_VARS['next']) ) ? $HTTP_GET_VARS['next'] : 'start'; // If debug is set we'll do all steps in one go. $debug = 1; // Parse the MySQL schema file into some arrays. $schema = get_schema(); $table_def = $schema['table_def']; $field_def = $schema['field_def']; $key_def = $schema['key_def']; $create_def = $schema['create_def']; // // Get mysql_basic data // $inserts = get_inserts(); // // Get smiley data // smiley_replace(); common_header(); if ( !empty($next) ) { switch($next) { case 'start': end_step('initial_drops'); case 'initial_drops': print " * Dropping sessions and themes tables :: "; flush(); query("DROP TABLE sessions", "Couldn't drop table 'sessions'"); query("DROP TABLE themes", "Couldn't drop table 'themes'"); print "<span class=\"ok\"><b>OK</b></span><br />\n"; end_step('mod_old_tables'); case 'mod_old_tables': $modtables = array( "banlist" => "banlist", "catagories" => "categories", "config" => "old_config", "forums" => "forums", "disallow" => "disallow", "posts" => "posts", "posts_text" => "posts_text", "priv_msgs" => "privmsgs", "ranks" => "ranks", "smiles" => "smilies", "topics" => "topics", "users" => "users", "words" => "words" ); while( list($old, $new) = each($modtables) ) { $result = query("SHOW INDEX FROM $old", "Couldn't get list of indices for table $old"); while( $row = $db->sql_fetchrow($result) ) { $index = $row['Key_name']; if ( $index != 'PRIMARY' ) { query("ALTER TABLE $old DROP INDEX $index", "Couldn't DROP INDEX $old.$index"); } } // Rename table $new = $table_prefix . $new; print " * Renaming '$old' to '$new' :: "; flush(); query("ALTER TABLE $old RENAME $new", "Failed to rename $old to $new"); print "<span class=\"ok\"><b>OK</b></span><br />\n"; } end_step('create_tables'); case 'create_tables': // Create array with tables in 'old' database $result = query('SHOW TABLES', "Couldn't get list of current tables"); while( $table = $db->sql_fetchrow($result) ) { $currenttables[] = $table[0]; } // Check what tables we need to CREATE while( list($table, $definition) = each($table_def) ) { if ( !inarray($table, $currenttables) ) { print " * Creating $table :: "; query($definition, "Couldn't create table $table"); print "<span class=\"ok\"><b>OK</b></span><br />\n"; } } end_step('create_config'); case 'create_config': print " * Inserting new values into new layout config table :: "; @reset($inserts); while( list($table, $inserts_table) = each($inserts) ) { if ( $table == CONFIG_TABLE ) { $per_pct = ceil( count($inserts_table) / 40 ); $inc = 0; while( list($nr, $insert) = each($inserts_table) ) { query($insert, "Couldn't insert value into config table"); $inc++; if ( $inc == $per_pct ) { print "."; flush(); $inc = 0; } } } } print " <span class=\"ok\"><b>OK</b></span><br />\n"; end_step('convert_config'); case 'convert_config': print " * Converting configuration table :: "; $sql = "SELECT * FROM $table_prefix" . "old_config"; $result = query($sql, "Couldn't get info from old config table"); $oldconfig = $db->sql_fetchrow($result); // // We don't need several original config types and two others // have changed name ... so take account of this. // $ignore_configs = array("selected", "admin_passwd", "override_themes", "allow_sig"); $rename_configs = array( "email_from" => "board_email", "email_sig" => "board_email_sig" ); while( list($name, $value) = each($oldconfig) ) { if ( is_int($name) ) { continue; } if ( !inarray($name, $ignore_configs) ) { $name = ( !empty($rename_configs[$name]) ) ? $rename_configs[$name] : $name; // phpBB 1.x has some problems with escaping strings in the database. Try to correct for // this by removing all slashes and then escaping once. $sql = "REPLACE INTO " . CONFIG_TABLE . " (config_name, config_value) VALUES ('$name', '".addslashes(stripslashes(stripslashes($value)))."')"; query($sql, "Couldn't update config table with values from old config table"); } } $sql = "UPDATE " . CONFIG_TABLE . " SET config_value = 'dutch' WHERE config_name = 'default_lang' && config_value = 'nederlands'"; query($sql, "Couldn't rename 'nederlands' to 'dutch' in config table"); print "<span class=\"ok\"><b>OK</b></span><br />\n"; end_step('convert_ips'); case 'convert_ips': $names = array( POSTS_TABLE => array( 'id' => 'post_id', 'field' => 'poster_ip' ), PRIVMSGS_TABLE => array( 'id' => 'msg_id', 'field' => 'poster_ip' ), BANLIST_TABLE => array( 'id' => 'ban_id', 'field' => 'ban_ip' ) ); lock_tables(1, array(POSTS_TABLE, PRIVMSGS_TABLE, BANLIST_TABLE)); $batchsize = 2000; while( list($table, $data_array) = each($names) ) { $sql = "SELECT MAX(" . $data_array['id'] . ") AS max_id FROM $table"; $result = query($sql, "Couldn't obtain ip data from $table (" . $fields . ")"); $row = $db->sql_fetchrow($result); $maxid = $row['max_id']; for($i = 0; $i <= $maxid; $i += $batchsize) { $batchstart = $i; $batchend = $i + $batchsize; $field_id = $data_array['id']; $field = $data_array['field']; print " * Converting IP format '" . $field . "' / '$table' ( $batchstart to $batchend ) :: "; flush(); $sql = "SELECT $field_id, $field FROM $table WHERE $field_id BETWEEN $batchstart AND $batchend"; $result = query($sql, "Couldn't obtain ip data from $table (" . $fields . ")"); $per_pct = ceil( $db->sql_numrows($result) / 40 ); $inc = 0; while( $row = $db->sql_fetchrow($result) ) { $sql = "UPDATE $table SET $field = '" . encode_ip($row[$field]) . "' WHERE $field_id = " . $row[$field_id]; query($sql, "Couldn't convert IP format of $field in $table with $field_id of " . $rowset[$field_id]); $inc++; if ( $inc == $per_pct ) { print "."; flush(); $inc = 0; } } print " <span class=\"ok\"><b>OK</b></span><br />\n"; } } lock_tables(0); end_step('convert_dates'); case 'convert_dates': $names = array( POSTS_TABLE => array('post_time'), TOPICS_TABLE => array('topic_time'), PRIVMSGS_TABLE => array('msg_time') ); lock_tables(1, array(POSTS_TABLE, TOPICS_TABLE, PRIVMSGS_TABLE)); while( list($table, $fields) = each($names) ) { print " * Converting date format of $fields[$i] in $table :: "; flush(); for($i = 0; $i < count($fields); $i++) { $sql = "UPDATE $table SET " . $fields[$i] . " = UNIX_TIMESTAMP(" . $fields[$i] . ")"; query($sql, "Couldn't convert date format of $table(" . $fields[$i] . ")"); } print "<span class=\"ok\"><b>OK</b></span><br />\n"; } lock_tables(0); end_step('fix_addslashes'); case 'fix_addslashes': $slashfields[TOPICS_TABLE] = array('topic_title'); $slashfields[FORUMS_TABLE] = array('forum_desc', 'forum_name'); $slashfields[CATEGORIES_TABLE] = array('cat_title'); $slashfields[WORDS_TABLE] = array('word', 'replacement'); $slashfields[RANKS_TABLE] = array('rank_title'); $slashfields[DISALLOW_TABLE] = array('disallow_username'); //convert smilies? $slashes = array( "\\'" => "'", "\\\"" => "\"", "\\\\" => "\\"); $slashes = array( "\\'" => "'", "\\\"" => "\"", "\\\\" => "\\"); lock_tables(1, array(TOPICS_TABLE, FORUMS_TABLE, CATEGORIES_TABLE, WORDS_TABLE, RANKS_TABLE, DISALLOW_TABLE, SMILIES_TABLE)); while( list($table, $fields) = each($slashfields) ) { print " * Removing slashes from $table table :: "; flush(); while( list($nr, $field) = each($fields) ) { @reset($slashes); while( list($search, $replace) = each($slashes) ) { $sql = "UPDATE $table SET $field = REPLACE($field, '" . addslashes($search) . "', '" . addslashes($replace) . "')"; query($sql, "Couldn't remove extraneous slashes from the old data."); } } print "<span class=\"ok\"><b>OK</b></span><br />\n"; } lock_tables(0); end_step('remove_topics'); case 'remove_topics': print " * Removing posts with no corresponding topics :: "; flush(); $sql = "SELECT p.post_id FROM " . POSTS_TABLE . " p LEFT JOIN " . TOPICS_TABLE . " t ON p.topic_id = t.topic_id WHERE t.topic_id IS NULL"; $result = query($sql, "Couldn't obtain list of deleted topics"); $post_total = $db->sql_numrows($result); if ( $post_total ) { $post_id_ary = array(); while( $row = $db->sql_fetchrow($result) ) { $post_id_ary[] = $row['post_id']; } $sql = "DELETE FROM " . POSTS_TABLE . " WHERE post_id IN (" . implode(", ", $post_id_ary) . ")"; query($sql, "Couldn't update posts to remove deleted user poster_id values"); $sql = "DELETE FROM " . POSTS_TEXT_TABLE . " WHERE post_id IN (" . implode(", ", $post_id_ary) . ")"; query($sql, "Couldn't update posts to remove deleted user poster_id values"); } echo "<span class=\"ok\"><b>OK</b></span> ( Removed $post_total posts )<br />\n"; end_step('convert_users'); case 'convert_users': // // Completely remove old soft-deleted users // $sql = "DELETE FROM " . USERS_TABLE . " WHERE user_level = -1"; query($sql, "Couldn't delete old soft-deleted users"); $sql = "SELECT COUNT(*) AS total, MAX(user_id) AS maxid FROM " . USERS_TABLE; $result = query($sql, "Couldn't get max user_id."); $row = $db->sql_fetchrow($result); $totalposts = $row['total']; $maxid = $row['maxid']; $sql = "ALTER TABLE " . USERS_TABLE . " ADD user_sig_bbcode_uid CHAR(10), MODIFY user_sig text"; query($sql, "Couldn't add user_sig_bbcode_uid field to users table"); $super_mods = array(); $first_admin = -2; $batchsize = 1000; for($i = -1; $i <= $maxid; $i += $batchsize) { $batchstart = $i; $batchend = $i + $batchsize; print " * Converting Users ( $batchstart to $batchend ) :: "; flush(); $sql = "SELECT * FROM " . USERS_TABLE . " WHERE user_id BETWEEN $batchstart AND $batchend"; $result = query($sql, "Couldn't get ". USERS_TABLE .".user_id $batchstart to $batchend"); // Array with user fields that we want to check for invalid data (to few characters) $checklength = array( 'user_occ', 'user_website', 'user_email', 'user_from', 'user_intrest', 'user_aim', 'user_yim', 'user_msnm'); lock_tables(1, array(USERS_TABLE, GROUPS_TABLE, USER_GROUP_TABLE, POSTS_TABLE)); $per_pct = ceil( $db->sql_numrows($result) / 40 ); $inc = 0; while( $row = $db->sql_fetchrow($result) ) { $sql = "INSERT INTO " . GROUPS_TABLE . " (group_name, group_description, group_single_user) VALUES ('" . addslashes($row['username']) . "', 'Personal User', 1)"; query($sql, "Wasn't able to insert user ".$row['user_id']." into table ".GROUPS_TABLE); $group_id = $db->sql_nextid(); $sql = "INSERT INTO " . USER_GROUP_TABLE . " (group_id, user_id, user_pending) VALUES ($group_id, " . $row['user_id'] . ", 0)"; query($sql, "Wasn't able to insert user ".$row['user_id']." into table ".USER_GROUP_TABLE); if ( is_int($row['user_regdate']) ) { // We already converted this post to the new style BBcode, skip this post. continue; } // // Nathan's bbcode2 conversion // // undo 1.2.x encoding.. $row['user_sig'] = bbdecode(stripslashes($row['user_sig'])); $row['user_sig'] = undo_make_clickable($row['user_sig']); $row['user_sig'] = str_replace("<BR>", "\n", $row['user_sig']); // make a uid $uid = make_bbcode_uid(); // do 2.x first-pass encoding.. $row['user_sig'] = bbencode_first_pass($row['user_sig'], $uid); $row['user_sig'] = addslashes($row['user_sig']); // Check for invalid info like '-' and '?' for a lot of fields @reset($checklength); while($field = each($checklength)) { $row[$field[1]] = strlen($row[$field[1]]) < 3 ? '' : $row[$field[1]]; } preg_match('/(.*?) (\d{1,2}), (\d{4})/', $row['user_regdate'], $parts); $row['user_regdate'] = gmmktime(0, 0, 0, $months[$parts[1]], $parts[2], $parts[3]); $website = $row['user_website']; if ( substr(strtolower($website), 0, 7) != "http://" ) { $website = "http://" . $website; } if( strtolower($website) == 'http://' ) { $website = ''; } $row['user_website'] = addslashes($website); $row['user_icq'] = (ereg("^[0-9]+$", $row['user_icq'])) ? $row['user_icq'] : ''; @reset($checklength); while($field = each($checklength)) { if ( strlen($row[$field[1]]) < 3 ) { $row[$field[1]] = ''; } $row[$field[1]] = addslashes($row[$field[1]]); } // // Is user a super moderator? // if( $row['user_level'] == 3 ) { $super_mods[] = $row['user_id']; } $row['user_level'] = ( $row['user_level'] == 4 ) ? ADMIN : USER; // // Used to define a 'practical' group moderator user_id // for super mods a little latter. // if( $first_admin == -2 && $row['user_level'] == ADMIN ) { $first_admin = $row['user_id']; } // // Dutch language files have been renamed from 'nederlands' to 'dutch' // if( $row['user_lang'] == 'nederlands' ) { $row['user_lang'] = 'dutch'; } $sql = "UPDATE " . USERS_TABLE . " SET user_sig = '" . $row['user_sig'] . "', user_sig_bbcode_uid = '$uid', user_regdate = '" . $row['user_regdate'] . "', user_website = '" . $row['user_website'] . "', user_occ = '" . $row['user_occ'] . "', user_email = '" . $row['user_email'] . "', user_from = '" . $row['user_from'] . "', user_intrest = '" . $row['user_intrest'] . "', user_aim = '" . $row['user_aim'] . "', user_yim = '" . $row['user_yim'] . "', user_msnm = '" . $row['user_msnm'] . "', user_level = '" . $row['user_level'] . "', user_desmile = NOT(user_desmile), user_bbcode = 1, user_theme = 1 WHERE user_id = " . $row['user_id']; query($sql, "Couldn't update ".USERS_TABLE." table with new BBcode and regdate for user_id ".$row['user_id']); $inc++; if ( $inc == $per_pct ) { print "."; flush(); $inc = 0; } } // Set any non-standard (like) email addresses to nothing // could do this above as a preg_ but this one query may // be faster $sql = "UPDATE " . USERS_TABLE . " SET user_email = '' WHERE user_email NOT REGEXP '^[a-zA-Z0-9_\+\.\-]+@.*[a-zA-Z0-9\-_]+\.[a-zA-Z]{2,}$'"; query($sql, "Couldn't update ".USERS_TABLE." table non-standard user_email entries"); print " <span class=\"ok\"><b>OK</b></span><br />\n"; lock_tables(0); } // // Handle super-mods, create hidden group for them // // Iterate trough access table if( count($super_mods) && $first_admin != -2 ) { print "\n<br />\n * Creating new group for super moderators :: "; flush(); $sql = "INSERT INTO " . GROUPS_TABLE . " (group_type, group_name, group_description, group_moderator, group_single_user) VALUES (" . GROUP_HIDDEN . ", 'Super Moderators', 'Converted super moderators', $first_admin, 0)"; $result = query($sql, "Couldn't create group for ".$row['forum_name']); $group_id = $db->sql_nextid(); if ( $group_id <= 0 ) { print "<font color=\"red\">Group creation failed. Aborting creation of groups...<br></font>\n"; continue 2; } print "<span class=\"ok\"><b>OK</b></span><br />\n"; print " * Updating auth_access for super moderator group :: "; flush(); $sql = "SELECT forum_id FROM " . FORUMS_TABLE; $result = query($sql, "Couldn't obtain forum_id list"); while( $row = $db->sql_fetchrow($result) ) { $sql = "INSERT INTO " . AUTH_ACCESS_TABLE . " (group_id, forum_id, auth_mod) VALUES ($group_id, " . $row['forum_id'] . ", 1)"; $result_insert = query($sql, "Unable to set group auth access for super mods."); } for($i = 0; $i < count($super_mods); $i++) { $sql = "INSERT INTO " . USER_GROUP_TABLE . " (group_id, user_id, user_pending) VALUES ($group_id, " . $super_mods[$i] . ", 0)"; query($sql, "Unable to add user_id $user_id to group_id $group_id (super mods)<br>\n"); } print "<span class=\"ok\"><b>OK</b></span><br />\n"; } end_step('convert_posts'); case 'convert_posts': print " * Adding enable_sig field to " . POSTS_TABLE . " :: "; flush(); $sql = "ALTER TABLE " . POSTS_TABLE . " ADD enable_sig tinyint(1) DEFAULT '1' NOT NULL"; $result = query($sql, "Couldn't add enable_sig field to " . POSTS_TABLE . "."); print "<span class=\"ok\"><b>OK</b></span><br />\n"; print " * Adding enable_bbcode field to " . POSTS_TEXT_TABLE . " :: "; flush(); $sql = "ALTER TABLE " . POSTS_TEXT_TABLE . " ADD enable_bbcode tinyint(1) DEFAULT '1' NOT NULL"; $result = query($sql, "Couldn't add enable_bbcode field to " . POSTS_TABLE . "."); print "<span class=\"ok\"><b>OK</b></span><br />\n"; print " * Adding bbcode_uid field to " . POSTS_TEXT_TABLE . " :: "; flush(); $sql = "ALTER TABLE " . POSTS_TEXT_TABLE . " ADD bbcode_uid char(10) NOT NULL"; $result = query($sql, "Couldn't add bbcode_uid field to " . POSTS_TABLE . "."); print "<span class=\"ok\"><b>OK</b></span><br />\n"; print " * Adding post_edit_time field to " . POSTS_TABLE . " :: "; flush(); $sql = "ALTER TABLE " . POSTS_TABLE . " ADD post_edit_time int(11)"; $result = query($sql, "Couldn't add post_edit_time field to " . POSTS_TABLE . "."); print "<span class=\"ok\"><b>OK</b></span><br />\n"; print " * Adding post_edit_count field to " . POSTS_TABLE . " :: "; flush(); $sql = "ALTER TABLE " . POSTS_TABLE . " ADD post_edit_count smallint(5) UNSIGNED DEFAULT '0' NOT NULL"; $result = query($sql, "Couldn't add post_edit_count field to " . POSTS_TABLE . "."); print "<span class=\"ok\"><b>OK</b></span><br />\n<br />\n"; $sql = "SELECT COUNT(*) as total, MAX(post_id) as maxid FROM " . POSTS_TEXT_TABLE; $result = query($sql, "Couldn't get max post_id."); $maxid = $db->sql_fetchrow($result); $totalposts = $maxid['total']; $maxid = $maxid['maxid']; $batchsize = 2000; for($i = 0; $i <= $maxid; $i += $batchsize) { $batchstart = $i + 1; $batchend = $i + $batchsize; print " * Converting BBcode ( $batchstart to $batchend ) :: "; flush(); $sql = "SELECT * FROM " . POSTS_TEXT_TABLE . " WHERE post_id BETWEEN $batchstart AND $batchend"; $result = query($sql, "Couldn't get ". POSTS_TEXT_TABLE .".post_id $batchstart to $batchend"); lock_tables(1, array(POSTS_TEXT_TABLE, POSTS_TABLE)); $per_pct = ceil( $db->sql_numrows($result) / 40 ); $inc = 0; while( $row = $db->sql_fetchrow($result) ) { if ( $row['bbcode_uid'] != '' ) { // We already converted this post to the new style BBcode, skip this post. continue; } // // Nathan's bbcode2 conversion // // undo 1.2.x encoding.. $row['post_text'] = bbdecode(stripslashes($row['post_text'])); $row['post_text'] = undo_make_clickable($row['post_text']); $row['post_text'] = str_replace('<BR>', "\n", $row['post_text']); // make a uid $uid = make_bbcode_uid(); // do 2.x first-pass encoding.. $row['post_text'] = smiley_replace($row['post_text']); $row['post_text'] = bbencode_first_pass($row['post_text'], $uid); $row['post_text'] = addslashes($row['post_text']); $edited_sql = ""; if ( preg_match('/^(.*?)([\n]+<font size=\-1>\[ This message was .*?)$/s', $row['post_text'], $matches) ) { $row['post_text'] = $matches[1]; $edit_info = $matches[2]; $edit_times = count(explode(' message ', $edit_info)) - 1; // Taken from example for substr_count in annotated PHP manual if ( preg_match('/^.* by: (.*?) on (....)-(..)-(..) (..):(..) \]<\/font>/s', $edit_info, $matches) ) { $edited_user = $matches[1]; $edited_time = gmmktime($matches[5], $matches[6], 0, $matches[3], $matches[4], $matches[2]); // // This isn't strictly correct since 2.0 won't include and edit // statement if the edit wasn't by the user who posted ... // $edited_sql = ", post_edit_time = $edited_time, post_edit_count = $edit_times"; } } if ( preg_match("/^(.*?)\n-----------------\n.*$/is", $row['post_text'], $matches) ) { $row['post_text'] = $matches[1]; $enable_sig = 1; } else { $checksig = preg_replace('/\[addsig\]$/', '', $row['post_text']); $enable_sig = ( strlen($checksig) == strlen($row['post_text']) ) ? 0 : 1; } $sql = "UPDATE " . POSTS_TEXT_TABLE . " SET post_text = '$checksig', bbcode_uid = '$uid' WHERE post_id = " . $row['post_id']; query($sql, "Couldn't update " . POSTS_TEXT_TABLE . " table with new BBcode for post_id :: " . $row['post_id']); $sql = "UPDATE " . POSTS_TABLE . " SET enable_sig = $enable_sig" . $edited_sql . " WHERE post_id = " . $row['post_id']; query($sql, "Couldn't update " . POSTS_TABLE . " table with signature status for post with post_id :: " . $row['post_id']); $inc++; if ( $inc == $per_pct ) { print '.'; flush(); $inc = 0; } } print " <span class=\"ok\"><b>OK</b></span><br />\n"; lock_tables(0); } print "<br />\n * Updating poster_id for deleted users :: "; flush(); $sql = "SELECT DISTINCT p.post_id FROM " . POSTS_TABLE . " p LEFT JOIN " . USERS_TABLE . " u ON p.poster_id = u.user_id WHERE u.user_id IS NULL"; $result = query($sql, "Couldn't obtain list of deleted users"); $users_removed = $db->sql_numrows($result); if ( $users_removed ) { $post_id_ary = array(); while( $row = $db->sql_fetchrow($result) ) { $post_id_ary[] = $row['post_id']; } $sql = "UPDATE " . POSTS_TABLE . " SET poster_id = " . ANONYMOUS . ", enable_sig = 0 WHERE post_id IN (" . implode(", ", $post_id_ary) . ")"; query($sql, "Couldn't update posts to remove deleted user poster_id values"); } print "<span class=\"ok\"><b>OK</b></span> ( Removed $users_removed non-existent user references )<br />\n"; end_step('convert_privmsgs'); case 'convert_privmsgs': $sql = "SELECT COUNT(*) as total, max(msg_id) as maxid FROM " . PRIVMSGS_TABLE; $result = query($sql, "Couldn't get max privmsgs_id."); $maxid = $db->sql_fetchrow($result); $totalposts = $maxid['total']; $maxid = $maxid['maxid']; $sql = "ALTER TABLE " . PRIVMSGS_TABLE . " ADD privmsgs_subject VARCHAR(255), ADD privmsgs_attach_sig TINYINT(1) DEFAULT 1"; query($sql, "Couldn't add privmsgs_subject field to " . PRIVMSGS_TABLE . " table"); $batchsize = 2000; for($i = 0; $i <= $maxid; $i += $batchsize) { $batchstart = $i + 1; $batchend = $i + $batchsize; print " * Converting Private Message ( $batchstart to $batchend ) :: "; flush(); $sql = "SELECT * FROM " . PRIVMSGS_TABLE . " WHERE msg_id BETWEEN $batchstart AND $batchend"; $result = query($sql, "Couldn't get " . POSTS_TEXT_TABLE . " post_id $batchstart to $batchend"); lock_tables(1, array(PRIVMSGS_TABLE, PRIVMSGS_TEXT_TABLE)); $per_pct = ceil( $db->sql_numrows($result) / 40 ); $inc = 0; while( $row = $db->sql_fetchrow($result) ) { if ( $row['msg_text'] == NULL ) { // We already converted this post to the new style BBcode, skip this post. continue; } // // Nathan's bbcode2 conversion // // undo 1.2.x encoding.. $row['msg_text'] = bbdecode(stripslashes($row['msg_text'])); $row['msg_text'] = undo_make_clickable($row['msg_text']); $row['msg_text'] = str_replace("<BR>", "\n", $row['msg_text']); // make a uid $uid = make_bbcode_uid(); // do 2.x first-pass encoding.. $row['msg_text'] = smiley_replace($row['msg_text']); $row['msg_text'] = bbencode_first_pass($row['msg_text'], $uid); $checksig = preg_replace('/\[addsig\]$/', '', $row['msg_text']); $enable_sig = (strlen($checksig) == strlen($row['msg_text'])) ? 0 : 1; if ( preg_match("/^(.*?)\n-----------------\n.*$/is", $checksig, $matches) ) { $checksig = $matches[1]; $enable_sig = 1; } $row['msg_text'] = $checksig; $row['msg_status'] = ($row['msg_status'] == 1) ? PRIVMSGS_READ_MAIL : PRIVMSGS_NEW_MAIL; // Subject contains first 60 characters of msg, remove any BBCode tags $subject = addslashes(strip_tags(substr($row['msg_text'], 0, 60))); $subject = preg_replace("/\[.*?\:(([a-z0-9]:)?)$uid.*?\]/si", "", $subject); $row['msg_text'] = addslashes($row['msg_text']); $sql = "INSERT INTO " . PRIVMSGS_TEXT_TABLE . " (privmsgs_text_id, privmsgs_bbcode_uid, privmsgs_text) VALUES ('" . $row['msg_id'] . "', '$uid', '" . $row['msg_text'] . "')"; query($sql, "Couldn't insert PrivMsg text into " . PRIVMSGS_TEXT_TABLE . " table msg_id " . $row['msg_id']); $sql = "UPDATE " . PRIVMSGS_TABLE . " SET msg_text = NULL, msg_status = " . $row['msg_status'] . ", privmsgs_subject = '$subject', privmsgs_attach_sig = $enable_sig WHERE msg_id = " . $row['msg_id']; query($sql, "Couldn't update " . PRIVMSGS_TABLE . " table for msg_id " . $row['post_id']); $inc++; if ( $inc == $per_pct ) { print '.'; flush(); $inc = 0; } } print " <span class=\"ok\"><b>OK</b></span><br />\n"; } lock_tables(0); end_step('convert_moderators'); case 'convert_moderators'; $sql = "SELECT * FROM forum_mods"; $result = query($sql, "Couldn't get list with all forum moderators"); while( $row = $db->sql_fetchrow($result) ) { // Check if this moderator and this forum still exist $sql = "SELECT user_id FROM " . USERS_TABLE . ", " . FORUMS_TABLE . " WHERE user_id = " . $row['user_id'] . " AND forum_id = " . $row['forum_id']; $check_data = query($sql, "Couldn't check if user " . $row['user_id'] . " and forum " . $row['forum_id'] . " exist"); if ( !($rowtest = $db->sql_fetchrow($check_data)) ) { // Either the moderator or the forum have been deleted, this line in forum_mods was redundant, skip it. continue; } $sql = "SELECT g.group_id FROM " . GROUPS_TABLE . " g, " . USER_GROUP_TABLE . " ug WHERE g.group_id = ug.group_id AND ug.user_id = " . $row['user_id'] . " AND g.group_single_user = 1"; $insert_group = query($sql, "Couldn't get group number for user " . $row['user_id'] . "."); $group_id = $db->sql_fetchrow($insert_group); $group_id = $group_id['group_id']; print " * Adding moderator for forum " . $row['forum_id'] . " :: "; flush(); $sql = "INSERT INTO " . AUTH_ACCESS_TABLE . " (group_id, forum_id, auth_mod) VALUES ($group_id, ".$row['forum_id'].", 1)"; query($sql, "Couldn't set moderator (user_id = " . $row['user_id'] . ") for forum " . $row['forum_id'] . "."); print "<span class=\"ok\"><b>OK</b></span><br />\n"; } print " * Setting correct user_level for moderators ::"; flush(); $sql = "SELECT DISTINCT u.user_id FROM " . USERS_TABLE . " u, " . USER_GROUP_TABLE . " ug, " . AUTH_ACCESS_TABLE . " aa WHERE aa.auth_mod = 1 AND ug.group_id = aa.group_id AND u.user_id = ug.user_id AND u.user_level <> " . ADMIN; $result = query($sql, "Couldn't obtain list of moderators"); if ( $row = $db->sql_fetchrow($result) ) { $ug_sql = ''; do { $ug_sql .= ( ( $ug_sql != '' ) ? ', ' : '' ) . $row['user_id']; } while ( $row = $db->sql_fetchrow($result) ); $sql = "UPDATE " . USERS_TABLE . " SET user_level = " . MOD . " WHERE user_id IN ($ug_sql)"; query($sql, "Couldn't set moderator status for users"); } print "<span class=\"ok\"><b>OK</b></span><br />\n"; end_step('convert_privforums'); case 'convert_privforums': $sql = "SELECT fa.*, f.forum_name FROM forum_access fa LEFT JOIN " . FORUMS_TABLE . " f ON fa.forum_id = f.forum_id ORDER BY fa.forum_id, fa.user_id"; $forum_access = query($sql, "Couldn't get list with special forum access (forum_access)"); $forum_id = -1; while( $row = $db->sql_fetchrow($forum_access) ) { // Iterate trough access table if ( $row['forum_id'] != $forum_id ) { // This is a new forum, create new group. $forum_id = $row['forum_id']; print " * Creating new group for forum $forum_id :: "; flush(); $sql = "INSERT INTO " . GROUPS_TABLE . " (group_type, group_name, group_description, group_moderator, group_single_user) VALUES (" . GROUP_HIDDEN . ", '" . addslashes($row['forum_name']) . " Group', 'Converted Private Forum Group', " . $row['user_id'] . ", 0)"; $result = query($sql, "Couldn't create group for ".$row['forum_name']); $group_id = $db->sql_nextid(); if ( $group_id <= 0 ) { print "<font color=\"red\">Group creation failed. Aborting creation of groups...<br></font>\n"; continue 2; } print "<span class=\"ok\"><b>OK</b></span><br />\n"; print " * Creating auth_access group for forum $forum_id :: "; flush(); $sql = "INSERT INTO " . AUTH_ACCESS_TABLE . " (group_id, forum_id, auth_view, auth_read, auth_post, auth_reply, auth_edit, auth_delete, auth_sticky, auth_announce, auth_vote, auth_pollcreate) VALUES ($group_id, $forum_id, 1, 1, 1, 1, 1, 1, 1, 0, 1, 1)"; $result = query($sql, "Unable to set group auth access."); if ( $db->sql_affectedrows($result) <= 0 ) { print "<font color=\"red\">Group creation failed. Aborting creation of groups...</font><br>\n"; continue 2; } print "<span class=\"ok\"><b>OK</b></span><br />\n"; } // Add user to the group $user_id = $row['user_id']; $sql = "INSERT INTO " . USER_GROUP_TABLE . " (group_id, user_id, user_pending) VALUES ($group_id, $user_id, 0)"; query($sql, "Unable to add user_id $user_id to group_id $group_id <br>\n"); } end_step('update_schema'); case 'update_schema': $rename = array( $table_prefix . "users" => array( "user_interests" => "user_intrest", "user_allowsmile" => "user_desmile", "user_allowhtml" => "user_html", "user_allowbbcode" => "user_bbcode", "user_style" => "user_theme" ), $table_prefix . "privmsgs" => array( "privmsgs_id" => "msg_id", "privmsgs_from_userid" => "from_userid", "privmsgs_to_userid" => "to_userid", "privmsgs_date" => "msg_time", "privmsgs_ip" => "poster_ip", "privmsgs_type" => "msg_status" ), $table_prefix . "smilies" => array( "smilies_id" => "id" ) ); $schema = get_schema(); $table_def = $schema['table_def']; $field_def = $schema['field_def']; // Loop tables in schema while (list($table, $table_def) = @each($field_def)) { // Loop fields in table print " * Updating table '$table' :: "; flush(); $sql = "SHOW FIELDS FROM $table"; $result = query($sql, "Can't get definition of current $table table"); while( $row = $db->sql_fetchrow($result) ) { $current_fields[] = $row['Field']; } $alter_sql = "ALTER TABLE $table "; while (list($field, $definition) = each($table_def)) { if ( $field == '' ) { // Skip empty fields if any (shouldn't be needed) continue; } $type = $definition['type']; $size = $definition['size']; $default = isset($definition['default']) ? "DEFAULT " . $definition['default'] : ''; $notnull = $definition['notnull'] == 1 ? 'NOT NULL' : ''; $auto_increment = $definition['auto_increment'] == 1 ? 'auto_increment' : ''; $oldfield = isset($rename[$table][$field]) ? $rename[$table][$field] : $field; if ( !inarray($field, $current_fields) && $oldfield == $field ) { // If the current is not a key of $current_def and it is not a field that is // to be renamed then the field doesn't currently exist. $changes[] = " ADD $field " . $create_def[$table][$field]; } else { $changes[] = " CHANGE $oldfield $field " . $create_def[$table][$field]; } } $alter_sql .= join(',', $changes); unset($changes); unset($current_fields); $sql = "SHOW INDEX FROM $table"; $result = query($sql, "Couldn't get list of indices for table $table"); unset($indices); while( $row = $db->sql_fetchrow($result) ) { $indices[] = $row['Key_name']; } while ( list($key_name, $key_field) = each($key_def[$table]) ) { if ( !inarray($key_name, $indices) ) { $alter_sql .= ($key_name == 'PRIMARY') ? ", ADD PRIMARY KEY ($key_field)" : ", ADD INDEX $key_name ($key_field)"; } } query($alter_sql, "Couldn't alter table $table"); print "<span class=\"ok\"><b>OK</b></span><br />\n"; flush(); } end_step('convert_forums'); case 'convert_forums': $sql = "SELECT * FROM " . FORUMS_TABLE; $result = query($sql, "Couldn't get list with all forums"); while( $row = $db->sql_fetchrow($result) ) { print " * Converting forum '" . $row['forum_name'] . "' :: "; flush(); // forum_access: (only concerns posting) // 1 = Registered users only // 2 = Anonymous Posting // 3 = Moderators/Administrators only switch( $row['forum_access'] ) { case 1: // Public forum, no anonymous posting $auth_view = AUTH_ALL; $auth_read = AUTH_ALL; $auth_post = AUTH_REG; $auth_reply = AUTH_REG; $auth_edit = AUTH_REG; $auth_delete = AUTH_REG; $auth_vote = AUTH_REG; $auth_pollcreate = AUTH_REG; $auth_sticky = AUTH_MOD; $auth_announce = AUTH_MOD; break; case 2: $auth_post = AUTH_ALL; $auth_reply = AUTH_ALL; $auth_edit = AUTH_REG; $auth_delete = AUTH_REG; $auth_vote = AUTH_ALL; $auth_pollcreate = AUTH_ALL; $auth_sticky = AUTH_MOD; $auth_announce = AUTH_MOD; break; default: $auth_post = AUTH_MOD; $auth_reply = AUTH_MOD; $auth_edit = AUTH_MOD; $auth_delete = AUTH_MOD; $auth_vote = AUTH_MOD; $auth_pollcreate = AUTH_MOD; $auth_sticky = AUTH_MOD; $auth_announce = AUTH_MOD; break; } // Old auth structure: // forum_type: (only concerns viewing) // 0 = Public // 1 = Private switch( $row['forum_type'] ) { case 0: $auth_view = AUTH_ALL; $auth_read = AUTH_ALL; break; default: // // Make it really private ... // $auth_view = AUTH_ACL; $auth_read = AUTH_ACL; $auth_post = AUTH_ACL; $auth_reply = AUTH_ACL; $auth_edit = AUTH_ACL; $auth_delete = AUTH_ACL; $auth_vote = AUTH_ACL; $auth_pollcreate = AUTH_ACL; $auth_sticky = AUTH_ACL; $auth_announce = AUTH_MOD; break; } $sql = "UPDATE " . FORUMS_TABLE . " SET auth_view = $auth_view, auth_read = $auth_read, auth_post = $auth_post, auth_reply = $auth_reply, auth_edit = $auth_edit, auth_delete = $auth_delete, auth_vote = $auth_vote, auth_pollcreate = $auth_pollcreate, auth_sticky = $auth_sticky, auth_announce = $auth_announce WHERE forum_id = ". $row['forum_id']; query($sql, "Was unable to update forum permissions!"); print "<span class=\"ok\"><b>OK</b></span><br />\n"; } end_step('insert_themes'); case 'insert_themes': print " * Inserting new values into themes table :: "; @reset($inserts); while( list($table, $inserts_table) = each($inserts) ) { if ( $table == THEMES_TABLE ) { $per_pct = ceil( count($inserts_table) / 40 ); $inc = 0; while( list($nr, $insert) = each($inserts_table) ) { query($insert, "Couldn't insert value into " . THEMES_TABLE); $inc++; if ( $inc == $per_pct ) { print "."; flush(); $inc = 0; } } } } print " <span class=\"ok\"><b>OK</b></span><br />\n"; end_step('update_topics'); case 'update_topics': $sql = "SELECT MAX(topic_id) AS max_topic FROM " . TOPICS_TABLE; $result = query($sql, "Couldn't get max topic id"); $row = $db->sql_fetchrow($result); $maxid = $row['max_topic']; lock_tables(1, array(TOPICS_TABLE, POSTS_TABLE)); $batchsize = 1000; for($i = 0; $i <= $maxid; $i += $batchsize) { $batchstart = $i + 1; $batchend = $i + $batchsize; print " * Setting topic first post_id ( $batchstart to $batchend ) :: "; flush(); $sql = "SELECT MIN(post_id) AS first_post_id, topic_id FROM " . POSTS_TABLE . " WHERE topic_id BETWEEN $batchstart AND $batchend GROUP BY topic_id ORDER BY topic_id ASC"; $result = query($sql, "Couldn't get post id data"); $per_pct = ceil( $db->sql_numrows($result) / 40 ); $inc = 0; if ( $row = $db->sql_fetchrow($result) ) { do { $sql = "UPDATE " . TOPICS_TABLE . " SET topic_first_post_id = " . $row['first_post_id'] . " WHERE topic_id = " . $row['topic_id']; query($sql, "Couldn't update topic first post id in topic :: $topic_id"); $inc++; if ( $inc == $per_pct ) { print "."; flush(); $inc = 0; } } while ( $row = $db->sql_fetchrow($result) ); } print " <span class=\"ok\"><b>OK</b></span><br />\n"; } lock_tables(0); end_step('final_configuration'); case 'final_configuration': // // Update forum last post information // $sql = "SELECT forum_id, forum_name FROM " . FORUMS_TABLE; $f_result = query($sql, "Couldn't obtain forum_ids"); while( $forum_row = $db->sql_fetchrow($f_result) ) { print " * Updating '" . $forum_row['forum_name'] . "' post info :: "; flush(); $id = $forum_row['forum_id']; $sql = "SELECT MIN(p.post_id) AS first_post, MAX(p.post_id) AS last_post FROM " . POSTS_TABLE . " p, " . TOPICS_TABLE . " t WHERE p.forum_id = $id AND p.topic_id = t.topic_id"; $result = query($sql, "Could not get post ID forum post information :: $id"); if ( $row = $db->sql_fetchrow($result) ) { $first_post = ( $row['first_post'] ) ? $row['first_post'] : 0; $last_post = ($row['last_post']) ? $row['last_post'] : 0; } else { $first_post = 0; $last_post = 0; } $sql = "SELECT COUNT(post_id) AS total FROM " . POSTS_TABLE . " WHERE forum_id = $id"; $result = query($sql, "Could not get post count forum post information :: $id"); if ( $row = $db->sql_fetchrow($result) ) { $total_posts = ($row['total']) ? $row['total'] : 0; } else { $total_posts = 0; } $sql = "SELECT COUNT(topic_id) AS total FROM " . TOPICS_TABLE . " WHERE forum_id = $id AND topic_status <> " . TOPIC_MOVED; $result = query($sql, "Could not get topic count forum post information :: $id"); if ( $row = $db->sql_fetchrow($result) ) { $total_topics = ($row['total']) ? $row['total'] : 0; } else { $total_topics = 0; } $sql = "UPDATE " . FORUMS_TABLE . " SET forum_last_post_id = $last_post, forum_posts = $total_posts, forum_topics = $total_topics WHERE forum_id = $id"; query($sql, "Could not update forum post information :: $id"); print "<span class=\"ok\"><b>OK</b></span><br />\n"; } print "<br />\n * Update default user and finalise configuration :: "; flush(); // // Update the default admin user with their information. // $sql = "SELECT MIN(user_regdate) AS oldest_time FROM " . USERS_TABLE . " WHERE user_regdate > 0 AND user_id > 0"; $result = query($sql, "Couldn't obtain oldest post time"); $row = $db->sql_fetchrow($result); $sql = "INSERT INTO " . $table_prefix . "config (config_name, config_value) VALUES ('board_startdate', " . $row['oldest_time'] . ")"; query($sql, "Couldn't insert board_startdate"); $sql = "UPDATE " . $table_prefix . "config SET config_value = '" . $server_name . "' WHERE config_name = 'server_name' OR config_name = 'cookie_domain'"; query($sql, "Couldn't insert Board Server domain"); $sql = "UPDATE " . $table_prefix . "config SET config_value = '" . $server_port . "' WHERE config_name = 'server_port'"; query($sql, "Couldn't insert Board server port"); $sql = "UPDATE " . $table_prefix . "config SET config_value = '" . $board_email . "' WHERE config_name = 'board_email'"; query($sql, "Couldn't insert Board admin email"); $sql = "UPDATE " . $table_prefix . "config SET config_value = '" . $script_path . "' WHERE config_name = 'script_path'"; query($sql, "Couldn't insert Board script path"); // // Change session table to HEAP if MySQL version matches // $sql = "SELECT VERSION() AS mysql_version"; $result = query($sql, "Couldn't obtain MySQL Version"); $row = $db->sql_fetchrow($result); $version = $row['mysql_version']; if ( preg_match("/^(3\.23)|(4\.)/", $version) ) { $sql = "ALTER TABLE " . $table_prefix . "sessions TYPE=HEAP MAX_ROWS=500"; $db->sql_query($sql); } echo "<span class=\"ok\"><b>OK</b></span><br />\n"; end_step('drop_fields'); case 'drop_fields': $fields = array( BANLIST_TABLE => array("ban_start", "ban_end", "ban_time_type"), FORUMS_TABLE => array("forum_access", "forum_moderator", "forum_type"), PRIVMSGS_TABLE => array("msg_text"), RANKS_TABLE => array("rank_max"), SMILIES_TABLE => array("emotion"), TOPICS_TABLE => array("topic_notify") ); while( list($table, $field_data) = each($fields) ) { for($i = 0; $i < count($field_data); $i++) { print " * Drop field '" . $field_data[$i] . "' in '$table' :: "; flush(); $sql = "ALTER TABLE $table DROP COLUMN " . $field_data[$i]; query($sql, "Couldn't drop field :: " . $field_data[$i] . " from table :: $table"); print "<span class=\"ok\"><b>OK</b></span><br />\n"; } } end_step('drop_tables'); case 'drop_tables': $drop_tables = array('access', 'forum_access', 'forum_mods', 'headermetafooter', 'whosonline', $table_prefix . 'old_config'); for($i = 0; $i < count($drop_tables); $i++) { print " * Dropping table '" . $drop_tables[$i] . "' :: "; flush(); $sql = "DROP TABLE " . $drop_tables[$i]; query($sql, "Couldn't drop table :: " . $drop_tables[$i]); print "<span class=\"ok\"><b>OK</b></span><br />\n"; } end_step('fulltext_search_indexing'); case 'fulltext_search_indexing': // // Generate search word list // // Fetch a batch of posts_text entries // $sql = "SELECT COUNT(*) as total, MAX(post_id) as max_post_id FROM " . POSTS_TEXT_TABLE; $result = query($sql, "Couldn't get post count totals"); $max_post_id = $db->sql_fetchrow($result); $totalposts = $max_post_id['total']; $max_post_id = $max_post_id['max_post_id']; $per_percent = round(( $totalposts / 500 ) * 10); $postcounter = ( !isset($HTTP_GET_VARS['batchstart']) ) ? 0 : $HTTP_GET_VARS['batchstart']; $batchsize = 150; // Process this many posts per loop $batchcount = 0; $total_percent = 0; for(;$postcounter <= $max_post_id; $postcounter += $batchsize) { $batchstart = $postcounter + 1; $batchend = $postcounter + $batchsize; $batchcount++; print " * Fulltext Indexing ( $batchstart to $batchend ) :: "; flush(); $sql = "SELECT * FROM " . POSTS_TEXT_TABLE ." WHERE post_id BETWEEN $batchstart AND $batchend"; $posts_result = query($sql, "Couldn't obtain post_text"); $per_pct = ceil( $db->sql_numrows($posts_result) / 40 ); $inc = 0; if ( $row = $db->sql_fetchrow($posts_result) ) { do { add_search_words('global', $row['post_id'], $row['post_text'], $row['post_subject']); $inc++; if ( $inc == $per_pct ) { print "."; flush(); $inc = 0; } } while( $row = $db->sql_fetchrow($posts_result) ); } $db->sql_freeresult($posts_result); // Remove common words after the first 2 batches and after every 4th batch after that. if ( $batchcount % 4 == 3 ) { remove_common('global', 4/10); } print " <span class=\"ok\"><b>OK</b></span><br />\n"; } echo "\n<br /><br />\n\n<font size=\"+3\"><b>UPGRADE COMPLETED</b></font><br />\n"; } } print "<br />If the upgrade completed without error you may click <a href=\"./../index.$phpEx\">Here</a> to proceed to the index<br />"; common_footer(); ?> 
