abstract.class.php

Go to the documentation of this file.

<?php
abstract class db_pdo_abstract extends db_abstract {

        protected $connection;

        protected function _connect() {
        if ($this->connection)
            return;

                $this->connection = new PDO(
                        $this->_dsn(),
                        $this->cfg->user,
                        $this->cfg->pass,
                        $this->cfg->driverOptions);
                
                foreach($this->cfg->conQuery as $q)
                        $this->connection->query($q);

                $this->connection->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
        }

        protected function _dsn() {
                return $this->cfg->driver.':host='.$this->cfg->host.';dbname='.$this->cfg->base;
        }

        public function closeConnection() {
                $this->connection = null;
        }

        public function prepare($sql, array $options=array()) {
                $this->_connect();
                return $this->connection->prepare($sql, $options);
        }

        public function lastInsertId() {
                $this->_connect();
        return $this->connection->lastInsertId();
        }

        protected function _beginTransaction() {
        $this->_connect();
        $this->connection->beginTransaction();
        }

        protected function _commit() {
        $this->_connect();
        $this->connection->commit();
        }

        protected function _rollBack() {
        $this->_connect();
        $this->connection->rollBack();
        }

}