一、 DBQuery對象
現在,我們的DBQuery對象簡單地模仿一個存儲過程—一旦被執行,即返回一個必須進行保存的結果資源;並且如果你想使用該結果集上的函數(例如num_rows()或fetch_row())的話,你必須傳遞MySqlDB對象。那麼,如果由DBQuery對象來實現MySqlDB對象(其設計目的是對一個執行查詢的結果進行操作)實現的函數,效果如何呢?讓我們繼續使用上一篇示例中的代碼;並且讓我們假定,現在由DBQuery對象管理我們的結果資源。DBQuery類的源碼如列表1所示。
列表1.使用DBQuery類。
require mysql_db.php;
require_once query.php;
$db = new MySqlDb;
$db->connect(host, username, pass);
$db->query(use content_management_system);
$query = new DBQuery($db);
$query->prepare(SELECT fname,sname FROM users WHERE username=:1S AND pword=:2S AND expire_time<:3I);
try {
if($query->execute("visualad", "apron", time()))->num_rows() == 1) {
echo(Correct Credentials);
} else {
echo(Incorrect Credentials / Session Expired);
}
} catch (QueryException $e) {
echo(Error executing query: . $e);
}
上面修改後的代碼中我們最感興趣的是,catch語句和execute語句。
· execute語句不再返回一個結果資源,現在它返回DBQuery對象本身。
· DBQuery對象現在實現num_rows()函數—我們從DB接口中已經熟悉。
· 如果查詢執行失敗,它拋出一個QueryException類型的異常。當被轉換成一個字符串時,它將返回發生的錯誤的細節信息。
為此,你需要使用代理。事實上,你在我們的DBQuery對象中已經使用代理了,但是現在將更為深入地使用它來把它與MySqlDB對象緊密綁定。該DBQuery對象已經被使用一個實現DB接口的對象初始化,並且它已經包含一個成員函數execute—由它調用DB對象的query()方法來執行該查詢。這個DBQuery對象本身並不實際地查詢數據庫,它把這項任務交由DB對象來完成。這就是代理,其實是一個進程—借助於這個進程,通過把消息發送給另一個實現相同的或類似行為的對象,一個對象可以實現一個特別的行為。
為此,你需要修改DBQuery對象以便包括所有的函數—它們操作一個來自DB對象的結果資源。當執行查詢以調用DB對象的相應函數並且返回它的結果時,你需要使用存儲的結果。下列函數將被添加:
列表2:使用代理擴展DBQuery類。
class DBQuery
{
.....
public function fetch_array()
{
if (! is_resource($this->result)) {
throw new Exception(Query not executed.);
}
return $this->db->fetch_array($this->result);
}
public function fetch_row()
{
if (! is_resource($this->result)) {
throw new Exception(Query not executed.);
}
return $this->db->fetch_row($this->result);
}
public function fetch_assoc()
{
if (! is_resource($this->result)) {
throw new Exception(Query not executed.);
}
return $this->db->fetch_assoc($this->result);
}
public function fetch_object()
{
if (! is_resource($this->result)) {
throw new Exception(Query not executed.);
}
return $this->db->fetch_object($this->result);
}
public function num_rows()
{
if (! is_resource($this->result)) {
throw new Exception(Query not executed.);
}
return $this->db->num_rows($this->result);
}
}
每個函數的實現相當簡單。它首先進行檢查,以確保已經執行查詢,然後把任務代理到DB對象,返回它的結果就好象它是查詢對象本身(稱作是基本數據庫函數)一樣。
二、 類型提示(Type Hinting)
為了使代理能夠工作,我們需要確保DBQuery對象的$db變量是一個實現了DB接口的對象的實例。類型提示是PHP 5中的一種新特征,它能夠使你把函數參數強制轉換成特定類型的對象。在PHP 5之前,唯一的確保函數參數是一個特定對象類型的方法是使用PHP中所提供的類型檢查函數(也即是is_a())。現在,你可以簡單地強制轉換對象類型—通過在函數參數的前面加上類型名。你已經從我們的DBQuery對象中看到了類型提示,這樣可以確保一個實現DB接口的對象被傳遞到對象構造器中。
public function __construct(DB $db)
{
$this->db = $db;
}
當使用類型提示時,你不僅可以指定對象類型,還可以指定抽象類和接口。
三、 拋出異常
你可能已經從上面的代碼中注意到,你捕獲的是一個稱為QueryException(我們將在後面實現這個對象)的異常。一個異常類似於一個錯誤,然而卻更具有一般性。描述一個異常的最好的方法是使用emergency。盡管一個emergency可以不會是“致命的”,但是還是必須處理它。當在PHP中拋出一個異常時,執行的當前范圍很快地被終止,不管它是一個函數,try..catch塊還是腳本本身。然後,該異常遍歷調用棧—終止每個執行范圍,直到或者在一個try..catch塊中捕獲它或者它到達調用棧的頂部—此時它將生成一個致命錯誤。
異常處理是PHP 5中的另外一個新特征,當與OOP聯用時,它能夠實現良好地控制錯誤處理和報告。一個try..catch塊是一種處理異常的重要機制。一旦被捕獲,腳本將會從異常被捕獲和被處理的代碼的下一行繼續執行。
如果查詢失敗,你需要改變你的execute函數以拋出一個異常。你將拋出一個稱為QueryException的定制異常對象—導致錯誤的DBQuery對象被傳遞給它。
列表3.拋出一個異常。
/**
*執行當前查詢
*
* 執行當前查詢—用提供的參數代替任何點位符
* .
*
* @參數: mixed $queryParams,... 查詢參數
* @返回:資源A—參考描述執行查詢的資源。
*/
public function execute($queryParams = )
{
//例如: SELECT * FROM table WHERE name=:1S AND type=:2I AND level=:3N
$args = func_get_args();
if ($this->stored_procedure) {
/*調用compile函數以得到查詢*/
$query = call_user_func_array(array($this, compile), $args);
} else {
/*一個存儲過程沒被初始化,因此,作為一種標准查詢來執行之*/
$query = $queryParams;
}
$result = $this->db->query($query);
if (! $result) {
throw new QueryException($this);