通过缓存数据库结果提高PHP性能的原理介绍
rdesc_tab)) t,
orders o, order_items d WHERE t.row_id = d.rowid AND d.order_id=o.order_id)
LOOP
sendNotification(url, tblname, rec.o_id);
END LOOP;
END IF;
重新创建 orders_nf_callback 后，您需要测试它能否正常工作。为此，您可以针对 ORDER_ITEMS 表执行下列 UPDATE 语句并提交该事务：
UPDATE ORDER_ITEMS SET quantity = 160 WHERE order_id=2421 AND line_item_id=1;
UPDATE ORDER_ITEMS SET quantity = 160 WHERE order_id=2421 AND line_item_id=2;
COMMIT;
然后，检查 nfresults 表，如下所示：
SELECT TO_CHAR(operdate, ''dd-mon-yy hh:mi:ss'') operdate,
rslt_msg FROM nfresults WHERE tblname = ''OE.ORDER_ITEMS''; 输出可能如下所示：
OPERDATE RSLT_MSG
------------------- --------------
03-mar-06 12:32:27 Not Found
您可能很奇怪为什么只向 nfresults 表中插入了一行 – 毕竟您更新了 ORDER_ITEMS 表中的两行。实际上，这两个更新了的行具有相同的 order_id – 即它们属于同一订单。此处，我们假设客户端应用程序将使用一个语句选择订单的所有订单项，因此它并不需要确切知道已经更改了某个订单的哪些订单项。相反，客户端需要知道其中至少修改、删除或插入了一个订单项的订单 ID。
构建客户端
现在，您已经针对 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'']);
return false;
}
$results = oci_fetch_assoc($rsStatement);
return $results;
}
?>
“清单 5”是 getOrderItems.php 脚本。该脚本包含 getOrderItems 函数，该
orders o, order_items d WHERE t.row_id = d.rowid AND d.order_id=o.order_id)
LOOP
sendNotification(url, tblname, rec.o_id);
END LOOP;
END IF;
重新创建 orders_nf_callback 后，您需要测试它能否正常工作。为此，您可以针对 ORDER_ITEMS 表执行下列 UPDATE 语句并提交该事务：
UPDATE ORDER_ITEMS SET quantity = 160 WHERE order_id=2421 AND line_item_id=1;
UPDATE ORDER_ITEMS SET quantity = 160 WHERE order_id=2421 AND line_item_id=2;
COMMIT;
然后，检查 nfresults 表，如下所示：
SELECT TO_CHAR(operdate, ''dd-mon-yy hh:mi:ss'') operdate,
rslt_msg FROM nfresults WHERE tblname = ''OE.ORDER_ITEMS''; 输出可能如下所示：
OPERDATE RSLT_MSG
------------------- --------------
03-mar-06 12:32:27 Not Found
您可能很奇怪为什么只向 nfresults 表中插入了一行 – 毕竟您更新了 ORDER_ITEMS 表中的两行。实际上，这两个更新了的行具有相同的 order_id – 即它们属于同一订单。此处，我们假设客户端应用程序将使用一个语句选择订单的所有订单项，因此它并不需要确切知道已经更改了某个订单的哪些订单项。相反，客户端需要知道其中至少修改、删除或插入了一个订单项的订单 ID。
构建客户端
现在，您已经针对 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'']);
return false;
}
$results = oci_fetch_assoc($rsStatement);
return $results;
}
?>
“清单 5”是 getOrderItems.php 脚本。该脚本包含 getOrderItems 函数，该