PHP数据库抽象层--PDO（PHP Data Object） [一]

2023-07-26 14:45:40

1、简介：（PDO数据库访问抽象层，统一各种数据库的访问接口）

PHP 数据对象（PDO）扩展为PHP访问数据库定义了一个轻量级的一致接口。实现 PDO 接口的每个数据库驱动可以公开具体数据库的特性作为标准扩展功能。注意利用 PDO 扩展自身并不能实现任何数据库功能；必须使用一个具体数据库的 PDO 驱动来访问数据库服务。
PDO 提供了一个数据访问抽象层，这意味着，不管使用哪种数据库，都可以用相同的函数（方法）来查询和获取数据。 PDO 不不提供数据库抽象层；它不会重写 SQL，也不会模拟缺失的特性。如果需要的话，应该使用一个成熟的抽象层。
（http://php.net/manual/zh/intro.pdo.php）

2、特点

3、开启PDO

在 php.ini 中的 php_pdo.dll后面启用。例如：

extension=php_pdo_mysql.dll
extension=php_pdo_pgsql.dll

DLL 文件应该在系统的extension_dir 中存在。更改 php.ini 文件后需要重启 PHP 服务才能使新的配置指令生效。

4、PDO连接数据库

更加详细的信息：http://php.net/manual/zh/pdo.construct.php

4.1、通过参数形式

1<?php
2// 通过参数形式连接数据库
3try{
4 $dsn ='mysql:host=localhost;dbname=pdotest';
5 $name ='root';
6 $passwd ='root';
7 $pdo =new PDO($dsn, $name, $passwd);
8 var_dump($pdo);
9}catch(PDOException $e){
10 echo $e->getMessage();
11}
12

4.2、通过URI形式

创建pdo_uri_conn.txt文件

mysql:dbname=pdotest;host=localhost;

Uri连接数据库

<?php
// 通过参数形式连接数据库
try{
$dsn ='uri:/var/www/html/php-code/pdo/pdo_uri_conn.txt';
$name ='root';
$passwd ='root';
$pdo =new PDO($dsn, $name, $passwd);
var_dump($pdo);
}catch(PDOException $e){
echo $e->getMessage();
}

4.3、通过配置php.ini文件的形式连接数据库

在你的php.ini文件的加入这一句；注意重启Apache服务器

链接数据库

注意：

连接数据成功后，返回一个 PDO 类的实例给脚本，此连接在 PDO 对象的生存周期中保持活动。要想关闭连接，需要销毁对象以确保所有剩余到它的引用都被删除，可以赋一个 NULL 值给对象变量。如果不明确地这么做，PHP 在脚本结束时会自动关闭连接。

<?php
......
// 现在运行完成，在此关闭连接
$dbh =null;

5、PDO对象使用

5.1、exec（）方法

exec（）方法执行一条sql语句，返回受修改或删除 SQL 语句影响的行数。如果没有受影响的行，则 PDO::exec() 返回 0

注意：PDO::exec() 不会从一条 SELECT 语句中返回结果。对于在程序中只需要发出一次的 SELECT 语句，可以考虑使用 PDO::query()。

5.1.1、使用 exec（）方法完成建表

1<?php
2// 通过参数形式连接数据库
3try{
4 $dsn ='mysql:host=localhost;dbname=pdotest';
5 $name ='root';
6 $passwd ='root';
7 $pdo =new PDO($dsn, $name, $passwd);
8 $sql =<<<EOF
9 CREATE TABLE IF NOT EXISTS user(
10 id INT UNSIGNED AUTO_INCREMENT PRIMARY KEY,
11 name VARCHAR(20) NOT NULL UNIQUE,
12 passwd VARCHAR(32) NOT NULL,
13 email VARCHAR(30) NOT NULL
14);
15 EOF;
16// exec 对于没有受影响的行数将返回0
17 $res = $pdo->exec($sql);
18 var_dump($res);
19// 现在运行完成，在此关闭连接
20 $pdo =null;
21}catch(PDOException $e){
22 echo $e->getMessage();
23}
24
25

5.1.2、使用exec（）插入数据

1<?php
2// 通过参数形式连接数据库
3try{
4 $dsn ='mysql:host=localhost;dbname=pdotest';
5 $name ='root';
6 $passwd ='root';
7 $pdo =new PDO($dsn, $name, $passwd);
8 $sql ="
9 INSERT INTO user (name, passwd, email)
10 VALUES('wangxb', MD5('123'), 'wangxb@mail.com'),
11 ('wangxb1', MD5('123'), 'wangxb@mail.com'),
12 ('wangxb2', MD5('123'), 'wangxb@mail.com')
13 ";
14// exec 对于没有受影响的行数将返回0
15 $res = $pdo->exec($sql);
16 var_dump($res);
17// 返回最后插入行的ID或序列值
18 echo $pdo->lastInsertId();
19// 现在运行完成，在此关闭连接
20 $pdo =null;
21}catch(PDOException $e){
22 echo $e->getMessage();
23}
24

5.1.3、exec（）执行更新和删除与插入类似，这里不再赘述。

5.1.4、exec（）方法对select是没有作用的，因为没有受影响的行数，虽然这么做没有什么程序语法上的错误，但是执行select时将返回 int（0），取不出我们想要的任何东西，所以exec不适合执行select语句。

5.2、errorCode（）和errorInfo（）方法返回错误信息

PDO::errorCode — 获取跟数据库句柄上一次操作相关的 SQLSTATE

PDO::errorInfo — 返回错误信息的一个数组

0: SQLSTATE error code

1: specific error code.

2: specific error message

1<?php

2/*

3 * 使用errorCode 和 errorInfo 两个方法显示错误信息

1 <?php

2 /*

3 * 使用errorCode 和 errorInfo 两个方法显示错误信息

4 */

5try{

6 $dsn ='mysql:host=localhost;dbname=pdotest';

7 $name ='root';

8 $passwd ='root';

9 $pdo =new PDO($dsn, $name, $passwd);

10// 我们这里插入的一个没有的表 user123 中

11 $sql ="

12 INSERT INTO user123 (name, passwd, email)

13 VALUES('wangxb', MD5('123'), 'wangxb@mail.com')

14 ";

15//

16 $res = $pdo->exec($sql);

17if(false=== $res){

18// errorCode 获取跟数据库句柄上一次操作相关的 SQLSTATE

19 echo $pdo->errorCode();

20print"\n";

21// errorInfo 返回一个错误信息数据：

22// 0: SQLSTATE error code

23// 1: specific error code.

24// 2: specific error message

25 print_r($pdo->errorInfo());

26returnfalse;

27}

28 var_dump($res);

29// 返回最后插入行的ID或序列值

30 echo "最后一天插入的信息ID：".$pdo->lastInsertId();

31// 现在运行完成，在此关闭连接

32 $pdo =null;

33}catch(PDOException $e){

34 echo $e->getMessage();

35}

36

运行：

我们在mysql客户端执行相同语句

可以看到 errorInfo（）返回的信息其实是将mysql错误信息以数组的形式返回

5.3、query（）方法执行查询

query（）方法虽然可以执行任何sql语句，但是更多的时候是执行select，对于insert、update、delete等使用exec（）方法

1<?php
2/*
3 * 使用exec方法执行插入语句
4 */
5// 通过参数形式连接数据库
6try{
7 $dsn ='mysql:host=localhost;dbname=pdotest';
8 $name ='root';
9 $passwd ='root';
10 $pdo =new PDO($dsn, $name, $passwd);
11//$sql = "SELECT * FROM user WHERE id=12";
12 $sql ="SELECT * FROM user";
13// query 方法执行将返回一个PDOStatment对象
14 $stmt = $pdo->query($sql);
15if(!$pdo &&!$stmt){
16 var_dump($pdo->errorInof());
17}
18// 对于query返回的PDOStatment对象，我们同样可是使用foreach方法来遍历数据其中的数据
19foreach($stmt as $row){
20 var_dump($row);
21 echo '<hr>';
22}
23
24//
25 echo '------------------- ';
26 var_dump($stmt->fetch());
27 echo '------------------- ';
28
29// prepare方法是为execute准备一个statmentObj
30 $sth = $pdo -> prepare ("SELECT name, id FROM user");
31 $sth -> execute ();
32 echo '++++++++++++++++++++++++';
33 var_dump($sth->fetch());
34 echo '++++++++++++++++++++++++';
35 var_dump($stmt);
36// 现在运行完成，在此关闭连接
37 $pdo =null;
38}catch(PDOException $e){
39 echo $e->getMessage();
40}
41
42
43

5.4、prepare（）和execute（）方法

1<?php
2/*
3 * 使用exec方法执行插入语句
4 */
5// 通过参数形式连接数据库
6try{
7 $dsn ='mysql:host=localhost;dbname=pdotest';
8 $name ='root';
9 $passwd ='root';
10 $pdo =new PDO($dsn, $name, $passwd);
11
12/*
13 * 使用prepare和execute方法形式
14 */
15 $id1 =12;
16 $id2 =13;
17// 利用占位符形式
18 $sql ="SELECT * FROM user WHERE id=? OR id=?";
19 $sth = $pdo -> prepare ($sql);
20 $sth -> execute(array($id1, $id2));
21 var_dump($sth->fetchAll(PDO::FETCH_ASSOC));
22
23 echo '<hr>';
24// 使用参数形式
25 $sql_1 ="SELECT id, name FROM user WHERE id= :id";
26 $sth_1 = $pdo -> prepare ($sql_1);
27 $sth_1 -> execute(array('id'=>$id1));
28 var_dump($sth_1->fetchAll(PDO::FETCH_ASSOC));
29
30 echo '<hr>';
31// 使用bindParam方式
32 $sql_2 ="SELECT * FROM user WHERE id=? OR id=?";
33 $sth_2 = $pdo -> prepare ($sql_2);
34 $sth_2->bindParam(1, $id1, PDO::PARAM_INT);
35 $sth_2->bindParam(2, $id2, PDO::PARAM_INT);
36 $sth_2 -> execute();
37 var_dump($sth_2->fetchAll(PDO::FETCH_ASSOC));
38
39// 现在运行完成，在此关闭连接
40 $pdo =null;
41}catch(PDOException $e){
42 echo $e->getMessage();
43}
44

5.5、getAttribute ( int $attribute ) 和 setAttribute ( int $attribute , mixed $value ) 方法

1<?php
2/*
3 * 使用exec方法执行插入语句
4 */
5// 通过参数形式连接数据库
6try{
7 $dsn ='mysql:host=localhost;dbname=pdotest';
8 $name ='root';
9 $passwd ='root';
10 $pdo =new PDO($dsn, $name, $passwd);
11 $sql ="SELECT * FROM user";
12 echo "自动提交：".$pdo->getAttribute(PDO::ATTR_AUTOCOMMIT);
13 echo ' ';
14 echo 'PDO默认的错误处理模式：'.$pdo->getAttribute(PDO::ATTR_ERRMODE);
15
16 echo ' ';
17//现在我们重设自动提交
18 $pdo->setAttribute(PDO::ATTR_AUTOCOMMIT,0);
19 echo "重设后的自动提交：".$pdo->getAttribute(PDO::ATTR_AUTOCOMMIT);
20
21// 现在运行完成，在此关闭连接
22 $pdo =null;
23
24// 我们也可以在new一个PDO对象时，利用传递参数中的第四个参数（可省略）来设置我们此次连接数据库时的各项参数
25// (我们可以在这里找到所有的设置项：http://php.net/manual/zh/pdo.constants.php)
26// 就像下面这样
27 $dsn ='mysql:host=localhost;dbname=pdotest';
28 $name ='root';
29 $passwd ='root';
30 $option = array(
31 PDO::ATTR_AUTOCOMMIT => O,
32 PDO::ATTR_ERRMODE => PDO::ERRMODE_EXCEPTION
33);
34 $pdo =new PDO($dsn, $name, $passwd, $option);
35 echo '<hr/>';
36 echo '使用option设置后';
37 echo ' ';
38 echo "自动提交：".$pdo->getAttribute(PDO::ATTR_AUTOCOMMIT);
39 echo ' ';
40 echo 'PDO错误处理模式：'.$pdo->getAttribute(PDO::ATTR_ERRMODE);
41}catch(PDOException $e){
42 echo $e->getMessage();
43}
44

来自为知笔记(Wiz)

码农公寓

相关文章