使用单例模式设计PDO数据操作类
2024-10-21 12:45:13
<?php
/**
* MyPDO
* @author LHL <506698615@qq.com>
* @date 2016.04.20
*/
class MyPDO{
protected static $_instance = null;
protected $dbName = '';
protected $dsn;
protected $dbh; /**
* 构造函数
*/
private function __construct($dbhost,$dbname,$dbUser,$dbPasswd,$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,$dbname,$dbUser,$dbPasswd,$dbCharset){
if(self::$_instance == null){
self::$_instance = new self($dbhost,$dbname,$dbUser,$dbPasswd,$dbCharset);
}
return self::$_instance;
}
/*
* Query 查询
* @param String $strSql SQL查询语句
* @param String $queryModel 查询方式(All or Row)
* @param Boolen $debug
* return Array
*/
public function query($strSql,$queryModel='All',$debug=false){
if($debug === true) $this->debug($strSql);
$recordset = $this->dbh->query($strSql);
$this->getPDOError();
if($recordset){
$recordset->setFetchMode(PDO::FETCH_ASSOC);
if($queryModel == 'All'){
$result = $recordset->fetchAll();
}elseif($queryModel == '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 = true)
{
$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);
}
/**
* 抛出错误信息
* @param string $strErrMsg
*/
private function outputError($strErrMsg){
throw new Exception('MySQL Error:'.$strErrMsg);
}
/**
* 关闭数据库连接
*/
public function destruct(){
$this->dbh = null;
}
}
$db = MyPDO::getInstance('localhost','test','root','','utf8');
$sql = "select * from article";
$result = $db->query($sql);
echo '<pre>';
print_r($result);
echo '</pre>';
?>
最新文章
- 周末发现一个BUG,时有时无,一出程序就崩溃,郁闷了好久,终于跟出来来了,记之,提醒自己今后一定规范编写,只要规范,绝对不会出问题
- JAXB最佳实践
- win8访问win7中的共享文件夹 映射网络驱动器
- iframe自适应高度js
- k8s入门系列之扩展组件(一)DNS安装篇
- Android学习一：文件操作
- (String)将一个String里面的单词反转
- 学习使用：before和：after伪元素
- Hadoop学习过程知识积累
- 使用 T4 文本模板生成设计时代码
- hadoop实例---多表关联
- 【知识分享】UIButton setTitle 设置为空 失效
- Linux命令行文本处理工具
- Ubuntu设置为命令行登录
- 调停者(Mediator)模式
- 输出一个对象，会默认执行toString()方法
- JSPatch实现原理详解
- 介绍一个基于jQuery的Cookie操作插件
- Qt多线程编程中的对象线程与函数执行线程
- Win10搜索不能用
热门文章
- Linux下批量替换文件内容和文件名（转）
- oracle function dtrace
- DevExpress打印功能介绍 z
- UnicodeEncodeError: 'ascii' codec can't encode character u'\u5728' in position 1
- python为不同的对象如何分配内存的小知识
- WM_SETFOCUS和WM_KILLFOCUS、WM_GETDLGCODE
- 使用TypeDescriptor给类动态添加Attribute【转】
- LINUX下GDB反汇编和调试
- 广告制胜无它，顺应人性尔——leo鉴书63
- CrtmpServer 接收推送视频流 注册流基本流程