PHP基于单例模式编写PDO类的方法

一、单例模式简介

简单的说，一个对象（在学习设计模式之前，需要比较了解面向对象思想）只负责一个特定的任务；
二、为什么要使用PHP单例模式？

     1、php的应用主要在于数据库应用, 所以一个应用中会存在大量的数据库操作, 使用单例模式, 则可以避免大量的new 操作消耗的资源。

     2、如果系统中需要有一个类来全局控制某些配置信息, 那么使用单例模式可以很方便的实现. 这个可以参看ZF的FrontController部分。

     3、在一次页面请求中, 便于进行调试, 因为所有的代码（例如数据库操作类db）都集中在一个类中, 我们可以在类中设置钩子, 输出日志，从而避免到处var_dump, echo。
三、PHP基于单例模式编写PDO类的示例代码

代码如下：

<?php/** * MyPDO * @author Jason.Wei <jasonwei06@hotmail.com> * @license http://www.sunbloger.com/ * @version 5.0 utf8 */class MyPDO{ protected static $_instance = null; protected $dbName = ""; protected $dsn; protected $dbh;/*** 构造* * @return MyPDO*/ private function __construct（$dbHost, $dbUser, $dbPasswd, $dbName, $dbCharset） {try { $this->dsn = "mysql:host=".$dbHost.";dbname=".$dbName; $this->dbh = new PDO（$this->dsn, $dbUser, $dbPasswd）; $this->dbh->exec（"SET character_set_connection=".$dbCharset.", character_set_results=".$dbCharset.", character_set_client=binary"）;} catch （PDOException $e） { $this->outputError（$e->getMessage（））;} }/*** 防止克隆* */ private function __clone（） {}/*** Singleton instance* * @return Object*/ public static function getInstance（$dbHost, $dbUser, $dbPasswd, $dbName, $dbCharset） {if （self::$_instance === null） { self::$_instance = new self（$dbHost, $dbUser, $dbPasswd, $dbName, $dbCharset）;}return self::$_instance; }/*** Query 查询** @param String $strSql SQL语句* @param String $queryMode 查询方式（All or Row）* @param Boolean $debug* @return Array*/ public function query（$strSql, $queryMode = "All", $debug = false） {if （$debug === true） $this->debug（$strSql）;$recordset = $this->dbh->query（$strSql）;$this->getPDOError（）;if （$recordset） { $recordset->setFetchMode（PDO::FETCH_ASSOC）; if （$queryMode == "All"） {$result = $recordset->fetchAll（）; } elseif （$queryMode == "Row"） {$result = $recordset->fetch（）; }} else { $result = null;}return $result; }/*** Update 更新** @param String $table 表名* @param Array $arrayDataValue 字段与值* @param String $where 条件* @param Boolean $debug* @return Int*/ public function update（$table, $arrayDataValue, $where = "", $debug = false） {$this->checkFields（$table, $arrayDataValue）;if （$where） { $strSql = ""; foreach （$arrayDataValue as $key => $value） {$strSql .= ", `$key`="$value""; } $strSql = substr（$strSql, 1）; $strSql = "UPDATE `$table` SET $strSql WHERE $where";} else { $strSql = "REPLACE INTO `$table` （`".implode（"`,`", array_keys（$arrayDataValue））."`） VALUES （"".implode（"","", $arrayDataValue）.""）";}if （$debug === true） $this->debug（$strSql）;$result = $this->dbh->exec（$strSql）;$this->getPDOError（）;return $result; }/*** Insert 插入** @param String $table 表名* @param Array $arrayDataValue 字段与值* @param Boolean $debug* @return Int*/ public function insert（$table, $arrayDataValue, $debug = false） {$this->checkFields（$table, $arrayDataValue）;$strSql = "INSERT INTO `$table` （`".implode（"`,`", array_keys（$arrayDataValue））."`） VALUES （"".implode（"","", $arrayDataValue）.""）";if （$debug === true） $this->debug（$strSql）;$result = $this->dbh->exec（$strSql）;$this->getPDOError（）;return $result; }/*** Replace 覆盖方式插入** @param String $table 表名* @param Array $arrayDataValue 字段与值* @param Boolean $debug* @return Int*/ public function replace（$table, $arrayDataValue, $debug = false） {$this->checkFields（$table, $arrayDataValue）;$strSql = "REPLACE INTO `$table`（`".implode（"`,`", array_keys（$arrayDataValue））."`） VALUES （"".implode（"","", $arrayDataValue）.""）";if （$debug === true） $this->debug（$strSql）;$result = $this->dbh->exec（$strSql）;$this->getPDOError（）;return $result; }/*** Delete 删除** @param String $table 表名* @param String $where 条件* @param Boolean $debug* @return Int*/ public function delete（$table, $where = "", $debug = false） {if （$where == ""） { $this->outputError（""WHERE" is Null"）;} else { $strSql = "DELETE FROM `$table` WHERE $where"; if （$debug === true） $this->debug（$strSql）; $result = $this->dbh->exec（$strSql）; $this->getPDOError（）; return $result;} }/*** execSql 执行SQL语句** @param String $strSql* @param Boolean $debug* @return Int*/ public function execSql（$strSql, $debug = false） {if （$debug === true） $this->debug（$strSql）;$result = $this->dbh->exec（$strSql）;$this->getPDOError（）;return $result; }/*** 获取字段最大值* * @param string $table 表名* @param string $field_name 字段名* @param string $where 条件*/ public function getMaxValue（$table, $field_name, $where = "", $debug = false） {$strSql = "SELECT MAX（".$field_name."） AS MAX_VALUE FROM $table";if （$where ！= ""） $strSql .= " WHERE $where";if （$debug === true） $this->debug（$strSql）;$arrTemp = $this->query（$strSql, "Row"）;$maxValue = $arrTemp["MAX_VALUE"];if （$maxValue == "" || $maxValue == null） { $maxValue = 0;}return $maxValue; }/*** 获取指定列的数量* * @param string $table* @param string $field_name* @param string $where* @param bool $debug* @return int*/ public function getCount（$table, $field_name, $where = "", $debug = false） {$strSql = "SELECT COUNT（$field_name） AS NUM FROM $table";if （$where ！= ""） $strSql .= " WHERE $where";if （$debug === true） $this->debug（$strSql）;$arrTemp = $this->query（$strSql, "Row"）;return $arrTemp["NUM"]; }/*** 获取表引擎* * @param String $dbName 库名* @param String $tableName 表名* @param Boolean $debug* @return String*/ public function getTableEngine（$dbName, $tableName） {$strSql = "SHOW TABLE STATUS FROM $dbName WHERE Name="".$tableName.""";$arrayTableInfo = $this->query（$strSql）;$this->getPDOError（）;return $arrayTableInfo[0]["Engine"]; }/*** beginTransaction 事务开始*/ private function beginTransaction（） {$this->dbh->beginTransaction（）; }/*** commit 事务提交*/ private function commit（） {$this->dbh->commit（）; }/*** rollback 事务回滚*/ private function rollback（） {$this->dbh->rollback（）; }/*** transaction 通过事务处理多条SQL语句* 调用前需通过getTableEngine判断表引擎是否支持事务** @param array $arraySql* @return Boolean*/ public function execTransaction（$arraySql） {$retval = 1;$this->beginTransaction（）;foreach （$arraySql as $strSql） { if （$this->execSql（$strSql） == 0） $retval = 0;}if （$retval == 0） { $this->rollback（）; return false;} else { $this->commit（）; return true;} }/*** checkFields 检查指定字段是否在指定数据表中存在** @param String $table* @param array $arrayField*/ private function checkFields（$table, $arrayFields） {$fields = $this->getFields（$table）;foreach （$arrayFields as $key => $value） { if （！in_array（$key, $fields）） {$this->outputError（"Unknown column `$key` in field list."）; }} }/*** getFields 获取指定数据表中的全部字段名** @param String $table 表名* @return array*/ private function getFields（$table） {$fields = array（）;$recordset = $this->dbh->query（"SHOW COLUMNS FROM $table"）;$this->getPDOError（）;$recordset->setFetchMode（PDO::FETCH_ASSOC）;$result = $recordset->fetchAll（）;foreach （$result as $rows） { $fields[] = $rows["Field"];}return $fields; }/*** getPDOError 捕获PDO错误信息*/ private function getPDOError（） {if （$this->dbh->errorCode（） ！= "00000"） { $arrayError = $this->dbh->errorInfo（）; $this->outputError（$arrayError[2]）;} }/*** debug* * @param mixed $debuginfo*/ private function debug（$debuginfo） {var_dump（$debuginfo）;exit（）; }/*** 输出错误信息* * @param String $strErrMsg*/ private function outputError（$strErrMsg） {throw new Exception（"MySQL Error: ".$strErrMsg）; }/*** destruct 关闭数据库连接*/ public function destruct（） {$this->dbh = null; }}?>

四、调用方法：

<?phprequire "MyPDO.class.php";$db = MyPDO::getInstance（"localhost", "root", "123456", "test", "utf8"）; //do something... $db->destruct（）;?>

五、总结

以上就是PHP基于单例模式编写PDO类的全部内容，希望对大家学习或者使用PHP能有所帮助，如果有疑问大家可以留言交流，谢谢大家对脚本之家的支持。