PHP语言怎样连接 MySQL 数据库并执行查询 PHP语言数据库查询操作的详细教程​

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

try {
    $pdo = new PDO($dsn, $username, $password);
    // 设置PDO错误模式为异常，这样当出现错误时会抛出PDOException
    $pdo->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
    // 禁用预处理语句的模拟，让MySQL服务器来处理预处理，更安全
    $pdo->setAttribute(PDO::ATTR_EMULATE_PREPARES, false);
    // 默认获取关联数组
    $pdo->setAttribute(PDO::ATTR_DEFAULT_FETCH_MODE, PDO::FETCH_ASSOC);

    echo "数据库连接成功！";

} catch (PDOException $e) {
    // 生产环境中不应直接暴露错误信息，这里仅为演示
    die("数据库连接失败: " . $e->getMessage());
}

// 接下来可以执行查询操作
?>

PDO::ATTR_EMULATE_PREPARES, false

<?php
// 假设 $pdo 已经成功连接
try {
    $stmt = $pdo->prepare("SELECT id, name, email FROM users WHERE id = :id");
    $userId = 1; // 假设我们要查询ID为1的用户
    $stmt->bindParam(':id', $userId, PDO::PARAM_INT); // 绑定参数，指定类型

    $stmt->execute(); // 执行查询

    // 获取单条结果
    $user = $stmt->fetch();
    if ($user) {
        echo "<br>查询到用户: ID-" . $user['id'] . ", 姓名-" . $user['name'] . ", 邮箱-" . $user['email'];
    } else {
        echo "<br>未找到用户。";
    }

    // 获取多条结果（重置stmt或重新prepare）
    $stmtAll = $pdo->prepare("SELECT id, name FROM products WHERE price > :min_price");
    $minPrice = 100.00;
    $stmtAll->bindParam(':min_price', $minPrice, PDO::PARAM_STR); // 价格通常用字符串或浮点数绑定

    $stmtAll->execute();
    echo "<br><br>价格高于100的产品列表:";
    while ($row = $stmtAll->fetch()) {
        echo "<br>ID: " . $row['id'] . ", 名称: " . $row['name'];
    }

} catch (PDOException $e) {
    die("<br>查询失败: " . $e->getMessage());
}
?>

<?php
// 假设 $pdo 已经成功连接
try {
    // 插入数据
    $name = '新用户';
    $email = 'newuser@example.com';
    $stmtInsert = $pdo->prepare("INSERT INTO users (name, email) VALUES (:name, :email)");
    $stmtInsert->bindParam(':name', $name);
    $stmtInsert->bindParam(':email', $email);
    $stmtInsert->execute();
    echo "<br><br>新用户插入成功！新ID: " . $pdo->lastInsertId();

    // 更新数据
    $newName = '更新后的名字';
    $updateId = $pdo->lastInsertId(); // 更新刚刚插入的用户
    $stmtUpdate = $pdo->prepare("UPDATE users SET name = :name WHERE id = :id");
    $stmtUpdate->bindParam(':name', $newName);
    $stmtUpdate->bindParam(':id', $updateId, PDO::PARAM_INT);
    $stmtUpdate->execute();
    echo "<br>用户ID " . $updateId . " 更新成功！影响行数: " . $stmtUpdate->rowCount();

    // 删除数据
    $deleteId = $updateId; // 删除刚刚更新的用户
    $stmtDelete = $pdo->prepare("DELETE FROM users WHERE id = :id");
    $stmtDelete->bindParam(':id', $deleteId, PDO::PARAM_INT);
    $stmtDelete->execute();
    echo "<br>用户ID " . $deleteId . " 删除成功！影响行数: " . $stmtDelete->rowCount();

} catch (PDOException $e) {
    die("<br>操作失败: " . $e->getMessage());
}
?>

?

:id

// MySQLi 预处理语句示例
$mysqli = new mysqli("localhost", "user", "password", "database");
if ($mysqli->connect_error) {
    die("连接失败: " . $mysqli->connect_error);
}

$stmt = $mysqli->prepare("SELECT name, email FROM users WHERE id = ?");
$userId = 5;
$stmt->bind_param("i", $userId); // "i" 表示整数类型
$stmt->execute();
$stmt->bind_result($name, $email); // 绑定结果到变量
$stmt->fetch();
echo "MySQLi 查询结果: 姓名 - " . $name . ", 邮箱 - " . $email;
$stmt->close();
$mysqli->close();

// 假设 $stmtAll 已经执行并有结果
while ($row = $stmtAll->fetch(PDO::FETCH_ASSOC)) { // PDO::FETCH_ASSOC 获取关联数组
    // 处理每一行数据
}

// 或者
$allProducts = $stmtAll->fetchAll(PDO::FETCH_ASSOC);
foreach ($allProducts as $row) {
    // 处理所有数据
}

rowCount()

lastInsertId()

try...catch

PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION

PDOException

try {
    // 你的数据库操作代码
    $pdo->query("SELECT * FROM non_existent_table"); // 故意制造一个错误
} catch (PDOException $e) {
    // 捕获到PDOException
    error_log("数据库错误: " . $e->getMessage()); // 记录错误到日志
    // 在生产环境中，给用户一个友好的提示，而不是直接显示错误信息
    echo "抱歉，服务器忙，请稍后再试。";
    // 也可以根据错误码进行更细致的判断和处理
    // if ($e->getCode() == '42S02') { // SQLSTATE for base table or view not found
    //     echo "表不存在！";
    // }
}

error_log()