过去几天我一直在玩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;
}
}
?>
谢谢两位你的建议,现在我已经加入回滚和提交到我的异常处理,我只是研究缓冲查询的使用,我不完全确定会给我什么?