DatabaseUtility.php

Go to the documentation of this file.

<?php
class Blob {
    protected $mData;
 
    function __construct( $data ) {
        $this->mData = $data;
    }
 
    function fetch() {
        return $this->mData;
    }
}
 
interface Field {
    function name();
 
    function tableName();
 
    function type();
 
    function isNullable();
}
 
class ResultWrapper implements Iterator {
    public $result;
 
    protected $db;
 
    protected $pos = 0;
 
    protected $currentRow = null;
 
    function __construct( $database, $result ) {
        $this->db = $database;
 
        if ( $result instanceof ResultWrapper ) {
            $this->result = $result->result;
        } else {
            $this->result = $result;
        }
    }
 
    function numRows() {
        return $this->db->numRows( $this );
    }
 
    function fetchObject() {
        return $this->db->fetchObject( $this );
    }
 
    function fetchRow() {
        return $this->db->fetchRow( $this );
    }
 
    function free() {
        $this->db->freeResult( $this );
        unset( $this->result );
        unset( $this->db );
    }
 
    function seek( $row ) {
        $this->db->dataSeek( $this, $row );
    }
 
    /*
     * ======= Iterator functions =======
     * Note that using these in combination with the non-iterator functions
     * above may cause rows to be skipped or repeated.
     */
 
    function rewind() {
        if ( $this->numRows() ) {
            $this->db->dataSeek( $this, 0 );
        }
        $this->pos = 0;
        $this->currentRow = null;
    }
 
    function current() {
        if ( is_null( $this->currentRow ) ) {
            $this->next();
        }
 
        return $this->currentRow;
    }
 
    function key() {
        return $this->pos;
    }
 
    function next() {
        $this->pos++;
        $this->currentRow = $this->fetchObject();
 
        return $this->currentRow;
    }
 
    function valid() {
        return $this->current() !== false;
    }
}
 
class FakeResultWrapper extends ResultWrapper {
    public $result = [];
 
    protected $db = null;
 
    protected $pos = 0;
 
    protected $currentRow = null;
 
    function __construct( $array ) {
        $this->result = $array;
    }
 
    function numRows() {
        return count( $this->result );
    }
 
    function fetchRow() {
        if ( $this->pos < count( $this->result ) ) {
            $this->currentRow = $this->result[$this->pos];
        } else {
            $this->currentRow = false;
        }
        $this->pos++;
        if ( is_object( $this->currentRow ) ) {
            return get_object_vars( $this->currentRow );
        } else {
            return $this->currentRow;
        }
    }
 
    function seek( $row ) {
        $this->pos = $row;
    }
 
    function free() {
    }
 
    function fetchObject() {
        $this->fetchRow();
        if ( $this->currentRow ) {
            return (object)$this->currentRow;
        } else {
            return false;
        }
    }
 
    function rewind() {
        $this->pos = 0;
        $this->currentRow = null;
    }
 
    function next() {
        return $this->fetchObject();
    }
}
 
class LikeMatch {
    private $str;
 
    public function __construct( $s ) {
        $this->str = $s;
    }
 
    public function toString() {
        return $this->str;
    }
}
 
interface DBMasterPos {
    public function asOfTime();
 
    public function hasReached( DBMasterPos $pos );
 
    public function channelsMatch( DBMasterPos $pos );
 
    public function __toString();
}