<?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']);
return false;
}
$results = oci_fetch_assoc($rsStatement);
return $results;
}
?>
“清单 5”是 getOrderItems.php 脚本。该脚本包含 getOrderItems 函数，该函数接受订单 ID 并返回一个二维数组，该数组包含表示订单的订单项的行。
清单 5. 获取指定订单的订单项
复制代码 代码如下:
<?php
//File:getOrderItems.php
require_once 'connect.php';
function getOrderItems($order_no) {
if (!$rsConnection = GetConnection()){
return false;
}
$strSQL = "SELECT * FROM ORDER_ITEMS WHERE
order_id =:order_no ORDER BY line_item_id";
$rsStatement = oci_parse($rsConnection,$strSQL);
oci_bind_by_name($rsStatement, ":order_no", $order_no, 12);
if (!oci_execute($rsStatement)) {
$err = oci_error();
trigger_error('Query failed:' . $err['message']);
return false;
}
$nrows = oci_fetch_all($rsStatement, $results);
return array ($nrows, $results);
}
?>
注意，以上两个函数都需要 connect.php 脚本，该脚本应包含返回数据库连接的 GetConnection 函数。清单 6 就是 connect.php 脚本：
清单 6. 获取数据库连接
复制代码 代码如下:
<?php
//File:connect.php
function GetConnection() {
$dbHost = "dbserverhost";
$dbHostPort="1521";
$dbServiceName = "orclR2";
$usr = "oe";
$pswd = "oe";
$dbConnStr = "(DESCRIPTION=(ADDRESS=(PROTOCOL=TCP)(HOST=".$dbHost.")
(PORT=".$dbHostPort."))(CONNECT_DATA=(SERVICE_NAME=".$dbServiceName.")))";
if(!$dbConn = oci_connect($usr,$pswd,$dbConnStr)) {
$err = oci_error();
trigger_error('Failed to connect ' .$err['message']);
return false;
}
return $dbConn;
}
?>
现在，您已经创建了与数据库通信所需的所有函数，下面我们将了解一下 Cache_Lite_Function 类的工作方式。清单 7 是 testCache.php 脚本，该脚本使用 Cache_Lite_Function 类缓存以上函数的结果。
清单 7. 使用 PEAR::Cache_Lite 缓存
复制代码 代码如下:
<?php
//File:testCache.php
require_once 'getOrderItems.php';
require_once 'getOrderFields.php';
require_once 'Cache/Lite/Function.php';
$options = array(
'cacheDir' => '/tmp/',
'lifeTime' => 86400
);
if (!isset($_GET['order_no'])) {
die('The order_no parameter is required');
}
$order_no=$_GET['order_no'];
$cache = new Cache_Lite_Function($options);
if ($orderfields = $cache->call('getOrderFields', $order_no)){
print "<h3>ORDER #$order_no</h3>\n";
print "<table>";
print "<tr><td>DATE:</td><td>".$orderfields['ORDER_DATE']."</td></tr>";
print "<tr><td>CUST_ID:</td><td>".$orderfields['CUSTOMER_ID']."</td></tr>";
print "<tr><td>TOTAL:</td><td>".$orderfields['ORDER_TOTAL']."</td></tr>";
print "</table>";
} else {
print "Some problem occurred while getting order fields!\n";
$cache->drop('getOrderFields', $order_no);
}
if (list($nrows, $orderitems) = $cache->call('getOrderItems', $order_no)){
//print "<h3>LINE ITEMS IN ORDER #$order_no</h3>";
print "<table border=1>";
print "<tr>\n";
while (list($key, $value) = each($orderitems)) {
print "<th>$key</th>\n";
}
print "</tr>\n";
for ($i = 0; $i < $nrows; $i++) {
print "<tr>";
print "<td>".$orderitems['ORDER_ID'][$i]."</td>";
print "<td>".$orderitems['LINE_ITEM_ID'][$i]."</td>";
print "<td>".$orderitems['PRODUCT_ID'][$i]."</td>";
print "<td>".$orderitems['UNIT_PRICE'][$i]."</td>";
print "<td>".$orderitems['QUANTITY'][$i]."</td>";
print "</tr>";
}
print "</table>";
} else {
print "Some problem occurred while getting order line items";
$cache->drop('getOrderItems', $order_no);
}
?>
“清单 7”中的 testCache.php 脚本应与 order_no URL 参数（代表 OE.ORDER 表中存储的订单 ID）一起被调用。例如，要检索与 ID 为 2408 的订单相关的信息，需要在浏览器中输入如下所示的 URL：
?order_no=2408 结果，浏览器将生成以下输出：
ORDER #2408
DATE: 29-JUN-99 06.59.31.333617 AM
CUST_ID: 166
TOTAL: 309
ORDER_ID LINE_ITEM_ID PRODUCT_ID UNIT_PRICE QUANTITY
2408 1 2751 61 3
2408 2 2761 26 1
2408 3 2783 10 10
现在，如果您单击浏览器中的 reload 按钮，testCache.php 脚本将不会再次调用 getOrderFields 和 getOrderItems 函数。相反，它将从本地缓存中读取它们的结果。因此，从现在起的 24 小时（因为 lifeTime 设置为 86400 秒）以内，本地缓存即可满足使用 order_no=2108 的每个 getOrderFields 或 getOrderItems 调用的需要。但请注意，Cache_Lite_Function 类未提供 API 来测试具有给定参数的给定函数是否存在可用缓存。因此，要确定每次使用相同参数调用函数时应用程序是实际上读取缓存还是仍执行该函数可能有点棘手。例如，在以上示例中，要确保缓存机制正常工作，您可以临时更改 connect.php 脚本中指定的连接信息，以便它无法建立数据库连接；比如指定一个错误的数据库服务器主机名称，然后再次使用 order_no=2108 运行 testCache.php 脚本。如果缓存正常工作，浏览器的输出应与先前的一样。
此外，您还可以检查缓存目录，该目录作为 cacheDir 选项的值（在该示例中为 /tmp）传递给 Cache_Lite_Function 类的构造函数。在该目录中，您将找到两个刚创建的缓存文件，这些文件的名称类似于：cache_7b181b55b55aee36ad5e7bd9d5a091ec_3ad04d3024f4cd54296f75c92a359154。注意，如果您是一位 Windows 用户，则可能要使用 %SystemDrive%\temp 目录保存缓存文件。如果是这样，则必须将 cacheDir 选项设置为 /temp/。
验证缓存机制正常工作后，可以接着创建一个 PHP 来处理从数据库服务器收到的更改通知。“清单 8”是 dropResult.php 脚本。数据库服务器将调用该脚本来响应 ORDERS 和 ORDER_ITEMS 表的更改。
清单 8. 处理从数据库服务器收到的更改通知
复制代码 代码如下: