PHP获取数据库记录的SQL查询方法
在PHP开发中，从数据库获取记录是最基础也最常用的操作之一。不管是展示文章列表、查询用户信息，还是统计业务数据，都需要通过SQL查询结合PHP的数据库扩展来实现。本文将介绍几种常见的PHP查询数据库记录的方法，以及对应的代码示例。
前期准备
在进行查询操作前，我们需要先建立数据库连接。这里以MySQL数据库为例，分别介绍面向过程和面向对象两种连接方式，后续的查询示例会基于这两种连接展开。
面向过程方式连接MySQL
使用mysqli_connect()函数建立连接，需要传入数据库地址、用户名、密码、数据库名四个参数，连接成功后会返回一个连接资源，失败则返回false。
<?php
// 数据库配置信息
$host = '127.0.0.1';
$user = 'root';
$password = '123456';
$dbname = 'test_db';
// 建立数据库连接
$conn = mysqli_connect($host, $user, $password, $dbname);
// 检查连接是否成功
if (!$conn) {
die('数据库连接失败: ' . mysqli_connect_error());
}
echo '数据库连接成功';
?>面向对象方式连接MySQL
使用mysqli类创建连接对象，同样需要传入上述四个配置参数，通过构造函数完成连接初始化。
<?php
// 数据库配置信息
$host = '127.0.0.1';
$user = 'root';
$password = '123456';
$dbname = 'test_db';
// 创建mysqli对象建立连接
$mysqli = new mysqli($host, $user, $password, $dbname);
// 检查连接是否成功
if ($mysqli->connect_error) {
die('数据库连接失败: ' . $mysqli->connect_error);
}
echo '数据库连接成功';
?>基础查询：获取单条/多条记录
最基础的查询就是执行一条SELECT语句，然后获取返回的结果。下面分别用两种连接方式演示查询所有用户记录的场景。
面向过程方式查询记录
使用mysqli_query()函数执行SQL语句，成功后会返回一个结果集对象，再通过mysqli_fetch_assoc()函数逐行获取关联数组形式的记录，直到结果集遍历完毕。
<?php
// 假设已经建立好上文的$conn连接
$sql = 'SELECT id, username, email FROM users';
$result = mysqli_query($conn, $sql);
// 检查查询是否执行成功
if ($result) {
// 遍历结果集，获取所有记录
while ($row = mysqli_fetch_assoc($result)) {
echo '用户ID: ' . $row['id'] . '<br/>';
echo '用户名: ' . $row['username'] . '<br/>';
echo '邮箱: ' . $row['email'] . '<br/>';
echo '----------------<br/>';
}
// 释放结果集
mysqli_free_result($result);
} else {
echo '查询失败: ' . mysqli_error($conn);
}
// 关闭数据库连接
mysqli_close($conn);
?>面向对象方式查询记录
通过mysqli对象的query()方法执行SQL语句，获取结果对象后，使用fetch_assoc()方法获取关联数组形式的记录。
<?php
// 假设已经建立好上文的$mysqli连接
$sql = 'SELECT id, username, email FROM users';
$result = $mysqli->query($sql);
// 检查查询是否执行成功
if ($result) {
// 遍历结果集，获取所有记录
while ($row = $result->fetch_assoc()) {
echo '用户ID: ' . $row['id'] . '<br/>';
echo '用户名: ' . $row['username'] . '<br/>';
echo '邮箱: ' . $row['email'] . '<br/>';
echo '----------------<br/>';
}
// 释放结果集
$result->free();
} else {
echo '查询失败: ' . $mysqli->error;
}
// 关闭数据库连接
$mysqli->close();
?>带条件的查询
实际开发中很少查询全表数据，通常会根据条件筛选记录，比如根据ID查询单条用户信息，或者根据时间范围查询记录。需要注意的是，直接拼接SQL字符串容易出现SQL注入风险，因此推荐使用预处理语句。
预处理查询单条记录
使用预处理语句可以将SQL逻辑和参数分离，避免SQL注入。下面以面向对象方式为例，演示根据ID查询用户信息：
<?php
// 假设已经建立好上文的$mysqli连接
$user_id = 1; // 要查询的用户ID
$sql = 'SELECT id, username, email FROM users WHERE id = ?';
$stmt = $mysqli->prepare($sql);
if ($stmt) {
// 绑定参数，i表示参数为整数类型
$stmt->bind_param('i', $user_id);
// 执行预处理语句
$stmt->execute();
// 绑定结果集变量
$stmt->bind_result($id, $username, $email);
// 获取单条记录
if ($stmt->fetch()) {
echo '用户ID: ' . $id . '<br/>';
echo '用户名: ' . $username . '<br/>';
echo '邮箱: ' . $email . '<br/>';
} else {
echo '未找到对应用户';
}
// 关闭预处理语句
$stmt->close();
} else {
echo '预处理语句准备失败: ' . $mysqli->error;
}
$mysqli->close();
?>预处理查询多条记录
如果需要查询符合条件的多条记录，可以在绑定参数执行后，用get_result()方法获取结果集，再遍历获取所有记录：
<?php
// 假设已经建立好上文的$mysqli连接
$min_id = 5; // 最小ID条件
$sql = 'SELECT id, username, email FROM users WHERE id > ?';
$stmt = $mysqli->prepare($sql);
if ($stmt) {
// 绑定参数，i表示参数为整数类型
$stmt->bind_param('i', $min_id);
// 执行预处理语句
$stmt->execute();
// 获取结果集
$result = $stmt->get_result();
// 遍历结果集
while ($row = $result->fetch_assoc()) {
echo '用户ID: ' . $row['id'] . '<br/>';
echo '用户名: ' . $row['username'] . '<br/>';
echo '邮箱: ' . $row['email'] . '<br/>';
echo '----------------<br/>';
}
// 释放结果集和关闭预处理语句
$result->free();
$stmt->close();
} else {
echo '预处理语句准备失败: ' . $mysqli->error;
}
$mysqli->close();
?>使用PDO扩展查询记录
除了mysqli扩展，PDO也是PHP中常用的数据库扩展，它支持多种数据库，使用方式更统一。下面演示用PDO连接MySQL并查询记录的示例：
<?php
// 数据库配置信息
$host = '127.0.0.1';
$dbname = 'test_db';
$user = 'root';
$password = '123456';
try {
// 创建PDO连接
$pdo = new PDO("mysql:host=$host;dbname=$dbname;charset=utf8", $user, $password);
// 设置PDO错误模式为异常
$pdo->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
// 预处理查询语句
$sql = 'SELECT id, username, email FROM users WHERE id > :min_id';
$stmt = $pdo->prepare($sql);
// 绑定参数
$min_id = 3;
$stmt->bindParam(':min_id', $min_id, PDO::PARAM_INT);
// 执行查询
$stmt->execute();
// 获取所有结果
$users = $stmt->fetchAll(PDO::FETCH_ASSOC);
// 遍历输出结果
foreach ($users as $user) {
echo '用户ID: ' . $user['id'] . '<br/>';
echo '用户名: ' . $user['username'] . '<br/>';
echo '邮箱: ' . $user['email'] . '<br/>';
echo '----------------<br/>';
}
} catch (PDOException $e) {
echo '操作失败: ' . $e->getMessage();
}
?>注意事项
- 生产环境中不要直接将数据库错误信息输出给用户，避免泄露数据库结构等敏感信息。
- 所有涉及用户输入的查询条件，都必须使用预处理语句，避免SQL注入攻击。
- 查询完成后及时释放结果集、关闭数据库连接，避免占用过多资源。
- 如果查询的数据量较大，建议分页查询，避免一次性加载过多数据导致内存溢出。