PDO Software Klasse

Hier eine PDO Software Klasse für Server, bei denen PDO nicht mitinstalliert ist.

PDO.inc

<?php

define('PDO::PARAM_BOOL ',5);
define('PDO::PARAM_NULL',0);
define('PDO::PARAM_INT',1);
define('PDO::PARAM_STR',2);
define('PDO::PARAM_LOB',3);
define('PDO::PARAM_STMT',4);
define('PDO::PARAM_INPUT_OUTPUT',-2147483648);
define('PDO::FETCH_LAZY',1);
define('PDO::FETCH_ASSOC',2);
define('PDO::FETCH_NAMED',11);
define('PDO::FETCH_NUM',3);
define('PDO::FETCH_BOTH',4);
define('PDO::FETCH_OBJ',5);
define('PDO::FETCH_BOUND',6);
define('PDO::FETCH_COLUMN',7);
define('PDO::FETCH_CLASS',8);
define('PDO::FETCH_INTO',9);
define('PDO::FETCH_FUNC',10);
define('PDO::FETCH_GROUP',65536);
define('PDO::FETCH_UNIQUE',196608);
define('PDO::FETCH_KEY_PAIR',12);
define('PDO::FETCH_CLASSTYPE',262144);
define('PDO::FETCH_SERIALIZE',524288);
define('PDO::FETCH_PROPS_LATE',1048576);
define('PDO::ATTR_AUTOCOMMIT',0);
define('PDO::ATTR_PREFETCH',1);
define('PDO::ATTR_TIMEOUT',2);
define('PDO::ATTR_ERRMODE',3);
define('PDO::ATTR_SERVER_VERSION',4);
define('PDO::ATTR_CLIENT_VERSION',5);
define('PDO::ATTR_SERVER_INFO',6);
define('PDO::ATTR_CONNECTION_STATUS',7);
define('PDO::ATTR_CASE',8);
define('PDO::ATTR_CURSOR_NAME',9);
define('PDO::ATTR_CURSOR',10);
define('PDO::ATTR_DRIVER_NAME','16');
define('PDO::ATTR_ORACLE_NULLS',11);
define('PDO::ATTR_PERSISTENT',12);
define('PDO::ATTR_STATEMENT_CLASS',13);
define('PDO::ATTR_FETCH_CATALOG_NAMES',15);
define('PDO::ATTR_FETCH_TABLE_NAMES',14);
define('PDO::ATTR_STRINGIFY_FETCHES',17);
define('PDO::ATTR_MAX_COLUMN_LEN',18);
define('PDO::ATTR_DEFAULT_FETCH_MODE',19);
define('PDO::ATTR_EMULATE_PREPARES',20);
define('PDO::ERRMODE_SILENT',0);
define('PDO::ERRMODE_WARNING',1);
define('PDO::ERRMODE_EXCEPTION',2);
define('PDO::CASE_NATURAL',0);
define('PDO::CASE_LOWER',2);
define('PDO::CASE_UPPER',1);
define('PDO::NULL_NATURAL',0);
define('PDO::NULL_EMPTY_STRING',1);
define('PDO::NULL_TO_STRING',2);
define('PDO::FETCH_ORI_NEXT',0);
define('PDO::FETCH_ORI_PRIOR',1);
define('PDO::FETCH_ORI_FIRST',2);
define('PDO::FETCH_ORI_LAST',3);
define('PDO::FETCH_ORI_ABS',4);
define('PDO::FETCH_ORI_REL',5);
define('PDO::CURSOR_FWDONLY',0);
define('PDO::CURSOR_SCROLL',1);
define('PDO::ERR_NONE','00000');
define('PDO::PARAM_EVT_ALLOC',0);
define('PDO::PARAM_EVT_FREE',1);
define('PDO::PARAM_EVT_EXEC_PRE',2);
define('PDO::PARAM_EVT_EXEC_POST',3);
define('PDO::PARAM_EVT_FETCH_PRE',4);
define('PDO::PARAM_EVT_FETCH_POST',5);
define('PDO::PARAM_EVT_NORMALIZE',6);

function debug($str) {}

class PDO {

    
    var $driver;

    //$db = new PDO('mysql:host=db.example.com;dbname=DB666543', 'user', 'password');

    function getAvailableDrivers() { return array('mysql'); }

    function PDO($id,$user,$password) { 
        list($driver, $dummy1, $host, $dummy2,$db) = split('[:=;]', $id);
        switch($driver) {
            case 'mysql':
                $this->driver = new mysqlDriver();
                break;
            default:
                die('no driver found');
        }
        $this->driver->connect($host, $user, $password);
        $this->driver->setDB($db);
    }

    function prepare($sql) {
        return new Statement($this->driver, $sql);
    }
    function query($statement,$typ=0,  $p1=''  , $p2=array()) {
        //query($statement, int $PDO::FETCH_COLUMN  , int $colno  )
        //query($statement, int $PDO::FETCH_CLASS , string $classname , array $ctorargs )
        //query($statement, int $PDO::FETCH_INTO , object $object )
        $stmt = new Statement($this->driver, $statement);
        $stmt->execute();
        return $stmt;
    }
    function exec($statement) {
        $stmt = new Statement($this->driver, $statement);
        $stmt->execute();
        return $this->driver->affectedRows();
    }
    function lastInsertId() {
        return $this->driver->lastInsertId();
    }
    function quote($string, $parameter_type  = 2) { //PDO::PARAM_STR
        return $this->driver->quote($string);
    }
    function errorCode() {    
        return $this->driver->errorCode(); 
    }
    function errorInfo() { 
        return $this->driver->errorInfo(); 
    }
    
    //not supported functions
    function beginTransaction() {}
    function commit() {}
    function rollBack() {}
    function getAttribute($attribute) { return null;}
    function setAttribute($attribute, $value) {}
}

class Statement {
    var $driver;
    var $sql;
    var $result;
    var $boundedData=array();

    function Statement($driver, $sql) {
        $this->driver = $driver;
        $this->sql = $sql;
    }
    function execute($data=array()) {
        if(!empty($data)) 
            $this->boundedData = $data;
        
        $pos=0;
        $sql = $this->sql;
        foreach($this->boundedData as $k=>$v) {
            if(is_numeric($k)) {
                $pos = strpos($sql,'?',$pos);
                if(is_int($v)) {
                    $sql = substr_replace($sql, $v, $pos, 1 );
                } else {
                    $sql = substr_replace($sql, $this->driver->quote($v), $pos, 1 );
                    $pos += strlen($v)+2;
                }
            } else { 
                $sql = str_replace($sql, $k, $this->driver->quote($v));
                $pos += strlen($v)+2;
            }
        }
        
        $this->result = $this->driver->query($sql);
        debug($sql);
        //echo "Result:".$this->result;
        if(mysql_errno()>0)
            debug(mysql_errno() . ": " . mysql_error());
    }
    function fetch($typ=MYSQL_BOTH) {
        return $this->driver->fetch($this->result, $typ);
    }
    function bindValue($id, $value, $typ='') {
        $this->boundedData[$id] = $value;
    }
    function rowCount() {
        return $this->driver->rowCount($this->result);
    }
}

class mysqlDriver {
    var $con;
    function connect($host, $user, $password) {
        $this->con = mysql_connect($host, $user, $password);
    }
    function setDB($db) {
        mysql_select_db($db, $this->con);
    }
    function query($sql) {
        return mysql_query($sql, $this->con);
    }
    function fetch($result, $typ=MYSQL_BOTH) {    //MYSQL_ASSOC, MYSQL_NUM
        return mysql_fetch_array($result, $typ);
    }
    function lastInsertId() {
        return mysql_insert_id($this->con);
    }
    function affectedRows() {
        return mysql_affected_rows($this->con);
    }
    function rowCount($result) {
        return mysql_num_rows($result);
    }
    function escape($str) {
        return str_replace("'","\\'",$str);
        //return mysql_real_escape_string($str);
    }
    function quote($string) {
        return "'".$this->escape($string)."'";
    }
    function errorCode() {
        return mysql_errno($this->con);
    }
    function errorInfo() {
        return array(mysql_errno($this->con),mysql_errno($this->con),mysql_error($this->con));
    }
}