構建客戶端
現在,您已經針對 ORDERS 和 ORDER_ITEMS
表創建了注冊,下面我們將了解一下訪問這些表中存儲的訂單及其訂單項的客戶端應用程序如何使用更改通知。為此,您可以構建一個 PHP
應用程序,它將緩存針對以上表的查詢結果,並采取相應的操作來響應有關對這些表所做更改的通知(從數據庫服務器中收到這些通知)。一個簡單的方法是使用
PEAR::Cache_Lite 程序包,它為您提供了一個可靠的機制來使緩存數據保持最新狀態。尤其是,您可以使用 Cache_Lite_Function
類(PEAR::Cache_Lite 程序包的一部分),通過該類您可以緩存函數調用。
例如,您可以創建一個函數來執行下列任務:建立數據庫連接、針對該數據庫執行 select
語句、獲取檢索結果並最終以數組形式返回結果。然後,您可以通過 Cache_Lite_Function 實例的 call
方法緩存由該函數返回的結果數組,以便可以從本地緩存而不是從後端數據庫讀取這些數組,這樣可以顯著提高應用程序的性能。然後,在收到緩存數據更改的通知時,您將使用
Cache_Lite_Function 實例的 drop 方法刪除緩存中的過期數據。
回過頭來看看本文的示例,您可能要創建兩個函數,用於應用程序與數據庫交互:第一個函數將查詢 ORDERS 表並返回具有指定 ID
的訂單,而另一個函數將查詢 ORDER_ITEMS 表並返回該訂單的訂單項。“清單 4”顯示了包含 getOrderFields 函數(該函數接受訂單 ID
並返回一個包含所檢索到訂單的某些字段的關聯數組)的 getOrderFields.php 腳本。
清單 4.
獲取指定訂單的字段
<?php
//File:getOrderFields.php
require_once 'connect.php';
function getOrderFields($order_no) {
if (!$rsConnection = GetConnection()){
return false;
}
$strSQL = "SELECT TO_CHAR(ORDER_DATE) ORDER_DATE, CUSTOMER_ID,
ORDER_TOTAL FROM ORDERS WHERE order_id =:order_no";
$rsStatement = oci_parse($rsConnection,$strSQL);
oci_bind_by_name($rsStatement, ":order_no", $order_no, 12);
if (!oci_execute($rsStatement)) {
$err = oci_error();
print $err['message'];
trigger_error('Query failed:' . $err['message']);