co_pdo.class.php

Go to the documentation of this file.

<?php
/***************************************************************************************************************************/
defined( 'LGV_DB_CATCHER' ) or die ( 'Cannot Execute Directly' );   // Makes sure that this file is in the correct context.
 
/***************************************************************************************************************************/
class CO_PDO {
    private $_pdo = NULL;
    var $driver_type = NULL;
    var $class_description = NULL;
    var $last_insert = NULL;
    var $owner_instance = NULL;
    
    private $fetchMode = PDO::FETCH_ASSOC;
 
    /***********************************************************************************************************************/
    /***********************/
    public function __construct(    $driver,            
                                    $host,              
                                    $database,          
                                    $user = NULL,       
                                    $password = NULL,   
                                    $charset = NULL     
                                ) {
        
        $this->class_description = 'A class for managing PDO access to the databases.';
 
        $this->_pdo = NULL;
        $this->driver_type = $driver;
        $this->last_insert = NULL;
        
        $dsn = $driver . ':host=' . $host . ';dbname=' . $database ;
        try {
            $this->_pdo = new PDO($dsn, $user, $password, array(PDO::MYSQL_ATTR_INIT_COMMAND => "SET NAMES 'utf8'"));
            $this->_pdo->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
            $this->_pdo->setAttribute(PDO::ATTR_CASE, PDO::CASE_LOWER);
            $this->_pdo->setAttribute(PDO::ATTR_EMULATE_PREPARES, true);
            if (strlen($charset) > 0) {
                self::preparedExec('SET NAMES :charset', array(':charset' => $charset), false);
            }
        } catch (PDOException $exception) {
            throw new Exception(__METHOD__ . '() ' . $exception->getMessage());
        }
    }
 
    /***********************/
    public function preparedExec(   $sql,               
                                    $params = array()   
                                )
    {
        $this->last_insert = NULL;
        try {
            if ('pgsql' == $this->driver_type) {
                if (strpos($sql, 'RETURNING id;')) {
                    $response = $this->preparedQuery($sql, $params);
                    $this->last_insert = intval($response[0]['id']);
                    return true;
                }
            }
            
            $sql = str_replace(' RETURNING id', '', $sql);
            // This represents a potential MASSIVE security, performnce and legal issue. This should ONLY be used for debugging!
            if (method_exists('CO_Config', 'call_low_level_log_handler_function')) {
                CO_Config::call_low_level_log_handler_function(isset($this->owner_instance) ? $this->owner_instance->access_object->get_login_id() : 0, $sql, $params);
            }
            $this->_pdo->beginTransaction(); 
            $stmt = $this->_pdo->prepare($sql);
            $stmt->execute($params);
            if ('pgsql' != $this->driver_type) {
                $this->last_insert = $this->_pdo->lastInsertId();
            }
            $this->_pdo->commit();
        
            return true;
        } catch (PDOException $exception) {
            $this->last_insert = NULL;
            $this->_pdo->rollback();
            throw new Exception(__METHOD__ . '() ' . $exception->getMessage());
        }
        
        return false;
    }
 
    /***********************/
    public function preparedQuery(  $sql,                   
                                    $params = array(),      
                                    $fetchKeyPair = false   
                                ) {
        $this->last_insert = NULL;
        try {
            // This represents a potential MASSIVE security, performnce and legal issue. This should ONLY be used for debugging!
            if (method_exists('CO_Config', 'call_low_level_log_handler_function')) {
                CO_Config::call_low_level_log_handler_function(isset($this->owner_instance) ? $this->owner_instance->access_object->get_login_id() : 0, $sql, $params);
            }
            $this->_pdo->beginTransaction(); 
            $stmt = $this->_pdo->prepare($sql);
            $stmt->setFetchMode($this->fetchMode);
            $stmt->execute($params);
            $this->_pdo->commit();
            
            $ret = NULL;
            
            if ($fetchKeyPair) {
                $ret = $stmt->fetchAll(PDO::FETCH_KEY_PAIR);
            } else {
                $ret = $stmt->fetchAll();
            }
            
            return $ret;
        } catch (PDOException $exception) {
            $this->last_insert = NULL;
            $this->_pdo->rollback();
            throw new Exception(__METHOD__ . '() ' . $exception->getMessage());
        }
        
        return false;
    }
};