PHPPDO数据库扩展介绍_PHPPDO连接配置与使用教程

<?php
$dsn = 'mysql:host=localhost;dbname=testdb;charset=utf8mb4';
$username = 'your_username';
$password = 'your_password';

try {
    $pdo = new PDO($dsn, $username, $password, [
        PDO::ATTR_ERRMODE => PDO::ERRMODE_EXCEPTION,
        PDO::ATTR_DEFAULT_FETCH_MODE => PDO::FETCH_ASSOC,
        PDO::ATTR_EMULATE_PREPARES => false, // 禁用模拟预处理，推荐使用真实预处理
    ]);
    echo "数据库连接成功！";
} catch (PDOException $e) {
    // 生产环境不应直接输出错误信息，应记录日志
    echo "数据库连接失败: " . $e->getMessage();
    exit();
}
?>

<?php
// 假设 $pdo 已经成功连接
$name = 'Alice';
$email = 'alice@example.com';

$stmt = $pdo->prepare("INSERT INTO users (name, email) VALUES (:name, :email)");
$stmt->bindParam(':name', $name);
$stmt->bindParam(':email', $email);
$stmt->execute();
echo "新用户插入成功，ID: " . $pdo->lastInsertId();
?>

<?php
// 假设 $pdo 已经成功连接
$userId = 1;

$stmt = $pdo->prepare("SELECT id, name, email FROM users WHERE id = :id");
$stmt->bindParam(':id', $userId, PDO::PARAM_INT); // 明确指定参数类型
$stmt->execute();
$user = $stmt->fetch(); // 获取一行数据

if ($user) {
    echo "用户ID: " . $user['id'] . ", 姓名: " . $user['name'] . ", 邮箱: " . $user['email'];
} else {
    echo "未找到用户。";
}

// 获取多行数据
$stmt = $pdo->query("SELECT id, name, email FROM users");
$users = $stmt->fetchAll(); // 获取所有行数据

foreach ($users as $u) {
    echo "ID: " . $u['id'] . ", Name: " . $u['name'] . "<br>";
}
?>

<?php
// 假设 $pdo 已经成功连接
$newEmail = 'new_alice@example.com';
$userId = 1;

$stmt = $pdo->prepare("UPDATE users SET email = :email WHERE id = :id");
$stmt->bindParam(':email', $newEmail);
$stmt->bindParam(':id', $userId, PDO::PARAM_INT);
$stmt->execute();
echo "更新了 " . $stmt->rowCount() . " 行数据。";
?>

<?php
// 假设 $pdo 已经成功连接
$userIdToDelete = 2;

$stmt = $pdo->prepare("DELETE FROM users WHERE id = :id");
$stmt->bindParam(':id', $userIdToDelete, PDO::PARAM_INT);
$stmt->execute();
echo "删除了 " . $stmt->rowCount() . " 行数据。";
?>

<?php
$dsn = 'mysql:host=localhost;dbname=testdb;charset=utf8mb4';
$username = 'your_username';
$password = 'your_password';

try {
    $pdo = new PDO($dsn, $username, $password, [
        PDO::ATTR_ERRMODE => PDO::ERRMODE_EXCEPTION,
        PDO::ATTR_DEFAULT_FETCH_MODE => PDO::FETCH_ASSOC,
        PDO::ATTR_EMULATE_PREPARES => false,
        PDO::ATTR_TIMEOUT => 5, // 连接超时5秒
        // PDO::ATTR_PERSISTENT => true, // 通常不推荐在Web应用中使用
    ]);
    // ... 数据库操作
} catch (PDOException $e) {
    // ... 错误处理
}
?>

<?php
$userId = $_GET['id']; // 假设用户输入 '1 OR 1=1'
$sql = "SELECT * FROM users WHERE id = " . $userId; // 拼接后变成 SELECT * FROM users WHERE id = 1 OR 1=1
$stmt = $pdo->query($sql); // 恶意SQL被执行
?>

<?php
$userId = $_GET['id']; // 用户输入 '1 OR 1=1'
$stmt = $pdo->prepare("SELECT * FROM users WHERE id = :id");
$stmt->bindParam(':id', $userId); // 或者 $stmt->execute([':id' => $userId]);
$stmt->execute();
// 此时，数据库会将 '1 OR 1=1' 视为字符串值进行匹配，而不是SQL逻辑
?>

<?php
try {
    $pdo = new PDO(/* ... */);
    $pdo->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);

    // 尝试执行一个可能出错的SQL（例如，表名错误）
    $stmt = $pdo->prepare("INSERT INTO non_existent_table (col1) VALUES (?)");
    $stmt->execute(['value']);

    echo "数据插入成功。";
} catch (PDOException $e) {
    // 捕获数据库异常
    echo "数据库操作失败: " . $e->getMessage();
    // 记录日志，而不是直接输出给用户
    error_log("Database Error: " . $e->getMessage() . " in " . $e->getFile() . " on line " . $e->getLine());
    // 可以在这里回滚事务，或者给用户一个友好的提示
}
?>

<?php
try {
    $pdo = new PDO(/* ... */);
    $pdo->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);

    $pdo->beginTransaction(); // 开启事务

    // 操作1：从账户A扣款
    $stmt1 = $pdo->prepare("UPDATE accounts SET balance = balance - ? WHERE id = ?");
    $stmt1->execute([100, 1]); // 从ID为1的账户扣100

    // 模拟一个错误或条件判断
    if (false) { // 假设这里出现了一个业务逻辑错误
        throw new Exception("业务逻辑失败，无法完成转账。");
    }

    // 操作2：向账户B加款
    $stmt2 = $pdo->prepare("UPDATE accounts SET balance = balance + ? WHERE id = ?");
    $stmt2->execute([100, 2]); // 向ID为2的账户加100

    $pdo->commit(); // 所有操作都成功，提交事务
    echo "转账成功！";

} catch (Exception $e) {
    $pdo->rollBack(); // 任何一步出错，回滚所有操作
    echo "转账失败: " . $e->getMessage();
    error_log("Transaction Error: " . $e->getMessage());
}
?>