MySQL PDO class?

[calm_man]

Hi

I dont know if this is the best forum-section to post in but here goes. Appology if not.
I usually use PDO to connect to mysql, i would like to use pdo in zencart too.
Is there any alreadymade addon for this, or should I just go ahead and create my own new addon ?

I dont want to replace the default zencart connection-code, i just want another another class. (I suppose people here have good PHP skills and know what PDO mysql is).

[calm_man]

Just replying to myself, any advice is welcome from anyone. Here is a little hack i put together from various examples:

class MyPDO_Wrapper extends PDO
{
  
    public static $log = array();   
  
  
  
  public $queryCount;             
  
  
    public function __construct( /*$dsn   , $username = null, $password = null */   ) 
  {
    
    
      $args = func_get_args();
      $r = call_user_func_array(array($this, 'parent::__construct'), $args);
      
      
      $this->queryCount = 0;
      ## PDO::ATTR_STATEMENT_CLASS: Set user-supplied statement class derived from PDOStatement. 
      ## Cannot be used with persistent PDO instances. Requires array(string classname, array(mixed constructor_args)).
      
      $this->setAttribute( PDO::ATTR_STATEMENT_CLASS,
                           
                           array('MyPDOStatement_Wrapper', array( & $this  )) );   
         
    
    }
  
  
  
  
  
  public function exec ($statement)
  {
    $this->queryCount++;
    
    $args = func_get_args();
    
    #var_dump($args);
    
    $start = microtime(true);
    $r= call_user_func_array(array($this, 'parent::exec'), $args);
    $time = microtime(true) - $start;
    self::$log[] = array('query' => $args[1], 'time' => sprintf('%01.4f', $time ));
    
    return $r;
    
  }
  
  
  
  
  
  /**
  *
  */
    public function query($query) 
  {
     
      $this->queryCount++;
  
      $args = func_get_args();  
      #var_dump($args);
  
      $start = microtime(true);
      $result = call_user_func_array(array($this, 'parent::query'),  $args    );
      $time = microtime(true) - $start;
  
      self::$log[] = array('query' => $query, 'time' => sprintf('%01.4f', $time ) ) ;
          
      return $result;
    }
  
  
  
  public static function printLog() 
  {
        $totalTime = 0;
        echo '<table border=1><tr><th>Query</th><th>Time (ms)</th></tr>';
        foreach(self::$log as $entry) 
    {
               $totalTime += $entry['time'];
               echo '<tr><td>' . $entry['query'] . '</td><td>' . $entry['time'] . "</td></tr>\n";
        }
    
        echo '<tr><th>' . count(self::$log) . ' queries</th><th>' . $totalTime . "</th></tr>\n";
        echo '</table>';
    }
  
  
  
  public static function printTotalTime() 
  {
        
        $totalTime = 0;
        foreach(self::$log as $entry) 
        {
             $totalTime += $entry['time'];
             
        }
          
        return $totalTime;
    
  } 
  
  
  public function getQueryCount()
  {
      return $this->queryCount;
  }
  
  
}#end class





class MyPDOStatement_Wrapper extends PDOStatement
{
  
 private $queryCount;
 
 protected function __construct (   & $this_pdo      )    
 {

    $this->queryCount = & $this_pdo->queryCount ;   
    $this->ptr_mypdo  = & $this_pdo;
 }



 public function execute ($input_parameters = array())
 {
  $this->queryCount++;
 
  $args = func_get_args();
  
  $start = microtime(true);
  $ret   =   call_user_func_array(  array($this, 'parent::execute'), $args);
  $time  = microtime(true) - $start;
  
  
  
  $this->ptr_mypdo-> log[] = array('query' => '[PS] ' . $this->queryString,
                                         'time'  =>   sprintf('%01.4f', $time )    );
  
  
  
  return $ret;
 }

}#end class. 

It should work like:

try { 
$_pdo = new MyPDO_Wrapper("mysql:dbname=".  DB_DATABASE .";host=". DB_SERVER , DB_SERVER_USERNAME, DB_SERVER_PASSWORD ,
                     array(PDO::MYSQL_ATTR_INIT_COMMAND => "SET NAMES utf8"));
} catch (PDOException $exception) { 
        printf("Failed to obtain database handle %s", $exception->getMessage());
        die();
}

$r = $_pdo->query("SELECT ..."  );
$ar_r = $r->fetchAll(PDO::FETCH_ASSOC ); 

 #this could go in the footer of the page
print $_pdo->getQueryCount();
print $_pdo->printTotalTime();