<?php
if (! @include_once('MDB2.php') ) {
    echo "Konnte das Modul MDB2 nicht laden!<br>";
    echo "Pr&uuml;fen Sie Ihre Installation:<br>";
    echo "pear list | grep MDB2<br>";
    echo "Variable '\$include_path' in der php.ini<br>";
    echo "aktueller Wert: ".ini_get('include_path');
    echo "<br><br><a href='inc/install.php?check=1'>Installations - Check durchf&uuml;hren</a><br>";
    exit (1);
};

final class myDB extends MDB2 {
    private $db = false;
    private $rc = false;
    private $showErr = false; // Browserausgabe
    private $log = true;     // Alle Abfragen mitloggen
    private $errfile = "/tmp/lxcrm.err";
    private $logfile = "/tmp/lxcrm.log";
    private $lfh = false;

    /**********************************************
    * dbFehler - Fehler in ein Log-File ausgeben
    * IN: $sql - SQL-Statement
    * IN: $err - Fehlermeldung
    * OUT: NONE
    **********************************************/
    public function dbFehler($sql,$err) {
        $efh=fopen($this->errfile,"a");
        fputs($efh,date("Y-m-d H:i:s \n"));
        fputs($efh,'SQL:'.$sql."\n");
        fputs($efh,'Msg:'.$err."\n");
        fputs($efh,print_r($this->rc->backtrace[0],true)."\n");
        $cnt=count($this->rc->backtrace);
        for ($i=0; $i<$cnt; $i++) {
            fputs($efh,$this->rc->backtrace[$i]['line'].':'.$this->rc->backtrace[$i]['file']."\n");
        }
        fputs($efh,"--------------------------------------------- \n");
        fputs($efh,"\n");
        fclose($efh);
        if ($this->showErr)
            echo "</td></tr></table><font color='red'>$sql : $err</font><br>";
    }

    /**********************************************
    * writelog - Texte in ein Log-File ausgeben
    * IN: $txt - SQL-Statement oder Text
    * OUT: NONE
    **********************************************/
    public function writeLog($txt, $all=true) {
        if ( $this->lfh === false )
            $this->lfh = fopen($this->logfile,"a");
        fputs($this->lfh, date("Y-m-d H:i:s ->") );
        fputs($this->lfh, $txt."\n" );
        if ( !$all ) return;
        if ( !empty($this->rc->backtrace[0] )) {
            fputs($this->lfh, 'Fehler: '."\n" );
            fputs($this->lfh, print_r($this->rc->backtrace[0],true)."\n" );
            $cnt = count($this->rc->backtrace) - 1;
            fputs($this->lfh, $this->rc->backtrace[$cnt]['line'].':'.$this->rc->backtrace[$cnt]['file']."\n" );
        } else {
            fputs($this->lfh, print_r($this->rc,true) );
        }
        fputs($this->lfh,"\n");
    }

    /**********************************************
    * myDB - Konstruktor
    * IN: $host,$user,$pwd,$db,$port - Parameter der Datenbank
    * OUT: DB-Objekt
    **********************************************/
    public function myDB($host,$user,$pwd,$db,$port) {
        $dsn = array(
                    'phptype'  => 'pgsql',
                    'username' => $user,
                    'password' => $pwd,
                    'hostspec' => $host,
                    'database' => $db,
                    'port'     => $port
                );
        if ($this->log) $this->writeLog(print_r($dsn,true));
        $options = array(
            'result_buffering' => false,
        );
        $this->db=& MDB2::factory($dsn,$options);
        //$this->db=& MDB2::connect($dsn,$options);
        if (!$this->db || PEAR::isError($this->db)) {
            if ($this->log) $this->writeLog('Connect Error: '.$dns);
            $this->dbFehler('Connect '.print_r($dsn,true),$this->db->getMessage());
            die ($this->db->getMessage());
        }
        $this->db->setFetchMode(MDB2_FETCHMODE_ASSOC);
        if ($this->log) $this->writeLog('Connect: ok ');
        return $this->db;
    }

    /**********************************************
    * query - beliebiges SQL-Statement absetzen
    * IN: $sql - Statement
    * OUT: true/false
    **********************************************/
    public function query($sql, $force = False) {
        if ($this->log) $this->writeLog($sql);
        if (strpos($sql,";")>0 and !$force) {
            //Sql-Injection? HTML-Sonderzeichen zulassen
            if (!preg_match("/&[a-zA-Z]+$/",substr($sql,0,strpos($sql,";"))))
                $this->dbFehler($sql,'SQL-injection??');
                return false;
        }
        $this->rc=@$this->db->query($sql);
        if(PEAR::isError($this->rc)) {
            $this->dbFehler($sql,$this->rc->getMessage());
            $this->rollback();
            return false;
        } else {
            return true;
        }
    }

    /**********************************************
    * update - einen Datensatz modifizieren
    * IN: $table - Tabelle
    * IN: $fields - betroffene Felder
    * IN: $values - dazugehörige Werte
    * IN: $where - welcher Datensatz
    * OUT: true/false
    **********************************************/
    public function update($table,$fields,$values,$where) {
        if (strpos($where,"=")<1) {
            $this->dbFehler('Update','Where missing or wrong: '.$where);
            $this->dbFehler('Update',print_r(debug_backtrace(),true));
            return false;
        }
        if ($this->log) {
            $this->writeLog('Update auf: '.$table,false);
            $this->writeLog(print_r($fields,true),false);
            $this->writeLog(print_r($values,true),false);
            $this->writeLog("UPDATE $table set ".implode('= ?, ',$fields)." = ? WHERE ".$where,false);
        }
        //SQL-Statement vorbereiten
        $sth = $this->db->prepare("UPDATE $table set ".implode('= ?, ',$fields)." = ? WHERE ".$where);
        if (PEAR::isError($sth)) {
            if ($this->log) {
                $this->writeLog('prepare',false);
                $this->writeLog($sth->getMessage(),false);
            }
            $this->dbFehler($sql,$sth->getMessage());
            $this->rollback();
            return false;
        }
        //wenn ok, ausführen
        $this->rc=@$sth->execute( $values);
        if(PEAR::isError($this->rc)) {
            if ($this->log) {
                $this->writeLog('execute',false);
                $this->writeLog($this->rc->getMessage(),false);
            }
            $this->dbFehler($sql,$this->rc->getMessage());
            $this->dbFehler(print_r($fields,true),print_r($values,true));
            $this->rollback();
            return false;
        }
        return true;
    }

    /**********************************************
    * insert - einen neuen Datensatz anlegen
    * IN: $table - Tabelle
    * IN: $fields - betroffene Felder
    * IN: $values - dazugehörige Werte
    * OUT: true/false
    **********************************************/
    public function insert($table,$fields,$values,$prepstatement='') {
        if ($this->log) {
            $this->writeLog('Insert in: '.$table,false);
            $this->writeLog(print_r($fields,true),false);
            $this->writeLog(print_r($values,true),false);
            $this->writeLog($prepstatement,false);
        }
        //SQL-Statement vorbereiten
        if ( $prepstatement != '' ) {
            $sth = $this->db->prepare($prepstatement);
        } else {
            $sth = $this->db->prepare("INSERT INTO $table (".implode(',',$fields).") VALUES (".str_repeat("?,",count($fields)-1)."?)");
        }
        if (PEAR::isError($sth)) {
            $this->writeLog("Prepare: ".$sth->getMessage(),false);
            $this->dbFehler($sql,$sth->getMessage());
            $this->dbFehler(print_r($fields,true),print_r($values,true));
            $this->rollback();
            return false;
        }
        //wenn ok, ausführen
        $this->rc=@$sth->execute( $values);
        if(PEAR::isError($this->rc)) {
            $this->writeLog("Execute: ".$this->rc->getMessage(),false);
            $this->dbFehler($sql,$this->rc->getMessage());
            $this->rollback();
            return false;
        } else {
            return $this->db->lastInsertID();
        }
    }

    public function begin() {
        if ($this->log) $this->writeLog('BEGIN');
        return $this->db->beginTransaction();
    }
    
    public function commit() {
        if ($this->log) $this->writeLog('COMMIT');
        return $this->db->commit();
    }
    
    public function rollback() {
        if ($this->log) $this->writeLog('ROLLBACK');
        return $this->db->rollback();
    }
    
    public function getAll($sql) {
        if ($this->log) $this->writeLog('getAll: '.$sql);
        if (strpos($sql,";")>0) { $this->dbFehler('Achtung','Semikolon'); return false;};
        $rs = $this->db->queryAll($sql);
        if(PEAR::isError($rs)) {
            $this->dbFehler($sql,$rs->getMessage());
            return false;
        } else {
            if ($this->log) $this->writeLog('getAll: '.print_r($rs,true));
            return $rs;
        }
    }
  
    /**
     * Holt die Daten als assoziatives Array aus der DB.
     * S.a. PEAR::getAssoc
     * return mixed, false
     */
    public function getAssoc($sql){
        if ($this->log) $this->writeLog('getAssoc: '.$sql);
        $this->db->loadModule('Extended');
        $this->rc=$this->db->getAssoc($sql);
        if(PEAR::isError($this->rc)) {
            $this->dbFehler($sql,$this->rc->getMessage());
            return false;
        } 
        else return $this->rc;
    }
    
    public function getOne($sql) {
        if ($this->log) $this->writeLog('getOne: '.$sql);
        $rs = $this->db->queryRow($sql);
        if(PEAR::isError($rs)) {
            $this->dbFehler($sql,$rs->getMessage());
            if ($this->log) $this->writeLog('getOne: '.$rs->getMessage());
            if ($this->log) $this->writeLog('getOne: '.print_r($rs,true));
            return false;
        } else {
            if ($this->log) $this->writeLog('getOne: '.print_r($rs,true));
            return $rs;
        }
    }
    public function saveData($txt) {
        //if (get_magic_quotes_gpc()) {
        if (get_magic_quotes_runtime()) {
            return $txt;
        } else {
            return $this->db->escape($txt);
        }
    }
    
    /*
     * Benutzt PEAR::executeMultiple. Erwartet als
     * Zeichenkette das PreparedStatement
     * und die entsprechenden Werte für das Statement
     * Ist ferner transaktionssicher (autocommit off)
     * @param string $statement
     * @param mixed $data
     *
     * @return boolean
     */
    public function executeMultiple($statement, $data){
        if ($this->log) {                            //Logging
            $this->writeLog("executeMultiple: $statement");
            $this->writeLog("mit den Werten:" . print_r($data,true));
        }
        $this->db->loadModule('Extended');
        if (!$this->db->supports('transactions')){
            $this->writeLog("No Transaction");
            exit();
        }

        $sth = $this->db->prepare($statement);                        //Prepare
        if (PEAR::isError($sth)) {
            $this->dbFehler($sql,$sth->getMessage());
            $this->rollback();
            return false;
        }

        $res =& $this->db->beginTransaction();
        $res =& $this->db->extended->executeMultiple($sth, $data);     //Daten senden
        if ($this->log){
                $this->writeLog($res);
        }
        if (PEAR::isError($res)) {
                $this->dbFehler($sql,$sth->getMessage());
                $this->rollback();
                return false;
        }else{
                $res = $this->commit();
                if ($this->log){
                        $this->writeLog($res);
                }
        }
        return true;
    }
    
    public function setShowError( $value ){
        $this->showErr = $value;
    }    
}
?>