PHP使用PDO连接数据库 PHP PDO操作MySQL教程-php教程-PHP中文网

PHP使用PDO连接数据库 PHP PDO操作MySQL教程

雪夜

发布： 2025-06-24 13:08:01

原创

413人浏览过

php使用pdo连接数据库的核心步骤包括：1.正确配置连接字符串；2.处理异常；3.设置pdo属性；4.执行sql语句；5.使用预处理防止sql注入；6.利用事务管理确保数据一致性。pdo通过统一接口支持多种数据库，提升了代码的可移植性和安全性，相比传统函数更具优势。

PHP使用PDO连接数据库 PHP PDO操作MySQL教程

PHP使用PDO连接数据库，核心在于通过PDO对象建立连接，并利用该对象执行SQL语句。PDO（PHP Data Objects）提供了一个轻量级的、一致性的接口，用于在PHP脚本中访问数据库。它支持多种数据库系统，例如MySQL、PostgreSQL、SQLite等，使得更换数据库变得更加容易。

连接数据库并执行操作，核心在于正确配置连接字符串、处理异常，以及理解PDO提供的预处理语句等功能。

PDO连接MySQL的正确姿势

立即学习“PHP免费学习笔记（深入）”；

首先，你需要一个可用的MySQL服务器。假设你的服务器运行在localhost，端口是3306，数据库名为testdb，用户名是user，密码是password。那么，连接字符串可能如下所示：

$dsn = 'mysql:host=localhost;port=3306;dbname=testdb;charset=utf8mb4';
$user = 'user';
$password = 'password';

try {
    $pdo = new PDO($dsn, $user, $password);
    $pdo->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION); // 设置错误模式为抛出异常
    $pdo->setAttribute(PDO::ATTR_DEFAULT_FETCH_MODE, PDO::FETCH_ASSOC); // 设置默认的fetch模式为关联数组
} catch (PDOException $e) {
    echo 'Connection failed: ' . $e->getMessage();
    exit;
}

登录后复制

这段代码尝试连接数据库。如果连接失败，会捕获PDOException异常并输出错误信息，然后退出脚本。setAttribute方法用于设置PDO的属性，这里设置了错误模式和默认的fetch模式。

执行查询操作：

$stmt = $pdo->query("SELECT * FROM users");
if ($stmt) {
    $users = $stmt->fetchAll();
    foreach ($users as $user) {
        echo $user['username'] . ' - ' . $user['email'] . '<br>';
    }
} else {
    echo "查询失败";
}

登录后复制

这段代码执行一个简单的SELECT查询，并遍历结果集，输出用户名和邮箱。

预处理语句的优势与应用场景

预处理语句是PDO的一个强大特性，可以有效防止SQL注入攻击，并提高查询效率。

$sql = "SELECT * FROM products WHERE id = :id";
$stmt = $pdo->prepare($sql);
$stmt->bindParam(':id', $id, PDO::PARAM_INT); // 绑定参数
$id = $_GET['id']; // 从GET请求获取id
$stmt->execute();
$product = $stmt->fetch();

if ($product) {
    echo $product['name'] . ' - ' . $product['price'];
} else {
    echo "Product not found";
}

登录后复制

这段代码首先准备一个SQL语句，其中id是一个占位符。然后，使用bindParam方法将占位符与变量绑定。最后，执行语句并获取结果。使用预处理语句可以确保id被正确转义，从而防止SQL注入攻击。

PDO事务管理：保障数据完整性的关键

事务是一系列数据库操作的集合，要么全部成功，要么全部失败。PDO提供了事务管理功能，可以确保数据的一致性和完整性。

try {
    $pdo->beginTransaction();

    // 执行多个SQL语句
    $pdo->exec("UPDATE accounts SET balance = balance - 100 WHERE id = 1");
    $pdo->exec("UPDATE accounts SET balance = balance + 100 WHERE id = 2");

    $pdo->commit();
    echo "Transaction completed successfully";
} catch (PDOException $e) {
    $pdo->rollBack();
    echo "Transaction failed: " . $e->getMessage();
}

登录后复制

这段代码首先开始一个事务，然后执行两个UPDATE语句。如果其中一个语句失败，会捕获异常并回滚事务，从而保证数据的一致性。

PDO与传统MySQL函数：选择的理由

相比于传统的mysql_*函数（已弃用）或mysqli_*函数，PDO提供了更高级的功能和更好的安全性。PDO支持预处理语句、事务管理、错误处理等，并且可以方便地切换数据库系统。虽然mysqli_*函数也提供了预处理语句等功能，但PDO的接口更加统一和灵活。

PDO的错误处理机制：如何优雅地处理数据库异常

PDO的错误处理机制非常灵活。你可以选择忽略错误、抛出异常或返回错误码。推荐使用抛出异常的方式，因为它可以让你更好地控制程序的流程，并及时发现和处理错误。

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

登录后复制

通过设置PDO::ATTR_ERRMODE属性，你可以控制PDO的错误处理方式。PDO::ERRMODE_EXCEPTION表示抛出异常，PDO::ERRMODE_WARNING表示发出警告，PDO::ERRMODE_SILENT表示忽略错误。

以上就是PHP使用PDO连接数据库 PHP PDO操作MySQL教程的详细内容，更多请关注php中文网其它相关文章！