###1、PDO数据库操作
PDO是一个PHP在`5.1+`版本后内置的系统类，

它主要在面向对象中代替`Mysqli()`系列函数，进行数据库操作处理。

Mysqli也有一个class系统类，但老师建议在面向对象中，一致使用PDO类即可，不需要去学习Mysqli类。

PDO的优点：
```
1、一致性的接口跨库操作更容易，不但支持mysql数据库，还支持其他类型的数据库
2、更高的运行效率
3、安全（使用PDO的预处理机制可以完全避免SQL注入攻击）
```

###2、使用PDO链接数据库
PDO链接数据库，只要依靠`new PDO()`类，

该PDO类实例化时，可传入4个参数，前3个为必传参数，最后一个为扩展参数(数组类型，详细参考官方手册`http://php.net/manual/zh/book.pdo.php`)。

其语法格式如下：
```
new PDO(DSN句柄, 数据库账号, 数据库密码, 扩展参数);
```
DSN句柄的格式如下：
```
数据库类型:dbname=数据库名称;host=数据库连接地址;port=端口号
```
注意：DSN句柄可以省略到如下格式：
```
数据库类型:host=数据库连接地址
```
使用这种格式的PDO连接，主要是用于对整个MySql进行操作，例如创建数据库、删除数据库等。

接下来我们来看下具体的使用案例：
```php
<?php
# DSN句柄
$dsn      = 'mysql:dbname=love_niu;host=127.0.0.1;port=3306';
$username = 'root';
$password = 'root';

# 连接数据库
$DB = new PDO($dsn, $username, $password);
if ($DB) {
    die('连接成功');
}
echo '连接失败';
```

###3、PDO连接错误压制
这时候可能有细心的同学会发现，上面的代码要是当PDO连接失败的时候，是会直接抛出一个错误，而不会执行到连接失败这一步。

如果你想PDO连接失败时，可以成功捕抓到，就只能使用`try{}catch(){}`语句。

不过要注意的是，错误异常类是使用得`PDOException`类，该异常子类是系统自带，专门对应PDO数据操作的。

完整代码如下：
```php
<?php
# DSN句柄
$dsn      = 'mysql:dbname=love_niu;host=127.0.0.1;port=3306';
$username = 'root';
$password = '';

# 连接数据库
try {
    $DB = new PDO($dsn, $username, $password);
} catch(PDOException $e) {
    die ('连接失败，错误信息：'.$e->getMessage());
}
echo '连接成功';
```

###4、PDO设置数据库编码
在PDO中设置数据库编码主要有三种方式，以案例中的`$DB`变量为例(成功连接PDO)：
```
1、$DB->exec('SET NAMES utf8;');
2、$DB->query('SET NAMES utf8;');
```
第三种比较特殊，是在对PDO连接时，利用第四个参数进行设置(比较少用)：
```
3、new PDO($dsn, $username, $password, [PDO::MYSQL_ATTR_INIT_COMMAND => 'SET NAMES utf8;']);
```
具体完整代码就不提供了，同学们结合上面的案例代码自行练习。

###5、PDO的query()成员函数
`query()`成员函数，是用于执行一条SQL语句，如果成功，则返回一个`PDOStatement`对象(PHP系统类)。

该成员函数有一个特点，就是可以直接遍历返回的记录集，但如果你直接`var_dump()`则是一个object对象。

案例代码如下：
```php
<?php
# DSN句柄
$dsn      = 'mysql:dbname=love_niu;host=127.0.0.1;port=3306';
$username = 'root';
$password = 'root';

# 连接数据库
try {
    $DB = new PDO($dsn, $username, $password);
} catch(PDOException $e) {
    die ('连接失败，错误信息：'.$e->getMessage());
}
$DB->query('SET NAMES utf8;');
$list = $DB->query('SELECT * FROM niu_user');

foreach ($list as $row) {
   var_dump($row);
}
var_dump($list);
```
###6、PDO的exec()成员函数
`exec()`成员函数，也是用于执行一条SQL语句，如果执行成功，返回受影响的行数，有可能返回`0`；若失败，则返回`false`。

此函数不会返回查询结果集。

案例代码如下：
```PHP
<?php
# DSN句柄
$dsn      = 'mysql:dbname=love_niu;host=127.0.0.1;port=3306';
$username = 'root';
$password = 'root';

# 连接数据库
try {
    $DB = new PDO($dsn, $username, $password);
} catch(PDOException $e) {
    die ('连接失败，错误信息：'.$e->getMessage());
}
$DB->query('SET NAMES utf8;');
$res = $DB->exec('UPDATE niu_user SET nice = "你妹" WHERE id > 1000;');
var_dump($res);
```
###7、query()和exec()的区别、使用场景
由于返回值的特性，`query()`一般只用于执行`SELECT`语句，

而`exec()`用于执行除`SELECT`语句以外的所有SQL语句。

同时，`query()`语句只能在DSN句柄指定连接数据库时才能够使用，否则将报错。

###8、PDO切换数据库
有些时候，在开发中，我们需要操作到2个或以上的数据库，那么使用PDO该如何切换不同的数据库呢？

一般有以下两种解决方案：
```
1、创建多个PDO连接实例
2、使用$PDO->query("USE 数据库名称");切换数据库
```
使用第二种方式时需要特别小心，假设：

你的主库是`love_niu`，当你在某段业务时需要切换到副库`no_love`进行操作，

那么记得在操作完成后，将其切换回主库`love_niu`，否则很容易发生数据库操作混乱的情况。

###9、获得查询返回的行数
假设，我们现在使用`query()`执行了下面的SQL语句：
```
SELECT * FROM user
```
假设我们的查询是正确的，现在返回了一个`PDOStatement`对象，我们可以用它获取到我们的结果或者是查看这次查询中一共查到多少条结果集。

但不足的是，PDO没有提供一个统一的方法去计算返回的行数。

`PDOStatement`包含了一个叫做`rowCount()`的成员函数，但是这个方法却不能保证在每一个数据库软件中起作用

（幸运的是，它能够在Mysql数据库中起作用）。

如果你的SQL驱动不支持这个方法，那么还有两个备用方案：
```
1、使用二次查询SELECT COUNT(*)语句
2、或者使用简单的count(返回结果)得到行数。
```
`rowCount()`的使用案例如下：
```php
<?php
# DSN句柄
$dsn      = 'mysql:dbname=love_niu;host=127.0.0.1;port=3306';
$username = 'root';
$password = 'root';

# 连接数据库
$DB = new PDO($dsn, $username, $password);
$DB->query('SET NAMES utf8;');
$res    = $DB->query('SELECT * FROM niu_user;');
$length = $res->rowCount();
var_dump($length);
```
###10、获得一条查询记录集
之前我们说过，`query()`直接遍历可以获得所有查询记录集(二维数组)，

注意：如果你不想直接遍历，也可以使用`fetchAll()`成员函数，获得所有查询记录集

那么当我们只想要获得一条查询结果(一维数组)，又或者还是我们本身只想查询出一条记录数时，

该怎样做呢？

PDO提供了一个`fetch()`成员函数，这个方法只会返回第一条记录集，

这对于只需要查询一条结果集是非常有用，并且高效的。

使用案例如下：
```php
<?php
# DSN句柄
$dsn      = 'mysql:dbname=love_niu;host=127.0.0.1;port=3306';
$username = 'root';
$password = 'root';

# 连接数据库
$DB = new PDO($dsn, $username, $password);
$DB->query('SET NAMES utf8;');
$res  = $DB->query('SELECT * FROM niu_user WHERE id = 1;');
$info = $res->FetchAll();
var_dump($info);
```
不过，同学们要注意的是，当SELECT语句查询不到对应的记录集时，`fetch()`返回的是`false`，而`fetchAll()`返回的是一个空数组。

###11、什么是预处理？
在PDO数据库操作中，有一个SQL处理的逻辑，叫预处理，

通常我们可以把预处理想象成是一套SQL语句的模板，这个模板中没有真实参数，

参数的位置都是用占位符代替着，当我们需要执行SQL的时候，只需要将参数与对应的占位符替换，

就可以成功执行了。

预处理语句具有两个主要的优点：

1、查询只需要被解析一次，但可以使用相同或不同的参数执行多次。

当SQL语句准备好之后，数据库就会分析，编译并优化它要执行查询的计划。

对于复杂的查询语句来说，如果你要重复执行许多次有不同参数的但结构相同的查询，这个过程会占用大量的时间，使得你的程序变慢。

通过使用一个预处理语句你就可以避免重复分析、编译、优化的环节。

简单来说，预处理语句使用更少的资源，执行速度也就更快。

2、传给预处理语句的参数不需要使用引号(字符串时)，底层驱动会为你处理这个。

如果你的程序全部都是使用预处理语句执行SQL语句，你就可以百分百的对领导说我们不会存在被SQL注入的可能。

####A、预处理的占位方式
在编写SQL语句时，PDO的预处理占位符使用方式主要有2种：

1、使用`?`符号占位，例如：
```
SELECT * FROM user WHERE name = ? AND age >= ?;
```

2、使用 `:关键字` 占位，例如：
```
SELECT * FROM user WHERE name = :name AND age >= :age;
```
注意：不能混合使用，只能单独使用其中一种。

####B、监听预处理后的SQL语句
在PDO中，带有占位符的预处理SQL语句，不能直接使用`query()`成员函数直接执行，

需要使用`prepare()`成员函数进行预处理监听，其返回值是一个`PDOStatement`对象，用于后续注入对应的参数。

例如：
```
$pdo->prepare('SELECT * FROM user WHERE name = ? AND age >= ?');
```

####C、预处理后的SQL语句绑定参数
预处理SQL语句绑定参数主要依赖其对应的占位符方式，

PDOStatement对象提供了2个成员函数用于绑定预处理参数，`bindValue()`和`bindParam()`，

下面，我们先以`bindValue()`为例进行案例讲解：
1、当我们使用：`$statement = $pdo->prepare('SELECT * FROM user WHERE name = ? AND age >= ?');`时；

就只能从左到右，使用阿拉伯数字1开始进行对应的占位替换：
```
$statement->bindValue(1, 'Cake');
$statement->bindValue(2, 17);
```
2、当我们使用：`$statement = $pdo->prepare('SELECT * FROM user WHERE name = :name AND age >= :age');`时；

就只能指定对应的占位进行替换：
```
$statement->bindValue(':name', 'Cake');
$statement->bindValue(':age', 17);
```

####D、bindValue()和bindParam()的区别
`bindValue()`和`bindParam()`对预处理SQL语句绑定参数的使用方式一样的，但使用顺序上有所区别。

`bindValue()`在绑定时，第二个参数为变量名时，这个变量必须是已经定义并且已赋值，既这个函数是会对SQL语句立即绑定参数；

`bindParam()`在绑定时，第二个参数为变量名时，这个变量可以未定义或未赋值，既这个函数是只对SQL语句进行变量绑定，如果后续你有这个变量进行赋值修改，那么绑定的内容也会同时修改。

`bindValue()`使用案例如下：
```PHP
<?php
# DSN句柄
$dsn      = 'mysql:dbname=love_niu;host=127.0.0.1;port=3306';
$username = 'root';
$password = 'root';

# 连接数据库
$DB = new PDO($dsn, $username, $password);
$DB->query('SET NAMES utf8;');
# 创建预处理SQL语句
$statement = $DB->prepare('SELECT * FROM niu_user WHERE name = ? AND id >= ?');
# 创建绑定内容
$name = '小黄牛';
$age  = 17;
# 绑定参数
$statement->bindValue(1, $name);
$statement->bindValue(2, $age); 
# 下面修改绑定内容的变量，不会对预处理语句绑定的内容有影响
$name = '你妹';
$age  = 20;
```
`bindParam()`使用案例如下：
```php
<?php
# DSN句柄
$dsn      = 'mysql:dbname=love_niu;host=127.0.0.1;port=3306';
$username = 'root';
$password = 'root';

# 连接数据库
$DB = new PDO($dsn, $username, $password);
$DB->query('SET NAMES utf8;');
# 创建预处理SQL语句
$statement = $DB->prepare('SELECT * FROM niu_user WHERE name = ? AND id >= ?');
# 创建绑定内容
$name = '小黄牛';
$age  = 17;
# 绑定参数
$statement->bindParam(1, $name);
$statement->bindParam(2, $age); 
# 下面修改绑定内容的变量，同时会对预处理语句绑定的内容进行修改
$name = '你妹';
$age  = 20;
```
###E、执行预处理后的SQL语句
现在剩下的唯一要做的事情，就是执行我们绑定参数后的SQL语句，
PDOStatement对象，提供了一个`execute()`成员函数，用于执行预处理后的SQL语句。

为了避免使用`bindValue()`或`bindParam()`绑定参数后带来的参数未设置 或 参数被修改的风险，`execute()`成员函数，还支持使用一维数组的方式绑定参数，像这样：
```php
<?php
# DSN句柄
$dsn      = 'mysql:dbname=love_niu;host=127.0.0.1;port=3306';
$username = 'root';
$password = 'root';

# 连接数据库
$DB = new PDO($dsn, $username, $password);
$DB->query('SET NAMES utf8;');
# 创建预处理SQL语句
$statement = $DB->prepare('SELECT * FROM niu_user WHERE name = :name AND id >= :age');
# 执行的同时，绑定参数
$statement->execute([ ':name'=>'小黄牛', ':age'=>17 ]);
# 获得查询结果
var_dump($statement->fetchAll());
```
###12、PDO事务处理？
PDO的事务处理过程与Mysqli一样，主要分为：
```
1、事务开启
2、事务提交
3、事务回滚
```
但与Mysqli有一点不同的是，PDO不需要手动关闭事务，提交完事务或回滚后，事务将会自动关闭。

####A、打开事务
在开发中，我们使用PDO类的`beginTransaction()`成员函数，开启一个事务，使用格式如下：
```
$DB->beginTransaction();
```

####B、提交事务
使用PDO类的`commit()`成员函数，提交一个事务(同时关闭)，使用格式如下：
```
$DB->commit();
```

####C、回滚事务
使用PDO类的`rollBack()`成员函数，回滚一个事务(同时关闭)，使用格式如下：
```
$DB->rollBack();
```
####D、完整案例
```php
<?php
# DSN句柄
$dsn      = 'mysql:dbname=love_niu;host=127.0.0.1;port=3306';
$username = 'root';
$password = 'root';

# 连接数据库
$DB = new PDO($dsn, $username, $password);
$DB->query('SET NAMES utf8;');
# 开启一个事务
$DB->beginTransaction();

try {
    # 创建预处理SQL语句
    $res = $DB->exec('INSERT INTO niu_user (user, nice) VALUES ("qwe", "小黄牛")');
} catch (PDOException $e) {
    # 错误回滚事务
    $DB->rollBack();
    echo '错误信息:' . $e->getMessage();
}
```

> 注意，数据库的事务处理，对删除表的监听并不友好，所以请勿对删表、改表的SQL语句进行事务操作。

已有0条评论

添加新评论☺

如果认为本文对您有所帮助请赞助本站

支付宝扫一扫赞助

已有0条评论

添加新评论☺