2009-10-27 26 views
3

过去几天我一直在玩PDO,我正在研究一个小的CMS系统来教自己的OOP技巧,但即使它只是一个小的CMS,我也希望它能够处理任何网站可以抛出它。我有这个PDO连接类吗?

这是我到目前为止,我将添加连接池到构造函数,以启用大量的并发连接点播。我对这个面向对象的东西很陌生,所以我想要一点建议和批评,毫无疑问,我在这里做了一些非常错误的事情。

我将Global or Singleton for database connection?的最佳答案作为基础设计,尽管我已经添加了一个私有构造函数,因为我希望在整个类中使用$ this-> dbConnectionInstance以使用许多辅助函数。

非常感谢您的时间,我真的会明白任何建议你可以给我,

-DREW

// Usage Example: $dbconn = dbManager::getConnection(); 
//    $dbconn->query("SELECT * FROM accounts WHERE id=:id", "':id' => $id"); 

<?php 

class dbManager { 
    private static $dbManagerInstance; 
    private $dbConnectionInstance; 
    private $stime; 
    private $etime; 
    public $timespent; 
    public $numqueries; 
    public $queries = array(); 

    public static function getManager(){ 
     if (!self::$dbManagerInstance){ 
      self::$dbManagerInstance = new dbManager(); 
     } 
     return self::$dbManagerInstance; 
    } 

    // Server details stored in definition file 
    private function __construct($db_server=DB_SERVER, $db_user=DB_USER, $db_pass=DB_PASS, $db_params=array(PDO::MYSQL_ATTR_INIT_COMMAND => "SET NAMES utf8")) { 
     if(!$this->dbConnectionInstance) 
     { 
      try{ 
       $this->dbConnectionInstance = new PDO($db_server, $db_user, $db_pass, $db_params); 
       $this->dbConnectionInstance->setAttribute(PDO::ATTR_PERSISTENT, PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION); 
      } catch (PDOException $e) { 
       $this->dbConnectionInstance = null; 
       die($e->getMessage()); 
      } 
     } 
     return $this->dbConnectionInstance; 
    } 

    private function __destruct(){ 
     $this->dbConnectionInstance = null; 
    } 

    private function query($sql, $params = array()) { 
     $this->queries[] = $sql; 
     $this->numqueries++; 
     $this->sTime = microtime(); 
     $stmt = $this->dbConnectionInstance->prepare($sql); 
     $stmt->execute($params); 
     $this->eTime = microtime(); 
     $this->timespent += round($this->eTime - $this->sTime, 4); 
     return $stmt; 
    } 

} 

?> 

谢谢两位你的建议,现在我已经加入回滚和提交到我的异常处理,我只是研究缓冲查询的使用,我不完全确定会给我什么?

回答

3

看起来不错,我想补充rollback功能,与缓冲查询一起/ errorInfo中的建议(如果你使用的是支持事务的RDBMS):

try { 
    $this->dbConnectionInstance->beginTransaction(); 
    $stmt = $this->dbConnectionInstance->prepare($sql); 
    $stmt->execute($params); 
    $this->dbConnectionInstance->commit(); 
}catch(PDOException $e){ 
    $this->dbConnectionInstance->rollback(); 
} 

commit()beginTransaction()

编辑:下面增加链接以获取关于缓冲查询的更多信息:

0

你的剂量看起来太糟糕了。但是,如果我可以做一些小的改变(主要是错误处理)。

prepare和execute语句都会在出错时返回false。您可以在上面的示例中访问$this->dbConnectionInstance->errorInfo()中的错误。

另外,如果你打算使用任何大型查询我建议使用一个缓冲查询:PDO::MYSQL_ATTR_USE_BUFFERED_QUERY => true

看起来像一个良好的开端。祝你的CMS好运。