phplibrary/core/database_pdo.php

<?php

/**
 * Êëàññ îáîëî÷êà äëÿ PDO äëÿ çàìåíû Creole 
 */
class Database extends PDO
{
    public function __construct($dsn, $username = false, $password = false)
    {
        parent::__construct($dsn, $username, $password);
        $this->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
        $this->setAttribute(PDO::ATTR_STATEMENT_CLASS, array('PDODatabaseStatement', array()));
    }

    public function getDSN()
    {
        return $this->dsn;
    }

    static function getConnection(array $dsn)
    {
        if ($dsn['phptype'] == 'pgsql') {            
            $port = (isset($dsn['port'])) ? "port={$dsn['port']};" : "";
            $connection = new Database("{$dsn['phptype']}:host={$dsn['hostspec']}; $port dbname={$dsn['database']}", $dsn['username'], $dsn['password']);
        }
        if ($dsn['phptype'] == 'sqlite') {
            $connection = new Database("{$dsn['phptype']}:{$dsn['database']}");
        }
        $connection->dsn = $dsn;
        return $connection;
    }

    public function executeQuery($query)
    {
        $sth = $this->prepare($query);
        $sth->setFetchMode(PDO::FETCH_ASSOC);
        $sth->execute();
//        print_r($sth->fetchAll());
        return $sth;//$sth->fetchAll();
    }    

    public function prepareStatement($query)
    {
        return new DatabaseStatement($query, $this);
    }

    // Äëÿ ñîâìåñòèìîñòè ñî ñòàðûì ïðåäñòàâëåíèåì áàç äàííûõ CIS
    public function fetchAllArray($query)
    {
        $sth = $this->prepare($query);
        $sth->setFetchMode(PDO::FETCH_ASSOC);
        $sth->execute();
        return $sth->fetchAll();
    }

    public function fetchOneArray($query) 
    {
        $sth = $this->prepare($query);
        $sth->setFetchMode(PDO::FETCH_ASSOC);
        $sth->execute();
        return $sth->fetch();
    }

    private function assignQuote($x, $y) 
    {
        return $x . "=" . $this->quote($y);
    }

    function insertQuery($table, array $values)
    {
        return $this->query("INSERT INTO $table (" . implode(",", array_keys($values)) 
        . ") VALUES (" . implode(",", array_map(array($this, 'quote'), array_values($values))) . ")");
    }

    function updateQuery($table, array $values, $cond)
    {
        return $this->query("UPDATE $table SET " . implode(",", 
            array_map(array($this, 'assignQuote'), array_keys($values), array_values($values))) . " WHERE $cond");
    }

    function getNextId($seq)
    {
        $result = $this->fetchOneArray("SELECT nextval('$seq')");
        return $result['nextval'];
    }
	
	function close()
    {
        return null;
    }
}
class PDODatabaseStatementIterator implements Iterator
{

    private $result;
    private $pos = 0;
    private $fetchmode;
    private $row_count;
    private $rs;
    
    /**
     * Construct the iterator.
     * @param PgSQLResultSet $rs
     */
    public function __construct($rs)
    {
        $this->result = $rs;
		$this->row_count = $rs->getRecordCount();
    }
    
    function rewind()
    {        
//        echo 'rewind';
        $this->pos = 0;
    }
    
    function valid()
    {
		return ( $this->pos < $this->row_count );
    }
    
    function key()
    {
        return $this->pos;
    }
    
    function current()
    {
       return $this->result->fetch(PDO::FETCH_ASSOC);
    }
    
    function next()
    {
        $this->pos++;
    }

    function seek ( $index )
    {
		$this->pos = $index;
    }

    function count ( ) {
		return $this->row_count;
    }
}

class PDODatabaseStatement extends PDOStatement implements IteratorAggregate
{
    protected $cursorPos = 0;

    function getIterator()
    {
//        echo 'getiterator';
        return new PDODatabaseStatementIterator($this);
    }

    protected function __construct() {    
    }

    function rewind()
    {        
//        echo 'rewind';
        $this->cursorPos = 0;
    }

	public function seek($rownum)
	{
//        echo 'seek';
		if ($rownum < 0) {
			return false;
		}
		
		// PostgreSQL rows start w/ 0, but this works, because we are
		// looking to move the position _before_ the next desired position
		$this->cursorPos = $rownum;
		return true;
	}

    function valid()
    {
//        echo 'valid';
		return ( true );
    }


    public function first()
    {
//        echo 'first';
        if($this->cursorPos !== 0) { $this->seek(0); }
        return $this->next();
    }

    function next()
    {
//        echo 'next';
        if ($this->getRecordCount() > $this->cursorPos) {
            $this->fields = $this->fetch(PDO::FETCH_ASSOC);
        } else {
            $this->fields = null;
        }
//		$this->cursorPos++;	
        return true;
    }

    function key() {
//        echo 'key';
        return $this->cursorPos;
    }

    function current()
    {
//        echo 'current';
       return $this->result->fetch(PDO::FETCH_ASSOC);
    }

    function getRow()
    {
        return $this->fields;
    }

    function getInt($name)
    {
        return intval($this->fields[$name]);
    }

    function getBlob($name)
    {
        return $this->fields[$name];
    }

    function getString($name)
    {
        return $this->fields[$name];
    }

    function get($name)
    {
        return $this->cursorPos[$name];
    }

    function getRecordCount()
    {
        return $this->rowCount();
    }
}


/**
 * Êëàññ îáîëî÷êà äëÿ PDOStatement äëÿ çàìåíû Creole 
 */
class DatabaseStatement 
{
    protected $limit = null;
    protected $offset = null;
    protected $statement = null;
    protected $binds = array();
    protected $conn;
    protected $query;

    function __construct($query, $conn) {    
        $this->query = $query;
        $this->conn = $conn;
    }
    
    function setInt($n, $value)
    {   
        $this->binds [] = array($n, $value, PDO::PARAM_INT);
    }

    function setString($n, $value)
    {
        $this->binds [] = array($n, $value, PDO::PARAM_STR);
    }

    function setBlob($n, $value)
    {
        $this->binds [] = array($n, $value, PDO::PARAM_BLOB);
    }

    function setLimit($limit)
    {
        $this->limit = $limit;
    }

    function setOffset($offset)
    {
        $this->offset = $offset;
    }

    function executeQuery()
    {
        if ($this->limit) {
            $this->queryString .= " LIMIT {$this->limit} OFFSET {$this->offset}";
        }
        $stmt = $this->conn->prepare($this->query);
        foreach ($this->binds as $bind) {
            list($n, $value, $type) = $bind;
            $stmt->bindValue($n, $value, $type);
        }
        $stmt->setFetchMode(PDO::FETCH_ASSOC);
        $stmt->execute();
        return $stmt;
    }
}