在PHP中向数据库添加数据是Web开发中的常见操作,通常涉及数据库连接、SQL语句构建和执行等步骤，本文将详细介绍这一过程，包括环境准备、安全措施、代码实现及常见问题处理，帮助开发者掌握数据添加的核心技术。
环境准备与数据库连接
在开始操作前,需确保开发环境已配置PHP和数据库管理系统（如MySQL），PHP提供了多种数据库扩展，其中MySQLi和PDO是两种主流选择，MySQLi专为MySQL设计，而PDO支持多种数据库类型，推荐使用PDO以增强代码的可移植性。
数据库连接是第一步,需提供主机名、用户名、密码和数据库名，以下是使用PDO连接MySQL的示例代码：
$host = 'localhost';
$dbname = 'test_db';
$username = 'root';
$password = '';
try {
$pdo = new PDO("mysql:host=$host;dbname=$dbname", $username, $password);
$pdo->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
} catch (PDOException $e) {
die("连接失败: " . $e->getMessage());
}
此代码通过异常处理捕获连接错误,确保程序健壮性。
构建安全的SQL语句
直接拼接SQL语句存在SQL注入风险,必须使用预处理语句（Prepared Statements）进行参数化查询，预处理语句将SQL命令与数据分离，确保用户输入仅作为数据处理。
以添加用户数据为例,假设表结构包含username和email字段：
$sql = "INSERT INTO users (username, email) VALUES (:username, :email)"; $stmt = $pdo->prepare($sql);
通过占位符（username、email）标记参数位置，避免直接拼接变量。
绑定参数与执行语句
使用bindParam()或bindValue()方法将变量绑定到占位符。bindParam()需指定参数类型，而bindValue()直接绑定值：
$username = 'example_user';
$email = 'user@example.com';
$stmt->bindParam(':username', $username, PDO::PARAM_STR);
$stmt->bindParam(':email', $email, PDO::PARAM_STR);
$stmt->execute();
执行后,数据将安全插入数据库，若需插入多条数据，可循环绑定参数并执行：
$users = [
['username' => 'user1', 'email' => 'user1@example.com'],
['username' => 'user2', 'email' => 'user2@example.com']
];
foreach ($users as $user) {
$stmt->bindParam(':username', $user['username']);
$stmt->bindParam(':email', $user['email']);
$stmt->execute();
}
处理自增ID与事务
插入数据后,常需获取自增ID（如用户ID），PDO通过lastInsertId()方法实现：
$user_id = $pdo->lastInsertId(); echo "新用户ID: " . $user_id;
对于需要保证数据一致性的操作（如多表关联插入），可使用事务（Transaction）：
$pdo->beginTransaction();
try {
$stmt1 = $pdo->prepare("INSERT INTO orders (user_id) VALUES (:user_id)");
$stmt1->execute(['user_id' => 1]);
$stmt2 = $pdo->prepare("INSERT INTO order_items (order_id, product_id) VALUES (:order_id, :product_id)");
$stmt2->execute(['order_id' => $pdo->lastInsertId(), 'product_id' => 101]);
$pdo->commit();
} catch (Exception $e) {
$pdo->rollBack();
echo "操作失败: " . $e->getMessage();
}
错误处理与调试
执行SQL语句时,需检查是否成功，PDO的rowCount()方法可获取受影响的行数：
if ($stmt->rowCount() > 0) {
echo "数据添加成功！";
} else {
echo "添加失败";
}
开发阶段可开启PDO的ERRMODE_EXCEPTION模式，通过异常捕获详细错误信息。
性能优化建议
- 批量插入：使用单条SQL语句插入多行数据，减少数据库交互次数。
- 索引优化：确保插入字段有适当索引，但避免过度索引影响写入性能。
- 连接池：高并发场景下，使用PDO持久连接（
new PDO(..., array(PDO::ATTR_PERSISTENT => true))）减少连接开销。
相关问答FAQs
Q1: 如何防止SQL注入攻击？
A1: 始终使用预处理语句（如PDO的prepare()和execute()方法）对用户输入进行参数化处理，避免直接拼接SQL字符串，对输入数据进行过滤和验证（如使用filter_var()函数）可进一步增强安全性。
Q2: 插入数据时遇到“Duplicate entry”错误如何处理？
A2: 此错误通常因唯一约束冲突导致，可通过try-catch捕获异常，检查错误代码（如MySQL的1062），提示用户更换唯一字段的值（如用户名或邮箱）。
try {
$stmt->execute();
} catch (PDOException $e) {
if ($e->errorInfo[1] == 1062) {
echo "该数据已存在，请使用其他值！";
} else {
throw $e;
}
}