PHPMySQLi数据库驱动使用_PHPMySQLi初始化及查询方法

mysqli

$host = 'localhost';
$user = 'your_username';
$password = 'your_password';
$database = 'your_database';
$port = 3306; // 默认端口，如果不是可以修改

// 尝试连接
$mysqli = new mysqli($host, $user, $password, $database, $port);

// 检查连接是否成功
if ($mysqli->connect_errno) {
    // 哎呀，连接失败了！通常我们会记录日志，然后给用户一个友好的提示。
    // 实际项目中，这里不应该直接暴露错误信息给前端。
    die("数据库连接失败: " . $mysqli->connect_error . " (错误码: " . $mysqli->connect_errno . ")");
}

// 设置字符集，这步非常关键，否则中文数据可能会乱码
if (!$mysqli->set_charset("utf8mb4")) {
    // 字符集设置失败也得处理
    die("设置字符集失败: " . $mysqli->error);
}

// 连接成功后，就可以执行查询了。
// 简单查询（非预处理语句，不建议直接用于用户输入）
$result = $mysqli->query("SELECT id, name, email FROM users WHERE status = 1");

if ($result) {
    // 遍历结果集
    while ($row = $result->fetch_assoc()) {
        echo "ID: " . $row['id'] . ", Name: " . $row['name'] . ", Email: " . $row['email'] . "<br>";
    }
    // 释放结果集
    $result->free();
} else {
    // 查询失败
    echo "查询失败: " . $mysqli->error;
}

// 插入、更新、删除操作也类似，但通常不需要获取结果集
$insert_sql = "INSERT INTO products (name, price) VALUES ('新产品', 99.99)";
if ($mysqli->query($insert_sql)) {
    echo "产品插入成功！新产品ID: " . $mysqli->insert_id . "<br>";
} else {
    echo "产品插入失败: " . $mysqli->error . "<br>";
}

// **更推荐且安全的方式是使用预处理语句**
// 比如我们要查询一个特定用户
$user_id = 123;
$stmt = $mysqli->prepare("SELECT name, email FROM users WHERE id = ?");
if ($stmt) {
    // 绑定参数，'i'表示整数类型
    $stmt->bind_param("i", $user_id);
    $stmt->execute();
    $stmt->bind_result($name, $email); // 绑定结果到变量
    $stmt->fetch(); // 获取一行结果
    echo "通过预处理查询，用户姓名: " . $name . ", 邮箱: " . $email . "<br>";
    $stmt->close(); // 关闭预处理语句
} else {
    echo "预处理语句准备失败: " . $mysqli->error . "<br>";
}


// 最后，别忘了关闭数据库连接，释放资源。
$mysqli->close();

// 假设我们要从一个账户转账到另一个账户
$from_account_id = 1;
$to_account_id = 2;
$amount = 100.00;

// 1. 禁用自动提交
$mysqli->autocommit(FALSE); // 或者 $mysqli->begin_transaction(); 在PHP 5.5+

try {
    // 2. 尝试从源账户扣款
    $stmt1 = $mysqli->prepare("UPDATE accounts SET balance = balance - ? WHERE id = ? AND balance >= ?");
    $stmt1->bind_param("dii", $amount, $from_account_id, $amount);
    $stmt1->execute();

    if ($stmt1->affected_rows === 0) {
        // 扣款失败，可能是余额不足或者账户ID错误
        throw new Exception("从账户 " . $from_account_id . " 扣款失败，可能余额不足或账户不存在。");
    }
    $stmt1->close();

    // 3. 尝试向目标账户加款
    $stmt2 = $mysqli->prepare("UPDATE accounts SET balance = balance + ? WHERE id = ?");
    $stmt2->bind_param("di", $amount, $to_account_id);
    $stmt2->execute();

    if ($stmt2->affected_rows === 0) {
        // 加款失败，可能是目标账户ID错误
        throw new Exception("向账户 " . $to_account_id . " 加款失败，目标账户不存在。");
    }
    $stmt2->close();

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

} catch (Exception $e) {
    // 出现任何异常，回滚事务
    $mysqli->rollback();
    echo "转账失败: " . $e->getMessage() . " 事务已回滚。<br>";
} finally {
    // 无论成功失败，最后都要重新启用自动提交，或者确保连接被关闭
    $mysqli->autocommit(TRUE);
    // 实际项目中，连接通常会在脚本结束时自动关闭，但显式关闭也是好习惯
    // $mysqli->close();
}