//**************************************
    //     
    // Name: Database independence object wr
    //     apper
    // Description:This is a database abstra
    //     ction layer, so that code can be written
    //     to run with any database. If you wish to
    //     switch database types, just change a par
    //     ameter in the abstraction class ... not 
    //     your entire code!! Currently supports my
    //     sql and postgres, I hope to add oracle a
    //     nd others. If you have any comments/sugg
    //     estions, pls email me at manik@post1.com
    //     by Manik Surtani
    // By: PHP Code Exchange
    //**************************************
    //     
    
    <?php
    //--------------------------------------
    //     -----------------
    // DATABASE.INDEPENDENCE.OBJECT.WRAPPER
    // VERSION 0.30
    // VERSION DATE: 15th July 1999
    //--------------------------------------
    //     -----------------
    // Author: Manik Surtani <manik@post1
    //     .com>
    //--------------------------------------
    //     -----------------
    //--------------------------------------
    //     -----------------
    // This version currently supports POSTG
    //     RESQL and MYSQL
    // databases. More support to be added s
    //     ometime .... !!
    //--------------------------------------
    //     -----------------
    // This wrapper provides 'physical' data
    //     base connectivity
    // and works as the link between the php
    //     3-based web site 
    // and the selected database. 
    //--------------------------------------
    //     -----------------
    // set the database TYPE. 
    //$database_type==1 --> POSTGRES
    //$database_type==2 --> MYSQL
    $database_type=2;
    /*
    ---------------------------------------------------------
    "class resultSet" deals with a recordset produced by a
    databse query.
    ---------------------------------------------------------
    */
    class resultSet {
    var $element = array();
    var $column_name = array();
    var $numrows;
    var $numcols;
    function getColumn_by_name($rowNum,$colName) {
    $j=-1;
    for($i=0;$i<$this->numcols;$i++)
    {
    if ($this->column_name[$i]==$colName) { $j=$i; }
    }
    if ($j!=-1) { return $this->element[$rowNum][$j];} else { return ""; }
    }
    function getColumn_by_num($rowNum,$colNum) {
    return $this->element[$rowNum][$colNum];
    }
    function getColName($column) {
    return $this->column_name[$column];
    }
    function getNumRows() {
    return $this->numrows;
    }
    function getNumCols() {
    return $this->numcols;
    }
    }
    /*
    ---------------------------------------------------------
    "class ConnInfo" provides a connection details object which returns information
    given on a connection parameter to a database.
    ---------------------------------------------------------
    */
    class ConnectionInfo {
    var $cdbname;
    var $cusername;
    var $cpassword;
    var $chost;
    var $cport;
    function SplitThis($cparam) {
    $tok = strtok($cparam," ");
    while($tok) {
    $pos=strpos($tok,"=");
    $type=substr($tok,0,$pos);
    switch ($type) {
    case "dbname":
    $this->cdbname=substr($tok,$pos+1);
    break;
    case "host":
    $this->chost=substr($tok,$pos+1);
    break;
    case "port":
    $this->cport=substr($tok,$pos+1);
    break;
    case "username":
    $this->cusername=substr($tok,$pos+1);
    break;
    case "password":
    $this->cpassword=substr($tok,$pos+1);
    break;
    }
    $tok = strtok(" ");
    } 
    }
    function dbName() { return $this->cdbname; }
    function Host() { return $this->chost; }
    function Port() { return $this->cport; }
    function UserName() { return $this->cusername; }
    function Password() { return $this->cpassword; }
    }
    /*
    ---------------------------------------------------------
    "class connection" provides functionality to deal with the
    actual database.
    ---------------------------------------------------------
    */
    class connection {
    var $my_connection;
    var $my_temp_resultID;
    var $my_temp_result_object = new resultSet;
    function open($p1, $p2 = "", $p3 = "", $p4 = "", $p5="" ) {
    global $database_type;
    $ok = false;
    if (($p2 == "") && ($p3 == "") && ($p4 == "") && ($p5 == "") && ($database_type==1))
    {
    	$this->my_connection=pg_connect($p1);
    	$ok = true;
    }
    if (($p5 == "") && ($database_type==2))
    {
    $connINF = new ConnectionInfo;
    $connINF->SplitThis($p1);
    $p1=$connINF->Host();
    $p2=$connINF->UserName();
    $p3=$connINF->Password();
    $p4=$connINF->dbName();
    	$this->my_connection=mysql_connect($p1, $p2, $p3);
    	mysql_select_db($p4,$this->my_connection);
    	$ok = true;
    }
    if (!($ok))
    {
    	print "\n\nTHERE WAS AN ERROR CONNECTING.\n\n";
    }
    }	
    function close() {
    global $database_type;
    if ($database_type==1)
    	{
    	pg_close($this->my_connection);
    	}
    if ($database_type==2)
    	{
    	mysql_close($this->my_connection);
    	}
    }
    function runActionQuery($someSQL)
    {
    global $database_type;
    // cleanup SQL for PHP versions! (sic)
    if (substr($someSQL,strlen($someSQL)-1,1)==";") {
    	 $someSQL=substr($someSQL,0,strlen($someSQL)-1);
    	}
    	if ($database_type==1)
    	{
    	pg_exec($this->my_connection, $someSQL);
    	}
    	if ($database_type==2)
    	{
    	mysql_query($someSQL, $this->my_connection);
    	}
    }
    function runSQL($someSQL)	
    {
    	global $database_type;
    // cleanup SQL for PHP versions! (sic)
    if (substr($someSQL,strlen($someSQL)-1,1)==";") {
    	 $someSQL=substr($someSQL,0,strlen($someSQL)-1);
    	}
    	if ($database_type==1)
    	{
    		$this->my_temp_resultID = pg_exec($this->my_connection, $someSQL);
    		$this->my_temp_result_object->numrows = pg_numrows($this->my_temp_resultID);
    		$this->my_temp_result_object->numcols = pg_numfields($this->my_temp_resultID);
    // fill column_names from resultset
    		for ($j=0; $j < $this->my_temp_result_object->numcols; $j++)
    		{
    			$this->my_temp_result_object->column_name[$j] = pg_fieldname($this->my_temp_resultID, $j);
    		}
    // fill data elements from resultset
    		for ($i=0; $i < $this->my_temp_result_object->numrows; $i++)
    		{
    			for ($j=0; $j < $this->my_temp_result_object->numcols; $j++)
    			{
    $this->my_temp_result_object->element[$i][$j] = pg_result($this->my_temp_resultID, $i, $j);
    			}
    		}
    		return $this->my_temp_result_object;
    pg_freeresult($this->my_temp_resultID);
    	}
    if ($database_type==2)
    	{
    	$this->my_temp_resultID = mysql_query($someSQL, $this->my_connection);
    	$this->my_temp_result_object->numrows = mysql_num_rows($this->my_temp_resultID);
    	$this->my_temp_result_object->numcols = mysql_num_fields($this->my_temp_resultID);
    // fill column_names from resultset
    	for ($j=0; $j < $this->my_temp_result_object->numcols; $j++)
    	{
    		$this->my_temp_result_object->column_name[$j] = mysql_fieldname($this->my_temp_resultID, $j);
    	}
    // fill data elements from resultset
    	for ($i=0; $i < $this->my_temp_result_object->numrows; $i++)
    		{
    		$x = mysql_fetch_row($this->my_temp_resultID);
    		for ($j=0; $j < $this->my_temp_result_object->numcols; $j++)
    			{
    			$this->my_temp_result_object->element[$i][$j] = $x[$j];
    			}
    		}
    	return $this->my_temp_result_object;
    	mysql_free_result($this->my_temp_resultID);
    	}
    	}
    } 
    ?>