class.ilPDOStatement.php

Go to the documentation of this file.

<?php

require_once 'Services/Database/interfaces/interface.ilDBStatement.php';

class ilPDOStatement implements ilDBStatement
{

    protected $pdo_statement;


    public function __construct(PDOStatement $pdo_statement)
    {
        $this->pdo_statement = $pdo_statement;
    }


    public function fetchRow($fetch_mode = ilDBConstants::FETCHMODE_ASSOC)
    {
        if ($fetch_mode == ilDBConstants::FETCHMODE_ASSOC) {
            return $this->pdo_statement->fetch(PDO::FETCH_ASSOC);
        } elseif ($fetch_mode == ilDBConstants::FETCHMODE_OBJECT) {
            return $this->pdo_statement->fetch(PDO::FETCH_OBJ);
        } else {
            throw new ilDatabaseException("No valid fetch mode given, choose ilDBConstants::FETCHMODE_ASSOC or ilDBConstants::FETCHMODE_OBJECT");
        }
    }


    public function fetch($fetch_mode = ilDBConstants::FETCHMODE_ASSOC)
    {
        return $this->fetchRow($fetch_mode);
    }


    public function closeCursor()
    {
        $this->pdo_statement->closeCursor();
    }


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


    public function fetchObject()
    {
        return $this->fetch(ilDBConstants::FETCHMODE_OBJECT);
    }


    public function fetchAssoc()
    {
        return $this->fetch(ilDBConstants::FETCHMODE_ASSOC);
    }


    public function numRows()
    {
        return $this->pdo_statement->rowCount();
    }


    public function execute($a_data = null)
    {
        $this->pdo_statement->execute($a_data);

        return $this;
    }

    public function errorCode()
    {
        return $this->pdo_statement->errorCode();
    }

    public function errorInfo()
    {
        return $this->pdo_statement->errorInfo();
    }
}