Failed SQL queries are now also reported in bug mails, SQL queries improved (more...
[mailer.git] / inc / db / lib-mysql3.php
index bb43adeba8f2a3ed8142c5862bb582938c6f6642..02e1722fe25d3d1b08db80b59f99d2429e2c38b6 100644 (file)
@@ -1,7 +1,7 @@
 <?php
 /************************************************************************
- * MXChange v0.2.1                                    Start: 08/29/2004 *
- * ===============                              Last change: 08/29/2004 *
+ * Mailer v0.2.1-FINAL                                Start: 08/29/2004 *
+ * ===================                          Last change: 08/29/2004 *
  *                                                                      *
  * -------------------------------------------------------------------- *
  * File              : lib-mysql3.php                                   *
@@ -17,7 +17,8 @@
  * Needs to be in all Files and every File needs "svn propset           *
  * svn:keywords Date Revision" (autoprobset!) at least!!!!!!            *
  * -------------------------------------------------------------------- *
- * Copyright (c) 2003 - 2008 by Roland Haeder                           *
+ * Copyright (c) 2003 - 2009 by Roland Haeder                           *
+ * Copyright (c) 2009, 2010 by Mailer Developer Team                    *
  * For more information visit: http://www.mxchange.org                  *
  *                                                                      *
  * This program is free software; you can redistribute it and/or modify *
 
 // Some security stuff...
 if (!defined('__SECURITY')) {
-       $INC = substr(dirname(__FILE__), 0, strpos(dirname(__FILE__), '/inc') + 4) . '/security.php';
-       require($INC);
-}
+       die();
+} // END - if
 
 // SQL queries
-function SQL_QUERY ($sql_string, $F, $L) {
+function SQL_QUERY ($sqlString, $F, $L) {
+       // Trim SQL string
+       $sqlString = trim($sqlString);
+
        // Link is up?
        if (!SQL_IS_LINK_UP()) {
                // We should not quietly ignore this!
-               trigger_error(sprintf("Cannot query database: sql_string=%s,file=%s,line=%s",
-                       $sql_string,
+               debug_report_bug(sprintf("Cannot query database: sqlString=%s,file=%s,line=%s",
+                       $sqlString,
                        basename($F),
                        $L
                ));
 
                // Return 'false' because it has failed
                return false;
-       } // END - if
+       } elseif (empty($sqlString)) {
+               // Empty SQL string!
+               debug_report_bug(sprintf("SQL string is empty. Please fix this. file=%s, line=%s",
+                       basename($F),
+                       $L
+               ));
+
+               // This is invalid, of course
+               return false;
+       }
 
        // Remove \t, \n and \r from queries they may confuse some MySQL version I have heard
-       $sql_string = str_replace("\t", " ", str_replace("\n", " ", str_replace("\r", " ", $sql_string)));
+       $sqlString = str_replace("\t", ' ', str_replace("\n", ' ', str_replace("\r", ' ', $sqlString)));
 
-       // Replace {!_MYSQL_PREFIX!} with constant, closes #84. Thanks to profi-concept
-       $sql_string = str_replace("{!_MYSQL_PREFIX!}", getConfig('_MYSQL_PREFIX'), $sql_string);
+       // Replace {PER}
+       $sqlString = str_replace('{PER}', '%', $sqlString);
 
-       // Replace {!_TABLE_TYPE!} with constant
-       $sql_string = str_replace("{!_TABLE_TYPE!}", getConfig('_TABLE_TYPE'), $sql_string);
+       // Compile config entries out
+       $eval = "\$sqlString = \"".FILTER_COMPILE_CONFIG(escapeQuotes($sqlString))."\";";
+       eval($eval);
 
        // Starting time
-       $querytimeBefore = array_sum(explode(' ', microtime()));
+       $querytimeBefore = microtime(true);
 
        // Run SQL command
-       //* DEBUG: */ OUTPUT_HTML($sql_string."<br />");
-       $result = mysql_query($sql_string, SQL_GET_LINK())
-               or addFatalMessage(__FUNCTION__, __LINE__, $F." (".$L."):".mysql_error()."<br />
-Query string:<br />
-".$sql_string);
-       //* DEBUG: */ OUTPUT_HTML(__LINE__ . ': numRows=' . SQL_NUMROWS($result) . ',affected=' . SQL_AFFECTEDROWS() . "<br />");
-
-       // Ending time
-       $querytimeAfter = array_sum(explode(' ', microtime()));
+       //* DEBUG: */ print('F=' . basename($F) . ',L=' . $L . 'sql=' . htmlentities($sqlString) . '<br />');
+       $result = mysql_query($sqlString, SQL_GET_LINK())
+               or debug_report_bug('[' . __FUNCTION__ . ':' . __LINE__ . '] ' . $F . ' (' . $L . '):' . mysql_error() . "\n".
+'Query string:' . $sqlString);
+       //* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'sql=' . $sqlString . ',numRows=' . SQL_NUMROWS($result) . ',affected=' . SQL_AFFECTEDROWS());
 
        // Calculate query time
-       $queryTime = $querytimeAfter - $querytimeBefore;
+       $queryTime = microtime(true) - $querytimeBefore;
+
+       // Add this query to array including timing
+       addSqlToDebug($result, $sqlString, $queryTime, $F, $L);
 
        // Save last successfull query
-       setConfigEntry('db_last_query', $sql_string);
+       setConfigEntry('db_last_query', $sqlString);
+
+       // Count all query times
+       incrementConfigEntry('sql_time', $queryTime);
 
        // Count this query
        incrementConfigEntry('sql_count');
 
        // Debug output
-       //* DEBUG: */ OUTPUT_HTML("Query=<pre>".$sql_string."</pre>, affected=<strong>".SQL_AFFECTEDROWS()."</strong>, numrows=<strong>".SQL_NUMROWS($result)."</strong><br />");
-       if ((getOutputMode() != '1') && (getOutputMode() != '-1') && (isDebugModeEnabled()) && (getConfig('DEBUG_SQL') == 'Y')) {
+       if ((getOutputMode() != 1) && (isDebugModeEnabled()) && (isSqlDebuggingEnabled())) {
                //
                // Debugging stuff...
                //
-               $fp = fopen(constant('PATH') . 'inc/cache/mysql.log', 'a') or app_die(__FILE__, __LINE__, "Cannot write mysql.log!");
+               $fp = fopen(getConfig('CACHE_PATH') . 'mysql.log', 'a') or app_die(__FILE__, __LINE__, 'Cannot write mysql.log!');
                if (!isset($GLOBALS['sql_first_entry'])) {
                        // Write first entry
                        fwrite($fp, 'Module=' . getModule() . "\n");
                        $GLOBALS['sql_first_entry'] = true;
                } // END - if
-               fwrite($fp, $F."(LINE=".$L."|NUM=".SQL_NUMROWS($result)."|AFFECTED=".SQL_AFFECTEDROWS()."|QUERYTIME:".$queryTime."): ".str_replace("\r", '', str_replace("\n", " ", $sql_string))."\n");
+               fwrite($fp, $F . '(LINE=' . $L . '|NUM=' . SQL_NUMROWS($result) . '|AFFECTED=' . SQL_AFFECTEDROWS() . '|QUERYTIME:' . $queryTime . '): ' . str_replace("\r", '', str_replace("\n", ' ', $sqlString)) . "\n");
                fclose($fp);
        } // END - if
 
        // Count DB hits
-       if (!isConfigEntrySet('db_hits_run')) {
+       if (!isStatsEntrySet('db_hits')) {
                // Count in dummy variable
-               setConfigEntry('db_hits_run', 1);
+               setStatsEntry('db_hits', 1);
        } else {
                // Count to config array
-               incrementConfigEntry('db_hits_run');
+               incrementStatsEntry('db_hits');
        }
 
        // Return the result
@@ -120,17 +134,25 @@ Query string:<br />
 
 // SQL num rows
 function SQL_NUMROWS ($result) {
+       // Valid link resource?
+       if (!SQL_IS_LINK_UP()) return false;
+
+       // Link is not up, no rows by default
+       $lines = false;
+
        // Is the result a valid resource?
        if (is_resource($result)) {
                // Get the count of rows from database
                $lines = mysql_num_rows($result);
 
                // Is the result empty? Then we have an error!
-               if (empty($lines)) $lines = 0;
+               if (empty($lines)) $lines = '0';
        } else {
-               // No resource given, no lines found!
-               $lines = 0;
+               // No resource given, please fix this
+               trigger_error('No resource given! result[]=' . gettype($result));
        }
+
+       // Return lines
        return $lines;
 }
 
@@ -149,16 +171,16 @@ function SQL_AFFECTEDROWS() {
 // SQL fetch row
 function SQL_FETCHROW ($result) {
        // Is a result resource set?
-       if (!is_resource($result)) return false;
+       if ((!is_resource($result)) || (!SQL_IS_LINK_UP())) return false;
 
        // Fetch the data and return it
        return mysql_fetch_row($result);
 }
 
 // SQL fetch array
-function SQL_FETCHARRAY($res, $nr=0, $remove_numerical=true) {
+function SQL_FETCHARRAY ($res, $nr=0, $remove_numerical=true) {
        // Is a result resource set?
-       if (!is_resource($res)) return false;
+       if ((!is_resource($res)) || (!SQL_IS_LINK_UP())) return false;
 
        // Initialize array
        $row = array();
@@ -172,7 +194,7 @@ function SQL_FETCHARRAY($res, $nr=0, $remove_numerical=true) {
                if ($remove_numerical) {
                        // So let's remove all numerical elements to save memory!
                        $max = count($row);
-                       for ($idx = 0; $idx < ($max / 2); $idx++) {
+                       for ($idx = '0'; $idx < ($max / 2); $idx++) {
                                // Remove entry
                                unset($row[$idx]);
                        } // END - for
@@ -181,15 +203,15 @@ function SQL_FETCHARRAY($res, $nr=0, $remove_numerical=true) {
                // Return row
                return $row;
        } else {
-               // Return a false here...
+               // Return a false, else some loops would go endless...
                return false;
        }
 }
 
 // SQL result
-function SQL_RESULT ($res, $row, $field = 0) {
+function SQL_RESULT ($res, $row, $field = '0') {
        // Is $res valid?
-       if (!is_resource($res)) return false;
+       if ((!is_resource($res)) || (!SQL_IS_LINK_UP())) return false;
 
        // Run the result command and return the result
        $result = mysql_result($res, $row, $field);
@@ -203,6 +225,9 @@ function SQL_CONNECT ($host, $login, $password, $F, $L) {
 
        // Set the link resource
        SQL_SET_LINK($connect);
+
+       // Destroy cache
+       unset($GLOBALS['is_sql_link_up']);
 }
 
 // SQL select database
@@ -221,16 +246,6 @@ function SQL_CLOSE ($F, $L) {
                return false;
        } // END - if
 
-       // Do we need to update cache/db counter?
-       //* DEBUG: */ OUTPUT_HTML("DB=".getConfig('db_hits').",CACHE=".getConfig('cache_hits')."<br />");
-       if ((GET_EXT_VERSION('cache') >= '0.0.7') && (getConfig('db_hits') > 0) && (getConfig('cache_hits') > 0) && (isCacheInstanceValid())) {
-               // Add new hits
-               incrementConfigEntry('db_hits', getConfig('db_hits_run'));
-
-               // Update counter for db/cache
-               updateConfiguration(array('db_hits', 'cache_hits'), array(getConfig('db_hits'), getConfig('cache_hits')));
-       } // END - if
-
        // Close database link and forget the link
        $close = mysql_close(SQL_GET_LINK())
                or addFatalMessage(__FUNCTION__, __LINE__, $F . ' (' . $L . '):'.mysql_error());
@@ -238,13 +253,16 @@ function SQL_CLOSE ($F, $L) {
        // Close link
        SQL_SET_LINK(null);
 
+       // Destroy cache
+       unset($GLOBALS['is_sql_link_up']);
+
        // Return the result
        return $close;
 }
 
 // SQL free result
 function SQL_FREERESULT ($result) {
-       if (!is_resource($result)) {
+       if ((!is_resource($result)) || (!SQL_IS_LINK_UP())) {
                // Abort here
                return false;
        } // END - if
@@ -256,48 +274,23 @@ function SQL_FREERESULT ($result) {
 // SQL string escaping
 function SQL_QUERY_ESC ($qstring, $data, $F, $L, $run=true, $strip=true, $secure=true) {
        // Link is there?
-       if (!SQL_IS_LINK_UP()) return false;
-
-       // Init variable
-       $query = 'failed';
+       if ((!SQL_IS_LINK_UP()) || (!is_array($data))) return false;
 
-       if ($strip === true) {
-               $strip = 'true';
-       } else {
-               $strip = 'false';
-       }
-
-       if ($secure === true) {
-               $secure = 'true';
-       } else {
-               $secure = 'false';
-       }
-
-       $eval = "\$query = sprintf(\"".$qstring."\"";
-       foreach ($data as $var) {
-               if ((!empty($var)) || ($var === 0)) {
-                       $eval .= ", SQL_ESCAPE(\"".$var."\", ".$secure.", ".$strip.")";
-               } else {
-                       $eval .= ", ''";
-               }
+       // Escape all data
+       $dataSecured['__sql_string'] = $qstring;
+       foreach ($data as $key => $value) {
+               $dataSecured[$key] = SQL_ESCAPE($value, $secure, $strip);
        } // END - foreach
-       $eval .= ");";
+
+       // Generate query
+       $query = call_user_func_array('sprintf', $dataSecured);
 
        // Debugging
        //
-       //* DEBUG: */ $fp = fopen(constant('PATH')."inc/cache/escape_debug.log", 'a') or app_die(__FILE__, __LINE__, "Cannot write debug.log!");
-       //* DEBUG: */ fwrite($fp, $F.'('.$L."): ".str_replace("\r", '', str_replace("\n", " ", $eval))."\n");
+       //* DEBUG: */ $fp = fopen(getConfig('CACHE_PATH') . 'escape_debug.log', 'a') or app_die(__FILE__, __LINE__, "Cannot write debug.log!");
+       //* DEBUG: */ fwrite($fp, $F.'('.$L."): ".str_replace("\r", '', str_replace("\n", ' ', $eval))."\n");
        //* DEBUG: */ fclose($fp);
 
-       // Run the code
-       eval($eval);
-
-       // Was the eval() command fine?
-       if ($query == 'failed') {
-               // Something went wrong?
-               debug_report_bug('eval=' . $eval);
-       } // END - if
-
        if ($run === true) {
                // Run SQL query (default)
                return SQL_QUERY($query, $F, $L);
@@ -307,7 +300,7 @@ function SQL_QUERY_ESC ($qstring, $data, $F, $L, $run=true, $strip=true, $secure
        }
 }
 
-// Get ID from last INSERT command
+// Get id from last INSERT command
 function SQL_INSERTID () {
        if (!SQL_IS_LINK_UP()) return false;
        return mysql_insert_id();
@@ -315,26 +308,35 @@ function SQL_INSERTID () {
 
 // Escape a string for the database
 function SQL_ESCAPE ($str, $secureString=true, $strip=true) {
-       // Secure string first? (which is the default behaviour!)
-       if ($secureString) {
-               // Then do it here
-               $str = secureString($str, $strip);
+       // Do we have cache?
+       if (!isset($GLOBALS['sql_escapes'][''.$str.''])) {
+               // Secure string first? (which is the default behaviour!)
+               if ($secureString === true) {
+                       // Then do it here
+                       $str = secureString($str, $strip);
+               } // END - if
+
+               if (!SQL_IS_LINK_UP()) {
+                       // Fall-back to escapeQuotes() when there is no link
+                       $ret = escapeQuotes($str);
+               } elseif (function_exists('mysql_real_escape_string')) {
+                       // The new and improved version
+                       //* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'str='.$str);
+                       $ret = mysql_real_escape_string($str, SQL_GET_LINK());
+               } elseif (function_exists('mysql_escape_string')) {
+                       // The obsolete function
+                       $ret = mysql_escape_string($str, SQL_GET_LINK());
+               } else {
+                       // If nothing else works, fall back to escapeQuotes() again
+                       $ret = escapeQuotes($str);
+               }
+
+               // Cache result
+               $GLOBALS['sql_escapes'][''.$str.''] = $ret;
        } // END - if
 
-       if (!SQL_IS_LINK_UP()) {
-               // Fall-back to smartAddSlashes() when there is no link
-               return smartAddSlashes($str);
-       } elseif (function_exists('mysql_real_escape_string')) {
-               // The new and improved version
-               //* DEBUG: */ OUTPUT_HTML(__FUNCTION__."(<font color=\"#0000aa\">".__LINE__."</font>):str={$str}<br />");
-               return mysql_real_escape_string($str, SQL_GET_LINK());
-       } elseif (function_exists('mysql_escape_string')) {
-               // The obsolete function
-               return mysql_escape_string($str, SQL_GET_LINK());
-       } else {
-               // If nothing else works, fall back to smartAddSlashes()
-               return smartAddSlashes($str);
-       }
+       // Return it
+       return $GLOBALS['sql_escapes'][''.$str.''];
 }
 
 // SELECT query string from table, columns and so on... ;-)
@@ -342,11 +344,18 @@ function SQL_RESULT_FROM_ARRAY ($table, $columns, $idRow, $id, $F, $L) {
        // Is columns an array?
        if (!is_array($columns)) {
                // No array
-               trigger_error(sprintf("columns is not array. %s!=array", gettype($columns)));
+               debug_report_bug(sprintf("columns is not an array. %s != array, file=%s, line=%s",
+                       gettype($columns),
+                       basename($F),
+                       $L
+               ));
+
+               // Abort here with 'false'
+               return false;
        } // END  - if
 
        // Prepare the SQL statement
-       $sql = "SELECT `".implode("`,`", $columns)."` FROM `{!_MYSQL_PREFIX!}_%s` WHERE `%s`='%s' LIMIT 1";
+       $sql = "SELECT `".implode("`,`", $columns)."` FROM `{?_MYSQL_PREFIX?}_%s` WHERE `%s`='%s' LIMIT 1";
 
        // Return the result
        return SQL_QUERY_ESC($sql,
@@ -360,6 +369,9 @@ function SQL_RESULT_FROM_ARRAY ($table, $columns, $idRow, $id, $F, $L) {
 
 // ALTER TABLE wrapper function
 function SQL_ALTER_TABLE ($sql, $F, $L) {
+       // Abort if link is down
+       if (!SQL_IS_LINK_UP()) return false;
+
        // This is the default result...
        $result = false;
 
@@ -367,6 +379,8 @@ function SQL_ALTER_TABLE ($sql, $F, $L) {
        $noIndex = (
        (
                strpos($sql, 'INDEX') === false
+       ) && (
+               strpos($sql, 'KEY') === false
        ) && (
                strpos($sql, 'FULLTEXT') === false
        ) && (
@@ -375,44 +389,58 @@ function SQL_ALTER_TABLE ($sql, $F, $L) {
        );
 
        // Extract table name
-       $tableArray = explode(" ", $sql);
+       $tableArray = explode(' ', $sql);
        $tableName = str_replace('`', '', $tableArray[2]);
 
        // Shall we add/drop?
        if (((strpos($sql, 'ADD') !== false) || (strpos($sql, 'DROP') !== false)) && ($noIndex === true)) {
-               // And column name as well
-               $columnName = str_replace('`', '', $tableArray[4]);
-
-               // Get column information
-               $result = SQL_QUERY_ESC("SHOW COLUMNS FROM `%s` LIKE '%s'",
-                       array($tableName, $columnName), __FILE__, __LINE__);
-
-               // Do we have no entry on ADD or an entry on DROP?
-               // 123           4       4     3    3      4           4          32    23           4       4     3    3      4            4          321
-               if (((SQL_NUMROWS($result) == 0) && (strpos($sql, 'ADD') !== false)) || ((SQL_NUMROWS($result) == 1) && (strpos($sql, 'DROP') !== false))) {
-                       // Do the query
-                       //* DEBUG: */ OUTPUT_HTML(__LINE__.':'.$sql."<br />");
-                       $result = SQL_QUERY($sql, $F, $L, false);
-               } // END - if
+               // Try two columns, one should fix
+               foreach (array(4,5) as $idx) {
+                       // And column name as well
+                       $columnName = str_replace('`', '', $tableArray[$idx]);
+
+                       // Get column information
+                       $result = SQL_QUERY_ESC("SHOW COLUMNS FROM `%s` LIKE '%s'",
+                               array($tableName, $columnName), __FILE__, __LINE__);
+
+                       // Do we have no entry on ADD or an entry on DROP?
+                       // 123           4       4     3    3      4           4          32    23           4       4     3    3      4            4          321
+                       if (((SQL_HASZERONUMS($result)) && (strpos($sql, 'ADD') !== false)) || ((SQL_NUMROWS($result) == 1) && (strpos($sql, 'DROP') !== false))) {
+                               // Do the query
+                               //* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'Executing: ' . $sql);
+                               $result = SQL_QUERY($sql, $F, $L, false);
+
+                               // Skip further attempt(s)
+                               break;
+                       } elseif ((((SQL_NUMROWS($result) == 1) && (strpos($sql, 'ADD') !== false)) || ((SQL_HASZERONUMS($result)) && (strpos($sql, 'DROP') !== false))) && ($columnName != 'KEY')) {
+                               // Abort here because it is alreay there
+                               //* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'Skipped: ' . $sql);
+                               break;
+                       } elseif ($columnName != 'KEY') {
+                               // Something didn't fit
+                               //* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'Possible problem: ' . $sql);
+                       }
+               } // END - foreach
        } elseif ((getConfig('_TABLE_TYPE') == 'InnoDB') && (strpos($sql, 'FULLTEXT') !== false)) {
                // Skip this query silently
-               //* DEBUG: */ DEBUG_LOG(__FUNCTION__, __LINE__, sprintf("Skipped FULLTEXT: sql=%s,file=%s,line=%s", $sql, $F, $L));
-       } elseif (!$noIndex) {
+               //* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, sprintf("Skipped FULLTEXT: sql=%s,file=%s,line=%s", $sql, $F, $L));
+       } elseif ($noIndex === false) {
                // And column name as well
-               $columnName = str_replace('`', '', $tableArray[4]);
+               //* DEBUG: */ print __LINE__.':tableArray=<pre>' . print_r($tableArray, true) . '</pre>';
+               $keyName = str_replace('`', '', $tableArray[5]);
 
                // Is this "UNIQUE" or so? FULLTEXT has been handled the elseif() block above
-               if (in_array(strtoupper($columnName), array('INDEX', 'UNIQUE', 'KEY', 'FULLTEXT'))) {
+               if (in_array(strtoupper($keyName), array('INDEX', 'UNIQUE', 'KEY', 'FULLTEXT'))) {
                        // Init loop
-                       $begin = 1; $columnName = ',';
-                       while (strpos($columnName, ',') !== false) {
+                       $begin = 1; $keyName = ',';
+                       while (strpos($keyName, ',') !== false) {
                                // Use last
-                               $columnName = str_replace('`', '', $tableArray[count($tableArray) - $begin]);
-                               //* DEBUG: */ OUTPUT_HTML(__LINE__.':'.$columnName."----------------".$begin."<br />");
+                               $keyName = str_replace('`', '', $tableArray[count($tableArray) - $begin]);
+                               //* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, $keyName . '----------------' . $begin);
 
                                // Remove brackes
-                               $columnName = str_replace('(', '', str_replace(')', '', $columnName));
-                               //* DEBUG: */ OUTPUT_HTML(__LINE__.':'.$columnName."----------------".$begin."<br />");
+                               $keyName = str_replace('(', '', str_replace(')', '', $keyName));
+                               //* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, $keyName . '----------------' . $begin);
 
                                // Continue
                                $begin++;
@@ -420,34 +448,50 @@ function SQL_ALTER_TABLE ($sql, $F, $L) {
                } // END - if
 
                // Show indexes
-               $result = SQL_QUERY_ESC("SHOW INDEX FROM `%s`",
-                       array($tableName), __FILE__, __LINE__);
+               $result = SQL_QUERY_ESC("SHOW INDEX FROM `%s`", array($tableName), __FILE__, __LINE__);
 
-               // Walk through all
+               // Non-skipping is default for ADD
                $skip = false;
+
+               // But should we DROP?
+               if ($tableArray[3] == 'DROP') {
+                       // Then skip if nothing found!
+                       $skip = true;
+                       //* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'Going to drop key ' . $keyName);
+               } // END - if
+
+               // Walk through all
                while ($content = SQL_FETCHARRAY($result)) {
                        // Is it found?
-                       //* DEBUG: */ OUTPUT_HTML("<pre>".print_r($content, true)."</pre>");
-                       if (($content['Column_name'] == $columnName) || ($content['Key_name'] == $columnName)) {
+                       //* DEBUG: */ print(__LINE__.':columnName='.$keyName.',content=<pre>' . print_r($content, true) . '</pre>');
+                       if (($content['Key_name'] == $keyName) && ($tableArray[3] == 'ADD')) {
                                // Skip this query!
-                               //* DEBUG: */ DEBUG_LOG(__FUNCTION__, __LINE__, sprintf("Skiped: %s", $sql));
+                               //* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, sprintf("ADD: Skiped: %s", $sql));
                                $skip = true;
                                break;
-                       } // END - if
+                       } elseif (($content['Key_name'] == $keyName) && ($tableArray[3] == 'DROP')) {
+                               // Don't skip this!
+                               //* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, sprintf("DROP: Not skiped: %s", $sql));
+                               $skip = false;
+                               break;
+                       }
                } // END - while
 
                // Free result
                SQL_FREERESULT($result);
 
                // Shall we run it?
-               if (!$skip) {
+               if ($skip === false) {
                        // Send it to the SQL_QUERY() function
-                       //* DEBUG: */ OUTPUT_HTML(__LINE__.':'.$sql."<br />");
+                       //* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, $sql);
                        $result = SQL_QUERY($sql, $F, $L, false);
-               } // END - if
+               } else {
+                       // Not executed
+                       //* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'Not executed: ' . $sql);
+               }
        } else {
                // Other ALTER TABLE query
-               //* DEBUG: */ OUTPUT_HTML(__LINE__.':'.$sql."<br />");
+               //* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, $sql);
                $result = SQL_QUERY($sql, $F, $L, false);
        }
 
@@ -475,7 +519,7 @@ function SQL_SET_LINK ($link) {
        // Is this a resource or null?
        if ((!is_resource($link)) && (!is_null($link))) {
                // This should never happen!
-               trigger_error(sprintf("link is not resource or null. Type: %s", gettype($link)));
+               debug_report_bug(sprintf("link is not resource or null. Type: %s", gettype($link)));
        } // END - if
 
        // Set it
@@ -484,12 +528,30 @@ function SQL_SET_LINK ($link) {
 
 // Checks if the link is up
 function SQL_IS_LINK_UP () {
-       // Get the link
-       $link = SQL_GET_LINK();
+       // Default is not up
+       $linkUp = false;
+
+       // Do we have cached this?
+       if (isset($GLOBALS['is_sql_link_up'])) {
+               // Then use this
+               $linkUp = $GLOBALS['is_sql_link_up'];
+       } else {
+               // Get it
+               $linkUp = is_resource(SQL_GET_LINK());
+
+               // And cache it
+               $GLOBALS['is_sql_link_up'] = $linkUp;
+       }
 
        // Return the result
-       return (is_resource($link));
+       return $linkUp;
+}
+
+// Wrapper function to make code more readable
+function SQL_HASZERONUMS ($result) {
+       // Just pass it through
+       return (SQL_NUMROWS($result) === 0);
 }
 
-//
+// [EOF]
 ?>