$file) { $filename = e_PLUGIN.$path.'/'.$file.'.php'; if(is_readable($filename)) { $id = str_replace('_sql','',$file); $temp = file_get_contents($filename); $tables[$id] = preg_replace("#\/\*.*?\*\/#mis", '', $temp); // Strip comments as we copy unset($temp); } else { $emessage->add($filename.DBLAN_22, E_MESSAGE_WARNING); } } function read_tables($tab) { global $tablines, $table_list, $tables, $pref; $mes = e107::getMessage(); $file = explode("\n", $tables[$tab]); foreach($file as $line) { $line = ltrim(stripslashes($line)); if ($line) { $match = array(); if (preg_match('/CREATE TABLE (.*) /', $line, $match)) { if($match[1] != "user_extended") { $table_list[$match[1]] = 1; $current_table = $match[1]; $x = 0; $cnt = 0; } } if (strpos($line, "TYPE=") !== FALSE) { $current_table = ""; } if ($current_table && $x) { $tablines[$current_table][$cnt++] = $line; } $x = 1; } } // Get multi-language tables as well if($pref['multilanguage']) { $langs = table_list(); $mes->add(print_a($langs,TRUE), E_MESSAGE_DEBUG); foreach(array_keys($table_list) as $name) { if($langs[$name]) { $ltab = $langs[$name]; $table_list[$ltab] = 1; $tablines[$ltab] = $tablines[$name]; } } } $mes->add(print_a($table_list,TRUE), E_MESSAGE_DEBUG); } // Get list of fields and keys for a table function get_current($tab, $prefix = "") { if(! $prefix) { $prefix = MPREFIX; } mysql_query('SET SQL_QUOTE_SHOW_CREATE = 1'); $qry = 'SHOW CREATE TABLE `' . $prefix . $tab . "`"; $z = mysql_query($qry); if($z) { $row = mysql_fetch_row($z); return str_replace("`", "", stripslashes($row[1])); } else { return FALSE; } } function check_tables($what) { global $tablines, $table_list, $frm, $emessage; $cur = 0; $table_list = ""; read_tables($what); $fix_active = FALSE; // Flag set as soon as there's a fix - enables 'Fix it' button $text = "
".DBLAN_16." - $what ".DBLAN_18." "; foreach(array_keys($table_list) as $k) { // $k is the DB table name (less prefix) $ttcount = 0; $ttext = " "; $prefix = MPREFIX; $current_tab = get_current($k, $prefix); // Get list of fields and keys from actual table unset($fields); unset($xfields); $xfield_errors = 0; if ($current_tab) { $lines = explode("\n", $current_tab); // Actual table - create one element of $lines per field or other line of info $fieldnum = 0; foreach($tablines[$k] as $x) { // $x is a line of the DB definition from the *_sql.php file $x = str_replace(' ',' ',$x); // Remove double spaces $fieldnum++; $ffound = 0; list($fname, $fparams) = explode(' ', $x, 2); // Pull out first word of definition if ($fname == 'UNIQUE' || $fname == 'FULLTEXT') { list($key, $key1, $keyname, $keyparms) = explode(' ', $x, 4); $fname = $key." ".$key1." ".$keyname; $fparams = $keyparms; } elseif ($fname == 'KEY') { list($key, $keyname, $keyparms) = explode(' ', $x, 3); $fname = $key." ".$keyname; $fparams = $keyparms; } elseif ($fname == 'PRIMARY') { // Nothing to do ATM } else { // Must be a field name $fname = str_replace('`','',$fname); // Just remove back ticks if present } $fields[$fname] = 1; $fparams = ltrim(rtrim($fparams)); $fparams = preg_replace("/\r?\n$|\r[^\n]$|,$/", '', $fparams); if(stristr($k, "lan_") !== FALSE && $cur != 1) { $cur = 1; } $head_txt = " "; $xfieldnum = -1; $body_txt = ''; foreach($lines as $l) { $xfieldnum++; list($xl, $tmp) = explode("\n", $l, 2); // $tmp should be null $xl = ltrim(rtrim(stripslashes($xl))); $xl = preg_replace('/\r?\n$|\r[^\n]$/', '', $xl); $xl = str_replace(' ',' ',$xl); // Remove double spaces list($xfname, $xfparams) = explode(" ", $xl, 2); // Field name and the rest if ($xfname == 'UNIQUE' || $xfname == 'FULLTEXT') { list($key, $key1, $keyname, $keyparms) = explode(" ", $xl, 4); $xfname = $key." ".$key1." ".$keyname; $xfparams = $keyparms; } elseif ($xfname == "KEY") { list($key, $keyname, $keyparms) = explode(" ", $xl, 3); $xfname = $key." ".$keyname; $xfparams = $keyparms; } if ($xfname != "CREATE" && $xfname != ")") { $xfields[$xfname] = 1; } $xfparams = preg_replace('/,$/', '', $xfparams); $fparams = preg_replace('/,$/', '', $fparams); if ($xfname == $fname) { // Field names match - or it could be the word 'KEY' and its name which matches $ffound = 1; //echo "Field: ".$xfname." Actuals: ".$xfparams." Expected: ".$fparams."
"; $xfsplit = explode(' ',$xfparams); $fsplit = explode(' ',$fparams); $skip = FALSE; $i = 0; $fld_err = FALSE; foreach ($xfsplit as $xf) { if ($skip) { $skip = FALSE; // echo " Unskip: ".$xf."
"; } elseif (strcasecmp(trim($xf),'collate') == 0) { // Strip out the collation definition $skip = TRUE; // cho "Skip = ".$xf; } else { // echo "Compare: ".$xf." - ".$fsplit[$i]."
"; // Since VARCHAR and CHAR are interchangeable, convert to CHAR (strictly, VARCHAR(3) and smalller becomes CHAR() ) if (stripos($xf,'VARCHAR') === 0) $xf = substr($xf,3); if (stripos($fsplit[$i],'VARCHAR') === 0) $fsplit[$i] = substr($fsplit[$i],3); if (strcasecmp(trim($xf),trim($fsplit[$i])) != 0) { $fld_err = TRUE; //echo "Mismatch: ".$xf." - ".$fsplit[$i]."
"; } $i++; } } if ($fld_err) { $body_txt .= " "; $fix_active = TRUE; $xfield_errors++; } /* FIXME - can't stay if there is no way of fixing the field numbers (e.g. AFTER query) elseif ($fieldnum != $xfieldnum) { // Field numbers different - missing field? $body_txt .= " "; } */ /* DISABLED for now (show only errors), could be page setting else { $body_txt .= " "; } */ } } // Finished checking one field if ($ffound == 0) { $prev_fname = $fname; //FIXME - wrong $prev_fname! $body_txt .= " "; $fix_active = TRUE; $xfield_errors++; } if($xfield_errors && $body_txt) { $ttext .= $head_txt.$body_txt." "; } } foreach(array_keys($xfields) as $tf) { if (!$fields[$tf] && $k != "user_extended") { $fix_active = TRUE; $xfield_errors++; $ttext .= " "; } } } else { // Table Missing. $ttext .= " "; $fix_active = TRUE; $xfield_errors++; } if(!$xfield_errors) { //no errors, so no table rows yet $ttext .= " "; } $ttext .= "
".DBLAN_4.": {$k} ".DBLAN_5." ".DBLAN_6." ".DBLAN_7." ".DBLAN_19."
{$k} {$fname} "; if (strpos($fparams, 'KEY') !== FALSE) { $head_txt .= " {$fparams} aa"; } $head_txt .= "".DBLAN_8." ".DBLAN_9."
{$xfparams}
".DBLAN_10."
{$fparams}
".fix_form($k, $fname, $fparams, "alter")."".DBLAN_5." ".DBLAN_8." ".DBLAN_9.": #{$xfieldnum}
".DBLAN_10.": #{$fieldnum}
 OK    ".DBLAN_11." ".DBLAN_10."
{$fparams}
".fix_form($k, $fname, $fparams, "insert"/*, $prev_fname*/)."
$k $tf ".DBLAN_12."   ".fix_form($k, $tf, $fparams, "drop")."
{$k}   ".DBLAN_13."   ".fix_form($k, $tf, $tablines[$k], "create") . "
Table status OK

"; //FIXME - add 'show_if_ok' switch if($xfield_errors || (!$xfield_errors && varsettrue($_GET['show_if_ok']))) { $text .= $ttext; $ttcount++; } } if(!$fix_active) { //Everything should be OK $emessage->add('DB successfully verified - no problems were found.', E_MESSAGE_SUCCESS); if(!$ttcount) { //very tired and sick of this page, so quick and dirty $text .= " "; } } if($fix_active) { $text .= "
".$frm->admin_button('do_fix', DBLAN_21, 'execute', '', array('id'=>false))." ".$frm->admin_button('check_all', 'jstarget:fix_active', 'action', LAN_CHECKALL, array('id'=>false))." ".$frm->admin_button('uncheck_all', 'jstarget:fix_active', 'action', LAN_UNCHECKALL, array('id'=>false))."
"; } foreach(array_keys($_POST) as $j) { $match = array(); if (preg_match('/table_(.*)/', $j, $match)) { $lx = $match[1]; $text .= "
\n"; } } $text .= "
".$frm->admin_button('back', DBLAN_17, 'back')."
"; return $text; } global $table_list; // -------------------- Table Fixing ------------------------------ if(isset($_POST['do_fix'])) { //$emessage->add(DBLAN_20); foreach( $_POST['fix_active'] as $key=>$val) { if (MAGIC_QUOTES_GPC == TRUE) { $table = stripslashes($_POST['fix_table'][$key][0]); $newval = stripslashes($_POST['fix_newval'][$key][0]); $mode = stripslashes($_POST['fix_mode'][$key][0]); $after = stripslashes($_POST['fix_after'][$key][0]); } else { $table = $_POST['fix_table'][$key][0]; $newval = $_POST['fix_newval'][$key][0]; $mode = $_POST['fix_mode'][$key][0]; $after = $_POST['fix_after'][$key][0]; } $field= $key; switch($mode) { case 'alter': $query = "ALTER TABLE `".MPREFIX.$table."` CHANGE `$field` `$field` $newval"; break; case 'insert': if($after) $after = " AFTER {$after}"; $query = "ALTER TABLE `".MPREFIX.$table."` ADD `$field` $newval{$after}"; break; case 'drop': $query = "ALTER TABLE `".MPREFIX.$table."` DROP `$field` "; break; case 'index': $query = "ALTER TABLE `".MPREFIX.$table."` ADD INDEX `$field` ($newval)"; break; case 'indexalt': $query = "ALTER TABLE `".MPREFIX.$table."` ADD $field ($newval)"; break; case 'indexdrop': $query = "ALTER TABLE `".MPREFIX.$table."` DROP INDEX `$field`"; break; case 'create': $query = "CREATE TABLE `".MPREFIX.$table."` ({$newval}"; if (!preg_match('#.*?\s+?(?:TYPE|ENGINE)\s*\=\s*(.*?);#is', $newval)) { $query .= ') TYPE=MyISAM;'; } break; } //FIXME - db handler!!! if(mysql_query($query)) $emessage->add(LAN_UPDATED.' [ '.$query.' ]', E_MESSAGE_SUCCESS); else { $emessage->add(LAN_UPDATED_FAILED.' [ '.$query.' ]', E_MESSAGE_WARNING); if(mysql_errno()) { $emessage->add('     SQL #'.mysql_errno().': '.mysql_error(), E_MESSAGE_WARNING); } } } } // ---------------------- Main Form and Submit. ------------------------ if (varset($_POST['db_verify']) || varset($_POST['do_fix'])) { $text = ''; foreach(array_keys($_POST) as $k) { $match = array(); if (preg_match("/table_(.*)/", $k, $match)) { $xx = $match[1]; $text .= check_tables($xx); } } if(!$text) $emessage->add(DBLAN_24, E_MESSAGE_WARNING); else { $e107->ns->tablerender(DBLAN_23.' - '.DBLAN_16, $emessage->render().$text); require_once(e_ADMIN."footer.php"); exit; } } $text = "
".DBLAN_14." "; foreach(array_keys($tables) as $x) { $text .= " "; } $text .= "
".$frm->checkbox_toggle('check-all-verify', 'table_').LAN_CHECKALL.' | '.LAN_UNCHECKALL."
".$frm->checkbox('table_'.$x, $x).$frm->label($x, 'table_'.$x, $x)."
".$frm->admin_button('db_verify', DBLAN_15)." ".$frm->admin_button('db_tools_back', DBLAN_17, 'back')."
"; $e107->ns->tablerender(DBLAN_23.' - '.DBLAN_16, $emessage->render().$text); require_once(e_ADMIN."footer.php"); exit; // -------------------------------------------------------------- function fix_form($table,$field, $newvalue,$mode,$after ='') { global $frm; if($mode == 'create') { $newvalue = implode("\n",$newvalue); $field = $table; // Value for $field may be rubbish! } else { if(stristr($field, 'KEY ') !== FALSE) { $field = chop(str_replace('KEY ','',$field)); $mode = ($mode == 'drop') ? 'indexdrop' : 'index'; $search = array('(', ')'); $newvalue = str_replace($search,'',$newvalue); $after = ''; } if($mode == 'index' && (stristr($field, 'FULLTEXT ') !== FALSE || stristr($field, 'UNIQUE ') !== FALSE)) { $mode = 'indexalt'; } elseif($mode == 'indexdrop' && (stristr($field, 'FULLTEXT ') !== FALSE || stristr($field, 'UNIQUE ') !== FALSE)) { $field = trim(str_replace(array('FULLTEXT ', 'UNIQUE '), '', $field)); } $field = trim($field, '`'); } $text .= $frm->checkbox("fix_active[$field][]", 1, false, array('id'=>false)); $text .= "\n"; $text .= "\n"; $text .= "\n"; $text .= ($after) ? "\n" : ""; return $text; } function table_list() { // grab default language lists. global $mySQLdefaultdb; $exclude[] = "banlist"; $exclude[] = "banner"; $exclude[] = "cache"; $exclude[] = "core"; $exclude[] = "online"; $exclude[] = "parser"; $exclude[] = "plugin"; $exclude[] = "user"; $exclude[] = "upload"; $exclude[] = "userclass_classes"; $exclude[] = "rbinary"; $exclude[] = "session"; $exclude[] = "tmp"; $exclude[] = "flood"; $exclude[] = "stat_info"; $exclude[] = "stat_last"; $exclude[] = "submit_news"; $exclude[] = "rate"; $exclude[] = "stat_counter";$exclude[] = "user_extended"; $exclude[] = "user_extended_struct"; $exclude[] = "pm_messages"; $exclude[] = "pm_blocks"; $replace = array(); $lanlist = explode(",",e_LANLIST); foreach($lanlist as $lang) { if($lang != $pref['sitelanguage']) { $replace[] = "lan_".strtolower($lang)."_"; } } $tables = mysql_list_tables($mySQLdefaultdb); while (list($temp) = mysql_fetch_array($tables)) { $prefix = MPREFIX."lan_"; $match = array(); if(strpos($temp,$prefix)!==FALSE) { $e107tab = str_replace(MPREFIX, "", $temp); $core = str_replace($replace,"",$e107tab); if (str_replace($exclude, "", $e107tab)) { $tabs[$core] = $e107tab; } } } return $tabs; } /** * Handle page DOM within the page header * * @return string JS source */ function headerjs() { require_once (e_HANDLER.'js_helper.php'); $ret = " "; return $ret; } ?>