From d75cda8193d7b6d4e6986f5aee75fb9d8cf47c3e Mon Sep 17 00:00:00 2001
From: Robert Sesek <rsesek@bluestatic.org>
Date: Fri, 14 Jan 2005 06:27:00 +0000
Subject: [PATCH] Finished database abstraction layer.

---
 db_mysql.php | 248 +++++++++++++++++++++++++++++++++++++++++++++++++++
 1 file changed, 248 insertions(+)
 create mode 100644 db_mysql.php

diff --git a/db_mysql.php b/db_mysql.php
new file mode 100644
index 0000000..3f5b72e
--- /dev/null
+++ b/db_mysql.php
@@ -0,0 +1,248 @@
+<?php
+/*=====================================================================*\
+|| ################################################################### ||
+|| # Iris Studios Shared Object Framework [#]version[#]
+|| # --------------------------------------------------------------- # ||
+|| # All parts of this file are ©2003-[#]year[#] Iris Studios, Inc. No     # || 
+|| # part of this file may be reproduced in any way: part or whole.  # ||
+|| # --------------------------------------------------------------- # ||
+|| # ©2003 - [#]year[#] Iris Studios, Inc. | http://www.iris-studios.com   # ||
+|| ################################################################### ||
+\*=====================================================================*/
+
+$OBJECT = 'MySQL Database Abstraction Layer';
+$CLASS = 'MySQL_Database_Driver';
+$OBJ = 'db';
+
+/**
+* MySQL Database Abstraction Layer
+*
+* This framework is a function wrapper for MySQL functions so we can have
+* better error reporting and query reporting.
+*
+* @author		Iris Studios, Inc.
+* @copyright	Copyright ©2003 - [#]year[#], Iris Studios, Inc.
+* @version		$Revision$
+* 
+*/
+class MySQL_Database_Driver
+{
+	/**
+	* Global environment variables
+	*
+	* @var	database	The name of the MySQL database used
+	* @var	errshow		Report errors durring execution?
+	* @var	errno		Current error number
+	* @var	errstr		Description of the current error
+	* @var	link_id		Link-ID for current connexion
+	* @var	query_id	Current query ID
+	* @var	query_str	Current query string
+	* @var	history		A list of all query reporting information
+	*/
+	var $database = '';
+	var $errshow = true;
+	var $errno = 0;
+	var $errstr = '';
+	var $link_id = 0;
+	var $query_id = 0;
+	var $query_str = '';
+	var $history = array();
+	
+	/**
+	* Connect to a the specified database
+	*
+	* @param	str		Server name
+	* @param	str		User name
+	* @param	str		Password
+	* @param	bool	Use p-connect?
+	*
+	* @return	bool	Result of connect
+	*/
+	function connect($server, $user, $password, $pconnect)
+	{
+		if ($this->link_id == 0)
+		{
+			if ($pconnect)
+			{
+				$this->link_id = @mysql_pconnect($server, $user, $password);
+			}
+			else
+			{
+				$this->link_id = @mysql_connect($server, $user, $password);
+			}
+			
+			if ($this->link_id == false)
+			{
+				$this->error('Link-Id == false, cannot connect');
+				return false;
+			}
+			
+			if (@mysql_select_db($this->database, $this->link_id))
+			{
+				return true;
+			}
+			else
+			{
+				$this->error('Cannot use the database \'' . $this->database . '\'');
+				return false;
+			}
+		}
+	}
+	
+	/**
+	* Send a query to MySQL
+	*
+	* @param	str		Query string
+	*
+	* @return	res		Resource ID for query
+	*/
+	function query($query_str)
+	{
+		$this->query_id = @mysql_query($query_str, $this->link_id);
+		$this->query_str = $query_str;
+		$this->history[] = $this->query_str;
+		
+		if (!$this->query_id)
+		{
+			$this->error('Invalid SQL query');
+		}
+		
+		return $this->query_id;
+	}
+	
+	/**
+	* Escape a string depending on character set
+	*
+	* @param	str		String to be escaped
+	*
+	* @return	str		Escaped string
+	*/
+	function escape_string($string)
+	{
+		return @mysql_real_escape_string($string, $this->link_id);
+	}
+	
+	/**
+	* Fetch the query result as an array
+	*
+	* @param	res		Query-ID
+	*
+	* @return	array	A row of the query result
+	*/
+	function fetch_array($query_id)
+	{
+		return @mysql_fetch_array($query_id, MYSQL_ASSOC);
+	}
+	
+	/**
+	* Fetch the query result as an object
+	*
+	* @param	res		Query-ID
+	*
+	* @return	obj		An object with the query result
+	*/
+	function fetch_object($query_id)
+	{
+		return @mysql_fetch_object($query_id);
+	}
+	
+	/**
+	* Free the current MySQL query result
+	*
+	* @param	res		Query-ID
+	*/
+	function free_result($query_id)
+	{
+		@mysql_free_result($query_id);
+		$this->query_id = 0;
+		$this->query_str = '';
+	}
+	
+	/**
+	* Send a MySQL query and return the first row of the results
+	*
+	* @param	str		Query string
+	* @param	str		Result return function (in the database layer)
+	*
+	* @return	mixed	Results in variable formats
+	*/
+	function query_first($query_str, $callback = 'fetch_array')
+	{
+		$resource = $this->query($query_str);
+		$return = $this->$callback($resource);
+		$this->free_result($resource);
+		return $return;
+	}
+	
+	/**
+	* Fetch the unique ID of the record just inserted
+	*
+	* @return	int		MySQL insert ID
+	*/
+	function insert_id()
+	{
+		return @mysql_insert_id($this->link_id);
+	}
+	
+	/**
+	* Fetch the number of rows in the result
+	*
+	* @param	res		Query-ID
+	*
+	* @return	int		Number of MySQL rows
+	*/
+	function num_rows($query_id)
+	{
+		return @mysql_num_rows($query_id);
+	}
+	
+	/**
+	* Fetch the number of rows affected by the query
+	*
+	* @return	int		Number of affected rows
+	*/
+	function affected_rows($query_id)
+	{
+		return @mysql_affected_rows($this->link_id);
+	}
+	
+	/**
+	* MySQL error wrapper for ISSO::_message()
+	*
+	* @param	str		User-defined error message
+	*/
+	function error($message)
+	{
+		global $_isso;
+		
+		if ($this->errshow)
+		{
+			if ($this->link_id)
+			{
+				$this->errno = mysql_errno($this->link_id);
+				$this->errstr = mysql_error($this->link_id);
+			}
+			
+			$style['code'] = 'font-family: \'Courier New\', Courier, mono; font-size: 11px;';
+			
+			$message_prepped = "<blockquote>\n<p>";
+			$message_prepped .= "\n\t&raquo; <strong>Query:</strong>\n<br /> <pre style=\"$style[code]\">" . $this->query_str ."</pre>\n<br />";
+			$message_prepped .= "\n\t&raquo; <strong>Error Number:</strong> <span style=\"$style[code]\">" . $this->errno . "</span>\n<br />";
+			$message_prepped .= "\n\t&raquo; <strong>Error Message:</strong> <span style=\"$style[code]\">" . $this->errstr . "</span>\n<br />";
+			$message_prepped .= "\n\t&raquo; <strong>Additional Notes:</strong> <span style=\"$style[code]\">" . $message . "</span>\n<br />";
+			$message_prepped .= "\n\t&raquo; <strong>File:</strong> <span style=\"$style[code]\">" . $_SERVER['PHP_SELF'] . "</span>\n";
+			$message_prepped .= "\n</p>\n</blockquote>";
+			
+			$_isso->_message('Database Error in `<em>' . $_isso->application . '</em>`', $message_prepped, 3);
+			exit;
+		}
+	}
+}
+
+/*=====================================================================*\
+|| ###################################################################
+|| # $HeadURL$
+|| # $Id$
+|| ###################################################################
+\*=====================================================================*/
+?>
\ No newline at end of file
-- 
2.22.5