PHP PDO 执行 SQL 语句

PHP Data Objects (PDO) 扩展提供了一个数据访问抽象层，使得 PHP 应用程序与不同类型的数据库进行通信变得更加容易。这篇教程将详细介绍如何使用 PDO 执行 SQL 语句。

前提条件

PHP 5.0 或更高版本
已安装并启用了 PDO 扩展
数据库服务器（如 MySQL，PostgreSQL 等）

创建数据库连接

首先，你需要创建一个到数据库的 PDO 实例。下面是一个基本的示例：

$dsn = 'mysql:dbname=testdb;host=127.0.0.1';
$user = 'username';
$password = 'password';

try {
    $pdo = new PDO($dsn, $user, $password);
} catch (PDOException $e) {
    echo 'Connection failed: ' . $e->getMessage();
}

在这个例子中，我们使用了 MySQL 数据库，你可以根据自己的需求替换为其他类型的数据库。$dsn 包含了连接数据库所需的信息，如数据库名称、主机地址等。

执行查询语句

一旦建立了数据库连接，你就可以使用 query() 方法执行 SQL 查询语句：

$sql = 'SELECT * FROM users';
$stmt = $pdo->query($sql);

if ($stmt === false) {
    die(print_r($pdo->errorInfo(), true));
}

while ($row = $stmt->fetch(PDO::FETCH_ASSOC)) {
    // 处理查询结果集中的每一行数据
}

在这个例子中，我们执行了一个简单的 SELECT 语句来获取 users 表中的所有记录。fetch() 方法用于遍历结果集中的每一行数据。

使用预处理语句

为了防止 SQL 注入攻击，更好的做法是使用预处理语句和绑定参数：

$sql = 'SELECT * FROM users WHERE id = :id';
$stmt = $pdo->prepare($sql);

if ($stmt === false) {
    die(print_r($pdo->errorInfo(), true));
}

$stmt->execute(['id' => $userId]);

while ($row = $stmt->fetch(PDO::FETCH_ASSOC)) {
    // 处理查询结果集中的每一行数据
}

在这个例子中，我们使用了 prepare() 方法创建了一个预处理语句。然后，我们将参数绑定到占位符上，并使用 execute() 方法执行该语句。这样做的好处是可以防止 SQL 注入攻击，提高应用程序的安全性。

错误处理

在处理数据库操作时，错误处理是非常重要的。你可以使用 PDOException 类捕获并处理异常：

try {
    // 执行 SQL 语句...
} catch (PDOException $e) {
    echo 'Error: ' . $e->getMessage();
}

通过这种方式，你可以捕获并处理与数据库操作相关的任何错误或异常。

总结

本教程详细介绍了如何使用 PHP PDO 执行 SQL 语句。我们首先创建了一个到数据库的连接，然后演示了如何执行查询语句和预处理语句。最后，我们讨论了错误处理的重要性。希望本教程能帮助你更好地使用 PDO 在 PHP 应用程序中与数据库进行交互。