class.ilPDOStatement.php

Go to the documentation of this file.

<?php
 
declare(strict_types=1);
 
class ilPDOStatement implements ilDBStatement
{
    protected \PDOStatement $pdo_statement;
 
 
    public function __construct(PDOStatement $pdo_statement)
    {
        $this->pdo_statement = $pdo_statement;
    }
 
 
    public function fetchRow(int $fetch_mode = ilDBConstants::FETCHMODE_ASSOC)
    {
        if ($fetch_mode === ilDBConstants::FETCHMODE_ASSOC) {
            return $this->pdo_statement->fetch(PDO::FETCH_ASSOC);
        }
 
        if ($fetch_mode === ilDBConstants::FETCHMODE_OBJECT) {
            return $this->pdo_statement->fetch(PDO::FETCH_OBJ);
        }
 
        throw new ilDatabaseException("No valid fetch mode given, choose ilDBConstants::FETCHMODE_ASSOC or ilDBConstants::FETCHMODE_OBJECT");
    }
 
 
    public function fetch(int $fetch_mode = ilDBConstants::FETCHMODE_ASSOC)
    {
        return $this->fetchRow($fetch_mode);
    }
 
 
    public function closeCursor(): void
    {
        $this->pdo_statement->closeCursor();
    }
 
 
    public function rowCount(): int
    {
        return $this->pdo_statement->rowCount();
    }
 
 
    public function fetchObject(): ?stdClass
    {
        return $this->fetch(ilDBConstants::FETCHMODE_OBJECT) ?: null;
    }
 
 
    public function fetchAssoc(): ?array
    {
        return $this->fetch(ilDBConstants::FETCHMODE_ASSOC) ?: null;
    }
 
 
    public function numRows(): int
    {
        return $this->pdo_statement->rowCount();
    }
 
 
    public function execute(array $a_data = null): ilDBStatement
    {
        $this->pdo_statement->execute($a_data);
 
        return $this;
    }
 
    public function errorCode(): string
    {
        return $this->pdo_statement->errorCode();
    }
 
    public function errorInfo(): array
    {
        return $this->pdo_statement->errorInfo();
    }
}