PHP执行MySQL查询语句 PHP源码操作数据库实例-php教程-PHP中文网

PHP执行MySQL查询语句 PHP源码操作数据库实例

雪夜

发布： 2025-06-23 16:49:06

原创

713人浏览过

使用php执行mysql查询需注意安全与性能。核心步骤包括建立连接、构造sql语句和处理结果。为防止sql注入，应使用预处理语句和参数绑定，如pdo或mysqli扩展实现参数化查询。对于大量数据，可禁用缓冲查询逐行处理或采用分页查询。此外，优化索引、避免select *、使用join代替子查询、缓存结果、调整mysql配置、使用连接池及避免循环中查询亦能提升效率。

PHP执行MySQL查询语句 PHP源码操作数据库实例

直接用PHP执行MySQL查询，核心在于建立连接、构造SQL语句和处理结果。这听起来很简单，但魔鬼藏在细节里。例如，如何安全地处理用户输入，避免SQL注入？如何有效地处理大量数据，避免内存溢出？这些才是真正需要关注的地方。

连接数据库，执行SQL查询，并处理结果。

如何安全地构建和执行SQL查询，防止SQL注入？

SQL注入是个老生常谈的问题，但仍然是Web安全的重大威胁。最直接的解决方案就是使用预处理语句（Prepared Statements）和参数绑定。

立即学习“PHP免费学习笔记（深入）”；

<?php
$servername = "localhost";
$username = "username";
$password = "password";
$dbname = "myDB";

try {
    $conn = new PDO("mysql:host=$servername;dbname=$dbname", $username, $password);
    // 设置 PDO 错误模式为异常
    $conn->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);

    // 预处理 SQL 并绑定参数
    $stmt = $conn->prepare("SELECT id, firstname, lastname FROM MyGuests WHERE lastname = :lastname");
    $stmt->bindParam(':lastname', $lastname);

    // 设置 lastname 的值并执行
    $lastname = $_POST['lastname']; // 从 POST 请求获取数据 (示例)
    $stmt->execute();

    // 获取结果
    $result = $stmt->fetchAll(PDO::FETCH_ASSOC);

    // 输出结果
    foreach($result as $row) {
        echo "id: " . $row["id"]. " - Name: " . $row["firstname"]. " " . $row["lastname"]. "<br>";
    }

} catch(PDOException $e) {
    echo "Connection failed: " . $e->getMessage();
}

$conn = null;
?>

登录后复制

这段代码的关键在于$stmt = $conn->prepare(...) 和 $stmt->bindParam(...)。prepare 语句将SQL语句发送到数据库服务器进行预编译，而bindParam则将用户输入作为参数传递，而不是直接拼接到SQL语句中。这样，即使用户输入包含恶意代码，也不会被当作SQL语句执行，从而避免了SQL注入。

另一种方法是使用 mysqli 扩展，同样支持预处理语句：

<?php
$servername = "localhost";
$username = "username";
$password = "password";
$dbname = "myDB";

// 创建连接
$conn = new mysqli($servername, $username, $password, $dbname);

// 检测连接
if ($conn->connect_error) {
  die("Connection failed: " . $conn->connect_error);
}

// 预处理 SQL
$stmt = $conn->prepare("SELECT id, firstname, lastname FROM MyGuests WHERE lastname = ?");
$stmt->bind_param("s", $lastname);

// 设置参数并执行
$lastname = $_POST['lastname']; // 从 POST 请求获取数据 (示例)
$stmt->execute();

// 获取结果
$result = $stmt->get_result();

if ($result->num_rows > 0) {
  // 输出数据
  while($row = $result->fetch_assoc()) {
    echo "id: " . $row["id"]. " - Name: " . $row["firstname"]. " " . $row["lastname"]. "<br>";
  }
} else {
  echo "0 results";
}
$stmt->close();
$conn->close();
?>

登录后复制

这里的 bind_param("s", $lastname) 中的 "s" 表示参数类型为字符串。

怪兽AI数字人

数字人短视频创作，数字人直播，实时驱动数字人

查看详情

如何处理大型数据集，避免内存溢出？

当查询返回大量数据时，一次性将所有数据加载到内存中可能会导致内存溢出。为了解决这个问题，可以使用游标（Cursors）或者分批处理数据。

对于 PDO，可以使用 PDO::MYSQL_ATTR_USE_BUFFERED_QUERY 属性来控制是否使用缓冲查询。禁用缓冲查询可以减少内存占用，但需要在循环中逐行获取数据：

<?php
// ... (数据库连接代码)

$conn->setAttribute(PDO::MYSQL_ATTR_USE_BUFFERED_QUERY, false); // 禁用缓冲查询

$stmt = $conn->prepare("SELECT * FROM VeryLargeTable");
$stmt->execute();

while ($row = $stmt->fetch(PDO::FETCH_ASSOC)) {
    // 处理每一行数据
    echo $row['id'] . " - " . $row['name'] . "<br>";
}

$stmt->closeCursor(); // 释放资源

// ...
?>

登录后复制

对于 mysqli，可以使用 mysqli_stmt::store_result() 函数将结果集存储在客户端，或者使用 mysqli_stmt::fetch() 逐行获取数据。

另一种方法是使用分页查询。每次只查询一部分数据，处理完后再查询下一部分。

<?php
$page = isset($_GET['page']) ? $_GET['page'] : 1;
$pageSize = 100;
$offset = ($page - 1) * $pageSize;

$sql = "SELECT * FROM VeryLargeTable LIMIT $offset, $pageSize";

// ... (执行查询并处理结果)
?>

登录后复制

除了预处理语句，还有哪些提高PHP执行MySQL查询效率的方法？

除了预处理语句和分页处理，还有一些其他的技巧可以提高PHP执行MySQL查询的效率：

索引优化： 确保你的表有合适的索引。索引可以大大加快查询速度，特别是对于大型表。使用 EXPLAIN 语句可以分析查询的执行计划，找出需要优化的索引。
*避免使用 `SELECT ：** 只选择需要的列。SELECT *` 会返回所有列的数据，即使你只需要其中的几列。这会增加网络传输的负担，降低查询效率。
使用连接（JOIN）代替子查询： 在某些情况下，使用连接可以比子查询更高效。
缓存查询结果： 对于不经常变化的数据，可以将查询结果缓存起来，避免每次都查询数据库。可以使用 Memcached 或 Redis 等缓存系统。
优化MySQL配置： 调整MySQL的配置参数，例如 innodb_buffer_pool_size 和 query_cache_size，可以提高数据库的整体性能。
使用数据库连接池： 频繁地建立和关闭数据库连接会消耗大量的资源。使用数据库连接池可以重用连接，减少连接开销。
避免在循环中执行查询： 尽量将多个查询合并成一个查询。如果必须在循环中执行查询，请确保使用预处理语句。