|
/** * MyPDO */ 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 查詢方式（全部或行）
* @param Boolean ## 公共函數查詢($strSql, $queryMode ='All', $debug = false)
{ # strSql); $recordset = $this->dbh->query($strSql);# { $recordset->setFetchMode(PDO::FETCH_ASSOC); $result = $recordset->fetchAll (); } elseif ($queryMode == 'Row') { } # } else { $result = null;# ## }
# /**
* Update 更新
*
* @param String $table # * @param String $where 條件
* @param Boolean $debug
*/
公用函數 update($table, $arrayDataValue, $where = '', $debug = false) ## #$ this->checkFields($table, $arrayDataValue); if ($where) { tags.php/foreach/\"" target="\"_blank\"">foreach; ($arrayDataValue as $key => $value) { ## $ strSql = substr($strSql, 1); 更新`$table` SET $strSql WHERE $where」; } else { array_keys($arrayDataValue))."`) VALUES ('".implode("','",$arrayDataValue)."')"; }## > == true) $this->debug($strSql); $result = $this->dbh->exec($strSql);# return $result; } #
/**
* Insert 插入
*
* @param String $table # * @param Boolean $debug
# * @return Int
# */
public function insert($table, $arrayDataValue, $debug = false)
{ ($table, $arrayDataValue);
$strSql = "INSERT INTO `$table` (`".implode('`,`', array_keys($arrayDataValue))."`) VALUES (' " .implode("','", $arrayDataValue)."')";
if ($debug === true) $ result = $this->dbh->exec($strSql);
$this->getPDOError();
##
/**
* Replace 覆寫方式插入
# *
* @param String $table 表名 * @param Boolean $debug
* @return Int
# */
# 公用函數取代（$table，$arrayDataValue，$debug = false） # # ## $this->checkFields($table, $arrayDataValue); $strSql = "替換為`$table`(`".implode('`,`', array_keys($ arrayDataValue))."` ) VALUES ('".implode("','", $arrayDataValue)."')"; if ($debug === true) $$0 # $result = $this->dbh->exec($strSql);
$this->getPDOError(
如果如果如果如果; } /** * Delete 刪除 * * @param String * @param Boolean $debug * @return Int */ 公用函數刪除($table, $where ='', $debug = false) { if ($where == '') { } else { $strSql = "DELETE FROM `$table` WHERE $where"; );
$result = $this->dbh->exec($strSql);
return $result;
}
}
/**
# * execSql 執行語句 # * execSql 執行語句#
* @param String $strSql
* @param Boolean $debug
Sql($ strSql, $debug = false)
{
if ($debug === ->dbh->exec($strSql);
$this->getPDOError();
# /** * 取得欄位最大值 * * @param string $table ## * @param string $where 條件 */# 公用函數getMaxValue($table, $field_name, $where ='', $debug = false)# { $strSql = "SELECT MAX(".$field_name.") AS MAX_VALUE FROM $table"; here "; if ($debug === true) $this->debug($strSql); ## $maxValue = $arrTemp["MAX_VALUE"]; if ($max ==) $maxValue = 0; } 返回$maxValue; }# ($table, $field_name, $where = '', $debug = false) { # if ($where != '') $strSql .= " WHERE $where"; # $arrTemp = $this->query($strSql, 'Row');
return ## /** * 取得指定列的數量 * * @param string $ @param string $where * @param bool $debug * @return int */
公用函數getTableEngine($dbName, $tableName)
{ ## $strSql = 「顯示表狀態來自於顯示表狀態來自於「顯示表狀態$dbName WHERE Name='”。$tableName。“'”;
$arrayTableInfo = $this->query($strSql);
$this-) # } /** * beginTransaction 事務開始 */ 私有函數beginTransaction( $this->dbh->beginTransaction();## }
## /**
* commit 事務提交
*/ ## # 私有函數提交()# 私有函數提交()# 私有函數提交()# 私有函數提交()# 私有函數提交()# 私有函數提交() { $this->dbh->commit();## }
# } 私有函數 rollback() { $this->dbh->rollback(); # /**
* rollback 事務回溯
*/
# 公用函數 execTransaction($arraySql)
{## ## this->beginTransaction();
foreach ($arraySql as $strSql) {
if # } if ($retval == 0) { } else { $this->commit(); ## /** * transaction 透過事務處理多條SQL語句 * 調用前需透過getTableEngine判斷表引擎是否支援事務## ## #para*#para> $arraySql * @return Boolean */ {## $fields = $this-# $fields = $this-> ;getFiel#($); ## foreach ($arrayFields as $key =>; $value) {
if (!in_array($key, $fields)) {
);
}
}
# }
私有函數 getFields($table) ## { $fields = $table 中的欄位"); $this->getPDOError(); $ recordset->fetchAll(); foreach ($result as $rows) {# } return $fields; } / {
if ($this->dbh->errorCode() != '00000') {##o##11005 ();
$this->outputError($arrayError[2]);
}
}
/**
* getPDOError 擷取PDO錯誤訊息
*/
。 }
/**
* 調試
*
* @param 混合$debuginfo
#111 */
私有函數outputError($strErrMsg Exception('MySQL 錯誤: '.$strErrMsg); ## } # /** * 輸出錯誤訊息## *
* @param String $strErrMsg
# /**
* destruct 關閉資料庫連線
{
$this->dbh = null;
}
}##gt;#？
#
呼叫方法：
|
1
2
# 3
4
5
6
|
#
require 'MyPDO.class。 ';
$db = MyPDO::getInstance('localhost', 'root', '123456', 'test', 'utf8');
$db->query (" select count(*) frome 表");
$db ->destruct();
?>
|
# |
