前言

PDO扩展为PHP访问数据库定义了一个轻量级的、一致性的接口，它提供了一个数据访问抽象层，这样，无论使用什么数据库，都可以通过一致的函数执行查询和获取数据。PDO随PHP5.1发行，在PHP5.0的PECL扩展中也可以使用。

我个人理解：PDO是一个抽象类，为我们提供访问数据的接口方法，下面这篇将给大家介绍关于PHP如何利用PDO封装简单易用的DB类，下面话不多说，来一起看看详细的介绍：

使用

创建测试库和表

create database db_test;
CREATE TABLE `user` (
 `id` int(10) unsigned NOT NULL AUTO_INCREMENT,
 `name` char(11) NOT NULL,
 `created_at` int(10) unsigned NOT NULL,
 PRIMARY KEY (`uid`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8;
INSERT INTO `user` VALUES ('1', 'wang', '1501109027');
INSERT INTO `user` VALUES ('2', 'meng', '1501109026');
INSERT INTO `user` VALUES ('3', 'liu', '1501009027');
INSERT INTO `user` VALUES ('4', 'yuan', '1500109027');

代码测试

require __DIR__ . '/DB.php';
$db = new DB();
$db->__setup([
 'dsn'=>'mysql:dbname=db_test;host=localhost',
 'username'=>'root',
 'password'=>'******',
 'charset'=>'utf8'
]);


$user = $db->fetch('SELECT * FROM user where id = :id', ['id' => 1]);
echo $user['name'];
echo "\n";

$insertId = $db->insert('user', ['name' => 'salamander', 'created_at' => time()]);
echo "insert user {$insertId}\n";
$users = $db->fetchAll('SELECT * FROM user');
foreach ($users as $item) {
 echo "user {$item['id']} is {$item['name']} \n";
} 

运行结果

DB工具类

<?php
/**
 * User: Salamander
 * Date: 2016/9/2
 * Time: 9:16
 */

class DB
{
 private $dsn;
 private $sth;
 private $dbh;
 private $user;
 private $charset;
 private $password;

 public $lastSQL = '';

 public function __setup($config = array())
 {
  $this->dsn = $config['dsn'];
  $this->user = $config['username'];
  $this->password = $config['password'];
  $this->charset = $config['charset'];
  $this->connect();
 }

 private function connect()
 {
  if(!$this->dbh){
   $options = array(
    \PDO::MYSQL_ATTR_INIT_COMMAND => 'SET NAMES ' . $this->charset,
   );
   $this->dbh = new \PDO($this->dsn, $this->user,
    $this->password, $options);
  }
 }

 public function beginTransaction()
 {
  return $this->dbh->beginTransaction();
 }

 public function inTransaction()
 {
  return $this->dbh->inTransaction();
 }

 public function rollBack()
 {
  return $this->dbh->rollBack();
 }

 public function commit()
 {
  return $this->dbh->commit();
 }

 function watchException($execute_state)
 {
  if(!$execute_state){
   throw new MySQLException("SQL: {$this->lastSQL}\n".$this->sth->errorInfo()[2], intval($this->sth->errorCode()));
  }
 }

 public function fetchAll($sql, $parameters=[])
 {
  $result = [];
  $this->lastSQL = $sql;
  $this->sth = $this->dbh->prepare($sql);
  $this->watchException($this->sth->execute($parameters));
  while($result[] = $this->sth->fetch(\PDO::FETCH_ASSOC)){ }
  array_pop($result);
  return $result;
 }

 public function fetchColumnAll($sql, $parameters=[], $position=0)
 {
  $result = [];
  $this->lastSQL = $sql;
  $this->sth = $this->dbh->prepare($sql);
  $this->watchException($this->sth->execute($parameters));
  while($result[] = $this->sth->fetch(\PDO::FETCH_COLUMN, $position)){ }
  array_pop($result);
  return $result;
 }

 public function exists($sql, $parameters=[])
 {
  $this->lastSQL = $sql;
  $data = $this->fetch($sql, $parameters);
  return !empty($data);
 }

 public function query($sql, $parameters=[])
 {
  $this->lastSQL = $sql;
  $this->sth = $this->dbh->prepare($sql);
  $this->watchException($this->sth->execute($parameters));
  return $this->sth->rowCount();
 }

 public function fetch($sql, $parameters=[], $type=\PDO::FETCH_ASSOC)
 {
  $this->lastSQL = $sql;
  $this->sth = $this->dbh->prepare($sql);
  $this->watchException($this->sth->execute($parameters));
  return $this->sth->fetch($type);
 }

 public function fetchColumn($sql, $parameters=[], $position=0)
 {
  $this->lastSQL = $sql;
  $this->sth = $this->dbh->prepare($sql);
  $this->watchException($this->sth->execute($parameters));
  return $this->sth->fetch(\PDO::FETCH_COLUMN, $position);
 }

 public function update($table, $parameters=[], $condition=[])
 {
  $table = $this->format_table_name($table);
  $sql = "UPDATE $table SET ";
  $fields = [];
  $pdo_parameters = [];
  foreach ( $parameters as $field=>$value){
   $fields[] = '`'.$field.'`=:field_'.$field;
   $pdo_parameters['field_'.$field] = $value;
  }
  $sql .= implode(',', $fields);
  $fields = [];
  $where = '';
  if(is_string($condition)) {
   $where = $condition;
  } else if(is_array($condition)) {
   foreach($condition as $field=>$value){
    $parameters[$field] = $value;
    $fields[] = '`'.$field.'`=:condition_'.$field;
    $pdo_parameters['condition_'.$field] = $value;
   }
   $where = implode(' AND ', $fields);
  }
  if(!empty($where)) {
   $sql .= ' WHERE '.$where;
  }
  return $this->query($sql, $pdo_parameters);
 }

 public function insert($table, $parameters=[])
 {
  $table = $this->format_table_name($table);
  $sql = "INSERT INTO $table";
  $fields = [];
  $placeholder = [];
  foreach ( $parameters as $field=>$value){
   $placeholder[] = ':'.$field;
   $fields[] = '`'.$field.'`';
  }
  $sql .= '('.implode(",", $fields).') VALUES ('.implode(",", $placeholder).')';

  $this->lastSQL = $sql;
  $this->sth = $this->dbh->prepare($sql);
  $this->watchException($this->sth->execute($parameters));
  $id = $this->dbh->lastInsertId();
  if(empty($id)) {
   return $this->sth->rowCount();
  } else {
   return $id;
  }
 }

 public function errorInfo()
 {
  return $this->sth->errorInfo();
 }

 protected function format_table_name($table)
 {
  $parts = explode(".", $table, 2);

  if(count($parts) > 1) {
   $table = $parts[0].".`{$parts[1]}`";
  } else {
   $table = "`$table`";
  }
  return $table;
 }

 function errorCode()
 {
  return $this->sth->errorCode();
 }
}

class MySQLException extends \Exception { }

框架中使用建议

在框架中使用DB类,用单例模式或者用依赖容器来管理较好。

总结

以上就是这篇文章的全部内容了，希望本文的内容对大家的学习或者工作能带来一定的帮助，如果有疑问大家可以留言交流，谢谢大家对的支持

# php  # pdo封装类  # 封装好的db类  # pdo封装  # php封装的pdo数据库操作工具类与用法示例  # PHP封装的数据库模型Model类完整示例【基于PDO】  # PHP封装的PDO数据库操作类实例  # php基于PDO实现功能强大的MYSQL封装类实例  # php封装pdo实例以及pdo长连接的优缺点总结  # 是一个  # 可以通过  # 较好  # 可以使用  # 这篇文章  # 中也  # 这篇  # 谢谢大家  # 多说  # 易用  # 将给  # 抽象类  # 有疑问  # liu  # yuan  # require  # meng  # VALUES  # wang 

相关栏目： 【 网站优化151355 】 【 网络推广146373 】 【 网络技术251813 】 【 AI营销90571 】

相关推荐： Laravel怎么进行数据库事务处理_Laravel DB Facade事务操作确保数据一致性  制作无缝贴图网站有哪些,3dmax无缝贴图怎么调？  Laravel怎么进行浏览器测试_Laravel Dusk自动化浏览器测试入门  Python高阶函数应用_函数作为参数说明【指导】  php打包exe后无法访问网络共享_共享权限设置方法【教程】  如何为不同团队 ID 动态生成多个独立按钮  桂林网站制作公司有哪些,桂林马拉松怎么报名？  惠州网站建设制作推广,惠州市华视达文化传媒有限公司怎么样？  uc浏览器二维码扫描入口_uc浏览器扫码功能使用地址  如何在万网ECS上快速搭建专属网站？  Laravel怎么清理缓存_Laravel optimize clear命令详解  Laravel如何实现本地化和多语言支持？（i18n教程）  北京专业网站制作设计师招聘,北京白云观官方网站？  Laravel如何集成Inertia.js与Vue/React？（安装配置）  php读取心率传感器数据怎么弄_php获取max30100的心率值【指南】  Laravel如何实现API版本控制_Laravel API版本化路由设计策略  如何确认建站备案号应放置的具体位置？  如何用IIS7快速搭建并优化网站站点？  HTML透明颜色代码在Angular里怎么设置_Angular透明颜色使用指南【详解】  深圳网站制作的公司有哪些,dido官方网站？  Android自定义listview布局实现上拉加载下拉刷新功能  Laravel Fortify是什么，和Jetstream有什么关系  Laravel如何实现图片防盗链功能_Laravel中间件验证Referer来源请求【方案】  Gemini手机端怎么发图片_Gemini手机端发图方法【步骤】  javascript事件捕获机制【深入分析IE和DOM中的事件模型】  UC浏览器如何切换小说阅读源_UC浏览器阅读源切换【方法】  微信小程序 HTTPS报错整理常见问题及解决方案  Laravel Pest测试框架怎么用_从PHPUnit转向Pest的Laravel测试教程  黑客如何通过漏洞一步步攻陷网站服务器？  如何用VPS主机快速搭建个人网站？  如何用AI一键生成爆款短视频文案？小红书AI文案写作指令【教程】  JavaScript如何实现继承_有哪些常用方法  如何安全更换建站之星模板并保留数据？  html5怎么画眼睛_HT5用Canvas或SVG画眼球瞳孔加JS控制动态【绘制】  谷歌浏览器如何更改浏览器主题 Google Chrome主题设置教程  UC浏览器如何设置启动页 UC浏览器启动页设置方法  Linux系统运维自动化项目教程_Ansible批量管理实战  用v-html解决Vue.js渲染中html标签不被解析的问题  Win11怎么关闭资讯和兴趣_Windows11任务栏设置隐藏小组件  如何基于PHP生成高效IDC网络公司建站源码？  微信小程序 闭包写法详细介绍  Laravel如何实现文件上传和存储？（本地与S3配置）  Laravel如何使用Blade组件和插槽？（Component代码示例）  js实现获取鼠标当前的位置  Laravel怎么导出Excel文件_Laravel Excel插件使用教程  大同网页,大同瑞慈医院官网？  如何用腾讯建站主机快速创建免费网站？  网站制作免费,什么网站能看正片电影？  Laravel怎么配置.env环境变量_Laravel生产环境敏感数据保护与读取【方法】  百度输入法ai组件怎么删除 百度输入法ai组件移除工具