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(); }

Quinvio AI

AI辅助下快速创建视频，虚拟代言人

30

查看详情