PHP怎么使用PDO连接数据库

发布时间：2021-10-28 11:11:03 作者：iii
来源：亿速云阅读：300

# PHP怎么使用PDO连接数据库

## 一、PDO简介

PDO（PHP Data Objects）是PHP中一个轻量级的数据库访问抽象层，它为访问不同数据库提供了统一的接口。使用PDO的主要优势包括：

1. **数据库无关性**：通过更换DSN即可切换不同数据库
2. **预处理语句**：内置防止SQL注入的机制
3. **错误处理**：支持多种错误处理模式
4. **面向对象**：完全面向对象的API设计
5. **性能优化**：比传统mysql_*函数更高效

## 二、PDO基本连接方法

### 2.1 连接MySQL数据库

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

try {
    $pdo = new PDO("mysql:host=$host;dbname=$dbname", $username, $password);
    echo "连接成功";
} catch (PDOException $e) {
    die("连接失败: " . $e->getMessage());
}
?>

2.2 连接参数说明

DSN（数据源名称）：格式为驱动名:host=主机名;dbname=数据库名
用户名：数据库账号
密码：数据库密码
选项数组（可选）：可设置持久连接等参数

2.3 常用连接选项

$options = [
    PDO::ATTR_ERRMODE => PDO::ERRMODE_EXCEPTION, // 错误处理模式
    PDO::ATTR_DEFAULT_FETCH_MODE => PDO::FETCH_ASSOC, // 默认获取模式
    PDO::ATTR_EMULATE_PREPARES => false, // 禁用预处理模拟
    PDO::ATTR_PERSISTENT => true // 持久连接
];

$pdo = new PDO($dsn, $username, $password, $options);

三、执行SQL查询

3.1 执行简单查询

$stmt = $pdo->query('SELECT * FROM users');
while ($row = $stmt->fetch()) {
    print_r($row);
}

3.2 使用预处理语句

$stmt = $pdo->prepare('SELECT * FROM users WHERE id = :id');
$stmt->execute([':id' => $userId]);
$user = $stmt->fetch();

3.3 插入数据示例

$data = [
    'name' => '张三',
    'email' => 'zhangsan@example.com',
    'age' => 25
];

$sql = "INSERT INTO users (name, email, age) VALUES (:name, :email, :age)";
$stmt = $pdo->prepare($sql);
$stmt->execute($data);

四、事务处理

PDO支持数据库事务，确保数据一致性：

try {
    $pdo->beginTransaction();
    
    // 执行多个SQL操作
    $pdo->exec("UPDATE accounts SET balance = balance - 100 WHERE user_id = 1");
    $pdo->exec("UPDATE accounts SET balance = balance + 100 WHERE user_id = 2");
    
    $pdo->commit();
} catch (Exception $e) {
    $pdo->rollBack();
    echo "事务失败: " . $e->getMessage();
}

五、错误处理

PDO提供三种错误处理模式：

PDO::ERRMODE_SILENT：默认模式，需手动检查错误
PDO::ERRMODE_WARNING：产生E_WARNING错误
PDO::ERRMODE_EXCEPTION：抛出异常（推荐）

设置异常模式：

$pdo->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);

获取错误信息：

$stmt = $pdo->prepare('SELECT * FROM non_existent_table');
try {
    $stmt->execute();
} catch (PDOException $e) {
    echo "错误代码: " . $e->getCode() . "<br>";
    echo "错误信息: " . $e->getMessage();
}

六、连接其他数据库

6.1 连接SQLite

$pdo = new PDO('sqlite:/path/to/database.sqlite');

6.2 连接PostgreSQL

$pdo = new PDO('pgsql:host=localhost;dbname=testdb', 'username', 'password');

6.3 连接Oracle

$pdo = new PDO('oci:dbname=//localhost:1521/mydb', 'username', 'password');

七、高级用法

7.1 获取最后插入ID

$pdo->lastInsertId();

7.2 批量插入数据

$data = [
    ['name' => '李四', 'email' => 'lisi@example.com'],
    ['name' => '王五', 'email' => 'wangwu@example.com']
];

$stmt = $pdo->prepare("INSERT INTO users (name, email) VALUES (?, ?)");
foreach ($data as $row) {
    $stmt->execute([$row['name'], $row['email']]);
}

7.3 存储过程调用

$stmt = $pdo->prepare("CALL sp_get_user(?)");
$stmt->execute([$userId]);
$result = $stmt->fetchAll();

八、安全注意事项

始终使用预处理语句防止SQL注入
禁用模拟预处理：$pdo->setAttribute(PDO::ATTR_EMULATE_PREPARES, false)
过滤所有用户输入
使用最小权限原则配置数据库用户
定期更新PHP和数据库修复安全漏洞

九、性能优化建议

使用持久连接减少连接开销
合理设置fetch模式减少内存消耗
批量操作时使用事务
为常用查询添加索引
定期清理不活跃的连接

十、完整示例代码

<?php
// 数据库配置
$config = [
    'host' => 'localhost',
    'dbname' => 'company',
    'username' => 'app_user',
    'password' => 'secure_password',
    'options' => [
        PDO::ATTR_ERRMODE => PDO::ERRMODE_EXCEPTION,
        PDO::ATTR_DEFAULT_FETCH_MODE => PDO::FETCH_ASSOC
    ]
];

// 连接数据库
try {
    $dsn = "mysql:host={$config['host']};dbname={$config['dbname']};charset=utf8";
    $pdo = new PDO($dsn, $config['username'], $config['password'], $config['options']);
    
    // 查询示例
    $stmt = $pdo->prepare("SELECT * FROM employees WHERE department = ? AND salary > ?");
    $stmt->execute(['IT', 5000]);
    $employees = $stmt->fetchAll();
    
    // 输出结果
    foreach ($employees as $emp) {
        echo "姓名: {$emp['name']}, 职位: {$emp['position']}<br>";
    }
    
} catch (PDOException $e) {
    die("数据库错误: " . $e->getMessage());
}
?>

结语

PDO作为PHP官方推荐的数据库访问方式，提供了安全、高效且统一的数据库操作接口。通过本文的介绍，您应该已经掌握了PDO的基本使用方法。在实际开发中，建议结合ORM框架或查询构建器使用PDO，可以进一步提高开发效率和代码可维护性。

记住，良好的数据库操作习惯是Web应用安全的基础，始终遵循安全最佳实践，才能构建出健壮的应用程序。 “`

这篇文章共计约2150字，全面介绍了PDO连接数据库的各个方面，包括基本连接、查询执行、事务处理、错误处理、连接不同数据库以及安全注意事项等内容。采用Markdown格式编写，结构清晰，包含代码示例和实用建议。