《如何使用PHP数据库连接实现数据查询和更新》
在Web开发中，PHP与数据库的交互是核心功能之一。无论是构建动态网站、管理系统还是数据驱动的应用，掌握PHP与数据库的连接、查询和更新操作都是开发者必备的技能。本文将详细介绍如何使用PHP连接常见数据库（如MySQL），并通过代码示例演示数据查询和更新的完整流程，帮助读者快速上手。
一、PHP数据库连接基础
PHP支持多种数据库扩展，其中最常用的是MySQLi（MySQL Improved）和PDO（PHP Data Objects）。MySQLi是专门为MySQL设计的扩展，提供面向对象和过程化两种接口；PDO则是一个数据库抽象层，支持多种数据库（如MySQL、PostgreSQL、SQLite等），具有更好的移植性。
1.1 使用MySQLi连接数据库
MySQLi扩展提供了两种连接方式：面向对象和过程化。以下是两种方式的示例：
面向对象方式：
connect_error) {
die("连接失败: " . $conn->connect_error);
}
echo "连接成功";
?>
过程化方式：
1.2 使用PDO连接数据库
PDO提供了统一的接口来操作不同数据库。以下是PDO连接MySQL的示例：
setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
echo "连接成功";
} catch(PDOException $e) {
echo "连接失败: " . $e->getMessage();
}
?>
二、数据查询操作
数据查询是数据库操作中最常见的任务之一。通过SQL的SELECT语句，可以从数据库中检索数据。下面分别介绍MySQLi和PDO的查询方法。
2.1 使用MySQLi查询数据
MySQLi提供了两种查询方式：直接执行SQL语句和使用预处理语句。
直接执行SQL语句：
connect_error) {
die("连接失败: " . $conn->connect_error);
}
$sql = "SELECT id, name, email FROM users";
$result = $conn->query($sql);
if ($result->num_rows > 0) {
// 输出每行数据
while($row = $result->fetch_assoc()) {
echo "id: " . $row["id"]. " - Name: " . $row["name"]. " - Email: " . $row["email"]. "
";
}
} else {
echo "0 结果";
}
$conn->close();
?>
使用预处理语句：
预处理语句可以防止SQL注入攻击，提高安全性。
connect_error) {
die("连接失败: " . $conn->connect_error);
}
// 准备和绑定
$stmt = $conn->prepare("SELECT id, name, email FROM users WHERE id = ?");
$stmt->bind_param("i", $id);
// 设置参数并执行
$id = 1;
$stmt->execute();
$result = $stmt->get_result();
if ($result->num_rows > 0) {
while($row = $result->fetch_assoc()) {
echo "id: " . $row["id"]. " - Name: " . $row["name"]. " - Email: " . $row["email"]. "
";
}
} else {
echo "0 结果";
}
$stmt->close();
$conn->close();
?>
2.2 使用PDO查询数据
PDO提供了统一的查询方法，支持预处理语句。
setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
$stmt = $conn->prepare("SELECT id, name, email FROM users WHERE id = :id");
$stmt->bindParam(':id', $id);
$id = 1;
$stmt->execute();
// 设置结果集为关联数组
$result = $stmt->setFetchMode(PDO::FETCH_ASSOC);
foreach($stmt->fetchAll() as $row) {
echo "id: " . $row["id"]. " - Name: " . $row["name"]. " - Email: " . $row["email"]. "
";
}
} catch(PDOException $e) {
echo "错误: " . $e->getMessage();
}
$conn = null;
?>
三、数据更新操作
数据更新包括插入（INSERT）、更新（UPDATE）和删除（DELETE）操作。下面分别介绍MySQLi和PDO的更新方法。
3.1 使用MySQLi更新数据
插入数据：
connect_error) {
die("连接失败: " . $conn->connect_error);
}
$sql = "INSERT INTO users (name, email) VALUES ('John Doe', 'john@example.com')";
if ($conn->query($sql) === TRUE) {
echo "新记录插入成功";
} else {
echo "错误: " . $sql . "
" . $conn->error;
}
$conn->close();
?>
使用预处理语句插入数据：
connect_error) {
die("连接失败: " . $conn->connect_error);
}
$stmt = $conn->prepare("INSERT INTO users (name, email) VALUES (?, ?)");
$stmt->bind_param("ss", $name, $email);
$name = "Jane Doe";
$email = "jane@example.com";
$stmt->execute();
echo "新记录插入成功";
$stmt->close();
$conn->close();
?>
更新数据：
connect_error) {
die("连接失败: " . $conn->connect_error);
}
$sql = "UPDATE users SET email='john.doe@example.com' WHERE id=1";
if ($conn->query($sql) === TRUE) {
echo "记录更新成功";
} else {
echo "错误: " . $sql . "
" . $conn->error;
}
$conn->close();
?>
删除数据：
connect_error) {
die("连接失败: " . $conn->connect_error);
}
$sql = "DELETE FROM users WHERE id=1";
if ($conn->query($sql) === TRUE) {
echo "记录删除成功";
} else {
echo "错误: " . $sql . "
" . $conn->error;
}
$conn->close();
?>
3.2 使用PDO更新数据
插入数据：
setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
$stmt = $conn->prepare("INSERT INTO users (name, email) VALUES (:name, :email)");
$stmt->bindParam(':name', $name);
$stmt->bindParam(':email', $email);
$name = "Alice Smith";
$email = "alice@example.com";
$stmt->execute();
echo "新记录插入成功";
} catch(PDOException $e) {
echo "错误: " . $e->getMessage();
}
$conn = null;
?>
更新数据：
setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
$stmt = $conn->prepare("UPDATE users SET email=:email WHERE id=:id");
$stmt->bindParam(':email', $email);
$stmt->bindParam(':id', $id);
$email = "alice.smith@example.com";
$id = 3;
$stmt->execute();
echo "记录更新成功";
} catch(PDOException $e) {
echo "错误: " . $e->getMessage();
}
$conn = null;
?>
删除数据：
setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
$stmt = $conn->prepare("DELETE FROM users WHERE id=:id");
$stmt->bindParam(':id', $id);
$id = 3;
$stmt->execute();
echo "记录删除成功";
} catch(PDOException $e) {
echo "错误: " . $e->getMessage();
}
$conn = null;
?>
四、错误处理与最佳实践
在数据库操作中，错误处理和最佳实践同样重要。以下是一些关键点：
4.1 错误处理
无论是MySQLi还是PDO，都应该设置错误处理机制。MySQLi可以通过检查返回值或使用异常模式；PDO默认使用异常模式，可以通过try-catch块捕获异常。
4.2 预处理语句
预处理语句可以防止SQL注入攻击，提高安全性。在处理用户输入时，务必使用预处理语句。
4.3 连接管理
及时关闭数据库连接，释放资源。在MySQLi中，使用$conn->close()；在PDO中，将$conn设为null。
4.4 事务处理
对于需要原子性的操作（如转账），使用事务确保数据一致性。以下是PDO事务处理的示例：
setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
// 开始事务
$conn->beginTransaction();
$conn->exec("INSERT INTO accounts (user_id, balance) VALUES (1, 1000)");
$conn->exec("INSERT INTO accounts (user_id, balance) VALUES (2, 500)");
// 提交事务
$conn->commit();
echo "新记录创建成功";
} catch(PDOException $e) {
// 回滚事务
$conn->rollBack();
echo "错误: " . $e->getMessage();
}
$conn = null;
?>
五、总结
本文详细介绍了如何使用PHP连接数据库，并通过MySQLi和PDO两种扩展实现了数据查询和更新操作。通过直接执行SQL语句和预处理语句两种方式，读者可以根据项目需求选择合适的方案。同时，本文还强调了错误处理、预处理语句、连接管理和事务处理等最佳实践，帮助读者编写更安全、高效的代码。
关键词：PHP数据库连接、MySQLi、PDO、数据查询、数据更新、预处理语句、错误处理、事务处理
简介：本文详细介绍了如何使用PHP连接数据库，并通过MySQLi和PDO两种扩展实现数据查询和更新操作。内容涵盖数据库连接基础、数据查询与更新方法、错误处理与最佳实践，帮助读者快速掌握PHP与数据库的交互技巧。
