ResultWrapper.php

Go to the documentation of this file.

<?php
 
namespace Wikimedia\Rdbms;
 
use stdClass;
use RuntimeException;
use InvalidArgumentException;
 
class ResultWrapper implements IResultWrapper {
    protected $db;
    protected $result;
 
    protected $pos = 0;
    protected $currentRow;
 
    public function __construct( IDatabase $db, $result ) {
        $this->db = $db;
        if ( $result instanceof self ) {
            $this->result = $result->result;
        } elseif ( $result !== null ) {
            $this->result = $result;
        } else {
            throw new InvalidArgumentException( "Null result resource provided" );
        }
    }
 
    public static function &unwrap( &$res ) {
        if ( $res instanceof self ) {
            if ( $res->result === null ) {
                throw new RuntimeException( "The result resource was already freed" );
            }
 
            return $res->result;
        } else {
            return $res;
        }
    }
 
    public function numRows() {
        return $this->getDB()->numRows( $this );
    }
 
    public function fetchObject() {
        return $this->getDB()->fetchObject( $this );
    }
 
    public function fetchRow() {
        return $this->getDB()->fetchRow( $this );
    }
 
    public function seek( $pos ) {
        $this->getDB()->dataSeek( $this, $pos );
        $this->pos = $pos;
    }
 
    public function free() {
        $this->db = null;
        $this->result = null;
    }
 
    function rewind() {
        if ( $this->numRows() ) {
            $this->getDB()->dataSeek( $this, 0 );
        }
        $this->pos = 0;
        $this->currentRow = null;
    }
 
    function current() {
        if ( $this->currentRow === null ) {
            $this->currentRow = $this->fetchObject();
        }
 
        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;
    }
 
    private function getDB() {
        if ( !$this->db ) {
            throw new RuntimeException( "Database handle was already freed" );
        }
 
        return $this->db;
    }
}
 
class_alias( ResultWrapper::class, 'ResultWrapper' );