PHP PDO 教程

news2025/2/8 23:13:01

PHP PDO 教程

概述

PHP PDO（PHP Data Objects）扩展为PHP提供了数据访问抽象层。PDO可以让你使用相同的接口访问多种数据库系统，这大大简化了数据库操作。本文将详细介绍PHP PDO的基本用法、优势以及在实际开发中的应用。

##PDO 简介

PDO是PHP5.1版本引入的一个扩展，用于提供一个数据访问抽象层。PDO允许你使用一套统一的接口来访问多种数据库，如MySQL、PostgreSQL、SQLite等。使用PDO，你可以轻松地在不同的数据库之间切换，而无需修改数据库访问代码。

##PDO 优势

数据库无关性：PDO可以让你使用相同的接口访问多种数据库，减少了代码重复，提高了开发效率。
错误处理：PDO提供了强大的错误处理机制，可以捕获并处理数据库错误。
预处理语句：PDO支持预处理语句，可以提高数据库操作的安全性，防止SQL注入攻击。
事务处理：PDO支持事务处理，可以保证数据的一致性和完整性。

安装PDO

在大多数Linux发行版中，PDO已经被默认安装。如果你使用的是Windows系统，可以通过以下命令安装PDO：

pear install pear.php.net/DBPDO

PDO 基本用法

以下是一个简单的PDO示例，演示如何连接MySQL数据库并执行查询：

<?php
$host = 'localhost';
$dbname = 'test';
$username = 'root';
$password = '';

try {
    $pdo = new PDO("mysql:host=$host;dbname=$dbname", $username, $password);
    $pdo->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
    
    // 执行查询
    $stmt = $pdo->query("SELECT * FROM users");
    while ($row = $stmt->fetch(PDO::FETCH_ASSOC)) {
        echo $row['username'] . '<br>';
    }
} catch (PDOException $e) {
    echo "数据库连接失败：" . $e->getMessage();
}
?>

预处理语句

预处理语句可以防止SQL注入攻击，并且可以提高查询性能。以下是一个使用预处理语句的示例：

<?php
$host = 'localhost';
$dbname = 'test';
$username = 'root';
$password = '';

try {
    $pdo = new PDO("mysql:host=$host;dbname=$dbname", $username, $password);
    $pdo->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
    
    // 准备预处理语句
    $stmt = $pdo->prepare("SELECT * FROM users WHERE username = :username");
    
    // 绑定参数
    $stmt->bindParam(':username', $username);
    
    // 执行查询
    $username = 'root';
    $stmt->execute();
    
    while ($row = $stmt->fetch(PDO::FETCH_ASSOC)) {
        echo $row['username'] . '<br>';
    }
} catch (PDOException $e) {
    echo "数据库连接失败：" . $e->getMessage();
}
?>

事务处理

PDO支持事务处理，可以保证数据的一致性和完整性。以下是一个使用事务处理的示例：

<?php
$host = 'localhost';
$dbname = 'test';
$username = 'root';
$password = '';

try {
    $pdo = new PDO("mysql:host=$host;dbname=$dbname", $username, $password);
    $pdo->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
    
    // 开启事务
    $pdo->beginTransaction();
    
    // 执行多个数据库操作
    $pdo->exec("INSERT INTO users (username, password) VALUES ('user1', 'password1')");
    $pdo->exec("INSERT INTO users (username, password) VALUES ('user2', 'password2')");
    
    // 提交事务
    $pdo->commit();
} catch (PDOException $e) {
    // 回滚事务
    $pdo->rollBack();
    echo "数据库操作失败：" . $e->getMessage();
}
?>