緩存SQL查詢結果

為什么要緩存查詢結果？

緩存查詢結果能極大地改進腳本執行時間和資源需求。

緩存SQL查詢結果也允許你通過后期處理數據。如果你用文件緩存去存儲全部腳本的輸出結果（HTML輸出），這樣可能是行不通的。

當你執行一個SQL查詢時，點典的處理過程是：

<!--[if !supportLists]-->l <!--[endif]-->連接數據庫

<!--[if !supportLists]-->l <!--[endif]-->準備SQL查詢

<!--[if !supportLists]-->l <!--[endif]-->發送查詢到數據庫

<!--[if !supportLists]-->l <!--[endif]-->取得返回結果

<!--[if !supportLists]-->l <!--[endif]-->關閉數據庫連接

以上方法非常占用資源并且相反的影響了腳本的性能。只能通過取得的大量返回數據和數據庫服務器的位置這二個要素來相互協調。盡管持續連接可以改進連接數據庫時的負載，但非常耗費內存資源，如果獲取的是大量的數據，那么存儲的全部時間會非常短暫。

創建一條SQL查詢：

SQL(結構化查詢語言)查詢被用作操作數據庫及它內容的接口。SQL可用于定義和編輯表的結構，插入數據到表，更新或刪除表中的信息。

SQL是用于與數據通訊的語言，在大多數PHP數據庫擴展(html' target='_blank'>MySQL,ODBC,Oracle等)通過傳遞SQL查詢到數據庫中來管理整個過程。

本教程中，僅僅用select語言來獲取數據庫中的數據。這些數據將被緩存，之后將用作數據源。

決定什么時候更新緩存：

根據程序的需要，緩存可以采取多種形式。最常見的3種方式是：

<!--[if !supportLists]-->l <!--[endif]-->時間觸發緩存（過期的時間戳）

<!--[if !supportLists]-->l <!--[endif]-->內容改變觸發緩存（發現數據改變后，相應地更新緩存）

<!--[if !supportLists]-->l <!--[endif]-->人工觸發緩存（人工的方式告知系統信息超期并且強制產生新的緩存）

你的緩存需求可能是以上原理的一個或多個的綜合。本教程將討論時間觸發方式。然而，在一個全面的緩存機制中，3種方式的綜合將被使用。

緩存結果：

基本的緩存是用PHP的兩個函數serialize()和unserialize()(譯注：這二個函數分別代表序列化與反序列化)。

函數serialize()用于存儲PHP的值，它能保證不失去這些值的類型和結構。

事實上，PHP的session擴展是用序列化過的變量，把session變量($_SESSION)存儲在系統的一個文件中。

函數unserialize()與以上操作相反并且使序列化過的字符串返回到它原來的結構和數據內容。

在本例中，以一個電子商務商店為例。商店有2個基本表，categories和products(此處為原始數據庫表名).product表可能每天都在變化，categories仍然是不變靜止的。

要顯示產品，你可以用一個輸出緩存腳本來存儲輸出的HTML結果到一個文件中。然而categories表可能需要后期處理。例如，所有的目錄通過變量category_id（通過$_REQUEST['category_id']來取得）被顯示，你可能希望高亮當前被選擇的目錄。

表categories結構

在本例中，通過時間觸發緩存技術被運用，設定一段時間后讓其緩存SQL輸出過期。在此特殊的例子中，定一段時間為24小時。

序列化例子：

<!--[if !supportLists]-->l <!--[endif]-->連接數據庫

<!--[if !supportLists]-->l <!--[endif]-->執行查詢

<!--[if !supportLists]-->l <!--[endif]-->取得所有結果構成一個數組以便后面你可以訪問

<!--[if !supportLists]-->l <!--[endif]-->序列化數組

<!--[if !supportLists]-->l <!--[endif]-->保存序列化過的數組到文件中

[php] view plaincopy

$file = 'sql_cache.txt';  $link = mysql_connect('localhost','username','password')      or die (mysql_error());  mysql_select_db('shop')      or die (mysql_error());  /* 構造SQL查詢 */  $query = "SELECT * FROM categories";  $result = mysql_query($query)      or die (mysql_error());  while ($record = mysql_fetch_array($result) )  {      $records[] = $record;  }  $OUTPUT = serialize($records);  $fp = fopen($file,"w"); // 以寫權限的方式打開文件fputs($fp, $OUTPUT);  fclose($fp);

查看sql_cache.txt文件，里面的內容可能類似這樣的：

a:1:{i:0;a:6:{i:0;s:1:"1";s:11:"category_id";s:1:"1";i:1;s:9:"Computers";s:13:"category_name";s:9:

"Computers" ;i:2;s:25:"Description for computers";s:20:"category_description"

;s:25:"Description for computers";}}

這個輸出是它的變量和類型的內部表現形式。假若你用mysql_fetch_array()函數返回數字索引的數組和一個關聯的數組（這就是為什么數據看起來像是發生了兩次），一個是數字索引，另一個是字符串索引。

使用緩存：

要用緩存，你需要用函數unserialize()來使數據還原成原始格式與類型。

你可以用file_get_contents()這個函數來讀取sql_cache.txt文件的內容，把它賦給一個變量。

請注意：這個函數在PHP4.3.0及以上版本有效。若你使用的是一個老版本的PHP,一個簡單的方法是用file()函數(讀整個文件到一個數組，每行變成一個數組)。implode()函數用于把數組的各元素連接成一個字符串然后使用unserialize()反序列化。

// file_get_contents() 適合于for PHP < 4.3.0

[php] view plaincopy

$file = 'sql_cache.txt';  $records = unserialize(implode('',file($file)));  //現在你可以通過$records數組并且取得原始查詢的數據：  foreach ($records as $id=>$row) {      print $row['category_name']."<br>";  }

注意$records是數組（一個包含了查詢結果的數字索引列——每行是一個數字和一個字符串...真是混亂）的一排。

把它們放在一塊：

基于本例子中的時間來決定是否緩存。如果文件修改的時間戳比當前時間戳減去過期時間戳大，那么就用緩存，否則更新緩存。

<!--[if !supportLists]-->l <!--[endif]-->檢查文件是否存在并且時間戳小于設置的過期時間

<!--[if !supportLists]-->l <!--[endif]-->獲取存儲在緩存文件中的記錄或者更新緩存文件

[php] view plaincopy

$file = 'sql_cache.txt';  $expire = 86400; // 24 小時 (單位：秒)if (file_exists($file) &&   filemtime($file) > (time() - $expire))  {      // 取得緩存中的記錄      $records = unserialize(file_get_contents($file));  } else {      // 通過 serialize() 函數創建緩存  }

附加其它可能的：

<!--[if !supportLists]-->l <!--[endif]-->把緩存結果存儲在共享內存中以獲取更快的速度

<!--[if !supportLists]-->l <!--[endif]-->增加一個功能隨機地運行SQL查詢并且檢查是否輸出與緩存輸出一致。如果不一致，則更新緩存（本函數運行次數的概率可以定為1/100）。通過哈希算法（如MD5()）可以協助判斷字符串或者文件是否改變。

<!--[if !supportLists]-->l <!--[endif]-->增加一個管理員的功能，人工的刪除這個緩存文件，以強制更新緩存（如file_exists()函數返回false時）。你可以用函數unlink()刪除文件。

腳本：

[php] view plaincopy

$file = 'sql_cache.txt';  $expire = 86400; // 24 小時if (file_exists($file) &&      filemtime($file) > (time() - $expire)) {      $records = unserialize(file_get_contents($file));  } else {      $link = mysql_connect('localhost','username','password')          or die (mysql_error());      mysql_select_db('shop')          or die (mysql_error());      /* 構造SQL查詢 */      $query = "SELECT * FROM categories";      $result = mysql_query($query)          or die (mysql_error());      while ($record = mysql_fetch_array($result) ) {          $records[] = $record;      }      $OUTPUT = serialize($records);      $fp = fopen($file,"w");      fputs($fp, $OUTPUT);      fclose($fp);  } // end else     // 查詢結果在數組 $records 中  foreach ($records as $id=>$row) {      if ($row['category_id'] == $_REQUEST['category_id']) {          // 被選擇的目錄顯示粗體字          print '<B>'.$row['category_name'].'</B><BR>';      } else {          // 其它目錄顯示用常規字體          print $row['category_name'].'<br>';      }  } // end foreach