Performing necessary upgrade queries..
"; flush(); if($db->type == "mysql" || $db->type == "mysqli") { $db->write_query("ALTER TABLE ".TABLE_PREFIX."adminsessions ADD INDEX ( `uid` )"); $db->write_query("ALTER TABLE ".TABLE_PREFIX."adminsessions ADD INDEX ( `dateline` )"); } if($db->type != "sqlite") { if($db->index_exists("users", "username")) { $db->write_query("ALTER TABLE ".TABLE_PREFIX."users DROP KEY username"); } $query = $db->simple_select("users", "username, uid", "1=1 GROUP BY uid, username HAVING count(*) > 1"); while($user = $db->fetch_array($query)) { $db->update_query("users", array('username' => $user['username']."_dup".$user['uid']), "uid='{$user['uid']}'", 1); } if($db->type == "pgsql") { $db->write_query("ALTER TABLE ".TABLE_PREFIX."users ADD UNIQUE(username)"); } else { $db->write_query("ALTER TABLE ".TABLE_PREFIX."users ADD UNIQUE KEY username (username)"); } } if($db->type == "pgsql") { $db->write_query("ALTER TABLE ".TABLE_PREFIX."users CHANGE longregip longregip int NOT NULL default '0'"); $db->write_query("ALTER TABLE ".TABLE_PREFIX."users CHANGE longlastip longlastip int NOT NULL default '0'"); $db->write_query("ALTER TABLE ".TABLE_PREFIX."posts CHANGE longipaddress longipaddress int NOT NULL default '0'"); } else { $db->write_query("ALTER TABLE ".TABLE_PREFIX."users CHANGE longregip longregip int(11) NOT NULL default '0'"); $db->write_query("ALTER TABLE ".TABLE_PREFIX."users CHANGE longlastip longlastip int(11) NOT NULL default '0'"); $db->write_query("ALTER TABLE ".TABLE_PREFIX."posts CHANGE longipaddress longipaddress int(11) NOT NULL default '0'"); } $contents .= "Click next to continue with the upgrade process."; $output->print_contents($contents); $output->print_footer("13_dbchanges1"); } function upgrade13_dbchanges1() { global $db, $output; $output->print_header("Post IP Repair Conversion"); if(!$_POST['ipspage']) { $ipp = 5000; } else { $ipp = (int)$_POST['ipspage']; } if($_POST['ipstart']) { $startat = (int)$_POST['ipstart']; $upper = $startat+$ipp; $lower = $startat; } else { $startat = 0; $upper = $ipp; $lower = 1; } $query = $db->simple_select("posts", "COUNT(pid) AS ipcount"); $cnt = $db->fetch_array($query); if($upper > $cnt['ipcount']) { $upper = $cnt['ipcount']; } echo "Repairing ip {$lower} to {$upper} ({$cnt['ipcount']} Total)
"; flush(); $ipaddress = false; $query = $db->simple_select("posts", "ipaddress, longipaddress, pid", "", array('limit_start' => $lower, 'limit' => $ipp)); while($post = $db->fetch_array($query)) { // Have we already converted this ip? if(my_ip2long($post['ipaddress']) < 0) { $db->update_query("posts", array('longipaddress' => my_ip2long($post['ipaddress'])), "pid = '{$post['pid']}'"); } $ipaddress = true; } $remaining = $upper-$cnt['ipcount']; if($remaining && $ipaddress) { $nextact = "13_dbchanges1"; $startat = $startat+$ipp; $contents = "Done. Click Next to move on to the next set of post ips.
"; } else { $nextact = "13_dbchanges2"; $contents = "Done
All post ips have been converted to the new ip format. Click next to continue.
"; } $output->print_contents($contents); global $footer_extra; $footer_extra = ""; $output->print_footer($nextact); } function upgrade13_dbchanges2() { global $db, $output; $output->print_header("User IP Repair Conversion"); if(!$_POST['ipspage']) { $ipp = 5000; } else { $ipp = (int)$_POST['ipspage']; } if($_POST['ipstart']) { $startat = (int)$_POST['ipstart']; $upper = $startat+$ipp; $lower = $startat; } else { $startat = 0; $upper = $ipp; $lower = 1; } $query = $db->simple_select("users", "COUNT(uid) AS ipcount"); $cnt = $db->fetch_array($query); if($upper > $cnt['ipcount']) { $upper = $cnt['ipcount']; } $contents .= "Repairing ip {$lower} to {$upper} ({$cnt['ipcount']} Total)
"; $ipaddress = false; $update_array = array(); $query = $db->simple_select("users", "regip, lastip, longlastip, longregip, uid", "", array('limit_start' => $lower, 'limit' => $ipp)); while($user = $db->fetch_array($query)) { // Have we already converted this ip? if(my_ip2long($user['regip']) < 0) { $update_array['longregip'] = (int)my_ip2long($user['regip']); } if(my_ip2long($user['lastip']) < 0) { $update_array['longlastip'] = (int)my_ip2long($user['lastip']); } if(!empty($update_array)) { $db->update_query("users", $update_array, "uid = '{$user['uid']}'"); } $update_array = array(); $ipaddress = true; } $remaining = $upper-$cnt['ipcount']; if($remaining && $ipaddress) { $nextact = "13_dbchanges2"; $startat = $startat+$ipp; $contents .= "Done. Click Next to move on to the next set of user ips.
"; } else { $nextact = "13_done"; $contents .= "Done
All user ips have been converted to the new ip format. Click next to continue.
"; } $output->print_contents($contents); global $footer_extra; $footer_extra = ""; $output->print_footer($nextact); }