db/db.inc.php

<?php if(!function_exists('startedIndexPhp')) { header("location:../index.php"); exit();}



class MysqlException extends Exception {
  public $backtrace;

  public function __construct($message=false, $code=false) {
    global $sql_obj;
    $this->message="";
    if($message) {
        $this->message="<pre>".$message;
    }

    ### define local variables for error.log ###

    $this->message .= $sql_obj->error;

    if(!$code) {
      $this->code = $sql_obj->errno;
    }
    #$this->backtrace = debug_backtrace();


    if(function_exists('mysql_error') && mysql_error()) {
        $mysql_error= mysql_error();
    }
    else if(confGet('DB_TYPE') == 'mysqli' && $sql_obj && function_exists('mysqli_error') && $sql_obj->getConnect() && mysqli_error($sql_obj->getConnect())) {
        $mysql_error= mysqli_error($sql_obj->getConnect());
    }
    else {
        $mysql_error = $sql_obj->error;
    }

    trigger_error(sprintf(__("Database exception. Please read %s next steps on database errors.%s") , "<a href=http://streber.pixtur.de/index.php?go=taskView&tsk=1272'>", "</a>"),E_USER_ERROR);
  }
}

interface DB_Connection {
  public function prepare($query);
  public function execute($query);
}

interface DB_Statement {
  public function execute();
  public function bind_param($key, $value);
  public function fetch_row();
  public function fetch_assoc();
  public function fetchall_assoc();
}

class DB_Mysql implements DB_Connection
{
  protected $user;
  protected $pass;
  protected $dbhost;
  protected $dbname;
  protected $dbh;

  public function __construct($user=NULL, $pass=NULL, $dbhost=NULL, $dbname=NULL)
  {

    if($user) {
        $this->user= $user;
    }
    else {
        $this->user = confGet('DB_USERNAME');
    }

    if($pass) {
        $this->pass= $pass;
    }
    else {
        $this->pass = confGet('DB_PASSWORD');
    }
    if($dbhost) {
        $this->dbhost= $dbhost;
    }
    else {
        $this->dbhost = confGet('HOSTNAME');
    }

    if($dbname) {
        $this->dbname= $dbname;
    }
    else {
        $this->dbname = confGet('DB_NAME');
    }


  }


  protected function connect()
  {

    global $sql_obj;
    if(!is_object($sql_obj)){
        $sql_obj = new sql_class($this->dbhost, $this->user, $this->pass, $this->dbname);
    }

    if(!$sql_obj->connect()) {
      throw new MysqlException;
    }
    if(!$sql_obj->selectdb()) {
      throw new MysqlException;
    }

    ### enable utf8 encoding
    if(confGet('DB_USE_UTF8_ENCODING')) {
        $sql_obj->execute('SET NAMES utf8;');
        $sql_obj->execute('SET CHARACTER SET utf8;');
    }
  }



    public function execute($query)
    {
        global $sql_obj;
        if(!is_object($sql_obj)){
            $sql_obj = new sql_class($this->dbhost, $this->user, $this->pass, $this->dbname);
        }
        if(!$sql_obj->connect()) {
          throw new MysqlException;
        }
        $ret = $sql_obj->execute($query);
        if(!$ret) {
            throw new MysqlException;
        }
        else if(!is_resource($ret)) {
            return TRUE;
        }
        else {
            $stmt = new DB_MysqlStatement($sql_obj, $query);
            $stmt->result = $ret;
            return $stmt;
        }
    }

    public function prepare($query)
    {
        global $sql_obj;
        if(!is_object($sql_obj)) {
          $this->connect();
        }

        return new DB_MysqlStatement($sql_obj, $query);
    }

    public function lastId()
    {
        #echo 'lastID '.$this->id.'<br />';
        global $sql_obj;
        if(!is_object($sql_obj)) {
          $this->connect();
        }
        #echo 'lastID '.$sql_obj->lastId().'<br />';
        return $sql_obj->lastId();
    }


    public   function getVersion()
    {
        global $sql_obj;
        if(!is_object($sql_obj)){
            $sql_obj = new sql_class($this->dbhost, $this->user, $this->pass, $this->dbname);
        }

        if(!$sql_obj->connect()) {
            ### can't connect db... ###
            return NULL;
        }
        if(!$sql_obj->selectdb()) {

            ### can't select... ###
            return NULL;
        }

        ### get version ###
        $prefix= confGet('DB_TABLE_PREFIX');

        if($sql_obj->execute("select * from {$prefix}db where updated is NULL")) {
            $row = $sql_obj->fetchArray();
            return $row;
        }
        else {
            return NULL;
        }
    }

}

class DB_MysqlStatement implements DB_Statement
{
    public $result;
    public $binds;
    public $query;
    public $dbh;
    public function __construct($dbh, $query) {
        global $sql_obj;
        $this->query = $query;
        $this->dbh = $dbh;

        if(!is_object($dbh)) {
            throw new MysqlException("Not a valid database connection");
        }
    }
    public function bind_param($ph, $pv) {
    $this->binds[$ph] = $pv;

    return $this;
}

  #-------------------------------------------------
  # execute()
  # - requires list of params
  #-------------------------------------------------
  public function execute() {
        global $sql_obj;
        $args = func_get_args();
        #if(count(func_get_args())) {
        #    throw new Exception("pass values as array");
        #}

        #--- bind args in member with 1 ----
        $this->binds=array();
        foreach($args as $index => $name) {
            $this->binds[$index + 1] = $name;
        }

        $cnt = count($args);
        $query = $this->query;

        foreach ($this->binds as $ph => $pv) {
            #$query = @str_replace(":$ph", , $query);
            $query= preg_replace("/ƒ$ph\b/", "'".$pv."'", $query);
        }

        if(!$sql_obj->execute($query)) {
            throw new MysqlException("Querry=".$query."\n");
        }

        #--- cound traffic for debug-output ----
        #global $DB_ITEMS_LOADED;
        #$DB_ITEMS_LOADED+= count($this->result);

        return $this;
    }

    public function fetch_row()
    {
        global $sql_obj;
        return $sql_obj->fetchRow();
    }

    public function fetch_assoc()
    {
        global $sql_obj;
        $row=array();

        if($res=$sql_obj->fetchArray()) {
            foreach($res as $key=>$value) {

                #$row[$key]= stripslashes(stripslashes(stripslashes($value)));
                $row[$key]= stripslashes($value);
            }
        }
        return $row;
    }

    public function fetchall_assoc()
    {
        global $sql_obj;
        $retval = array();
        while($row = $this->fetch_assoc()) {
            foreach($row as $key=>$value) {
                #$row[$key]= stripslashes(stripslashes(stripslashes($row[$key])));
                $row[$key]= stripslashes($row[$key]);
            }
            $retval[] = $row;

            #--- cound traffic for debug-output ----
            global $DB_ITEMS_LOADED;
            $DB_ITEMS_LOADED+= count($row);

        }
        return $retval;
    }
}

class DB_Result {
  protected $stmt;
  protected $result = array();
  private $rowIndex = 0;
  private $currIndex = 0;
  private $done = false;

  public function __construct(DB_Statement $stmt)
  {
    $this->stmt = $stmt;

  }
  public function first()
  {
    if(!$this->result) {
      $this->result[$this->rowIndex++] = $this->stmt->fetch_assoc();
    }
    $this->currIndex = 0;
    return $this;
  }
  public function last()
  {
    if(!$this->done) {
      array_push($this->result, $this->stmt->fetchall_assoc());
    }
    $this->done = true;
    $this->currIndex = $this->rowIndex = count($this->result) - 1;
    return $this;
  }
  public function next()
  {
    if($this->done) {
      return false;
    }
    $offset = $this->currIndex + 1;
    if(!$this->result[$offset]) {
      $row = $this->stmt->fetch_assoc();
      if(!$row) {
        $this->done = true;
        return false;
      }
      $this->result[$offset] = $row;
      ++$this->rowIndex;
      ++$this->currIndex;
      return $this;
    }
    else {
      ++$this->currIndex;
      return $this;
    }
  }
  public function prev()
  {
    if($this->currIndex == 0) {
      return false;
    }
    --$this->currIndex;
    return $this;
  }
  public function __get($value)
  {
    if(array_key_exists($value, $this->result[$this->currIndex])) {
      return $this->result[$this->currIndex][$value];
    }
  }
}

require_once(dirname(__FILE__)."/../".confGet('DIR_SETTINGS').confGet('FILE_DB_SETTINGS'));



class DB_Mysql_Debug extends DB_Mysql {
  protected $elapsedTime;
  public function execute($query) {
    // set timer;
    parent::execute($query);
    // end timer;
  }
  public function getElapsedTime() {
    return $this->$elapsedTime;
  }
}

?>

---