php手写一个pdo数据库操作类(附增删改查实例)

数据库操作类的优点 优点可以说是非常多了,常见的优点就是便于维护、复用、高效、安全、易扩展。例如PDO支持的数据库类型是非常多的,与mysqli不同的就是,PDO还支持其他数据库,一套写法多种数据库的匹配,而mysqli仅仅是支持mysql。
代码 Db.php

'mysql', // 数据库类型 'host'=>'localhost', // 主机名称 'port'=>'3306', // 默认端口 'user'=>'root', // 用户名 'pass'=>'root', // 密码 'charset'=>'utf8', // 默认字符集 'dbname'=>'edu', // 默认数据库 ]; // 新增主键id public $insertId = null; // 受影响的记录 public $num = 0; // 单例模式,本类的实例 private static $instance = null; // 数据库的连接 private $conn = null; /** * Db构造方法 * 私有化以防止外部实例化 */ private function __construct($params=[]) { // 初始化连接参数 $this->dbConfig = array_merge($this->dbConfig,$params); // 连接数据库 $this->connect(); }/** * 禁止外部克隆该实例 */ private function __clone() { // TODO:Implement __clone() method. }/** * 获取当前类的单一实例 */ public static function getInstance($params=[]) { if (!self::$instance instanceof self) { self::$instance = new self($params); } return self::$instance; }private function connect() { try{ // 配置数据源DSN $dsn = "{$this->dbConfig['db']}:host={$this->dbConfig['host']}; port={$this->dbConfig['port']}; dbname={$this->dbConfig['dbname']}; charset={$this->dbConfig['charset']}"; // 创建PDO对象 $this->conn = new PDO($dsn,$this->dbConfig['user'],$this->dbConfig['pass']); // 设置客户端字符集 $this->conn->query("SET NAMES {$this->dbConfig['charset']}"); }catch (PDOException $e){ die('数据库连接失败'.$e->getMessage()); } }/** * 完成数据表的操作:CURD */public function exec($sql) { $num = $this->conn->exec($sql); // 如果有受影响的记录 if($num > 0){ // 如果是新增操作,初始化新增主键id属性 if(null !==$this->conn->lastInsertId()){ $this->insertId = $this->conn->lastInsertId(); } $this->num = $num; // 返回受影响的记录 }else{ $error = $this->conn->errorInfo(); // 获取最后操作错误信息的数组 var_dump($error); } }// 获取单条查询结果 public function fetch($sql) { return $this->conn->query($sql)->fetch(PDO::FETCH_ASSOC); }// 获取多条查询结果 public function fetchAll($sql) { return $this->conn->query($sql)->fetchAll(PDO::FETCH_ASSOC); } } ?>

调用 Demo.php
exec($sql); // echo '成功插入了'.$db->num.'条记录,主键id是'.$db->insertId; // 删除操作 // $sql = "DELETE FROM student WHERE id='4'"; // $db->exec($sql); // echo '成功删除了'.$db->num.'条记录'; // 更新操作 // $sql = "UPDATE student SET grade='1199' WHERE id='1'"; // $db->exec($sql); // echo '成功更新了'.$db->num.'条记录'; // 查询单条操作 // $sql = "SELECT id,name,email,grade FROM student WHERE grade < '60'"; // $row = $db->fetch($sql); // var_dump($row); // // 查询多条操作 // $sql = "SELECT id,name,email,grade FROM student WHERE grade > '80'"; // $rows = $db->fetchAll($sql); // var_dump($rows); ?>

数据库表格结构 php手写一个pdo数据库操作类(附增删改查实例)
文章图片

SQL 【php手写一个pdo数据库操作类(附增删改查实例)】全选下面的SQL语句粘贴至数据库管理工具的SQL执行框进行执行即可快速创建测试数据库。
-- phpMyAdmin SQL Dump -- version 4.8.5 -- https://www.phpmyadmin.net/ -- -- 主机: localhost -- 生成日期: 2022-08-08 10:46:35 -- 服务器版本: 5.7.26 -- PHP 版本: 7.3.4SET SQL_MODE = "NO_AUTO_VALUE_ON_ZERO"; SET AUTOCOMMIT = 0; START TRANSACTION; SET time_zone = "+00:00"; /*!40101 SET @OLD_CHARACTER_SET_CLIENT=@@CHARACTER_SET_CLIENT */; /*!40101 SET @OLD_CHARACTER_SET_RESULTS=@@CHARACTER_SET_RESULTS */; /*!40101 SET @OLD_COLLATION_CONNECTION=@@COLLATION_CONNECTION */; /*!40101 SET NAMES utf8mb4 */; -- -- 数据库: `edu` ---- ---------------------------------------------------------- -- 表的结构 `student` --CREATE TABLE `student` ( `id` int(11) NOT NULL, `name` varchar(32) COLLATE utf8_unicode_ci NOT NULL, `email` text COLLATE utf8_unicode_ci NOT NULL, `grade` varchar(32) COLLATE utf8_unicode_ci NOT NULL, `course` varchar(32) COLLATE utf8_unicode_ci NOT NULL ) ENGINE=MyISAM DEFAULT CHARSET=utf8 COLLATE=utf8_unicode_ci; -- -- 转存表中的数据 `student` --INSERT INTO `student` (`id`, `name`, `email`, `grade`, `course`) VALUES (1, '王兴', 'meituan@qq.com', '80', 'ruby'), (2, '黄峥', 'pdd@qq.com', '68', 'mysql'), (6, '李彦宏', 'baidu@qq.com', '95', 'python'), (5, '马云', 'mayun@qq.com', '88', 'php'), (7, '刘强东', 'jd@qq.com', '76', 'C++'), (8, '马化腾', '10001@qq.com', '59', 'java'), (9, '张一鸣', 'ByteDance@qq.com', '77', 'golang'); -- -- 转储表的索引 ---- -- 表的索引 `student` -- ALTER TABLE `student` ADD PRIMARY KEY (`id`); -- -- 在导出的表使用AUTO_INCREMENT ---- -- 使用表AUTO_INCREMENT `student` -- ALTER TABLE `student` MODIFY `id` int(11) NOT NULL AUTO_INCREMENT, AUTO_INCREMENT=10; COMMIT; /*!40101 SET CHARACTER_SET_CLIENT=@OLD_CHARACTER_SET_CLIENT */; /*!40101 SET CHARACTER_SET_RESULTS=@OLD_CHARACTER_SET_RESULTS */; /*!40101 SET COLLATION_CONNECTION=@OLD_COLLATION_CONNECTION */;

作者 TANKING

    推荐阅读