~gecka/gecka-framework/nautile

<?php

 

require_once 'Gecka/Database/Abstract.php';

 

class Gecka_Database_Pdo extends Gecka_Database_Abstract {

        

        private $_pdo = null;

                

        public function connect() {

 

                if($this->_isConnected) return $this;

                

                

                try {

                        

                        $this->pdo = new PDO( $this->_type . ':host=' . $this->_host . ';dbname=' . $this->_database . '', $this->_user, $this->_password);

                

                } 

                catch (PDOException $e) {

                        

                        throw new Gecka_Database_Exception('Error connecting: ' . $e->getMessage(), $e->getCode() );

                

                }

 

                $this->_isConnected = true;

                

                return $this;

                

        }

        

        public function query($query) {

                

                $this->connect();

                

                return $this->_pdo->query($query);

                

        }

        

        public function exec($query) {

                

                $this->connect();

                

                return $this->_pdo->exec($query);

                

        }

        

        public function beginTransaction() {

                

                $this->connect();

                

                return $this->_pdo->beginTransaction();

                

        }

        

        public function commit() { 

                

                $this->connect();

                

                return $this->_pdo->beginTransaction();

                

        }

        

        public function rollback() {

                

                $this->connect();

                

                return $this->_pdo->rollback();

                

        }

        

        public function insert($table, $data) {

                

                $query = $this->buildQuery('INSERT', $table, $data);

                

                return $this->exec($query);

                

        }

        

        public function update($table, $data, $condition)  {

                

                $query = $this->buildQuery('UPDATE', $table, $data, $condition);

                

                return $this->exec($query);

                

        }

        

        public function replace($table, $data, $condition) {

                

                $query = $this->buildQuery('REPLACE', $table, $data, $condition);

                

                return $this->exec($query);

                

        }

        

        public function delete($table, $condition) {

                

                $query = $this->buildQuery('DELETE', $table, null, $condition);

                

                return $this->exec($query);

                

        }

        

        public function quote($string) {

                

                return $this->_pdo->quote($string);

                

        }

        

        

        

        

}

 

 

?>