PHP基于單例模式編寫(xiě)PDO類的方法
更新時(shí)間：2016年09月13日 11:57:07 投稿：daisy
這篇文章的代碼是用此前一個(gè)名為MyPDO的類改寫(xiě)的，引入了單例模式來(lái)保證在全局調(diào)用中不會(huì)重復(fù)實(shí)例化這個(gè)類，降低系統(tǒng)資源的浪費(fèi)。有需要的朋友們可以參考借鑒，下面來(lái)一起看看吧。
一、單例模式簡(jiǎn)介
簡(jiǎn)單的說(shuō)，一個(gè)對(duì)象（在學(xué)習(xí)設(shè)計(jì)模式之前，需要比較了解面向?qū)ο笏枷耄┲回?fù)責(zé)一個(gè)特定的任務(wù)；
二、為什么要使用PHP單例模式？
1、php的應(yīng)用主要在于數(shù)據(jù)庫(kù)應(yīng)用, 所以一個(gè)應(yīng)用中會(huì)存在大量的數(shù)據(jù)庫(kù)操作, 使用單例模式, 則可以避免大量的new 操作消耗的資源。
2、如果系統(tǒng)中需要有一個(gè)類來(lái)全局控制某些配置信息, 那么使用單例模式可以很方便的實(shí)現(xiàn). 這個(gè)可以參看ZF的FrontController部分。
3、在一次頁(yè)面請(qǐng)求中, 便于進(jìn)行調(diào)試, 因?yàn)樗械拇a(例如數(shù)據(jù)庫(kù)操作類db)都集中在一個(gè)類中, 我們可以在類中設(shè)置鉤子, 輸出日志，從而避免到處var_dump, echo。
三、PHP基于單例模式編寫(xiě)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;
/**
* 構(gòu)造
*
* @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語(yǔ)句
* @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 執(zhí)行SQL語(yǔ)句
*
* @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;
}
/**
* 獲取指定列的數(shù)量
*
* @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 庫(kù)名
* @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 事務(wù)開(kāi)始
*/
private function beginTransaction()
{
$this->dbh->beginTransaction();
}
/**
* commit 事務(wù)提交
*/
private function commit()
{
$this->dbh->commit();
}
/**
* rollback 事務(wù)回滾
*/
private function rollback()
{
$this->dbh->rollback();
}
/**
* transaction 通過(guò)事務(wù)處理多條SQL語(yǔ)句
* 調(diào)用前需通過(guò)getTableEngine判斷表引擎是否支持事務(wù)
*
* @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 檢查指定字段是否在指定數(shù)據(jù)表中存在
*
* @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 獲取指定數(shù)據(jù)表中的全部字段名
*
* @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錯(cuò)誤信息
*/
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();
}
/**
* 輸出錯(cuò)誤信息
*
* @param String $strErrMsg
*/
private function outputError($strErrMsg)
{
throw new Exception('MySQL Error: '.$strErrMsg);
}
/**
* destruct 關(guān)閉數(shù)據(jù)庫(kù)連接
*/
public function destruct()
{
$this->dbh = null;
}
}
?>
四、調(diào)用方法：
<?php
require 'MyPDO.class.php';
$db = MyPDO::getInstance('localhost', 'root', '123456', 'test', 'utf8');
//do something...
$db->destruct();
?>
五、總結(jié)
以上就是PHP基于單例模式編寫(xiě)PDO類的全部?jī)?nèi)容，希望對(duì)大家學(xué)習(xí)或者使用PHP能有所幫助，如果有疑問(wèn)大家可以留言交流，謝謝大家對(duì)腳本之家的支持。
您可能感興趣的文章:
- PHP單例模式數(shù)據(jù)庫(kù)連接類與頁(yè)面靜態(tài)化實(shí)現(xiàn)方法
- PHP中數(shù)據(jù)庫(kù)單例模式的實(shí)現(xiàn)代碼分享
- PHP基于單例模式實(shí)現(xiàn)的數(shù)據(jù)庫(kù)操作基類
- PHP單例模式應(yīng)用示例【多次連接數(shù)據(jù)庫(kù)只實(shí)例化一次】
- PHP實(shí)現(xiàn)單例模式最安全的做法
- php單例模式的簡(jiǎn)單實(shí)現(xiàn)方法
- php利用單例模式實(shí)現(xiàn)日志處理類庫(kù)
- PHP最常用的2種設(shè)計(jì)模式工廠模式和單例模式介紹
- PHP設(shè)計(jì)模式之工廠模式與單例模式
- PHP實(shí)現(xiàn)單例模式建立數(shù)據(jù)庫(kù)連接的方法分析
相關(guān)文章
這篇文章主要介紹了dedecms集成財(cái)付通支付接口的相關(guān)資料,需要的朋友可以參考下2014-12-12
PHP采用get獲取url漢字出現(xiàn)亂碼的解決方法
這篇文章主要介紹了PHP采用get獲取url漢字出現(xiàn)亂碼的解決方法,是很多PHP程序員都曾遇到的問(wèn)題,非常具有實(shí)用價(jià)值,需要的朋友可以參考下2014-11-11
php中通過(guò)代碼備份網(wǎng)站的實(shí)現(xiàn)代碼，很方面大家在線備份網(wǎng)站，需要的朋友可以參考下。2011-06-06
這篇文章主要介紹了PHP文件上傳處理方法,結(jié)合實(shí)例形式分析了php文件上傳操作中遇到的問(wèn)題與相關(guān)解決方法,需要的朋友可以參考下2016-10-10
PHP樹(shù)的深度編歷生成迷宮及A*自動(dòng)尋路算法實(shí)例分析
這篇文章主要介紹了PHP樹(shù)的深度編歷生成迷宮及A*自動(dòng)尋路算法,實(shí)例分析了php實(shí)現(xiàn)A*尋路算法的技巧,具有一定參考借鑒價(jià)值,需要的朋友可以參考下2015-03-03
php 獲取今日、昨日、上周、本月的起始時(shí)間戳和結(jié)束時(shí)間戳的方法
php 獲取今日、昨日、上周、本月的起始時(shí)間戳和結(jié)束時(shí)間戳的方法，主要使用到了 php 的時(shí)間函數(shù) mktime,下面首先還是直奔主題以示例說(shuō)明如何使用 mktime 獲取今日、昨日、上周、本月的起始時(shí)間戳和結(jié)束時(shí)間戳，然后在介紹一下 mktime 函數(shù)作用和用法2013-09-09
詳解WordPress開(kāi)發(fā)中g(shù)et_header()獲取頭部函數(shù)的用法
這篇文章主要介紹了詳解WordPress開(kāi)發(fā)中g(shù)et_header()獲取頭部的用法,get_header()函數(shù)在WordPress主題的制作中一定會(huì)用到,需要的朋友可以參考下2016-01-01
這篇文章主要為大家詳細(xì)介紹了php強(qiáng)制下載文件函數(shù)，具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下2016-08-08
PHP 過(guò)濾器用于驗(yàn)證和清理外部輸入。PHP 過(guò)濾器擴(kuò)展具有檢查用戶輸入所需的許多功能，旨在使數(shù)據(jù)驗(yàn)證更容易、更快2022-11-11
php數(shù)組函數(shù)序列之rsort() - 對(duì)數(shù)組的元素值進(jìn)行降序排序
rsort() 函數(shù)對(duì)數(shù)組的元素按照鍵值進(jìn)行逆向排序。與 arsort() 的功能基本相同。注釋：該函數(shù)為 array 中的單元賦予新的鍵名。這將刪除原有的鍵名而不僅是重新排序。2011-11-11