在 PHP 中处理 MySQL 数据库查询时，我们经常需要从一个函数中返回多条数据库记录，并可能需要同时附带一些自定义的文本信息。传统的做法是在循环中构建一个字符串，但这会导致只保留最后一条记录的信息，无法获取完整的查询结果集。为了解决这一问题并提高代码的模块化和可读性，我们可以采用一种更结构化的方法：让函数返回一个包含所有必要数据的数组。
解决方案核心思路
核心思想是让 PHP 函数返回一个关联数组，该数组中包含至少两个元素：一个用于存储从数据库中获取的所有行数据（作为数组），另一个用于存储任何自定义的文本信息。此外，为了遵循良好的编程实践，数据库连接对象应该作为参数传递给函数，而不是在函数内部创建或依赖全局变量。
这种方法的优势在于：
- 完整性： 一次性返回所有查询结果，而非单条记录。
- 灵活性： 可以在同一返回值中包含不同类型的数据（数据库结果、自定义文本、状态码等）。
- 模块化： 函数职责清晰，易于测试和复用。
- 可维护性： 避免全局变量，降低代码耦合度。
实现步骤详解
我们将创建一个名为 Get 的函数，它接收一个 mysqli 连接对象作为参数，并返回一个包含查询结果和自定义文本的数组。
立即学习“PHP免费学习笔记（深入）”；
1. 函数定义与参数传递
首先，定义函数签名，确保它接受一个 mysqli 类型的参数。这是依赖注入的一种形式，使得函数不依赖于外部的全局连接，提高了函数的独立性。
function Get(mysqli $connect)
{
// 初始化一个空数组，用于存储所有要返回的数据
$ret = [];
$value4 = 'certain'; // 示例自定义变量
// ... 后续逻辑
}2. 执行查询与结果获取
使用传入的 $connect 对象执行 SQL 查询。为了获取所有结果行，我们使用 mysqli::query() 执行查询，并利用 mysqli_result::fetch_all(MYSQLI_ASSOC) 方法一次性获取所有结果行，并以关联数组的形式存储。MYSQLI_ASSOC 确保结果集的键是数据库表的列名，便于访问。
function Get(mysqli $connect)
{
$ret = [];
$value4 = 'certain';
// 执行查询，并检查查询是否成功
if ($res = $connect->query("SELECT * FROM blabla")) {
// 使用 fetch_all(MYSQLI_ASSOC) 获取所有结果行作为关联数组的数组
$rows = $res->fetch_all(MYSQLI_ASSOC);
// 封装自定义文本。这里假设自定义文本可能使用第一行数据（如果存在）
// 或者可以是完全独立的字符串。为了示例，我们使用第一行数据。
if (!empty($rows)) {
$ret['mytext'] = 'Fun ' . $rows[0]['value1'] . ' ' . $rows[0]['value2'] . ' ' . $rows[0]['value3'] . 'percent ' . $value4 . '<br />';
} else {
$ret['mytext'] = 'No data found. Powered by Hisenseb';
}
// 将数据库结果集存储到返回数组中
$ret['result-set'] = $rows;
// 释放结果集
$res->free();
} else {
// 查询失败，可以记录错误或设置错误信息
error_log("Database query failed: " . $connect->error);
return false; // 或者返回一个包含错误信息的数组
}
// 关闭数据库连接（如果该连接只用于此函数，否则在外部管理）
// 注意：通常连接的关闭由调用者负责，尤其是在一个请求中可能多次使用同一个连接时。
// 如果此函数是唯一使用者且连接不被复用，则在此处关闭是合理的。
$connect->close();
// 根据 $ret 数组是否为空来决定返回结果或 false
return count($ret) > 0 ? $ret : false;
}3. 完整示例代码（函数定义）
将上述逻辑整合，得到完整的 Get 函数：
<?php
/**
* 从数据库中获取数据并返回结果集与自定义文本。
*
* @param mysqli $connect 数据库连接对象。
* @return array|false 包含 'mytext' 和 'result-set' 的关联数组，或在失败时返回 false。
*/
function Get(mysqli $connect)
{
$ret = [];
$value4 = 'certain'; // 示例自定义变量
// 检查数据库连接是否成功
if ($connect->connect_error) {
error_log("Database connection failed: " . $connect->connect_error);
return false;
}
// 执行查询
if ($res = $connect->query("SELECT * FROM blabla")) {
// 获取所有结果行作为关联数组的数组
$rows = $res->fetch_all(MYSQLI_ASSOC);
// 封装自定义文本。这里假设自定义文本可能使用第一行数据（如果存在）。
if (!empty($rows)) {
$ret['mytext'] = 'Fun ' . $rows[0]['value1'] . ' ' . $rows[0]['value2'] . ' ' . $rows[0]['value3'] . 'percent ' . $value4 . '<br />';
} else {
$ret['mytext'] = 'No data available. Powered by Hisenseb';
}
// 将数据库结果集存储到返回数组中
$ret['result-set'] = $rows;
// 释放结果集资源
$res->free();
} else {
// 查询失败，记录错误
error_log("Database query failed: " . $connect->error);
return false;
}
// 关闭数据库连接。注意：在实际应用中，如果连接在其他地方复用，不应在此处关闭。
// 在本示例中，假设函数负责管理连接的生命周期。
$connect->close();
// 如果 $ret 中有数据，则返回 $ret 数组，否则返回 false
return count($ret) > 0 ? $ret : false;
}
?>函数调用与结果访问
在 PHP 脚本中，首先需要建立 mysqli 数据库连接，然后将连接对象传递给 Get 函数。函数返回后，可以通过数组的键名来访问其中的数据库结果集和自定义文本。
<?php
// 1. 建立数据库连接
// 请替换为您的实际数据库凭据
$conn = new mysqli("localhost", "your_username", "your_password", "your_database");
// 检查连接是否成功
if ($conn->connect_error) {
die("Connection failed: " . $conn->connect_error);
}
// 2. 调用 Get 函数
$result = Get($conn);
// 3. 检查函数返回结果并访问数据
if ($result !== false) {
$sql_results = $result['result-set']; // 获取数据库结果集
$my_custom_text = $result['mytext']; // 获取自定义文本
echo "<h2>自定义文本:</h2>";
echo $my_custom_text;
echo "<h2>数据库结果:</h2>";
if (!empty($sql_results)) {
echo "<table border='1'><thead><tr>";
// 动态生成表头
foreach (array_keys($sql_results[0]) as $column_name) {
echo "<th>" . htmlspecialchars($column_name) . "</th>";
}
echo "</tr></thead><tbody>";
// 遍历并显示每一行数据
foreach ($sql_results as $row) {
echo "<tr>";
foreach ($row as $value) {
echo "<td>" . htmlspecialchars($value) . "</td>";
}
echo "</tr>";
}
echo "</tbody></table>";
// 示例：如何访问特定列的值（例如，第一行的 'column1'）
if (isset($sql_results[0]['column1'])) {
$first_row_column1 = $sql_results[0]['column1'];
echo "<p>第一行 'column1' 的值为: " . htmlspecialchars($first_row_column1) . "</p>";
}
} else {
echo "<p>数据库中没有找到数据。</p>";
}
} else {
echo "<p>获取数据失败，请检查日志。</p>";
}
// 注意：Get 函数内部已经关闭了连接，这里无需再次关闭。
// 如果 Get 函数不关闭连接，则需要在外部手动关闭：$conn->close();
?>注意事项与最佳实践
- 依赖注入： 将 mysqli 连接对象作为参数传递给函数（依赖注入）是最佳实践。这使得函数更独立、可测试，并避免了对全局变量的依赖。
- 错误处理： 在实际应用中，对数据库连接和查询操作进行更详细的错误检查和日志记录至关重要。例如，$connect->connect_error 用于连接错误，$connect->error 用于查询错误。
- 资源管理： 及时关闭数据库连接（$connect->close()）和释放结果集（$res->free()）是良好的习惯，可以避免资源泄露。然而，关于何时关闭连接需要权衡：如果连接在整个请求生命周期中可能被多次使用，那么在每个函数调用后立即关闭它可能效率低下，此时应由调用者或框架来统一管理连接的生命周期。在本教程的示例中，为简化说明，函数内部关闭了连接。
- 数据结构选择： 返回关联数组是非常灵活的方式，可以根据需要添加更多键值对，例如状态码、错误信息等，以提供更丰富的功能。
- 安全性： 本例中的 SELECT * FROM blabla 是一个静态查询，但如果查询中包含用户输入，务必使用预处理语句（Prepared Statements）来防止 SQL 注入攻击。
总结
通过让 PHP 函数返回一个结构化的数组，我们可以高效地封装并传递多行 MySQL 查询结果以及自定义文本数据。这种方法不仅解决了只返回最后一条记录的问题，还通过依赖注入和清晰的数据结构，显著提升了代码的模块化、可读性和可维护性。在开发数据库驱动的 PHP 应用时，采用这种模式将有助于构建更健壮、更专业的代码。
