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();
    }
}