PHP从数据库收集数据后，如何正确关闭连接避免资源泄露？

adminZpd 专业教程 2026-01-12 03:21:18

PHP是一种广泛使用的服务器端脚本语言，特别适合Web开发，在Web应用中，从数据库中收集数据是一个常见的需求，本文将详细介绍如何使用PHP从数据库中收集数据,并确保操作的安全性和效率。

PHP从数据库收集数据后，如何正确关闭连接避免资源泄露？-第1张图片-99系统专家

连接数据库

在使用PHP从数据库收集数据之前，首先需要建立与数据库的连接，PHP提供了多种扩展来连接不同类型的数据库，如MySQL、PostgreSQL等，以MySQL为例，可以使用MySQLi或PDO扩展，MySQLi是专门为MySQL设计的，而PDO则支持多种数据库类型,以下是一个使用MySQLi连接数据库的示例代码：

$servername = "localhost";
$username = "username";
$password = "password";
$dbname = "database_name";
$conn = new mysqli($servername, $username, $password, $dbname);
if ($conn->connect_error) {
    die("连接失败: " . $conn->connect_error);
}

执行查询

连接成功后，可以使用SQL语句从数据库中查询数据，假设我们有一个名为users的表，包含id、name和email字段,以下是如何执行查询并获取结果的代码：

$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"]. "<br>";
    }
} else {
    echo "0 结果";
}

使用预处理语句防止SQL注入

直接将用户输入拼接到SQL语句中可能会导致SQL注入攻击，为了防止这种情况，应使用预处理语句,以下是使用MySQLi预处理语句的示例：

PHP从数据库收集数据后，如何正确关闭连接避免资源泄露？-第2张图片-99系统专家

$stmt = $conn->prepare("SELECT id, name, email FROM users WHERE id = ?");
$stmt->bind_param("i", $id);
$id = 1;
$stmt->execute();
$result = $stmt->get_result();
while($row = $result->fetch_assoc()) {
    echo "ID: " . $row["id"]. " Name: " . $row["name"]. " Email: " . $row["email"]. "<br>";
}
$stmt->close();

关闭数据库连接

完成数据收集后，应关闭数据库连接以释放资源,可以使用以下代码关闭连接：

$conn->close();

使用PDO扩展

PDO是另一种连接数据库的方式，它支持多种数据库类型,以下是使用PDO连接数据库并执行查询的示例：

$dsn = "mysql:host=localhost;dbname=database_name";
$username = "username";
$password = "password";
try {
    $pdo = new PDO($dsn, $username, $password);
    $pdo->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
    $stmt = $pdo->prepare("SELECT id, name, email FROM users");
    $stmt->execute();
    $result = $stmt->setFetchMode(PDO::FETCH_ASSOC);
    foreach($stmt->fetchAll() as $row) {
        echo "ID: " . $row["id"]. " Name: " . $row["name"]. " Email: " . $row["email"]. "<br>";
    }
} catch(PDOException $e) {
    echo "错误: " . $e->getMessage();
}
$pdo = null;