<?
// let's get the adodb included
// refer to the php include path in the apache virtualhost block for this domain
//require('adodb.inc.php'); This one does not use ADODB

// this file is basically just a 2nd abstraction layer that I'm gonna put on top of the ADODB layer
// ADODB formats the results of the queries satisfactorily, but I don't like how it deals with the input
// this way, we can just include a hash or associative array into the argument of the query function
// and the actual query string will be automatically created. This saves us alot of hassle not having to deal
// with accidental SQL syntax errors and whatnot. There's prolly some way to plug something like this
// right into ADODB, but I didn't feel like digging though all the files to figure out how. This method was
// quick, and can't be too much slower than a better one. Enjoy!
class DB
{
    /*## Database Variables ##*/
    /*## ------------------ ##*/
    var $DBhost = "127.0.0.1";
    var $DBuser = "family";
    var $DBpass = "dr!v3r";
    var $DBname = "vmem";
//    var $DBtype = "mysql";
    var $DBdebug = false;
    /*## ------------------ ##*/
    /*## DON'T CHANGE BELOW ##*/

    var $dbh = 0;
    var $totalQueries = 0;

    function __construct()
    {
        //## Connect to Server ##
//        if($this->DBdebug) $this->ADODB->debug = true;
        $this->dbh = mysql_connect($this->DBhost, $this->DBuser, $this->DBpass);
        mysql_select_db($this->DBname, $this->dbh);
        $this->dbgtxt = '';
    }

    function __destruct()
    {
        mysql_close($this->dbh);
    }

    function simpleQuery ($table,$fields,$where,$extra)
    {

        if($where) $where = "WHERE ".$where;

        if ($fields == "*" || $fields == ""){
            $fieldsArray = $this->getFields($table);
            $fields = "`".implode("`,`",$fieldsArray)."`";
        }

        $query = "SELECT $fields FROM `$table` $where $extra";
        $this->dbgtxt .= $query."\n";
        $dh = mysql_query($query, $this->dbh);
        $data = array();
        if(is_resource($dh)){
            while($dataline = mysql_fetch_assoc($dh)){
                $data[] = $dataline;
            }
            mysql_free_result($dh);
        }
        $this->totalQueries++;

        // let's make sure that we have data to return, or else return false
        if(count($data) > 0) {
            return $data;
        } else {
            return false;
        }
    }

    function dbWrite($table,$pairs,$where)
    {
        if($where) $where = "WHERE ".$where;

        $nPairs = count($pairs);
        for ($i=0;$i<$nPairs;$i++)
        {
            $keys .= "`".key($pairs)."`";
            $values .= "'".mysql_real_escape_string($pairs[key($pairs)])."'";
            if ($i<($nPairs -1)) { $keys .= ","; $values .= ","; }
            next($pairs);
        }

        $query = "INSERT INTO `$table` ($keys) VALUES ($values) $where";
        $this->dbgtxt .= $query."\n";
        mysql_query($query,$this->dbh);
        $this->totalQueries++;
        return mysql_insert_id($this->dbh);
    }

    function dbBatchWrite($table,$arrs,$where)
    {
        if($where) $where = "WHERE ".$where;

        $numr = count($arrs);
        $i=0;
        foreach($arrs as $pairs){
            if($i==0){
                $i++;
                $keys = "`".implode('`,`',array_keys($pairs))."`";
                $values = "(";
            }else{
                $values.=",(";
            }
            foreach($keys as $aky){
                $values .= "'".mysql_real_escape_string($pairs[$aky])."'";
            }
            $values.=")";
        }

        $query = "INSERT INTO `$table` ($keys) VALUES $values $where";
        $this->dbgtxt .= $query."\n";
        mysql_query($query,$this->dbh);
        $this->totalQueries++;
        return mysql_insert_id($this->dbh);
    }

    function dbReplace($table,$pairs,$where)
    {
        if($where) $where = "WHERE ".$where;

        $nPairs = count($pairs);
        for ($i=0;$i<$nPairs;$i++)
        {
            $keys .= "`".key($pairs)."`";
            $values .= "'".mysql_real_escape_string($pairs[key($pairs)])."'";
            if ($i<($nPairs -1)) { $keys .= ","; $values .= ","; }
            next($pairs);
        }

        $query = "REPLACE INTO `$table` ($keys) VALUES ($values) $where";
        $this->dbgtxt .= $query."\n";
        mysql_query($query,$this->dbh);
        $this->totalQueries++;
        return mysql_insert_id($this->dbh);
    }

    // this function does a INSERT... SELECT - it also works a lil bit differently than the other funcs
    //function dbInsertSelect($insTable,$insFields,$selTable,$selFields,$selWhere,$selExtra)
    function dbInsertSelect($data)
    {
        if($data['selWhere']) $data['selWhere'] = "WHERE ".$data['selWhere'];

        if ($data['insFields'] == "*" || $data['insFields'] == ""){
            $data['insFieldsArray'] = $this->getFields($data['insTable']);
            $data['insFields'] = implode(",",$data['insFieldsArray']);
        }

        if ($data['selFields'] == "*" || $data['selFields'] == ""){
            $data['selFieldsArray'] = $this->getFields($data['selTable']);
            $data['selFields'] = implode(",",$data['selFieldsArray']);
        }

        $query = "INSERT INTO `".$data['insTable']."` (".$data['insFields'].") SELECT ".$data['selFields']." FROM `".$data['selTable']."` ".$data['selWhere']." ".$data['selExtra'];
        $this->dbgtxt .= $query."\n";
        mysql_query($query,$this->dbh);
        $this->totalQueries++;
        $ar = mysql_affected_rows($this->dbh);
        if($ar >= 1) return $ar;
        else return false;
    }

    function dbUpdate($table,$pairs,$where,$type)
    {
        if($where) $where = "WHERE ".$where;

        // let's check to see whether or not the pairs var is an array
        if(is_array($pairs)) {
            $nPairs = count($pairs);
            for ($i=0;$i<$nPairs;$i++)
            {
                if(!$type) $update .= "`".key($pairs)."`='".mysql_real_escape_string($pairs[key($pairs)])."'";
                else $update .= "`".key($pairs)."`=".($pairs[key($pairs)]+0);
                if ($i<($nPairs -1)) $update .= ",";
                next($pairs);
            }
        } else $update = $pairs;

        $query = "UPDATE `$table` SET $update $where";
        $this->dbgtxt .= $query."\n";
        mysql_query($query,$this->dbh);
        $this->totalQueries++;
        $ar = mysql_affected_rows($this->dbh);
        if($ar >= 1) return $ar;
        else return false;
    }

    function delete($table,$where,$extra)
    {
        $query = "DELETE FROM `$table` WHERE $where $extra";
        $this->dbgtxt .= $query."\n";
        mysql_query($query,$this->dbh);
        $this->totalQueries++;
        $ar = mysql_affected_rows($this->dbh);
        if($ar >= 1) return $ar;
        else return false;
    }

    function getFields($ftable)
    {
        $fquery = "SHOW COLUMNS FROM `$ftable`";
//error_log('getFields query: '.$fquery);
        $fdh = mysql_query($fquery,$this->dbh);
        $retfields = array();
        while($fdt = mysql_fetch_assoc($fdh)){
            $retfields[] = $fdt['Field'];
        }
        mysql_free_result($fdh);
        return $retfields;
    }
}
?>