用array_map() 批量處理mysqli_result 行數據

M66 2025-05-18

在PHP 中，使用mysqli擴展進行數據庫操作時，我們經常需要對查詢結果進行進一步的處理。 mysqli_result對象存儲了從數據庫中查詢返回的所有數據。通常我們需要遍歷每一行數據來進行某些操作。一個常見的方式是通過循環，但如果我們希望使用一種更簡潔的方式，可以藉助PHP 內置的array_map()函數來批量處理每一行數據。

1. array_map()函數簡介

array_map()是一個高階函數，它允許你對數組中的每一個元素應用一個回調函數，返回一個新的數組。簡單來說，它通過回調函數修改數組中的每個元素。

其基本語法如下：

 array_map(callable $callback, array $array, array ...$arrays): array

callback是我們要應用的回調函數。
array是我們要處理的數組。
可以接受多個數組作為參數，但一般情況下我們只傳入一個數組。

2. 用array_map()處理mysqli_result結果

在處理mysqli_result時，首先我們需要將其轉換成一個數組。可以通過mysqli_fetch_all()函數來實現，它將查詢結果轉為一個二維數組。然後我們就可以使用array_map()來對每一行進行處理。

示例代碼：

 <?php
// 連接到數據庫
$mysqli = new mysqli("localhost", "root", "password", "database_name");

// 檢查連接是否成功
if ($mysqli->connect_error) {
    die("連接失敗: " . $mysqli->connect_error);
}

// 執行查詢
$result = $mysqli->query("SELECT * FROM users");

// 將查詢結果轉換為二維數組
$data = mysqli_fetch_all($result, MYSQLI_ASSOC);

// 定義一個回調函數，用於處理每一行數據
function processRow($row) {
    // 例如，修改每一行的數據（這裡只是一個示例）
    $row['email'] = str_replace('@old-domain.com', '@m66.net', $row['email']);
    return $row;
}

// 使用 array_map 批量處理每一行
$processedData = array_map('processRow', $data);

// 輸出處理後的數據
print_r($processedData);

// 關閉數據庫連接
$mysqli->close();
?>

代碼說明：

連接數據庫：首先，我們通過new mysqli()建立數據庫連接。
執行查詢：用mysqli->query()執行查詢語句，從數據庫中獲取mysqli_result 。
將查詢結果轉為數組：使用mysqli_fetch_all()將查詢結果轉換成一個關聯數組（ MYSQLI_ASSOC ）。
定義回調函數： processRow()是一個自定義的回調函數，我們在其中對每一行的數據進行修改。例如，這裡我們通過str_replace()將email中的域名從old-domain.com替換為m66.net 。
批量處理：通過array_map()函數批量處理每一行數據，傳入回調函數processRow來對每一行進行處理。
輸出處理後的數據：最終，我們打印出處理後的數據。

3. 為什麼選擇array_map() ？

與使用foreach循環逐行處理數據相比， array_map()具有更簡潔的語法，使得代碼更加緊湊和清晰。尤其是在處理比較複雜的操作時，使用array_map()能夠讓代碼看起來更具函數式編程的風格。

4. 注意事項

array_map()返回的是一個新的數組，並不會修改原始數組。所以如果你需要保留原始數據，可以將返回值存儲在另一個變量中。
mysqli_fetch_all()返回的是一個二維數組，因此我們可以直接在array_map()中處理它。如果你只需要處理單一的列，可以使用其他函數如array_column()先提取列，再進行處理。

5. 總結

通過使用array_map()函數，我們能夠簡潔、高效地批量處理mysqli_result查詢結果中的每一行。它比傳統的foreach循環更加簡潔，並且能夠清晰地表達數據處理的意圖。希望這個方法能夠幫助你更好地處理數據庫查詢結果中的數據。