X-Git-Url: https://git.mxchange.org/?p=mailer.git;a=blobdiff_plain;f=inc%2Fdb%2Flib-mysql3.php;h=e11f335446711f138efd577d25edb2e31caa661e;hp=b64e3937ec828ef647e2bec44dc6b9be87949201;hb=841656d70d60cbd5f0768e12cf73a62aa643cf35;hpb=114d6b94e8c2aa1ec5c79465fb2011196ec6f70b

diff --git a/inc/db/lib-mysql3.php b/inc/db/lib-mysql3.php
index b64e3937ec..e11f335446 100644
--- a/inc/db/lib-mysql3.php
+++ b/inc/db/lib-mysql3.php
@@ -4,15 +4,20 @@
  * ===============                              Last change: 08/29/2004 *
  *                                                                      *
  * -------------------------------------------------------------------- *
- * File              : lib.php                                          *
+ * File              : lib-mysql3.php                                   *
  * -------------------------------------------------------------------- *
- * Short description :                                                  *
+ * Short description : Database layer for MySQL +3.x server             *
  * -------------------------------------------------------------------- *
- * Kurzbeschreibung  :                                                  *
+ * 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                           *
+ * Copyright (c) 2003 - 2009 by Roland Haeder                           *
  * For more information visit: http://www.mxchange.org                  *
  *                                                                      *
  * This program is free software; you can redistribute it and/or modify *
@@ -32,118 +37,164 @@
  ************************************************************************/
 
 // Some security stuff...
-if (ereg(basename(__FILE__), $_SERVER['PHP_SELF'])) {
-	$INC = substr(dirname(__FILE__), 0, strpos(dirname(__FILE__), "/inc") + 4) . "/security.php";
-	require($INC);
-}
+if (!defined('__SECURITY')) {
+	die();
+} // END - if
 
 // SQL queries
-function SQL_QUERY($sql_string, $F, $L) {
-	global $link, $CSS, $_CONFIG, $OK;
+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!
+		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;
+	} 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)));
+
+	// Compile config out
+	$sqlString = FILTER_COMPILE_CONFIG($sqlString);
 
 	// Starting time
 	$querytimeBefore = array_sum(explode(' ', microtime()));
 
 	// Run SQL command
-	$result = @mysql_query($sql_string, $link)
-	 or ADD_FATAL($F." (".$L."):".mysql_error()."<br />
-".MYSQL_QUERY_STRING."<br />
-".$sql_string);
+	//* DEBUG: */ print($sqlString . '<br />');
+	$result = mysql_query($sqlString, SQL_GET_LINK())
+		or addFatalMessage(__FUNCTION__, __LINE__, $F . ' (' . $L . '):' . mysql_error() . '<br />
+Query string:<br />
+' . $sqlString);
+	//* DEBUG: */ print(__LINE__ . ': numRows=' . SQL_NUMROWS($result) . ',affected=' . SQL_AFFECTEDROWS() . "<br />");
 
-	// Starting time
+	// Ending time
 	$querytimeAfter = array_sum(explode(' ', microtime()));
 
 	// Calculate query time
 	$queryTime = $querytimeAfter - $querytimeBefore;
 
+	// Add this query to array including timing
+	addSqlToDebug($result, $sqlString, $queryTime, $F, $L);
+
+	// Save last successfull query
+	setConfigEntry('db_last_query', $sqlString);
+
+	// Count all query times
+	incrementConfigEntry('sql_time', $queryTime);
+
 	// Count this query
-	if (!isset($_CONFIG['sql_count'])) $_CONFIG['sql_count'] = 0;
-	$_CONFIG['sql_count']++;
+	incrementConfigEntry('sql_count');
 
 	// Debug output
-	//* DEBUG: */ print "Query=<pre>".$sql_string."</pre>, affected=<b>".SQL_AFFECTEDROWS()."</b>, numrows=<b>".SQL_NUMROWS($result)."</b><br />\n";
-
-	if (($CSS != "1") && ($CSS != "-1") && (isBooleanConstantAndTrue('DEBUG_MODE')) && (DEBUG_SQL)) {
+	if ((getOutputMode() != 1) && (isDebugModeEnabled()) && (getConfig('DEBUG_SQL') == 'Y')) {
 		//
 		// Debugging stuff...
 		//
-		$fp = @fopen(PATH."inc/cache/debug.log", 'a') or mxchange_die("Cannot write debug.log!");
-		if (!isset($OK)) {
+		$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=".$GLOBALS['module']."\n");
-			$OK = true;
-		}
-		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, '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", ' ', $sqlString)) . "\n");
 		fclose($fp);
-	}
+	} // END - if
 
 	// Count DB hits
-	if (!isset($_CONFIG['db_hits'])) {
+	if (!isStatsEntrySet('db_hits_run')) {
 		// Count in dummy variable
-		$_CONFIG['db_hits'] = 0;
+		setStatsEntry('db_hits_run', 1);
 	} else {
 		// Count to config array
-		$_CONFIG['db_hits']++;
+		incrementStatsEntry('db_hits_run');
 	}
+
+	// Return the result
 	return $result;
 }
 
 // SQL num rows
-function SQL_NUMROWS($result) {
+function SQL_NUMROWS ($result) {
+	// 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);
+		$lines = mysql_num_rows($result);
 
 		// Is the result empty? Then we have an error!
-		if (empty($lines)) $lines = "0";
-	} else {
+		if (empty($lines)) $lines = 0;
+	} elseif (SQL_IS_LINK_UP()) {
 		// No resource given, no lines found!
-		$lines = "0";
+		$lines = 0;
 	}
+
+	// Return lines
 	return $lines;
 }
 
 // SQL affected rows
-function SQL_AFFECTEDROWS($lnk="x", $F="dummy", $L="dummy") {
-	global $link;
-	// $lnk will be ignored for now!
-	$lines = @mysql_affected_rows($link);
+function SQL_AFFECTEDROWS() {
+	// Valid link resource?
+	if (!SQL_IS_LINK_UP()) return false;
+
+	// Get affected rows
+	$lines = mysql_affected_rows(SQL_GET_LINK());
+
+	// Return it
 	return $lines;
 }
 
 // SQL fetch row
-function SQL_FETCHROW($result) {
-	$DATA = array();
-	$DATA = @mysql_fetch_row($result);
-	return $DATA;
+function SQL_FETCHROW ($result) {
+	// Is a result resource set?
+	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=false, $nr=0, $remove_numerical=true) {
+function SQL_FETCHARRAY ($res, $nr=0, $remove_numerical=true) {
 	// Is a result resource set?
-	if (!$res) return false;
+	if ((!is_resource($res)) || (!SQL_IS_LINK_UP())) return false;
 
 	// Initialize array
 	$row = array();
 
 	// Load row from database
-	$row = @mysql_fetch_array($res);
+	$row = mysql_fetch_array($res);
 
 	// Return only arrays here
 	if (is_array($row)) {
 		// Shall we remove numerical data here automatically?
 		if ($remove_numerical) {
-				 // So let's remove all numerical elements to save memory!
+			// So let's remove all numerical elements to save memory!
 			$max = count($row);
 			for ($idx = 0; $idx < ($max / 2); $idx++) {
 				// Remove entry
 				unset($row[$idx]);
-			}
-		}
+			} // END - for
+		} // END - if
 
 		// Return row
 		return $row;
@@ -154,111 +205,356 @@ function SQL_FETCHARRAY($res=false, $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)) || (!SQL_IS_LINK_UP())) 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);
+
+	// Destroy cache
+	unset($GLOBALS['sql_link_res']);
 }
+
 // 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;
-	if ((GET_EXT_VERSION("cache") >= "0.0.7") && (isset($_CONFIG['db_hits'])) && (isset($_CONFIG['cache_hits'])) && (is_object($cacheInstance))) {
-		// Update counter for db/cache
-		$result = SQL_QUERY_ESC("UPDATE "._MYSQL_PREFIX."_config SET db_hits=%d, cache_hits=%d WHERE config=0 LIMIT 1",
-			array(bigintval($_CONFIG['db_hits']), bigintval($_CONFIG['cache_hits'])), __FILE__, __LINE__);
-
-		// Update cache here
-		if (GET_EXT_VERSION("cache") >= "0.1.2") {
-			if ($cacheInstance->cache_file("config", true)) {
-				// Replace data
-				$cacheInstance->cache_replace("cache_hits", $_CONFIG['cache_hits'], "0", $cacheArray);
-				$cacheInstance->cache_replace("db_hits"   , $_CONFIG['db_hits']   , "0", $cacheArray);
-			}
-		}
-	}
+function SQL_CLOSE ($F, $L) {
+	if (!SQL_IS_LINK_UP()) {
+		// Skip double close
+		return false;
+	} // END - if
+
+	// Close database link and forget the link
+	$close = mysql_close(SQL_GET_LINK())
+		or addFatalMessage(__FUNCTION__, __LINE__, $F . ' (' . $L . '):'.mysql_error());
+
+	// Close link
+	SQL_SET_LINK(null);
+
+	// Destroy cache
+	unset($GLOBALS['sql_link_res']);
 
-	// Close database link
-	$close = @mysql_close($link) or ADD_FATAL($F." (".$L."):".mysql_error());
+	// Move stats
+	incrementStatsEntry('db_hits', getStatsEntry('db_hits_run'));
+
+	// 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)) || (!SQL_IS_LINK_UP())) {
+		// 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;
-	$eval = "\$query = sprintf(\"".$qstring."\"";
+function SQL_QUERY_ESC ($qstring, $data, $F, $L, $run=true, $strip=true, $secure=true) {
+	// Link is there?
+	if ((!SQL_IS_LINK_UP()) || (!is_array($data))) return false;
+
+	/* Other way */
+	// Escape all data
+	$dataSecured['__sql_string'] = $qstring;
+	foreach ($data as $key => $value) {
+		$dataSecured[$key] = SQL_ESCAPE($value, $secure, $strip);
+	} // END - foreach
+
+	// Generate query
+	$query = call_user_func_array('sprintf', $dataSecured);
+	/*
+	/* Old eval() way... *
+	// Init variable
+	$query = 'failed';
+
+	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)) {
-			if ($strip) {
-				$eval .= ", SQL_ESCAPE(\"".strip_tags($var)."\")";
-			} else {
-				$eval .= ", SQL_ESCAPE(\"".$var."\")";
-			}
+		if ((!empty($var)) || ($var === 0)) {
+			$eval .= ", SQL_ESCAPE('" . $var . "', " . $secure . ', ' . $strip . ')';
 		} else {
 			$eval .= ", ''";
 		}
-	}
-	$eval .= ");";
-	//
+	} // END - foreach
+	$eval .= ');';
+	**/
+
 	// Debugging
 	//
-	//$fp = fopen(PATH."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);
+	//* 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);
-	if ($run) {
+
+	// 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, $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) {
-	global $link;
-	if (!is_resource($link)) {
-		// Fall-back to addslashes() when there is no link
-		return addslashes($str);
-	}
+function SQL_ESCAPE ($str, $secureString=true, $strip=true) {
+	// Do we have cache?
+	if (isset($GLOBALS['sql_escapes'][$str])) {
+		// Then use it instead
+		return $GLOBALS['sql_escapes'][$str];
+	} // END - if
 
-	if (function_exists('mysql_real_escape_string')) {
+	// 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 smartAddSlashes() when there is no link
+		$ret = smartAddSlashes($str);
+	} elseif (function_exists('mysql_real_escape_string')) {
 		// The new and improved version
-		return mysql_real_escape_string($str, $link);
+		//* DEBUG: */ print(__FUNCTION__."(<font color=\"#0000aa\">".__LINE__."</font>):str={$str}<br />");
+		$ret = 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
+		$ret = mysql_escape_string($str, SQL_GET_LINK());
 	} else {
-		// If nothing else works
-		return addslashes($str);
+		// If nothing else works, fall back to smartAddSlashes() again
+		$ret = smartAddSlashes($str);
 	}
+
+	// Cache result
+	$GLOBALS['sql_escapes'][$str] = $ret;
+
+	// Return it
+	return $ret;
 }
+
 // SELECT query string from table, columns and so on... ;-)
-function SQL_RESULT_FROM_ARRAY ($table, $columns, $idRow, $id) {
+function SQL_RESULT_FROM_ARRAY ($table, $columns, $idRow, $id, $F, $L) {
+	// Is columns an array?
+	if (!is_array($columns)) {
+		// No array
+		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."_".$table." WHERE ".$idRow."=%d LIMIT 1";
+	$sql = "SELECT `".implode("`,`", $columns)."` FROM `{?_MYSQL_PREFIX?}_%s` WHERE `%s`='%s' LIMIT 1";
 
 	// Return the result
-	return SQL_QUERY_ESC($SQL, array(bigintval($id)), __FILE__, __LINE__);
+	return SQL_QUERY_ESC($sql,
+		array(
+			$table,
+			$idRow,
+			bigintval($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;
+
+	// Determine index/fulltext/unique word
+	$noIndex = (
+	(
+		strpos($sql, 'INDEX') === false
+	) && (
+		strpos($sql, 'FULLTEXT') === false
+	) && (
+		strpos($sql, 'UNIQUE') === false
+	)
+	);
+
+	// Extract table name
+	$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: */ print(__LINE__.':'.$sql."<br />");
+			$result = SQL_QUERY($sql, $F, $L, false);
+		} // END - if
+	} elseif ((getConfig('_TABLE_TYPE') == 'InnoDB') && (strpos($sql, 'FULLTEXT') !== false)) {
+		// Skip this query silently
+		//* 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]);
+
+		// 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."<br />");
+
+				// Remove brackes
+				$columnName = str_replace('(', '', str_replace(')', '', $columnName));
+				//* DEBUG: */ print(__LINE__.':'.$columnName."----------------".$begin."<br />");
+
+				// 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("<pre>".print_r($content, true)."</pre>");
+			if (($content['Column_name'] == $columnName) || ($content['Key_name'] == $columnName)) {
+				// Skip this query!
+				//* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, sprintf("Skiped: %s", $sql));
+				$skip = true;
+				break;
+			} // END - if
+		} // END - while
+
+		// Free result
+		SQL_FREERESULT($result);
+
+		// Shall we run it?
+		if ($skip === false) {
+			// Send it to the SQL_QUERY() function
+			//* DEBUG: */ print(__LINE__.':'.$sql."<br />");
+			$result = SQL_QUERY($sql, $F, $L, false);
+		} // END - if
+	} else {
+		// Other ALTER TABLE query
+		//* DEBUG: */ print(__LINE__.':'.$sql."<br />");
+		$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!
+		debug_report_bug(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 () {
+	// Default is not up
+	$linkUp = false;
+
+	// Do we have cached this?
+	if (isset($GLOBALS['sql_link_res'])) {
+		// Then use this
+		$linkUp = $GLOBALS['sql_link_res'];
+	} else {
+		// Get it
+		$linkUp = is_resource(SQL_GET_LINK());
+
+		// And cache it
+		$GLOBALS['sql_link_res'] = $linkUp;
+	}
+
+	// Return the result
+	return $linkUp;
+}
+
+// [EOF]
 ?>