PHP开发笔记系列（一）-PDO使用

OStack程序员社区-中国程序员成长平台 › 门户 › 编程› PHP›PHP编程经验

原作者: [db:作者] 来自: [db:来源] 收藏邀请

之前一段时间，开始了php的研究，看了关于PDO的一些资料，发现不错，整理和总结一下，作为开发笔记，留待日后使用，《PHP开发笔记系列（一）-PDO使用》。

PDO是PHP Data Objects的简称，是一种数据库访问抽象层。PDO是用于多种数据库的一致接口。类比的说，PDO做的事情类似于JAVA中的持久层框架（Hibernate、OpenJPA）的功能，为异构数据库提供一个统一的编程接口，这样就不必再使用mysql_*、pg_*这样的函数，也不必再写自己的"GenericDAO"了。PDO在PHP5.1的时候一起发布，所以我们用的PHP5.2、PHP5.3都已经可以使用。

为了方便，我们使用MySQL5来做演示。

0. 建立实验环境数据库及相关表

Sql代码

CREATE TABLE `blog` (
`id` int(10) NOT NULL AUTO_INCREMENT,
`title` varchar(255) NOT NULL,
PRIMARY KEY (`id`)
) ENGINE=InnoDB AUTO_INCREMENT=16 DEFAULT CHARSET=latin1

1. 使用PDO访问数据库
通过PDO访问数据库的步骤是：a)指定dsn、username、password，b)通过#a中的设置构造PDO对象，代码如下：

Php代码

file:pdo-access.php
url:http://localhost:88/pdo/pdo-access.php
<?php
// 设置dsn、username、passwd
$dsn = 'mysql:host=localhost;dbname=pdotest';
$username = 'root';
$passwd = 'password';
// 构造PDO对象
try {
$dbh = new PDO($dsn, $username, $passwd);
echo 'connect to database successfully!';
} catch (Exception $e) {
echo 'Fail to connect to database!\n';
echo $e->getMessage();
}
?>

备注：DSN即Data Source Name-数据源名称，提供数据库的连接信息，包括三部分，PDO驱动名称（MySQL、SQLite、PostgreSQL等）、冒号和驱动特定的语法。但是一般情况下，我们都很难记住这些，可以下载个php manual查，也可以到php的官网查。

2. 使用Query方法查询数据
在#1的基础上，连接数据库成功后，构造SQL语句，调用query方法返回结构数组，通过foreach进行数据结果遍历，代码如下：

Php代码

file:pdo-query.php
url:http://localhost:88/pdo/pdo-query.php?title=title1
<?php
$dsn = 'mysql:host=localhost;dbname=pdotest';
$username = 'root';
$passwd = 'password';
try {
$dbh = new PDO($dsn, $username, $passwd);
echo 'connect to database successfully!'."\r\n";
$title = 'title1';
// 构造SQL语句
$sql = "SELECT * FROM blog WHERE title = '".$title."'";
// 执行查询并遍历结果
foreach ($dbh->query($sql) as $row){
print $row['id']."\t";
print $row['title']."\t";
}
} catch (PDOException $e) {
echo 'Errors occur when query data!\n';
echo $e->getMessage();
}
?>

    备注：一般情况下，通过构造SQL语句的方法来进行query、update、insert、delete，都会需要指定where条件，因此不可避免的需要防止SQL注入的问题出现。

    例如，正常情况下，当用户输入“title1”时，我们构造的sql语句会是SELECT * FROM blog WHERE title='title1'，但是对SQL比较熟悉的用户会输入'OR id LIKE '%，此时我们构造的SQL就会变成SELECT * FROM blog where title='' OR id LIKE '%'，这样整张blog 表中的数据都会被读取，因此需要避免，所以需要用到quote方法，把所有用户提供的数据进行转移，从而防止SQL注入的发生。使用quote方法后的sql为$sql = "SELECT * FROM blog WHERE title = ".$dbh->quote($title)，转移出来后的sql是SELECT * FROM blog WHERE title = '\'OR id LIKE \'%'，把所有的单引号（'）都转移了。

3. 使用prepare和execute方法查询数据
    如果我们用到的SQL查询是使用频率不高的查询，那么使用query或prepare和execute方法来查询都无太大差别，查询速度也不会差太远。两者不同的是，使用query时，php向数据库发送的sql，每执行一次都需要编译一次，而使用prepare和execute方法，则不需要，因此做大并发量的操作时，使用prepare和execute方法的优势会更加明显。

    使用prepare和execute方法的步骤不多，a)构造SQL，b)将SQL传入PDO->prepart方法，得到一个PDOStatement对象，3)调用PDOStatement对象的execute方法，4)通过PDOStatement->fetch或PDOStatement->fetchObject遍历结果集。代码如下：

Php代码

file:pdo-prepare-fetch.php
url:http://localhost:88/pdo/pdo-prepare-fetch.php?title=title1
<?php
$dsn = 'mysql:host=localhost;dbname=pdotest';
$username = 'root';
$passwd = 'password';
// 从请求获取title参数值
$title = $_GET['title'];
try {
$dbh = new PDO($dsn, $username, $passwd);
echo 'connect to database successfully!'." ";
// 构造SQL语句，使用绑定变量
$sql = "SELECT * FROM blog WHERE title = :title";
// 编译SQL
$stmt = $dbh->prepare($sql);
// 为绑定变量赋值
$stmt->bindParam(":title", $title, PDO::PARAM_STR);
// 执行SQL
$stmt->execute();
// 以联合数组方式获取结果，并遍历结果
while ($row = $stmt->fetch(PDO::FETCH_ASSOC)) {
print $row['id']."\t";
print $row['title']."\t";
}
} catch (PDOException $e) {
echo 'Errors occur when query data!\n';
echo $e->getMessage();
}
?>

除了使用上面的PDO::FETCH_ASSOC返回联合数组外，还可以使用fetchObject方法，返回结果集对象，代码如下：

Php代码

file:pdo-prepare-fetch-object.php
url:http://localhost:88/pdo/pdo-prepare-fetch-object.php?title=title1
<?php
$dsn = 'mysql:host=localhost;dbname=pdotest';
$username = 'root';
$passwd = 'password';
$title = $_GET['title'];
try {
$dbh = new PDO($dsn, $username, $passwd);
echo 'connect to database successfully!'." ";
$sql = "SELECT * FROM blog WHERE title = :title";
$stmt = $dbh->prepare($sql);
$stmt->bindParam(":title", $title, PDO::PARAM_STR);
$stmt->execute();
// 以对象数组方式获取结果，并遍历结果
while ($row = $stmt->fetchObject()) {
print $row->id."\t";
print $row->title."\t";
}
} catch (Exception $e) {
echo 'Errors occur when query data!\n';
echo $e->getMessage();
}
?>

4. 设置PDO的错误级别
    PDO的错误级别分成PDO::ERRMODE_SILENT（默认）、PDO::ERRORMODE_WARNING、PDO::ERRORMODE_EXCEPTION三种。
    PDO::ERRMODE_SILENT级别，当出现错误时，会自动设置PDOStatement对象的errorCode属性，但不进行任何其他操作，因此需要我们手工检查是否出现错误（使用empty($stmt->errorCode())），否则程序将继续走下去。
    PDO::ERRORMODE_WARNING级别，基本与PDO::ERRMODE_SILENT一致，都是需要使用empty($stmt->errorCode())手工检查。
    只需要在创建PDO对象后，加入以下代码即可：$dbh->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_SILENT);或$dbh->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_WARNING);
    PDO::ERRORMODE_WARNING级别，当出现错误时，系统将抛出一个PDOException，并设置errorCode属性，程序可以通过try{...}catch{...}进行捕捉，否则未catch的exception会导致程序中断，加入以下代码即可：$dbh->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);

Php代码

<?php
...
try {
...
} catch (Exception $e) {
echo 'Errors occur when operation!'." ";
// 获取Exception信息
echo $e->getMessage()." ";
// 获取错误码
echo $e->getCode()." ";
// 获取出错文件名
echo $e->getFile()." ";
// 获取出错行
echo $e->getLine()." ";
// 把异常以字符串返回
echo $e->getTraceAsString();
}
?>

5. 使用prepare和execute方法插入/更新数据
方法和#3中进行查询的差不多，只是构造的SQL语句是insert语句或update语句，代码如下：

Php代码

file:pdo-prepare-insert.php
url:http://localhost:88/pdo/pdo-insert.php?title=title11
<?php
$dsn = 'mysql:host=localhost;dbname=pdotest';
$username = 'root';
$passwd = 'password';
$title = $_GET['title'];
try {
$dbh = new PDO($dsn, $username, $passwd);
$dbh->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
echo 'connect to database successfully!'." ";
// 构造Insert语句
$sql = "INSERT INTO blog(title) VALUES(:title)";
$stmt = $dbh->prepare($sql);
$stmt->bindParam(":title", $title);
$stmt->execute();
} catch (Exception $e) {
echo 'Errors occur when query data!\n';
echo $e->getMessage();
}
?>

Php代码

file:pdo-prepare-update.php
url:http://localhost:88/pdo/pdo-update.php?id=1&title=title12
<?php
$dsn = 'mysql:host=localhost;dbname=pdotest';
$username = 'root';
$passwd = 'password';
$id = $_GET['id'];
$title = $_GET['title'];
try {
$dbh = new PDO($dsn, $username, $passwd);
$dbh->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
echo 'connect to database successfully!'." ";
// 构造update语句
$sql = "UPDATE blog SET title=:title where id=:id";
$stmt = $dbh->prepare($sql);
$stmt->bindParam(":id", $id);
$stmt->bindParam(":title", $title);
$stmt->execute();
} catch (Exception $e) {
echo 'Errors occur when query data!\n';
echo $e->getMessage();
}
?>

6. 获取返回的行数
使用#3中的prepare和execute方法，然后将sql语句改成count的，例如SELECT COUNT(id) FROM article ...，代码如下：

Php代码

file:pdo-prepare-fetch-column.php
url:http://localhost:88/pdo/pdo-prepare-fetch-column.php?id=1&title=title12
<?php
$dsn = 'mysql:host=localhost;dbname=pdotest';
$username = 'root';
$passwd = 'password';
try {
$dbh = new PDO($dsn, $username, $passwd);
$dbh->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_SILENT);
echo 'connect to database successfully!'." ";
// 构造count语句
$sql = "SELECT COUNT(id) FROM blog";
$stmt = $dbh->prepare($sql);
$stmt->execute();
// 使用fetchColumn获取0列值
echo $stmt->fetchColumn()." rows returned!";
} catch (Exception $e) {
echo 'Errors occur when query data!\n';
echo $e->getMessage();
}
?>

7. 获取受影响的行数
使用#3中的prepare和execute方法，然后将SQL语句改成insert、update、delete语句即可，代码如下：

Php代码

file:pdo-prepare-row-count.php
url:http://localhost:88/pdo/pdo-prepare-row-count.php?id=1
<?php
$dsn = 'mysql:host=localhost;dbname=pdotest';
$username = 'root';
$passwd = 'password';
$id = $_GET['id'];
try {
$dbh = new PDO($dsn, $username, $passwd);
$dbh->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_SILENT);
echo 'connect to database successfully!'." ";
$sql = "DELETE FROM blog WHERE id=:id";
$stmt = $dbh->prepare($sql);
$stmt->bindParam(":id", $id);
$stmt->execute();
// 获取update、insert、delete操作后影响的行数
echo $stmt->rowCount()." rows affected!";
} catch (Exception $e) {
echo 'Errors occur when data operation!\n';
echo $e->getMessage();
}
?>

8. 获得新插入行的ID值
为数据库表插入新数据行时，我们需要获得刚刚插入的新行的ID值，此时我们需要使用到PDO的lastInsertId()方法，代码如下：

Php代码

file:pdo-prepare-last-insertid.php
url:http://localhost:88/pdo/pdo-prepare-last-insertid.php?title=title13
<?php
$dsn = 'mysql:host=localhost;dbname=pdotest';
$username = 'root';
$passwd = 'password';
$title = $_GET['title'];
try {
$dbh = new PDO($dsn, $username, $passwd);
$dbh->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
echo 'connect to database successfully!'." ";
$sql = "INSERT INTO blog(title) VALUES(:title)";
$stmt = $dbh->prepare($sql);
$stmt->bindParam(":title", $title);
$stmt->execute();
// 获取上一个之行的insert语句插入的数据的id值
echo $dbh->lastInsertId();
} catch (Exception $e) {
echo 'Errors occur when query data!\n';
echo $e->getMessage();
}
?>

9. 使用PDO进行事务管理
事务是进行程序开发时，保证数据ACID（可分性、一致性、独立性、持久性）的工具。要不全部成功，要不全部不成功，这样才能保证关联数据的保存能够达到预期的目的。下面使用PDO的Transaction来进行实验，进行多比数据插入，开启事务，第一句sql是可以正常插入，第二句sql插入出错，检查是否rollback。

Php代码

file:pdo-prepare-transaction.php
url:http://localhost:88/pdo/pdo-prepare-transaction.php
<?php
$dsn = 'mysql:host=localhost;dbname=pdotest';
$username = 'root';
$passwd = 'password';
try {
$dbh = new PDO($dsn, $username, $passwd);
$dbh->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
echo 'connect to database successfully!'." ";
// 开启事务
$dbh->beginTransaction();
$sql = "INSERT INTO blog(title) VALUES(:title)";
$stmt = $dbh->prepare($sql);
$stmt->execute(array(':title'=>'insert title1'));
$stmt->execute(array(':title'=>NULL));
// 提交事务
$dbh->commit();
} catch (Exception $e) {
echo 'Errors occur when data operation!\n';
echo $e->getMessage();
// 回滚事务
$dbh->rollBack();
}
?>

10. 使用PDO进行数据库备份
使用system函数，将我们构造的mysqldump命令传入即可。下面为了演示，只做了简单的调用。

Php代码

file:pdo-backup.php
url:http://localhost:88/pdo/pdo-backup.php
<?php
$username="root";
$passwd="password";
$dbname="pdotest";
$file='d:/'.$dbname.'.sql';
// 构造备份命令
$cmd = "mysqldump -u".$username." -p".$passwd." ".$dbname." >".$file;
// 执行备份命令
system($cmd,$error);
if($error){
trigger_error("backup failed".$error);
}
?>

采用工厂模式：

Php代码

file:AbstractMySQLDump.php
<?php
require_once 'MySQLDump_Win.php';
abstract class AbstractMySQLDump {
protected $cmd;
abstract function __construct($username, $passwd, $dbname, $file);
// 依据操作系统类型，使用工厂方法构造备份类
public static function factory($username, $passwd, $dbname, $file){
if(strtoupper(substr(PHP_OS, 0, 3))==='WIN'){
return new MySQLDump_Win($username, $passwd, $dbname, $file);
}else{
// implement MySQLDump_NIX($username, $passwd, $dbname, $file);
}
}
// 备份逻辑
public function backup(){
system($this->cmd, $error);
// 判断是否出错及出错逻辑
if($error){
trigger_error("backup failure! command:".$this->cmd." Error:".$error);
}
}
}
?>

Php代码

file:MySQLDump_Win.php
<?php
class MySQLDump_Win extends AbstractMySQLDump {
// 覆盖父类的构造方法
public function __construct($username, $passwd, $dbname, $file){
$this->cmd = "mysqldump -u".$username." -p".$passwd." ".$dbname." > ".$file;
}
}
?>

Php代码

file:MySQLDumpTest.php
url:http://localhost:88/pdo/MySQLDumpTest.php
<?php
require_once 'AbstractMySQLDump.php';
$username = "root";
$passwd = "password";
$dbname = "pdotest";
$file = "d:/".$dbname.".sql";
// 使用工厂方法生成备份类
$dump = AbstractMySQLDump::factory($username, $passwd, $dbname, $file);
// 执行备份类的backup方法
$dump->backup();
?>

鲜花

握手

雷人

路过

鸡蛋

该文章已有0人参与评论

请发表评论

全部评论

专题导读

More+

10-27 六六分期app的软件客服如何联系？(六六分期

11-06 可心卡盟:win10系统火狐flash插件崩溃怎么

11-06 亲亲特价:怎么删除回收站图标

11-06 济南大学虚拟社区:鲁大师节能降温的具体办

11-06 xlueops.exe:无线网络安装向导

11-06 女斗合众国:win7系统cf与主机连接不稳定怎

11-06 0xc000022-[cf烟雾头]cf怎么调烟雾头

11-06 qizideyouhuo:应用程序无法正常启动0xc0000

11-06 ipz-185:win7系统vcf文件怎么打开

11-06 傻哥蹦迪:win10系统s4怎么打开usb调试

11-06 八神浩树gtaste:回收站清空了怎么恢复

11-06 妖尾之黑色守护:win10系统电脑没有1440x900

11-06 校园至尊魔王小说:win7系统浏览网页时字体

11-06 女斗合众国:win10系统访问共享文件夹提示请

11-06 tokyo hot n0654:恢复win7系统默认字体一招

11-06 雨酷仙境:设置win7系统转移临时文件夹腾出

11-06 阿穆纳伊之杖:win7系统开始菜单在右边还原

11-06 tunespotting:win10系统火狐flash插件总是

11-06 甘尔葛分析师：计谋网站seo关键词暴涨有什

11-06 蔡贵霖: 计谋网站seo关键词暴涨有什么秘密

11-06 博益网首页:ao3网页版进入不了解决方法

11-06 漏斗子专栏: 网站数据分析小白易懂精华篇

11-06 见证双虹怎么做:win7系统开启telnet命令的

11-06 颾狐蝶蜋:系统资源不足无法完成请求的服务

11-06 国光中学校歌:提交网站到alexa查询详细步骤

11-06 西安有情天:静态网页和动态网页的区别

11-06 红木雅尚斋:外部链接构造对网站的好处

11-06 前官礼遇：防止域名劫持–增强域安全性的10

11-06 密传二转答案: 中文分词算法有哪些

11-06 金泉家园邮编:百度快照劫持的表现及应对方

php不能往mysql数据库添加汉字,只能添加字母和数字发布时间：2022-07-10

php+mysql下拉框中的树型菜单发布时间：2022-07-10

chipscope数据导入matlab

1 CVE-2022-34501

The bin-collection package in PyPI before v0.1 included a code execution backdoo

阅读：759|2022-07-29

2 kojino/Harvard-Robust-Machine-Learning:

kojino/Harvard-Robust-Machine-Learning: Repository for CS282R: Robust Machine Le

阅读：792|2022-08-18

3 cescoffier/puppet-nexus: A Puppet Module

cescoffier/puppet-nexus: A Puppet Module for Nexus (Maven)

阅读：770|2022-08-16

4 文的笔顺,诠释文的笔画,解读文的部首

文字笔顺怎么写?文字笔顺笔画顺序是什么?诠释文字的笔画顺序怎么写了解到好多的写字朋

阅读：997|2022-11-06

5 Cassolotl/sentient.cloud · GitHub

Cassolotl/sentient.cloud · GitHub

阅读：604|2022-08-18

6 matlab练习程序（随机粒子切换特效）

视频制作软件中一般都会有相邻帧切换的特效，我过去用过vagas好像就有很多切换特效。

阅读：682|2022-07-18

7 CVE-2017-20135

A vulnerability classified as critical was found in Itech Dating Script 3.26. Af

阅读：842|2022-07-29

8 zentyal/zentyal: Linux Small Business Se

zentyal/zentyal: Linux Small Business Server

阅读：523|2022-08-15

9 updownpress/markdown-lint: Markdown Lint

updownpress/markdown-lint: Markdown Lint Tool / Checker Documentation by Mark Ha

阅读：881|2022-08-18

10 Liam0205/LaTeX_hard_way: Learn LaTeX the

Liam0205/LaTeX_hard_way: Learn LaTeX the Hard Way

阅读：540|2022-08-12

客服电话

电子邮件

PHP开发笔记系列（一）-PDO使用

请发表评论

全部评论

上一篇：

下一篇：

matlab-GUI整理-图形处理

solegalli/feature-selection-for-machine-

tianli/matlab_offscreen: Matlab offscree

win7系统重装系统初始设置的操作方法

これがマストドンだ！使い方からインスタ

chipscope数据导入matlab

PacktPublishing/Python-Machine-Learning-

sussillo/hfopt-matlab: A parallel, cpu-b

鲁东大学一米网:Win7系统USB驱动器RAM的操

emersion/go-ostatus: An OStatus library

CVE-2022-2118

关于我们

产品与服务

解决方案

139-2527-9053

客服电话

电子邮件

PHP开发笔记系列（一）-PDO使用

请发表评论

全部评论

上一篇：

下一篇：

matlab-GUI整理-图形处理

solegalli/feature-selection-for-machine-

tianli/matlab_offscreen: Matlab offscree

win7系统重装系统初始设置的操作方法

これがマストドンだ！ 使い方からインスタ

chipscope数据导入matlab

PacktPublishing/Python-Machine-Learning-

sussillo/hfopt-matlab: A parallel, cpu-b

鲁东大学一米网:Win7系统USB驱动器RAM的操

emersion/go-ostatus: An OStatus library

CVE-2022-2118

关于我们

产品与服务

解决方案

139-2527-9053

これがマストドンだ！使い方からインスタ