一、 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類型的異常。當被轉換成一個字符串時,它將返回發生的錯誤的細節信息。
為此,你需要使用PHP代理。事實上,你在我們的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對象,返回它的結果就好象它是查詢對象本身(稱作是基本數據庫函數)一樣。 1