PHP 连接 MySQL 的 3 种方式：mysql_*、mysqli、PDO 对比与最佳实践

<?php
// 连接数据库（已废弃）
$conn = mysql_connect("localhost", "root", "");
mysql_select_db("php_demo", $conn);
mysql_set_charset("utf8", $conn);

// 查询数据（存在SQL注入风险）
$id = $_GET['id'];
$sql = "SELECT * FROM users WHERE id = $id";
$result = mysql_query($sql);
$user = mysql_fetch_assoc($result);

print_r($user);
mysql_close($conn);
?>

<?php
// 连接数据库
$conn = mysqli_connect("localhost", "root", "", "php_demo");
if (mysqli_connect_errno()) {
    die("连接失败：" . mysqli_connect_error());
}
mysqli_set_charset($conn, "utf8");

// 预处理语句（防SQL注入）
$id = $_GET['id'];
$stmt = mysqli_prepare($conn, "SELECT * FROM users WHERE id = ?");
mysqli_stmt_bind_param($stmt, "i", $id); // i=整数，s=字符串，d=浮点数
mysqli_stmt_execute($stmt);
$result = mysqli_stmt_get_result($stmt);
$user = mysqli_fetch_assoc($result);

print_r($user);
mysqli_close($conn);
?>

<?php
// 连接数据库
$mysqli = new mysqli("localhost", "root", "", "php_demo");
if ($mysqli->connect_errno) {
    die("连接失败：" . $mysqli->connect_error);
}
$mysqli->set_charset("utf8");

// 预处理语句
$id = $_GET['id'];
$stmt = $mysqli->prepare("SELECT * FROM users WHERE id = ?");
$stmt->bind_param("i", $id);
$stmt->execute();
$result = $stmt->get_result();
$user = $result->fetch_assoc();

print_r($user);
$mysqli->close();
?>

<?php
// 连接数据库
try {
    $pdo = new PDO(
        "mysql:host=localhost;dbname=php_demo;charset=utf8",
        "root",
        "",
        [
            PDO::ATTR_ERRMODE => PDO::ERRMODE_EXCEPTION, // 抛出异常
            PDO::ATTR_DEFAULT_FETCH_MODE => PDO::FETCH_ASSOC // 默认关联数组
        ]
    );
} catch (PDOException $e) {
    die("连接失败：" . $e->getMessage());
}

// 预处理语句（防SQL注入）
$id = $_GET['id'];
$stmt = $pdo->prepare("SELECT * FROM users WHERE id = :id");
$stmt->bindParam(":id", $id, PDO::PARAM_INT);
$stmt->execute();
$user = $stmt->fetch();

print_r($user);
?>

<?php
class DB {
    private static $instance = null;
    private $pdo;

    // 单例模式：避免重复连接数据库
    private function __construct() {
        $dsn = "mysql:host=localhost;dbname=php_demo;charset=utf8";
        $options = [
            PDO::ATTR_ERRMODE => PDO::ERRMODE_EXCEPTION,
            PDO::ATTR_DEFAULT_FETCH_MODE => PDO::FETCH_ASSOC,
            PDO::ATTR_PERSISTENT => true // 长连接，提升性能
        ];
        $this->pdo = new PDO($dsn, "root", "", $options);
    }

    // 获取实例
    public static function getInstance() {
        if (self::$instance === null) {
            self::$instance = new self();
        }
        return self::$instance;
    }

    // 查询单条数据
    public function getOne($sql, $params = []) {
        $stmt = $this->pdo->prepare($sql);
        $stmt->execute($params);
        return $stmt->fetch();
    }

    // 查询多条数据
    public function getAll($sql, $params = []) {
        $stmt = $this->pdo->prepare($sql);
        $stmt->execute($params);
        return $stmt->fetchAll();
    }

    // 新增/修改/删除
    public function exec($sql, $params = []) {
        $stmt = $this->pdo->prepare($sql);
        $stmt->execute($params);
        return $stmt->rowCount(); // 影响行数
    }

    // 获取最后插入的ID
    public function lastInsertId() {
        return $this->pdo->lastInsertId();
    }

    // 禁止克隆
    private function __clone() {}
}

// 使用示例
$db = DB::getInstance();
$user = $db->getOne("SELECT * FROM users WHERE id = ?", [1]);
print_r($user);
?>