1. 连接数据库 首先需要创建一个 PDO 对象来连接到数据库。你需要提供数据源名称(DSN),用户名和密码以及数据库名。以下是示例代码: ```php // 数据库配置参数 $host = 'localhost'; // 或者可以是 IP 地址或服务器名 $dbname = 'your_database_name'; $username = 'your_username'; $password = 'your_password'; try { // 创建 PDO 对象,使用 MySQL 作为 DSN,并开启异常处理以捕获连接错误 $pdo = new PDO("mysql:host=$host;dbname=$dbname", $username, $password); $pdo->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION); echo "数据库连接成功!"; } catch (PDOException $e) { // 如果发生错误,则输出错误信息 die("数据库连接失败: " . $e->getMessage()); } ```
2. 执行查询 使用 `PDO` 对象进行查询操作,通常包括预处理语句和绑定参数。 ```php // 假设你想执行一个简单的 SELECT 查询获取特定用户数据 $userId = 1; // 这是你要查找的用户ID try { $query = "SELECT * FROM users WHERE id = :user_id"; $stmt = $pdo->prepare($query); // 准备查询语句,可以用于预处理和参数绑定 // 绑定参数到查询 $stmt->bindParam(':user_id', $userId, PDO::PARAM_INT); // 执行查询并获取结果集 $stmt->execute(); // 获取查询结果,并遍历返回的数组或单条数据 $result = $stmt->fetch(PDO::FETCH_ASSOC); if ($result) { echo "用户信息: "; print_r($result); } else { echo '未找到该用户'; } } catch (PDOException $e) { die("查询失败: " . $e->getMessage()); } ```
3. 处理结果和关闭连接 在执行完数据库操作后,通常需要关闭连接。 ```php // 关闭 PDO 连接(可选) $pdo = null; ``` 以上步骤展示了如何使用 PDO 在 PHP 中进行数据库操作。PDO 提供了异常处理、预处理语句和参数绑定等功能,可以帮助提高代码的健壮性和安全性。通过这种方式,你可以方便地在不同的数据库系统之间切换,并减少 SQL 注入的风险