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