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