<?php/**
 * PDO 数据库工具类：封装连接、关闭、异常处理
 */class PDODB {
    // 数据库连接参数（实际开发建议放在配置文件中）
    private static $host = 'localhost';
    private static $dbname = 'php_db';
    private static $username = 'root';
    private static $password = '123456';
    private static $charset = 'utf8mb4';
    private static $dsn; // 数据源名称（PDO 连接格式）
    private static $pdo = null; // PDO 实例（单例模式，避免重复创建连接）

    /**
     * 初始化连接（单例模式）
     * @return PDO 连接实例
     * @throws PDOException 连接异常
     */
    public static function getConnection() {
        // 若已创建连接，直接返回
        if (self::$pdo !== null) {
            return self::$pdo;
        }

        // 构建 DSN（PDO 连接格式：mysql:host=xxx;dbname=xxx;charset=xxx）
        self::$dsn = "mysql:host=" . self::$host . ";dbname=" . self::$dbname . ";charset=" . self::$charset;

        try {
            // 创建 PDO 实例（开启异常模式，便于捕获错误）
            self::$pdo = new PDO(
                self::$dsn,
                self::$username,
                self::$password,
                [
                    PDO::ATTR_ERRMODE => PDO::ERRMODE_EXCEPTION, // 抛出异常
                    PDO::ATTR_DEFAULT_FETCH_MODE => PDO::FETCH_ASSOC // 默认以关联数组返回结果
                ]
            );
            echo "PDO 数据库连接成功！<br>";
            return self::$pdo;
        } catch (PDOException $e) {
            // 连接失败，抛出异常（实际开发可记录日志）
            die("PDO 连接失败：" . $e->getMessage());
        }
    }

    /**
     * 关闭连接（PDO 会自动关闭，手动关闭仅作演示）
     */
    public static function closeConnection() {
        self::$pdo = null;
        echo "PDO 连接已关闭！<br>";
    }}

<?php// MySQLi 面向对象连接$host = 'localhost';$dbname = 'php_db';$username = 'root';$password = '123456';// 创建 MySQLi 实例$mysqli = new mysqli($host, $username, $password, $dbname);// 检查连接错误if ($mysqli->connect_error) {
    die("MySQLi 连接失败：" . $mysqli->connect_error);}// 设置字符编码$mysqli->set_charset('utf8mb4');echo "MySQLi 连接成功！<br>";// 关闭连接$mysqli->close();echo "MySQLi 连接已关闭！<br>";

<?phprequire_once 'PDODB.php'; // 引入 PDO 工具类try {
    // 1. 获取数据库连接
    $pdo = PDODB::getConnection();

    // 2. 定义 SQL（:name 为命名占位符，也可使用 ? 问号占位符）
    $sql = "INSERT INTO users (name, age, email) VALUES (:name, :age, :email)";

    // 3. 预处理 SQL（编译 SQL，避免重复解析，提升性能）
    $stmt = $pdo->prepare($sql);

    // 4. 绑定参数并执行（两种方式可选）
    // 方式1：数组绑定（推荐，简洁）
    $userData = [
        ':name' => '张三',
        ':age' => 24,
        ':email' => 'zhangsan@example.com'
    ];
    $stmt->execute($userData);

    // 方式2：逐个绑定（适合需要指定参数类型的场景）
    // $stmt->bindParam(':name', $name, PDO::PARAM_STR);
    // $stmt->bindParam(':age', $age, PDO::PARAM_INT);
    // $stmt->execute();

    // 获取新增数据的自增 ID
    $newUserId = $pdo->lastInsertId();
    echo "新增用户成功！用户ID：" . $newUserId . "<br>";} catch (PDOException $e) {
    echo "新增失败：" . $e->getMessage() . "<br>";} finally {
    // 关闭连接（可选，PDO 脚本结束会自动关闭）
    PDODB::closeConnection();}

<?phprequire_once 'PDODB.php';try {
    $pdo = PDODB::getConnection();
    $targetId = 1; // 要查询的用户ID

    // 预处理查询 SQL
    $sql = "SELECT id, name, age, email, create_time FROM users WHERE id = :id";
    $stmt = $pdo->prepare($sql);

    // 执行查询（绑定参数）
    $stmt->execute([':id' => $targetId]);

    // 获取单条结果（关联数组格式）
    $user = $stmt->fetch();

    if ($user) {
        echo "查询到用户：<br>";
        echo "ID：" . $user['id'] . "<br>";
        echo "姓名：" . $user['name'] . "<br>";
        echo "年龄：" . $user['age'] . "<br>";
        echo "邮箱：" . $user['email'] . "<br>";
        echo "注册时间：" . $user['create_time'] . "<br>";
    } else {
        echo "未查询到 ID 为 " . $targetId . " 的用户<br>";
    }} catch (PDOException $e) {
    echo "查询失败：" . $e->getMessage() . "<br>";} finally {
    PDODB::closeConnection();}

<?phprequire_once 'PDODB.php';try {
    $pdo = PDODB::getConnection();

    // 查询所有用户（按注册时间倒序）
    $sql = "SELECT id, name, age, email FROM users ORDER BY create_time DESC";
    $stmt = $pdo->prepare($sql);
    $stmt->execute();

    // 获取所有结果（关联数组集合）
    $users = $stmt->fetchAll();

    if (count($users) > 0) {
        echo "所有用户列表：<br>";
        foreach ($users as $index => $user) {
            echo "序号 " . ($index + 1) . "：";
            echo "ID=" . $user['id'] . "，姓名=" . $user['name'] . "，邮箱=" . $user['email'] . "<br>";
        }
    } else {
        echo "暂无用户数据<br>";
    }} catch (PDOException $e) {
    echo "查询失败：" . $e->getMessage() . "<br>";} finally {
    PDODB::closeConnection();}

<?phprequire_once 'PDODB.php';try {
    $pdo = PDODB::getConnection();
    $userId = 1; // 要修改的用户ID

    // 定义修改 SQL
    $sql = "UPDATE users SET name = :name, age = :age WHERE id = :id";
    $stmt = $pdo->prepare($sql);

    // 绑定参数并执行
    $updateData = [
        ':name' => '张三_更新',
        ':age' => 25,
        ':id' => $userId
    ];
    $stmt->execute($updateData);

    // 获取受影响的行数
    $affectedRows = $stmt->rowCount();
    if ($affectedRows > 0) {
        echo "修改成功！受影响行数：" . $affectedRows . "<br>";
    } else {
        echo "修改失败：未找到用户或数据未变更<br>";
    }} catch (PDOException $e) {
    echo "修改失败：" . $e->getMessage() . "<br>";} finally {
    PDODB::closeConnection();}

<?phprequire_once 'PDODB.php';try {
    $pdo = PDODB::getConnection();
    $userId = 1; // 要删除的用户ID

    // 定义删除 SQL
    $sql = "DELETE FROM users WHERE id = :id";
    $stmt = $pdo->prepare($sql);

    // 执行删除
    $stmt->execute([':id' => $userId]);

    $affectedRows = $stmt->rowCount();
    if ($affectedRows > 0) {
        echo "删除成功！已删除 ID 为 " . $userId . " 的用户<br>";
    } else {
        echo "删除失败：未找到该用户<br>";
    }} catch (PDOException $e) {
    echo "删除失败：" . $e->getMessage() . "<br>";} finally {
    PDODB::closeConnection();}