PHP使用PDO连接MySQL数据库的代码示例-精创网络云防护

帮助文档
PHP使用PDO连接MySQL数据库的代码示例
来源：www.jcwlyf.com更新时间：2025-01-30
在现代Web开发中，PHP是一种非常常见的服务器端编程语言，而MySQL则是最流行的数据库管理系统之一。为了让PHP与MySQL数据库进行交互，我们通常使用一种称为PDO（PHP Data Objects）的数据库访问方法。PDO不仅能够支持多种数据库，还能提供更高的安全性和灵活性。在这篇文章中，我们将详细介绍如何在PHP使用PDO连接MySQL数据库，帮助你实现更加高效、安全的数据库操作。
一、什么是PDO？
PDO（PHP Data Objects）是PHP提供的一种数据库抽象层，旨在统一不同数据库的访问接口，简化数据库操作。PDO本身不直接提供数据库操作的实现，而是通过数据库驱动来与特定类型的数据库进行通信。例如，PDO支持MySQL、PostgreSQL、SQLite等多种数据库管理系统。
与传统的MySQLi或mysql扩展不同，PDO支持面向对象编程，并且能够提供更高的可移植性。通过PDO，你只需要修改数据库连接字符串，就可以在不同的数据库之间切换。更重要的是，PDO对SQL注入攻击具有更强的防护能力，这使得它成为现代PHP开发中处理数据库操作的推荐方式。
二、使用PDO连接MySQL数据库
要在PHP中使用PDO连接MySQL数据库，首先需要确保你的PHP环境已经启用PDO扩展。PDO扩展是PHP自带的，如果你使用的是较新的PHP版本，通常它默认已经启用。
下面是一个简单的PDO连接MySQL数据库的示例代码：
```
<?php
// 数据库配置信息
$host = 'localhost'; // 数据库主机
$dbname = 'test_db'; // 数据库名称
$username = 'root';  // 数据库用户名
$password = '';      // 数据库密码

try {
    // 创建PDO实例，连接数据库
    $dsn = "mysql:host=$host;dbname=$dbname;charset=utf8"; // DSN（数据源名称）
    $pdo = new PDO($dsn, $username, $password);

    // 设置错误模式为异常
    $pdo->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);

    echo "数据库连接成功！";
} catch (PDOException $e) {
    echo "连接失败: " . $e->getMessage();
}
?>
```
在上面的代码中，我们通过创建PDO实例来连接MySQL数据库。DSN（数据源名称）包含了数据库类型、主机、数据库名称和字符集等信息。使用try-catch语句块可以捕获连接过程中可能发生的异常，确保程序在出错时能够给出明确的提示。
三、PDO连接中的常见配置选项
在创建PDO实例时，我们可以为PDO对象配置不同的选项，以控制数据库连接的行为。以下是一些常见的PDO配置选项：
```
<?php
// 设置错误模式为异常
$pdo->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);

// 设置字符集为UTF-8
$pdo->setAttribute(PDO::MYSQL_ATTR_INIT_COMMAND, "SET NAMES 'UTF8'");

// 设置持久化连接
$pdo->setAttribute(PDO::ATTR_PERSISTENT, true);
?>
```
四、使用PDO执行SQL语句
PDO提供了多种执行SQL语句的方法，包括执行普通的SELECT、INSERT、UPDATE和DELETE等语句。以下是几种常见的操作：
1. 执行SELECT查询
PDO执行SELECT语句时，我们通常使用prepare和execute方法来预处理和执行SQL查询，这样可以防止SQL注入风险。以下是一个执行SELECT查询并返回结果的示例：
```
<?php
$sql = "SELECT * FROM users WHERE age > :age"; // 使用占位符
$stmt = $pdo->prepare($sql);

// 绑定参数
$stmt->bindParam(':age', $age, PDO::PARAM_INT);

// 设置参数值并执行查询
$age = 25;
$stmt->execute();

// 获取查询结果
$results = $stmt->fetchAll(PDO::FETCH_ASSOC);

foreach ($results as $row) {
    echo "用户名: " . $row['username'] . "
";
    echo "年龄: " . $row['age'] . "

";
}
?>
```
在上面的代码中，我们使用了预处理语句和占位符来绑定查询参数。通过调用"bindParam()"方法，参数":age"将会在执行查询时绑定到实际的变量值。
2. 执行INSERT、UPDATE和DELETE语句
除了SELECT查询，PDO还支持INSERT、UPDATE和DELETE等数据库修改操作。与SELECT类似，INSERT、UPDATE和DELETE通常使用预处理语句来执行。以下是一个执行INSERT语句的示例：
```
<?php
$sql = "INSERT INTO users (username, age) VALUES (:username, :age)";
$stmt = $pdo->prepare($sql);

// 绑定参数
$stmt->bindParam(':username', $username, PDO::PARAM_STR);
$stmt->bindParam(':age', $age, PDO::PARAM_INT);

// 设置参数值并执行插入操作
$username = 'john_doe';
$age = 28;
$stmt->execute();

echo "数据插入成功！";
?>
```
在此代码中，我们首先通过"prepare()"方法预处理了INSERT语句，随后使用"bindParam()"方法绑定了查询参数，最后通过"execute()"方法执行了插入操作。
五、使用事务确保数据一致性
在进行多个数据库操作时，事务（transaction）是非常有用的，它可以确保操作要么全部成功，要么全部失败，从而保持数据库的一致性。PDO提供了对事务的支持。
以下是一个使用PDO事务的示例：
```
<?php
try {
    // 开始事务
    $pdo->beginTransaction();

    // 执行多条SQL操作
    $pdo->exec("UPDATE users SET age = 30 WHERE username = 'john_doe'");
    $pdo->exec("UPDATE users SET age = 25 WHERE username = 'jane_doe'");

    // 提交事务
    $pdo->commit();
    echo "事务提交成功！";
} catch (Exception $e) {
    // 出现异常时回滚事务
    $pdo->rollBack();
    echo "事务回滚: " . $e->getMessage();
}
?>
```
在上面的代码中，我们通过"beginTransaction()"开始了一个事务，然后执行了两条UPDATE语句。如果没有出现任何异常，就通过"commit()"提交事务。如果有任何异常发生，"rollBack()"方法将会回滚所有的操作，保证数据的原子性。
六、PDO的错误处理和异常捕获
PDO提供了多种错误处理模式，可以根据需要选择不同的错误处理策略。最常用的错误处理模式是异常模式，在这种模式下，如果发生数据库错误，PDO会抛出异常。
在创建PDO实例时，可以通过"setAttribute()"方法设置错误模式，以下是设置为异常模式的示例：
```
<?php
$pdo->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
?>
```
当启用异常模式后，如果发生错误，PDO会抛出"PDOException"异常。你可以使用try-catch语句来捕获异常并进行处理，从而避免程序崩溃。
七、总结
PDO提供了一个灵活、安全的数据库访问层，使得PHP开发者可以轻松地与MySQL数据库进行交互。通过预处理语句和事务控制，PDO不仅能够提高数据库操作的效率，还能有效防止SQL注入等安全风险。在本篇文章中，我们介绍了如何使用PDO连接MySQL数据库，并展示了常见的数据库操作方法，包括查询、插入、更新和事务控制。掌握PDO的使用，将有助于你编写更加高效、安全的PHP数据库应用。