X-Git-Url: https://git.mxchange.org/?p=mailer.git;a=blobdiff_plain;f=inc%2Fdb%2Flib-mysql3.php;h=56ebf64d1bfda1e70f23b9227b92129171803a2c;hp=3f26d2ce900bba950f1340c7cb8a50e1a851f4d4;hb=51c6ad72422e13bfae559bf116b54baee68cd1e5;hpb=ae51687a0bf708aeca3d68263320804ae0dd42ef diff --git a/inc/db/lib-mysql3.php b/inc/db/lib-mysql3.php index 3f26d2ce90..56ebf64d1b 100644 --- a/inc/db/lib-mysql3.php +++ b/inc/db/lib-mysql3.php @@ -10,7 +10,12 @@ * -------------------------------------------------------------------- * * Kurzbeschreibung : Datenbankschicht fuer MySQL +3.x Server * * -------------------------------------------------------------------- * - * * + * $Revision:: $ * + * $Date:: $ * + * $Tag:: 0.2.1-FINAL $ * + * $Author:: $ * + * 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 * * For more information visit: http://www.mxchange.org * @@ -38,59 +43,64 @@ if (!defined('__SECURITY')) { } // SQL queries -function SQL_QUERY($sql_string, $F, $L) { - global $link, $CSS, $_CONFIG, $OK; +function SQL_QUERY ($sql_string, $F, $L) { + // Link is up? + if (!SQL_IS_LINK_UP()) 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))); + // Replace {!_MYSQL_PREFIX!} with constant, closes #84. Thanks to profi-concept + $sql_string = str_replace("{!_MYSQL_PREFIX!}", constant('_MYSQL_PREFIX'), $sql_string); + + // Replace {!_TABLE_TYPE!} with constant + $sql_string = str_replace("{!_TABLE_TYPE!}", constant('_TABLE_TYPE'), $sql_string); + // Starting time $querytimeBefore = array_sum(explode(' ', microtime())); // Run SQL command //* DEBUG: */ echo $sql_string."
\n"; - $result = @mysql_query($sql_string, $link) - or ADD_FATAL($F." (".$L."):".mysql_error()."
-".MYSQL_QUERY_STRING."
+ $result = mysql_query($sql_string, SQL_GET_LINK()) + or addFatalMessage(__FUNCTION__, __LINE__, $F." (".$L."):".mysql_error()."
+Query string:
".$sql_string); - // Save last successfull query - $_CONFIG['db_last_query'] = $sql_string; - // Ending time $querytimeAfter = array_sum(explode(' ', microtime())); // Calculate query time $queryTime = $querytimeAfter - $querytimeBefore; + // Save last successfull query + setConfigEntry('db_last_query', $sql_string); + // Count this query - if (!isset($_CONFIG['sql_count'])) $_CONFIG['sql_count'] = 0; - $_CONFIG['sql_count']++; + incrementConfigEntry('sql_count'); // Debug output - //* DEBUG: */ print "Query=
".$sql_string."
, affected=".SQL_AFFECTEDROWS().", numrows=".SQL_NUMROWS($result)."
\n"; - - if (($CSS != "1") && ($CSS != "-1") && (isBooleanConstantAndTrue('DEBUG_MODE')) && (isBooleanConstantAndTrue('DEBUG_SQL'))) { + //* DEBUG: */ print "Query=
".$sql_string."
, affected=".SQL_AFFECTEDROWS().", numrows=".SQL_NUMROWS($result)."
\n"; + if (($GLOBALS['output_mode'] != "1") && ($GLOBALS['output_mode'] != "-1") && (isDebugModeEnabled()) && (isBooleanConstantAndTrue('DEBUG_SQL'))) { // // Debugging stuff... // - $fp = @fopen(PATH."inc/cache/mysql.log", 'a') or mxchange_die("Cannot write mysql.log!"); - if (!isset($OK)) { + $fp = fopen(constant('PATH')."inc/cache/mysql.log", 'a') or mxchange_die("Cannot write mysql.log!"); + if (!isset($GLOBALS['sql_first_entry'])) { // Write first entry fwrite($fp, "Module=".$GLOBALS['module']."\n"); - $OK = true; + $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"); fclose($fp); } // END - if // Count DB hits - if (!isset($_CONFIG['db_hits_run'])) { + if (!isConfigEntrySet('db_hits_run')) { // Count in dummy variable - $_CONFIG['db_hits_run'] = 1; + setConfigEntry('db_hits_run', 1); } else { // Count to config array - $_CONFIG['db_hits_run']++; + incrementConfigEntry('db_hits_run'); } // Return the result @@ -98,11 +108,11 @@ function SQL_QUERY($sql_string, $F, $L) { } // SQL num rows -function SQL_NUMROWS($result) { +function SQL_NUMROWS ($result) { // Is the result a valid resource? if (is_resource($result)) { // Get the count of rows from database - $lines = @mysql_num_rows($result); + $lines = mysql_num_rows($result); // Is the result empty? Then we have an error! if (empty($lines)) $lines = 0; @@ -115,13 +125,11 @@ function SQL_NUMROWS($result) { // SQL affected rows function SQL_AFFECTEDROWS() { - global $link; - // Valid link resource? - if (!is_resource($link)) return false; + if (!SQL_IS_LINK_UP()) return false; // Get affected rows - $lines = @mysql_affected_rows($link); + $lines = mysql_affected_rows(SQL_GET_LINK()); // Return it return $lines; @@ -135,7 +143,7 @@ function SQL_FETCHROW($result) { // Is a result resource set? if (!is_resource($result)) return false; - $DATA = @mysql_fetch_row($result); + $DATA = mysql_fetch_row($result); return $DATA; } @@ -148,7 +156,7 @@ function SQL_FETCHARRAY($res, $nr=0, $remove_numerical=true) { $row = array(); // Load row from database - $row = @mysql_fetch_array($res); + $row = mysql_fetch_array($res); // Return only arrays here if (is_array($row)) { @@ -159,8 +167,8 @@ function SQL_FETCHARRAY($res, $nr=0, $remove_numerical=true) { for ($idx = 0; $idx < ($max / 2); $idx++) { // Remove entry unset($row[$idx]); - } - } + } // END - for + } // END - if // Return row return $row; @@ -171,62 +179,85 @@ function SQL_FETCHARRAY($res, $nr=0, $remove_numerical=true) { } // SQL result -function SQL_RESULT($res, $row, $field) { - $result = @mysql_result($res, $row, $field); +function SQL_RESULT ($res, $row, $field = 0) { + // Is $res valid? + if (!is_resource($res)) return false; + + // Run the result command and return the result + $result = mysql_result($res, $row, $field); return $result; } + // SQL connect -function SQL_CONNECT($host, $login, $password, $F, $L) { - $connect = @mysql_connect($host, $login, $password) or ADD_FATAL($F." (".$L."):".mysql_error()); - return $connect; +function SQL_CONNECT ($host, $login, $password, $F, $L) { + // Try to connect + $connect = mysql_connect($host, $login, $password) or addFatalMessage(__FUNCTION__, __LINE__, $F." (".$L."):".mysql_error()); + + // Set the link resource + SQL_SET_LINK($connect); } + // SQL select database -function SQL_SELECT_DB($dbName, $link, $F, $L) { - $select = false; - if (is_resource($link)) { - $select = @mysql_select_db($dbName, $link) or ADD_FATAL($F." (".$L."):".mysql_error()); - } - return $select; +function SQL_SELECT_DB ($dbName, $F, $L) { + // Is there still a valid link? If not, skip it. + if (!SQL_IS_LINK_UP()) return false; + + // Return the result + return mysql_select_db($dbName, SQL_GET_LINK()) or addFatalMessage(__FUNCTION__, __LINE__, $F." (".$L."):".mysql_error()); } -// SQL close link -function SQL_CLOSE(&$link, $F, $L) { - global $_CONFIG, $cacheInstance, $cacheArray; - // Is there still a valid link? - if (!is_resource($link)) { +// SQL close link +function SQL_CLOSE ($F, $L) { + if (!SQL_IS_LINK_UP()) { // Skip double close return false; } // END - if - // Add new hits - $_CONFIG['db_hits'] += $_CONFIG['db_hits_run']; - //* DEBUG: */ echo "DB=".$_CONFIG['db_hits'].",CACHE=".$_CONFIG['cache_hits']."
\n"; - if ((GET_EXT_VERSION("cache") >= "0.0.7") && (isset($_CONFIG['db_hits'])) && (isset($_CONFIG['cache_hits'])) && (is_object($cacheInstance))) { + // Do we need to update cache/db counter? + //* DEBUG: */ echo "DB=".getConfig('db_hits').",CACHE=".getConfig('cache_hits')."
\n"; + 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 - UPDATE_CONFIG(array("db_hits", "cache_hits"), array(bigintval($_CONFIG['db_hits']), bigintval($_CONFIG['cache_hits']))); + UPDATE_CONFIG(array("db_hits", "cache_hits"), array(getConfig(('db_hits')), getConfig(('cache_hits')))); } // END - if // Close database link and forget the link - $close = @mysql_close($link) or ADD_FATAL($F." (".$L."):".mysql_error()); - $link = null; + $close = mysql_close(SQL_GET_LINK()) or addFatalMessage(__FUNCTION__, __LINE__, $F." (".$L."):".mysql_error()); + + // Close link + SQL_SET_LINK(null); + + // Return the result return $close; } + // SQL free result -function SQL_FREERESULT($result) { - $res = @mysql_free_result($result); +function SQL_FREERESULT ($result) { + if (!is_resource($result)) { + // Abort here + return false; + } // END - if + + $res = mysql_free_result($result); return $res; } + // SQL string escaping -function SQL_QUERY_ESC($qstring, $data, $file, $line, $run=true, $strip=true) { - global $link; +function SQL_QUERY_ESC ($qstring, $data, $F, $L, $run=true, $strip=true) { + // Link is there? + if (!SQL_IS_LINK_UP()) return false; - if ($strip) { + // Init variable + $query = "failed"; + + if ($strip === true) { $strip = "true"; } else { $strip = "false"; } - $query = ""; $eval = "\$query = sprintf(\"".$qstring."\""; foreach ($data as $var) { if ((!empty($var)) || ($var === 0)) { @@ -234,94 +265,208 @@ function SQL_QUERY_ESC($qstring, $data, $file, $line, $run=true, $strip=true) { } else { $eval .= ", ''"; } - } + } // END - foreach $eval .= ");"; // // Debugging // - //$fp = fopen(PATH."inc/cache/escape_debug.log", 'a') or mxchange_die("Cannot write debug.log!"); - //fwrite($fp, $file."(".$line."): ".str_replace("\r", "", str_replace("\n", " ", $eval))."\n"); - //fclose($fp); - @eval($eval); + //* DEBUG: */ $fp = fopen(constant('PATH')."inc/cache/escape_debug.log", 'a') or mxchange_die("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 (empty($query)) { + if ($query == "failed") { // Something went wrong? - print "eval=".htmlentities($eval)."
";
-		debug_print_backtrace();
-		die("
"); + debug_report_bug("eval={$eval}"); } // END - if - if ($run) { + if ($run === true) { // Run SQL query (default) - return SQL_QUERY($query, $file, $line); + return SQL_QUERY($query, $F, $L); } else { // Return secured string return $query; } } + // Get ID from last INSERT command -function SQL_INSERTID() { - return @mysql_insert_id(); +function SQL_INSERTID () { + if (!SQL_IS_LINK_UP()) return false; + return mysql_insert_id(); } -// Escape a string for the database -function SQL_ESCAPE($str, $secureString=true,$strip=true) { - global $link; +// 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); } // END - if - if (!is_resource($link)) { - // Fall-back to addslashes() when there is no link - return addslashes($str); - } // END - if - - if (function_exists('mysql_real_escape_string')) { + 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: */ echo __FUNCTION__.":str={$str}
\n"; - return mysql_real_escape_string($str, $link); + //* DEBUG: */ print __FUNCTION__."(".__LINE__."):str={$str}
\n"; + return mysql_real_escape_string($str, SQL_GET_LINK()); } elseif (function_exists('mysql_escape_string')) { - // The obsulete function - return mysql_escape_string($str, $link); + // The obsolete function + return mysql_escape_string($str, SQL_GET_LINK()); } else { - // If nothing else works - return addslashes($str); + // If nothing else works, fall back to smartAddSlashes() + return smartAddSlashes($str); } } + // SELECT query string from table, columns and so on... ;-) 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))); + } // END - if + // Prepare the SQL statement - $SQL = "SELECT ".implode(", ", $columns)." FROM "._MYSQL_PREFIX."_".$table." WHERE ".$idRow."=%s LIMIT 1"; + $sql = "SELECT `".implode("`,`", $columns)."` FROM `{!_MYSQL_PREFIX!}_%s` WHERE ``='%s' LIMIT 1"; // Return the result - return SQL_QUERY_ESC($SQL, array(bigintval($id)), $F, $L); + return SQL_QUERY_ESC($sql, + array( + bigintval($id), + $table, + $idRow + ), $F, $L); } + // ALTER TABLE wrapper function -function SQL_ALTER_TABLE($sql, $F, $L) { - // Shall we add? - if (eregi("ADD", $sql) > 0) { - // Extract table name - $tableArray = explode(" ", $sql); - $tableName = str_replace("`", "", $tableArray[2]); +function SQL_ALTER_TABLE ($sql, $F, $L) { + // This is the default result... + $result = false; + + // Determine index/fulltext/unique word + // 12 3 3 2 2 3 3 2 2 3 3 21 + $noIndex = ((ereg("INDEX", $sql) == false) && (ereg("FULLTEXT", $sql) == false) && (ereg("UNIQUE", $sql) == false)); + // Extract table name + $tableArray = explode(" ", $sql); + $tableName = str_replace("`", "", $tableArray[2]); + + // Shall we add/drop? + if (((ereg("ADD", $sql)) || (ereg("DROP", $sql))) && ($noIndex)) { // 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), $F, $L); + array($tableName, $columnName), __FILE__, __LINE__); - // Do we have no entry? - if (SQL_NUMROWS($result) == 0) { + // Do we have no entry on ADD or an entry on DROP? + // 123 4 4 3 3 4 432 23 4 4 3 3 4 4321 + if (((SQL_NUMROWS($result) == 0) && (ereg("ADD", $sql))) || ((SQL_NUMROWS($result) == 1) && (ereg("DROP", $sql)))) { // Do the query - return SQL_QUERY($sql, $F, $L, false); + //* DEBUG: */ print __LINE__.":".$sql."
\n"; + $result = SQL_QUERY($sql, $F, $L, false); + } // END - if + } elseif ((constant('_TABLE_TYPE') == "InnoDB") && (ereg("FULLTEXT", $sql))) { + // Skip this query silently + //* DEBUG: */ DEBUG_LOG(__FUNCTION__, __LINE__, sprintf("Skipped FULLTEXT: sql=%s,file=%s,line=%s", $sql, $F, $L)); + } elseif (!$noIndex) { + // And column name as well + $columnName = str_replace("`", "", $tableArray[4]); + + // Is this "UNIQUE" or so? FULLTEXT has been handled the elseif() block above + if (in_array(strtoupper($columnName), array("INDEX", "UNIQUE", "KEY", "FULLTEXT"))) { + // Init loop + $begin = 1; $columnName = ","; + while (strpos($columnName, ",") !== false) { + // Use last + $columnName = str_replace("`", "", $tableArray[count($tableArray) - $begin]); + //* DEBUG: */ print __LINE__.":".$columnName."----------------".$begin."
\n"; + + // Remove brackes + $columnName = str_replace("(", "", str_replace(")", "", $columnName)); + //* DEBUG: */ print __LINE__.":".$columnName."----------------".$begin."
\n"; + + // Continue + $begin++; + } // END while + } // END - if + + // Show indexes + $result = SQL_QUERY_ESC("SHOW INDEX FROM %s", + array($tableName), __FILE__, __LINE__); + + // Walk through all + $skip = false; + while ($content = SQL_FETCHARRAY($result)) { + // Is it found? + //* DEBUG: */ print "
".print_r($content, true)."
"; + if (($content['Column_name'] == $columnName) || ($content['Key_name'] == $columnName)) { + // Skip this query! + //* DEBUG: */ DEBUG_LOG(__FUNCTION__, __LINE__, sprintf("Skiped: %s", $sql)); + $skip = true; + break; + } // END - if + } // END - while + + // Free result + SQL_FREERESULT($result); + + // Shall we run it? + if (!$skip) { + // Send it to the SQL_QUERY() function + //* DEBUG: */ print __LINE__.":".$sql."
\n"; + $result = SQL_QUERY($sql, $F, $L, false); } // END - if } else { - // Send it to the SQL_QUERY() function - return SQL_QUERY($sql, $F, $L, false); + // Other ALTER TABLE query + //* DEBUG: */ print __LINE__.":".$sql."
\n"; + $result = SQL_QUERY($sql, $F, $L, false); } + + // Return result + return $result; } + +// Getter for SQL link +function SQL_GET_LINK () { + // Init link + $link = null; + + // Is it in the globals? + if (isset($GLOBALS['sql_link'])) { + // Then take it + $link = $GLOBALS['sql_link']; + } // END - if + + // Return it + return $link; +} + +// Setter for link +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))); + } // END - if + + // Set it + $GLOBALS['sql_link'] = $link; +} + +// Checks if the link is up +function SQL_IS_LINK_UP () { + // Get the link + $link = SQL_GET_LINK(); + + // Return the result + return (is_resource($link)); +} + // ?>