简介

PDO（PHP Data Object）是指PHP数据对象，它定义了一个轻量级的一致接口来统一操作各种数据库。PDO提供了一个数据访问抽象层,这意味着，不管使用哪种数据库，都可以用相同的函数（方法）来查询和获取数据。当选择不同的数据库时，只需要修改PDO的DSN（数据源）即可，有效的解决了早期PHP版本中各个数据库扩展互不兼容，维护性差，可移植性差的缺点。注意：从 PHP 5.1开始附带了PDO，在 PHP 5.0 中是作为一个 PECL 扩展使用。 PDO 需要PHP 5 核心的新 OO 特性，因此不能在较早版本的 PHP 上运行。

基本使用

创建测试数据表并且插入测试数据

 CREATE TABLE `book` (

  `id` int(10) unsigned NOT NULL AUTO_INCREMENT,

  `name` varchar(20) NOT NULL COMMENT '书名',

  `author` varchar(15) DEFAULT NULL COMMENT '作者',

  `ptime` varchar(100) DEFAULT NULL,

  PRIMARY KEY (`id`),

  KEY `name` (`name`)

) ENGINE=InnoDB AUTO_INCREMENT=10 DEFAULT CHARSET=utf8;

INSET INTO book VALUES(1,'php','leo',now()),(2,'mysql','lisi',now()),(3,'linux','ben',now()),(4,'apache','lily',now());

连接数据库、执行SQL语句、处理结果集并且展示到模板

<?php

header('Content-type:text/html;charset=utf-8');

//保存数据源基本信息

$arr = array(

    'dbms' =>'mysql',

    'host' =>'localhost',

    'port' =>3306,

    'dbname' =>'mytest',

    'charset' =>'utf8',

    'user' =>'root',

    'pwd'=>123456

);

$dsn = "$arr[dbms]:host=$arr[host];port=$arr[port];dbname=$arr[dbname];charset=$arr[charset]";//php版本需大于5.3.6才能使用charset属性设置字符集

try{

    //连接数据库、选择数据库

    $pdo = new PDO($dsn,$arr['user'],$arr['pwd']);

    //执行sql语句

    $sql ='SELECT * FROM book';

    $result = $pdo->query($sql);

    //定义空数组保存数据

    $info = array();

    //遍历结果集获取数据详细信息

    while ($row = $result->fetch()){

        $info[] = $row;

    }

}catch (PDOException $e){

    //输出异常信息

    echo $e->getMessage().'<br>';

}

?>

<!doctype html>

<html lang="en">

<head>

    <meta charset="UTF-8">

    <meta name="viewport"

          content="width=device-width, user-scalable=no, initial-scale=1.0, maximum-scale=1.0, minimum-scale=1.0">

    <meta http-equiv="X-UA-Compatible" content="ie=edge">

    <title>Document</title>

</head>

<body>

    <h2>书籍信息列表</h2>

<table border="1" >

    <tr>

        <td>图书名称</td>

        <td>图书作者</td>

        <td>出版日期</td>

    </tr>

    <?php foreach ($info as $v):?>

    <tr>

        <td><?php echo $v['name'];?></td>

        <td><?php echo $v['author'];?></td>

        <td><?php echo $v['ptime'];?></td>

    </tr>

    <?php endforeach;?>

</table>

</body>

</html>

执行SQL语句

PDO中提供了query()和exec()方法用于执行SQL语句，query()方法主要是用于有记录结果返回的操作，特别是SELECT操作，执行成功则返回一个PDOStatement类的对象，失败则返回false。exec()则主要针对没有结果集合返回的操作，如INSERT、UPDATE、DELETE等，它用于执行一条SQL语句并且返回执行后受影响的行数。

处理结果集

PDO中常用获取结果集的方式有三种：fetch()、fetchColumn()、fetchAll()

PDO中的fetch()方法可以从结果集中获取下一行数据
PDO中的fetchColumn()方法用于获取结果集中单独一列
PDO中的fetchAll()方法用于返回一个包含结果集中所有行的数组

具体的语法参数就不一一赘述了，可参看PHP手册。

预处理语句

PDO中的预处理语句机制可简单理解为SQL的一种编译过的模板，在执行时，只需在服务器和客户端之间传输有变化的数据即可，可以避免重复分析与编译，由于预处理语句实现了将SQL和数据的分离，因此可以防止SQL注入。以下代码演示预处理语句的使用

<?php

header("Content-type:text/html;charset=utf-8");

try{

    //连接数据库

    $pdo = new PDO('mysql:host=localhost;dbname=mytest;charset=utf8','root','123456');

    //预处理sql语句

    $stmt = $pdo->prepare("insert into `book`(`name`,`author`)VALUES (?,?)");

    //print_r($stmt);exit();

    //为占位符绑定变量

    $stmt->bindParam(1,$name);

    $stmt->bindParam(2,$author);

    // 第二种占位符使用方式

    // $stmt = $pdo->prepare("insert into `book`(`name`,`author`)VALUES (:name,:author)");

    // $stmt->bindParam(':name',$name);

    // $stmt->bindParam(':author',$author);

    //准备数据

    $data = array(

        array('php第一本教材','人民邮电出版社'),

        array('php第二本教材','人民邮电出版社'),

        array('php第三本教材','人民邮电出版社'),

        array('php第四本教材','人民邮电出版社'),

        array('php第五本教材','人民邮电出版社')

    );

    foreach ($data as $row){

        //为绑定的变量赋值

        $name = $row[0];

        $author = $row[1];

        //执行预处理语句

        $stmt->execute();

    }

}catch (PDOException $e){

    echo $e->getMessage().'<br>';

}

占位符

可以在SQL语句中添加占位符，当多次执行SQL语句时，只需要编译一次SQL语句，可以使用相同或不同的参数执行多次，可以节省资源。PDO支持两种占位符：问号占位符(?)和命名参数占位符(:参数名称)，使用时需注意，同一条SQL语句只能选择一种占位符使用。

参数绑定

准备好预处理语句后可以使用bindParam()方法为占位符绑定变量参数，方法的第一个参数表示参数标识符，第二个参数用于表示参数标识符对应的变量名。

excute()方法

excute()方法有个可选参数，表示一个元素个数与预处理语句占位符数量一样多的数组，用于为预处理语句中的占位符赋值。当占位符为问号占位符时，需要给excute()方法传递一个索引数组参数，反之，当占位符为命名参数占位符时传入一个关联数组参数

错误处理

PDO错误处理机制提供了三种方案，通过设置"PDO::ATTR_ERRMODE"的值来进行不同的处理。下面分别阐述：

PDO错误处理默认模式

"PDO::ERRMODE_SILENT"为PDO默认的错误处理模式。在发生错误时不进行任何操作，只简单设置错误代码，可以通过PDO提供的errorCode()和errorInfo()这两个方法对语句和数据库对象进行排查。
PDO错误处理WARNING模式

如果想要查看发生了什么问题且不中断应用程序的流程，可以将PDO的错误模式设置为"PDO::ERRMODE_WARNING",当错误发生时，除了设置错误代码外，PDO还会发出一条E_WARNING信息。
PDO错误处理EXCEPTION模式

"PDO::ERRMODE_EXCEPTION"表示进行错误异常处理，可以在PDO执行SQL语句错误时，使用try...catch捕捉到PDOException异常。代码如下：

<?php

header("Content-type:text/html;charset=utf-8");

try{

    //1.连接数据库

    $pdo = new PDO('mysql:host=localhost;dbname=mytest;charset=utf8','root','123456');

    //2.设置错误处理

    $pdo->setAttribute(PDO::ATTR_ERRMODE,PDO::ERRMODE_SILENT);

    //3.预处理SQL语句

    $stmt = $pdo->prepare('select * from books');

    //4.执行预处理语句

    $stmt->execute();

    echo"well-done!";

    //5.获取错误码

    $code = $stmt->errorCode();

    //6.判断执行错误

    if (!empty($code)){

        echo"<br>$code<br>";

        print_r($stmt->errorInfo());

    }

}catch (PDOException $e){

    echo  $e->getMessage().'<br>';

}

事务处理

PDO提供了事务处理机制，对于MySQL数据库来说支持事务的数据引擎有InnoDB和BDB两种。有三个PDO方法可以完成事务任务：beginTransaction()、commit()和rollBack()。测试代码如下：

<?php

    header("Content-type:text/html;charset=utf-8");

    //1.连接数据库

    $pdo = new PDO('mysql:host=localhost;dbname=mytest;charset=utf8','root','123456');

    $pdo->exec('set names utf8');

    //2.设置错误处理

    $pdo->setAttribute(PDO::ATTR_ERRMODE,PDO::ERRMODE_EXCEPTION);

    //3.开启事务

    $pdo->beginTransaction();

try{

    //一次操作

    $sql = "delete from book where id=3";

    $stmt = $pdo->prepare($sql);

    $stmt->execute();

    //一次操作

    $sql = "delete from book where id=4";

    $stmt = $pdo->prepare($sql);

    $stmt->execute();

    //一次操作

    $sql = "delete from book where id=5";

    $stmt = $pdo->prepare($sql);

    $stmt->execute();

    //提交

    $pdo->commit();

}catch (PDOException $e){

    echo  $e->getMessage().'<br>';

    //回滚

    $pdo->rollBack();

}

巴特西

PHP基础之PDO

简介

基本使用

执行SQL语句

处理结果集

预处理语句

占位符

参数绑定

excute()方法

错误处理

事务处理

最新文章

热门文章