当前位置：极客教程 > PHP > PHP 教程 > PHP PDO 教程

PHP PDO 教程

在本教程中，我们展示了如何在 PHP PDO 中对数据库进行编程。

PHP PDO

PHP 数据对象（PDO）定义了用于访问 PHP 中数据库的轻量级接口。 它提供了一个数据访问抽象层，用于在 PHP 中使用数据库。 它定义了用于各种数据库系统的一致 API。

PHP PDO 类

PDO表示 PHP 与数据库服务器之间的连接。 PDOStatement代表准备好的语句，在执行该语句后，代表关联的结果集。 PDOException表示 PDO 引发的错误。

MySQL 数据库

在本教程中，我们将使用 MySQL 数据库。

countries_mysql.sql

DROP TABLE IF EXISTS countries;
CREATE TABLE countries(id BIGINT NOT NULL PRIMARY KEY AUTO_INCREMENT, 
    name VARCHAR(255), population INT);

INSERT INTO countries(name, population) VALUES('China', 1382050000);
INSERT INTO countries(name, population) VALUES('India', 1313210000);
INSERT INTO countries(name, population) VALUES('USA', 324666000);
INSERT INTO countries(name, population) VALUES('Indonesia', 260581000);
INSERT INTO countries(name, population) VALUES('Brazil', 207221000);
INSERT INTO countries(name, population) VALUES('Pakistan', 196626000);
INSERT INTO countries(name, population) VALUES('Nigeria', 186988000);
INSERT INTO countries(name, population) VALUES('Bangladesh', 162099000);
INSERT INTO countries(name, population) VALUES('Nigeria', 186988000);
INSERT INTO countries(name, population) VALUES('Russia', 146838000);
INSERT INTO countries(name, population) VALUES('Japan', 126830000);

这些 SQL 命令创建一个countries表。

PHP PDO 查询

PDO query()在单个函数调用中执行一条 SQL 语句，返回该语句返回的结果集（如果有）。

version.php

<?php

dsn = "mysql:host=localhost;dbname=mydb";user = "user12";
passwd = "12user";pdo = new PDO(dsn,user, passwd);stm = pdo->query("SELECT VERSION()");version = stm->fetch();

echoversion[0] . PHP_EOL;

该示例返回 MySQL 的版本。

$dsn = "mysql:host=localhost;dbname=mydb";
$user = "user12";
$passwd = "12user";

这些变量用于创建到数据库的连接字符串。 dsn是数据源名称，其中包含连接到数据库所需的信息。

$pdo = new PDO($dsn, $user, $passwd);

创建一个新的PDO对象，我们向构造函数传递数据源名称以及用户名和密码。 PDO类表示 PHP 与数据库服务器之间的连接。

$stm = $pdo->query("SELECT VERSION()");

query()方法在单个函数调用中执行一条 SQL 语句，它返回结果集。

$version = $stm->fetch();

PDO 语句的fetch()方法从结果集中获取下一行，在我们的例子中，它是 MySQL 的一个版本。

echo $version[0] . PHP_EOL;

$version是一个数组，我们得到它的第一价值。

$ php version.php
5.7.22-0ubuntu0.16.04.1

PHP PDO 执行

PDO exec()执行一条 SQL 语句并返回受影响的行数。

affected_rows.php

<?php

dsn = "mysql:host=localhost;dbname=mydb";user = "user12";
passwd = "12user";pdo = new PDO(dsn,user, passwd);id = 12;

nrows =pdo->exec("DELETE FROM countries WHERE id IN (1, 2, 3)");

echo "The statement affected $nrows rows\n";

该代码示例将删除三行，它打印受影响的行数。

$nrows = $pdo->exec("DELETE FROM countries WHERE id IN (1, 2, 3)");

在此 SQL 语句中，我们删除 ID 为 1、2 和 3 的行，已删除的行数存储在$nrows变量中。

echo "The statement deleted $nrows rows\n";

我们打印已删除的行数。

PHP PDO 提取样式

提取样式参数控制如何将下一行返回给调用方。 例如，PDO::FETCH_ASSOC返回按列名索引的数组，PDO::FETCH_NUM返回按列号索引的数组，PDO::FETCH_BOTH返回按列名和索引列号索引的数组。 默认的获取样式为PDO::FETCH_BOTH。

fetch_style_num.php

<?php

dsn = "mysql:host=localhost;dbname=mydb";user = "user12";
passwd = "12user";pdo = new PDO(dsn,user, passwd);stm = pdo->query("SELECT * FROM countries");rows = stm->fetchAll(PDO::FETCH_NUM);

foreach(rows as row) {

    printf("row[0] row[1]row[2]\n");
}

在此代码示例中，我们在索引数组中获取数据。

$stm = $pdo->query("SELECT * FROM countries");

我们从countries表中选择所有数据。

$rows = $stm->fetchAll(PDO::FETCH_NUM);

我们将PDO:FETCH_NUM样式传递给fetchAll()方法。

foreach(rows asrow) {

    printf("row[0]row[1] $row[2]\n");
}

我们遍历$rows数组并打印字段，通过数组索引访问这些字段。

fetch_style_assoc.php

<?php

dsn = "mysql:host=localhost;dbname=mydb";user = "user12";
passwd = "12user";pdo = new PDO(dsn,user, passwd);stm = pdo->query("SELECT * FROM countries");rows = stm->fetchAll(PDO::FETCH_ASSOC);

foreach(rows as row) {

    printf("{row['id']} {row['name']} {row['population']}\n");
}

在此示例中，我们以关联数组的形式获取数据。

$rows = $stm->fetchAll(PDO::FETCH_ASSOC);

在fetchAll()方法中，我们使用PDO::FETCH_ASSOC样式。

PHP PDO 参数绑定

SQL 语句通常是动态构建的。 用户提供一些输入，并且此输入已内置到语句中。 每当我们处理来自用户的输入时，我们都必须谨慎。 它具有一些严重的安全隐患。 动态构建 SQL 语句的推荐方法是使用参数绑定。

PDO 包含bindParam()和bindValue()方法来创建参数化查询。

PDO 允许将数据绑定到问号或命名的占位符。

parameterized_query.php

<?php

dsn = "mysql:host=localhost;dbname=mydb";user = "root";
passwd = "andrea";pdo = new PDO(dsn,user, passwd);id = 12;

stm =pdo->prepare("SELECT * FROM countries WHERE id = ?");
stm->bindValue(1,id);
stm->execute();row = stm->fetch(PDO::FETCH_ASSOC);

echo "Id: " .row['id'] . PHP_EOL;
echo "Name: " . row['name'] . PHP_EOL;
echo "Population: " .row['population'] . PHP_EOL;

在示例中，我们使用bindValue()创建参数化查询，我们使用问号占位符。

$id = 12;

此输入来自用户。

$stm = $pdo->prepare("SELECT * FROM countries WHERE id = ?");
$stm->bindValue(1, $id);
$stm->execute();

select 语句从表中获取特定行。 我们将带有bindValue()的值绑定到问号占位符。

在第二种情况下，我们使用bindParam()。

parameterized_query2.php

<?php

dsn = "mysql:host=localhost;dbname=mydb";user = "user12";
passwd = "12user";pdo = new PDO(dsn,user, passwd);id = 12;

stm =pdo->prepare("SELECT * FROM countries WHERE id = :id");
stm->bindParam(":id",id, PDO::PARAM_INT);
stm->execute();row = stm->fetch(PDO::FETCH_ASSOC);

echo "Id: " .row['id'] . PHP_EOL;
echo "Name: " . row['name'] . PHP_EOL;
echo "Population: " .row['population'] . PHP_EOL;

该示例选择并打印特定的行。

$stm = $pdo->prepare("SELECT * FROM countries WHERE id = :id");
$stm->bindParam(":id", $id, PDO::PARAM_INT);
$stm->execute();

这次我们使用命名占位符（:id）和bindParam()。

PHP PDO 最后插入的行 ID

PDO lastInsertId()方法返回最后插入的行 ID。

create_table.php

<?php

dsn = "mysql:host=localhost;dbname=mydb";user = "user12";
passwd = "12user";pdo = new PDO(dsn,user, passwd);sql = "CREATE TABLE words(id INT PRIMARY KEY AUTO_INCREMENT,
    word VARCHAR(255))";

ret =pdo->exec(sql);pdo->exec("INSERT INTO words(word) VALUES ('pen')");
pdo->exec("INSERT INTO words(word) VALUES ('bum')");pdo->exec("INSERT INTO words(word) VALUES ('hum')");
pdo->exec("INSERT INTO words(word) VALUES ('den')");rowid = pdo->lastInsertId();

echo "The last inserted row id is:rowid\n";

在示例中，我们创建一个新表。 创建表后，我们用lastInsertId()找出最后插入的 ID。

$ php create_table.php
The last inserted row id is: 4


mysql> select * from words;
+----+------+
| id | word |
+----+------+
|  1 | pen  |
|  2 | bum  |
|  3 | hum  |
|  4 | den  |
+----+------+
4 rows in set (0.01 sec)

PHP PDO 事务

事务是针对一个或多个数据库中数据的数据库操作的基本单位。 事务中所有 SQL 语句的影响可以全部提交给数据库，也可以全部回滚。

PDO beginTransaction()启动新事务。 PDO commit()提交事务。 PDO rollback()将回滚事务。

transaction.php

<?php

dsn = "mysql:host=localhost;dbname=mydb";user = "user12";
passwd = "12user";pdo = new PDO(dsn,user, passwd);

try {pdo->beginTransaction();
    stm =pdo->exec("INSERT INTO countries(name, population) VALUES ('Iraq', 38274000)");
    stm =pdo->exec("INSERT INTO countries(name, population) VALUES ('Uganda', 37673800)");

    pdo->commit();

} catch(Exceptione) {

    pdo->rollback();
    throwe;
}

在示例中，我们将两个新的国家/地区添加到数据库表中。 将 insert 语句放置在事务中：要么执行两个插入，要么都不执行。

} catch(Exception e) {pdo->rollback();
    throw $e;
}

如果发生异常，我们回滚事务：没有数据写入数据库。 我们抛出异常，以便异常处理继续按常规方式进行。

PHP PDO 获取元数据

元数据是有关数据库中数据的信息。 元数据包含有关我们存储数据的表和列的信息。 SQL 语句影响的行数是元数据。 结果集中返回的行数和列数也是元数据。

column_count.php

<?php

dsn = "mysql:host=localhost;dbname=mydb";user = "user12";
passwd = "12user";pdo = new PDO(dsn,user, passwd);stm = pdo->query("SELECT name, population FROM countries WHERE id=1");ncols = stm->columnCount();

echo "The result set containsncols columns\n";

在示例中，我们使用columnCount()方法打印结果集中的列数。

getAttribute()方法检索数据库连接属性。

connection_attributes.php

<?php

dsn = "mysql:host=localhost;dbname=mydb";user = "user12";
passwd = "12user";pdo = new PDO(dsn,user, passwd);driver = pdo->getAttribute(PDO::ATTR_DRIVER_NAME);server_version = pdo->getAttribute(PDO::ATTR_SERVER_VERSION);autocommit_mode = pdo->getAttribute(PDO::ATTR_AUTOCOMMIT);

echo "Driver:driver\n";
echo "Server version: server_version\n";
echo "Autocommit mode:autocommit_mode\n";

在示例中，我们使用getAttribute()方法获取驱动程序名称，服务器版本和自动提交模式。

$ php connection_attributes.php
Driver: mysql
Server version: 5.7.22-0ubuntu0.16.04.1
Autocommit mode: 1

在以下示例中，我们打印列元数据。 列元数据通过getColumnMeta()方法检索。

column_metadata.php

<?php

dsn = "mysql:host=localhost;dbname=mydb";user = "user12";
passwd = "12user";pdo = new PDO(dsn,user, passwd);stm = pdo->query("SELECT * FROM countries WHERE id=1");col_meta = stm->getColumnMeta(0);

echo "Table name: {col_meta["table"]}\n";
echo "Column name: {col_meta["name"]}\n";
echo "Column length: {col_meta["len"]}\n";
echo "Column flags: {col_meta["flags"][0]} {col_meta["flags"][1]} \n";

在示例中，我们获取列表，名称，长度和标志。

$ php column_metadata.php
Table name: countries
Column name: id
Column length: 20
Column flags: not_null primary_key

您可能也对以下相关教程感兴趣： PHP SQLite3 教程， CakePHP 数据库教程， Doctrine QueryBuilder 教程， PHP 文件系统 ， Twig 教程， PHP Faker 教程， PHP 教程。

Python教程

Python 教程

Python 教程
Tkinter 教程

Tkinter 教程
Pandas 教程

Pandas 教程
NumPy 教程

NumPy 教程
Flask 教程

Flask 教程
Django 教程

Django 教程
PySpark 教程

PySpark 教程
wxPython 教程

wxPython 教程
SymPy 教程

SymPy 教程
Seaborn 教程

Seaborn 教程
SciPy 教程

SciPy 教程
RxPY 教程

RxPY 教程
Pycharm 教程

Pycharm 教程
Pygame 教程

Pygame 教程
PyGTK 教程

PyGTK 教程
PyQt 教程

PyQt 教程
PyQt5 教程

PyQt5 教程
PyTorch 教程

PyTorch 教程
Matplotlib 教程

Matplotlib 教程
Web2py 教程

Web2py 教程
BeautifulSoup 教程

BeautifulSoup 教程

Java教程

Java 教程

Java 教程

Web教程

HTML 教程

HTML 教程
CSS 教程

CSS 教程
CSS3 教程

CSS3 教程
jQuery 教程

jQuery 教程
Ajax 教程

Ajax 教程
AngularJS 教程

AngularJS 教程
TypeScript 教程

TypeScript 教程
WordPress 教程

WordPress 教程
Laravel 教程

Laravel 教程
Next.js 教程

Next.js 教程
PhantomJS 教程

PhantomJS 教程
Three.js 教程

Three.js 教程
Underscore.JS 教程

Underscore.JS 教程
WebGL 教程

WebGL 教程
WebRTC 教程

WebRTC 教程
VueJS 教程

VueJS 教程

数据库教程

SQL 教程

SQL 教程
MySQL 教程

MySQL 教程
MongoDB 教程

MongoDB 教程
PostgreSQL 教程

PostgreSQL 教程
SQLite 教程

SQLite 教程
Redis 教程

Redis 教程
MariaDB 教程

MariaDB 教程

图形图像教程

Vulkan 教程

Vulkan 教程
OpenCV 教程

OpenCV 教程

大数据教程

R语言 教程

R语言 教程

开发工具教程

Git 教程

Git 教程
VSCode 教程

VSCode 教程
Docker 教程

Docker 教程
Gerrit 教程

Gerrit 教程
Excel 教程

Excel 教程

计算机教程

Go语言 教程

Go语言 教程
C++ 教程

C++ 教程

PHP 教程