在使用 PHP 连接数据库时，PDO（PHP Data Objects）是一种常用的方式。PDO 提供了一个数据访问抽象层，可以连接多种类型的数据库（如 MySQL、PostgreSQL、SQLite 等）。以下是使用 PDO 连接数据库并进行错误处理的基本方法。
### 1. PDO 连接数据库
```php
<?php
$host = 'localhost'; // 数据库主机
$dbname = 'test_db'; // 数据库名称
$username = 'root'; // 数据库用户名
$password = 'password'; // 数据库密码
try {
// 创建 PDO 实例
$pdo = new PDO("mysql:host=$host;dbname=$dbname", $username, $password);
// 设置 PDO 错误模式为异常模式
$pdo->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
echo "数据库连接成功！";
} catch (PDOException $e) {
// 捕获异常并处理错误
echo "数据库连接失败: " . $e->getMessage();
}
?>
```
### 2. 错误处理
PDO 提供了三种错误处理模式：
- `PDO::ERRMODE_SILENT`：默认模式。PDO 不会抛出异常，而是通过返回错误码来处理错误。
- `PDO::ERRMODE_WARNING`：PDO 会发出一个 `E_WARNING` 级别的错误，但不会抛出异常。
- `PDO::ERRMODE_EXCEPTION`：PDO 会抛出 `PDOException` 异常，这是推荐的处理方式。
在上面的代码中，我们使用了 `PDO::ERRMODE_EXCEPTION` 模式，这样当发生错误时，PDO 会抛出异常，我们可以通过 `try-catch` 块来捕获并处理这些异常。
### 3. 执行查询并处理错误
```php
<?php
try {
// 准备 SQL 语句
$stmt = $pdo->prepare("SELECT * FROM users WHERE id = :id");
// 绑定参数
$stmt->bindParam(':id', $id, PDO::PARAM_INT);
// 执行查询
$stmt->execute();
// 获取结果
$user = $stmt->fetch(PDO::FETCH_ASSOC);
if ($user) {
echo "用户信息: " . print_r($user, true);
} else {
echo "未找到用户。";
}
} catch (PDOException $e) {
echo "查询失败: " . $e->getMessage();
}
?>
```
### 4. 事务处理
PDO 还支持事务处理，可以在事务中执行多个 SQL 语句，并在发生错误时回滚。
```php
<?php
try {
// 开始事务
$pdo->beginTransaction();
// 执行多个 SQL 语句
$pdo->exec("INSERT INTO users (name, email) VALUES ('John', 'john@example.com')");
$pdo->exec("UPDATE accounts SET balance = balance - 100 WHERE user_id = 1");
// 提交事务
$pdo->commit();
} catch (PDOException $e) {
// 回滚事务
$pdo->rollBack();
echo "事务失败: " . $e->getMessage();
}
?>
```
### 5. 关闭连接
PDO 连接在脚本结束时自动关闭，但你可以手动关闭连接：
```php
$pdo = null;
```
### 总结
- 使用 `PDO::ERRMODE_EXCEPTION` 模式可以方便地捕获和处理数据库错误。
- 通过 `try-catch` 块捕获 `PDOException` 异常，并进行相应的错误处理。
- 使用事务可以确保多个 SQL 语句的原子性。
通过以上方法，你可以安全地使用 PDO 连接数据库，并有效地处理可能出现的错误。
评论