# PHP中處理SQL查詢結果的常用函數有哪些
## 引言
在PHP開發中,數據庫操作是不可或缺的重要環節。無論是簡單的數據檢索還是復雜的業務邏輯處理,我們都需要與數據庫進行交互并處理返回的查詢結果。PHP提供了豐富的函數和擴展來幫助我們高效地處理SQL查詢結果,這些函數分布在不同的數據庫擴展中,如MySQLi、PDO等。
本文將系統介紹PHP中處理SQL查詢結果的常用函數,包括基礎函數、MySQLi擴展函數、PDO擴展函數以及一些實用技巧和最佳實踐。通過掌握這些函數的使用方法,開發者可以更加游刃有余地處理數據庫查詢結果,構建健壯高效的PHP應用。
## 一、基礎結果處理函數
### 1. mysql_fetch_array()(已廢棄)
```php
// 示例代碼
$result = mysql_query("SELECT * FROM users");
while ($row = mysql_fetch_array($result)) {
echo $row['username'] . "<br>";
}
說明: - 從結果集中獲取一行作為關聯數組、數字數組或兩者兼有 - 第二個參數可選:MYSQL_ASSOC、MYSQL_NUM或MYSQL_BOTH - PHP 5.5.0起已廢棄,建議使用MySQLi或PDO替代
$result = mysql_query("SELECT id, name FROM products");
while ($row = mysql_fetch_assoc($result)) {
echo "ID: {$row['id']}, Name: {$row['name']}<br>";
}
特點: - 專門返回關聯數組 - 代碼可讀性更好,直接使用列名訪問數據
$result = mysql_query("SELECT id, name FROM products");
while ($row = mysql_fetch_row($result)) {
echo "ID: {$row[0]}, Name: {$row[1]}<br>";
}
特點: - 返回數字索引數組 - 訪問速度快于關聯數組
$result = mysql_query("SELECT * FROM orders");
$row_count = mysql_num_rows($result);
echo "Found $row_count records";
應用場景: - 獲取SELECT查詢返回的行數 - 常用于分頁計算
$mysqli = new mysqli("localhost", "user", "password", "database");
$result = $mysqli->query("SELECT * FROM products");
while ($row = $result->fetch_array(MYSQLI_BOTH)) {
echo $row[0] . " " . $row['product_name'];
}
參數選項: - MYSQLI_ASSOC - MYSQLI_NUM - MYSQLI_BOTH(默認)
$result = $mysqli->query("SELECT id, name, price FROM products");
while ($row = $result->fetch_assoc()) {
echo "Product: {$row['name']} (¥{$row['price']})<br>";
}
優勢: - 代碼可讀性強 - 直接使用列名訪問數據
$result = $mysqli->query("SELECT id, name FROM users");
while ($row = $result->fetch_row()) {
echo "User ID: $row[0], Name: $row[1]<br>";
}
適用場景: - 需要快速訪問數據 - 不需要列名信息的情況
$result = $mysqli->query("SELECT * FROM employees");
while ($employee = $result->fetch_object()) {
echo "Employee: {$employee->first_name} {$employee->last_name}<br>";
}
特點: - 返回對象形式的結果 - 可以通過箭頭運算符訪問屬性
$result = $mysqli->query("SELECT * FROM products");
$result->data_seek(5); // 跳轉到第6條記錄
$row = $result->fetch_assoc();
用途: - 移動結果集內部指針 - 實現隨機訪問記錄
$result = $mysqli->query("SELECT * FROM orders WHERE status = 'pending'");
echo "Pending orders: " . $result->num_rows;
注意: - 對于無緩沖查詢,需要先獲取所有結果才能準確計數 - 替代方案:使用COUNT(*)SQL函數
$stmt = $pdo->query("SELECT * FROM users");
while ($row = $stmt->fetch(PDO::FETCH_ASSOC)) {
echo $row['username'] . "<br>";
}
常用獲取模式: - PDO::FETCH_ASSOC - PDO::FETCH_NUM - PDO::FETCH_BOTH - PDO::FETCH_OBJ
$stmt = $pdo->query("SELECT * FROM products");
$products = $stmt->fetchAll(PDO::FETCH_ASSOC);
foreach ($products as $product) {
echo $product['name'] . ": " . $product['price'] . "<br>";
}
優勢: - 一次性獲取所有結果 - 減少數據庫連接時間
$count = $pdo->query("SELECT COUNT(*) FROM users")->fetchColumn();
echo "Total users: $count";
典型應用: - 獲取單列值 - 聚合函數結果
$stmt = $pdo->query("SELECT * FROM books");
while ($book = $stmt->fetchObject()) {
echo "Title: {$book->title}, Author: {$book->author}<br>";
}
特點: - 返回自定義類的實例 - 支持類型轉換
$stmt = $pdo->prepare("DELETE FROM logs WHERE created_at < ?");
$stmt->execute([date('Y-m-d', strtotime('-30 days'))]);
echo "Deleted " . $stmt->rowCount() . " records";
注意: - 不是所有數據庫都支持SELECT的行數統計 - 對SELECT建議使用COUNT(*)替代
// 使用預處理語句防止SQL注入
$stmt = $pdo->prepare("SELECT * FROM articles ORDER BY created_at DESC LIMIT :limit OFFSET :offset");
$perPage = 10;
$page = isset($_GET['page']) ? (int)$_GET['page'] : 1;
$offset = ($page - 1) * $perPage;
$stmt->bindParam(':limit', $perPage, PDO::PARAM_INT);
$stmt->bindParam(':offset', $offset, PDO::PARAM_INT);
$stmt->execute();
$articles = $stmt->fetchAll(PDO::FETCH_ASSOC);
class User {
public $id;
public $name;
public $email;
}
$stmt = $pdo->query("SELECT id, name, email FROM users");
$users = $stmt->fetchAll(PDO::FETCH_CLASS, 'User');
foreach ($users as $user) {
echo "User: {$user->name} ({$user->email})<br>";
}
// 使用無緩沖查詢處理大量數據
$mysqli->real_query("SELECT * FROM large_table");
$result = $mysqli->use_result();
while ($row = $result->fetch_assoc()) {
// 處理每一行數據
process_row($row);
}
$result->close();
try {
$pdo->beginTransaction();
// 執行多個查詢
$pdo->exec("UPDATE accounts SET balance = balance - 100 WHERE user_id = 1");
$pdo->exec("UPDATE accounts SET balance = balance + 100 WHERE user_id = 2");
$pdo->commit();
} catch (Exception $e) {
$pdo->rollBack();
echo "Transaction failed: " . $e->getMessage();
}
// 正確的做法 \(stmt = \)pdo->prepare(“SELECT * FROM users WHERE id = ?”); \(stmt->execute([\)_GET[‘id’]]);
2. **驗證和過濾輸入**
```php
$userId = filter_input(INPUT_GET, 'id', FILTER_VALIDATE_INT);
if ($userId === false) {
die("Invalid ID");
}
try {
$stmt = $pdo->prepare("INSERT INTO logs (message) VALUES (?)");
$stmt->execute([$message]);
} catch (PDOException $e) {
error_log("Database error: " . $e->getMessage());
// 向用戶顯示友好信息
}
選擇合適的獲取方式
*使用列名而非SELECT ** “`php // 不推薦 \(stmt = \)pdo->query(“SELECT * FROM products”);
// 推薦 \(stmt = \)pdo->query(“SELECT id, name, price FROM products”);
3. **合理使用緩沖查詢**
```php
// 無緩沖查詢(大數據量)
$mysqli->real_query("SELECT * FROM large_table");
$result = $mysqli->use_result();
// 緩沖查詢(小數據量)
$result = $mysqli->query("SELECT * FROM small_table");
$result = $mysqli->query("SELECT * FROM temp_data");
// 處理結果...
$result->free(); // 釋放內存
function verifyLogin(PDO $pdo, string $username, string $password): ?array {
$stmt = $pdo->prepare("SELECT id, username, password_hash FROM users WHERE username = ?");
$stmt->execute([$username]);
$user = $stmt->fetch(PDO::FETCH_ASSOC);
if ($user && password_verify($password, $user['password_hash'])) {
return $user;
}
return null;
}
function generateSalesReport(PDO $pdo, DateTime $startDate, DateTime $endDate): array {
$stmt = $pdo->prepare("
SELECT
p.category,
SUM(oi.quantity) as total_quantity,
SUM(oi.quantity * oi.unit_price) as total_revenue
FROM order_items oi
JOIN products p ON oi.product_id = p.id
JOIN orders o ON oi.order_id = o.id
WHERE o.order_date BETWEEN ? AND ?
GROUP BY p.category
");
$stmt->execute([
$startDate->format('Y-m-d'),
$endDate->format('Y-m-d')
]);
return $stmt->fetchAll(PDO::FETCH_ASSOC);
}
function batchInsertUsers(PDO $pdo, array $users): int {
$stmt = $pdo->prepare("INSERT INTO users (username, email) VALUES (?, ?)");
$pdo->beginTransaction();
try {
$count = 0;
foreach ($users as $user) {
$stmt->execute([$user['username'], $user['email']]);
$count += $stmt->rowCount();
}
$pdo->commit();
return $count;
} catch (PDOException $e) {
$pdo->rollBack();
throw $e;
}
}
PHP提供了多種處理SQL查詢結果的函數和方法,從基礎的mysql_*函數(已廢棄)到現代的MySQLi和PDO擴展。選擇合適的結果處理方式需要考慮以下因素:
隨著PHP版本的更新,數據庫處理的最佳實踐也在不斷發展。建議開發者:
通過熟練掌握這些結果處理函數和技術,PHP開發者可以構建出既安全又高效的數據庫驅動應用程序。
函數/方法 | 擴展 | 描述 | 返回類型 |
---|---|---|---|
mysql_fetch_array | mysql | 獲取行作為混合數組 | 數組 |
mysqli_fetch_assoc | mysqli | 獲取行作為關聯數組 | 數組 |
PDO::fetch | PDO | 獲取下一行 | 數組/對象 |
fetchAll | PDO | 獲取所有行 | 多維數組 |
fetchColumn | PDO | 獲取單列值 | 標量值 |
num_rows | mysqli | 獲取行數 | 整數 |
rowCount | PDO | 獲取受影響行數 | 整數 |
data_seek | mysqli | 移動結果指針 | 布爾 |
fetch_object | mysqli/PDO | 獲取行作為對象 | 對象 |
”`
注:本文約4100字,涵蓋了PHP中處理SQL查詢結果的主要函數和技術,包括基礎函數、MySQLi和PDO擴展的使用方法,以及安全注意事項和性能優化建議。文章采用Markdown格式,包含代碼示例和實用表格,可直接用于技術文檔或博客發布。
免責聲明:本站發布的內容(圖片、視頻和文字)以原創、轉載和分享為主,文章觀點不代表本網站立場,如果涉及侵權請聯系站長郵箱:is@yisu.com進行舉報,并提供相關證據,一經查實,將立刻刪除涉嫌侵權內容。