时时商务社区

标题: PHP基于单例模式编写PDO类的方法 [打印本页]

作者: 阿情 时间: 2018-2-14 05:33

         一、单例模式简介
简单的说，一个对象（在学习设计模式之前，需要比较了解面向对象思想）只负责一个特定的任务；
二、为什么要使用PHP单例模式？
   1、php的应用主要在于数据库应用, 所以一个应用中会存在大量的数据库操作, 使用单例模式, 则可以避免大量的new 操作消耗的资源。
   2、如果系统中需要有一个类来全局控制某些配置信息, 那么使用单例模式可以很方便的实现. 这个可以参看ZF的FrontController部分。
   3、在一次页面请求中, 便于进行调试, 因为所有的代码(例如数据库操作类db)都集中在一个类中, 我们可以在类中设置钩子, 输出日志，从而避免到处var_dump, echo。
三、PHP基于单例模式编写PDO类的示例代码
代码如下：
* @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;
}
}
?>
四、调用方法：
destruct();
?>
五、总结
以上就是PHP基于单例模式编写PDO类的全部内容，希望对大家学习或者使用PHP能有所帮助，如果有疑问大家可以留言交流，谢谢大家对脚本之家的支持。


您可能感兴趣的文章:

全新的PDO数据库操作类php版（仅适用Mysql）

PHP数据库链接类(PDO+Access)实例分享

PHP实现PDO的mysql数据库操作类

详解PHP中的PDO类

PHP的PDO常用类库实例分析

简单的pgsql pdo php操作类实现代码

php基于PDO实现功能强大的MYSQL封装类实例

PHP封装的PDO数据库操作类实例

PHP基于PDO实现的SQLite操作类【包含增删改查及事务等操作】

php实现的pdo公共类定义与用法示例

欢迎光临时时商务社区 (http://bbs.4435.cn/)