|
|
“數據庫更改通知”入門
“數據庫更改通知”特性的用法非常簡單：創建一個針對通知執行的通知處理程序 – 一個 PL/SQL 存儲過程或客戶端 OCI 回調函數。然后，針對要接收其更改通知的數據庫對象注冊一個查詢，以便每當事務更改其中的任何對象并提交時調用通知處理程序。通常情況下，通知處理程序將被修改的表的名稱、所做更改的類型以及所更改行的行 ID（可選）發送給客戶端監聽程序，以便客戶端應用程序可以在響應中執行相應的處理。
為了了解“數據庫更改通知”特性的作用方式，請考慮以下示例。假設您的 php 應用程序訪問 OE.ORDERS 表中存儲的訂單以及 OE.ORDER_ITEMS 中存儲的訂單項。鑒于很少更改已下訂單的信息，您可能希望應用程序同時緩存針對 ORDERS 和 ORDER_ITEMS 表的查詢結果集。要避免訪問過期數據，您可以使用“數據庫更改通知”，它可讓您的應用程序方便地獲知以上兩個表中所存儲數據的更改。
您必須先將 CHANGE NOTIFICATION 系統權限以及 EXECUTE ON DBMS_CHANGENOTIFICATION 權限授予 OE 用戶，才能注冊對 ORDERS 和 ORDER_ITEMS 表的查詢，以便接收通知和響應對這兩個表所做的 DML 或 DDL 更改。為此，可以從 SQL 命令行工具（如 SQL*Plus）中執行下列命令。
CONNECT / AS SYSDBA;
GRANT CHANGE NOTIFICATION TO oe;
GRANT EXECUTE ON DBMS_CHANGE_NOTIFICATION TO oe;
確保將 init.ora 參數 job_queue_processes 設置為非零值，以便接收 PL/SQL 通知。或者，您也可以使用下面的 ALTER SYSTEM 命令：
ALTER SYSTEM SET "job_queue_processes"=2; 然后，在以 OE/OE 連接后，您可以創建一個通知處理程序。但首先，您必須創建將由通知處理程序使用的數據庫對象。例如，您可能需要創建一個或多個數據庫表，以便通知處理程序將注冊表的更改記錄到其中。在以下示例中，您將創建 nfresults 表來記錄以下信息：更改發生的日期和時間、被修改的表的名稱以及一個消息（說明通知處理程序是否成功地將通知消息發送給客戶端）。
CONNECT oe/oe;
CREATE TABLE nfresults (
operdate DATE,
tblname VARCHAR2(60),
rslt_msg VARCHAR2(100)
);
在實際情況中，您可能需要創建更多表來記錄通知事件以及所更改行的行 ID 等信息，但就本文而言，nfresults 表完全可以滿足需要。
使用 UTL_HTTP 向客戶端發送通知
您可能還要創建一個或多個 PL/SQL 存儲過程，并從通知處理程序中調用這些存儲過程，從而實現一個更具可維護性和靈活性的解決方案。例如，您可能要創建一個實現將通知消息發送給客戶端的存儲過程。“清單 1”是 PL/SQL 過程 sendNotification。該過程使用 UTL_HTTPPL 程序包向客戶端應用程序發送更改通知。
清單 1. 使用 UTL_HTTP 向客戶端發送通知
復制代碼 代碼如下:
CREATE OR REPLACE PROCEDURE sendNotification(url IN VARCHAR2,
tblname IN VARCHAR2, order_id IN VARCHAR2) IS
req UTL_HTTP.REQ;
resp UTL_HTTP.RESP;
err_msg VARCHAR2(100);
tbl VARCHAR(60);
BEGIN
tbl:=SUBSTR(tblname, INSTR(tblname, '.', 1, 1)+1, 60);
BEGIN
req := UTL_HTTP.BEGIN_REQUEST(url||order_id||'&'||'table='||tbl);
resp := UTL_HTTP.GET_RESPONSE(req);
INSERT INTO nfresults VALUES(SYSDATE, tblname, resp.reason_phrase);
UTL_HTTP.END_RESPONSE(resp);
EXCEPTION WHEN OTHERS THEN
err_msg := SUBSTR(SQLERRM, 1, 100);
INSERT INTO nfresults VALUES(SYSDATE, tblname, err_msg);
END;
COMMIT;
END;
/
如“清單 1”所示，sendNotification 以 UTL_HTTP.BEGIN_REQUEST 函數發出的 HTTP 請求的形式向客戶端發送通知消息。此 URL 包含 ORDERS 表中已更改行的 order_id。然后，它使用 UTL_HTTP.GET_RESPONSE 獲取客戶端發出的響應信息。實際上，sendNotification 并不需要處理客戶端返回的整個響應，而是只獲取一個在 RESP 記錄的 reason_phrase 字段中存儲的簡短消息（描述狀態代碼）。
創建通知處理程序
現在，您可以創建一個通知處理程序，它將借助于上面介紹的 sendNotification 過程向客戶端發送更改通知。來看一看“清單 2”中的 PL/SQL 過程 orders_nf_callback。
清單 2. 處理對 OE.ORDERS 表所做更改的通知的通知處理程序
復制代碼 代碼如下:
CREATE OR REPLACE PROCEDURE orders_nf_callback (ntfnds IN SYS.CHNF$_DESC) IS
tblname VARCHAR2(60);
numtables NUMBER;
event_type NUMBER;
row_id VARCHAR2(20);
numrows NUMBER;
ord_id VARCHAR2(12);
url VARCHAR2(256) := 'http://webserverhost/phpcache/dropResults.php?order_no=';
BEGIN
event_type := ntfnds.event_type;
numtables := ntfnds.numtables;
IF (event_type = DBMS_CHANGE_NOTIFICATION.EVENT_OBJCHANGE) THEN
FOR i IN 1..numtables LOOP
tblname := ntfnds.table_desc_array(i).table_name;
IF (bitand(ntfnds.table_desc_array(i).opflags,
DBMS_CHANGE_NOTIFICATION.ALL_ROWS) = 0) THEN
numrows := ntfnds.table_desc_array(i).numrows;
ELSE
numrows :=0;
END IF;
IF (tblname = 'OE.ORDERS') THEN
FOR j IN 1..numrows LOOP
row_id := ntfnds.table_desc_array(i).row_desc_array(j).row_id;
SELECT order_id INTO ord_id FROM orders WHERE rowid = row_id;
sendNotification(url, tblname, ord_id);
END LOOP;
END IF;
END LOOP;
END IF;
COMMIT;
END;
/
如“清單 2”所示，此通知處理程序將 SYS.CHNF$_DESC 對象用作參數，然后使用它的屬性獲取該更改的詳細信息。在該示例中，此通知處理程序將只處理數據庫為響應對注冊對象進行的 DML 或 DDL 更改（也就是說，僅當通知類型為 EVENT_OBJCHANGE 時）而發布的通知，并忽略有關其他數據庫事件（如實例啟動或實例關閉）的通知。從以上版本開始，處理程序可以處理針對 OE.ORDERS 表中每個受影響的行發出的更改通知。在本文后面的“將表添加到現有注冊”部分中，您將向處理程序中添加幾行代碼，以便它可以處理針對 OE.ORDER_ITEMS 表中被修改的行發出的通知。
為更改通知創建注冊
創建通知處理程序后，必須為其創建一個查詢注冊。對于本示例而言，您必須在注冊過程中對 OE.ORDER 表執行查詢并將 orders_nf_callback 指定為通知處理程序。您還需要在 DBMS_CHANGE_NOTIFICATION 程序包中指定 QOS_ROWIDS 選項，以便在通知消息中啟用 ROWID 級別的粒度。“清單 3”是一個 PL/SQL 塊，它為 orders_nf_callback 通知處理程序創建查詢注冊。
清單 3. 為通知處理程序創建查詢注冊
復制代碼 代碼如下:
DECLARE
REGDS SYS.CHNF$_REG_INFO;
regid NUMBER;
ord_id NUMBER;
qosflags NUMBER;
BEGIN
qosflags := DBMS_CHANGE_NOTIFICATION.QOS_RELIABLE +
DBMS_CHANGE_NOTIFICATION.QOS_ROWIDS;
REGDS := SYS.CHNF$_REG_INFO ('orders_nf_callback', qosflags, 0,0,0);
regid := DBMS_CHANGE_NOTIFICATION.NEW_REG_START (REGDS);
SELECT order_id INTO ord_id FROM orders WHERE ROWNUM<2;
DBMS_CHANGE_NOTIFICATION.REG_END;
END;
/
本示例針對 ORDERS 表創建了一個注冊，并將 orders_nf_callback 用作通知處理程序。現在，如果您使用 DML 或 DDL 語句修改 ORDERS 表并提交事務，則將自動調用 orders_nf_callback 函數。例如，您可能針對 ORDERS 表執行下列 UPDATE 語句并提交該事務：
UPDATE ORDERS SET order_mode = 'direct' WHERE order_id=2421;
UPDATE ORDERS SET order_mode = 'direct' WHERE order_id=2422;
COMMIT;
要確保數據庫發布了通知來響應以上事務，您可以檢查 nfresults 表：
SELECT TO_CHAR(operdate, 'dd-mon-yy hh:mi:ss') operdate,
tblname, rslt_msg FROM nfresults;
結果應如下所示：
OPERDATE TBLNAME RSLT_MSG
--------------------- ----------- ---------
02-mar-06 04:31:28 OE.ORDERS Not Found
02-mar-06 04:31:29 OE.ORDERS Not Found
從以上結果中可以清楚地看到，orders_nf_callback 已經正常工作，但未找到客戶端腳本。在該示例中出現這種情況并不意外，這是因為您并未創建 URL 中指定的 dropResults.php 腳本。
將表添加到現有注冊
前一部分介紹了如何使用更改通知服務使數據庫在注冊對象（在以上示例中為 ORDERS 表）發生更改時發出通知。但從性能角度而言，客戶端應用程序可能更希望緩存 ORDER_ITEMS 表而非 ORDERS 表本身的查詢結果集，這是因為它在每次訪問訂單時，不得不從 ORDERS 表中只檢索一行，但同時必須從 ORDER_ITEMS 表中檢索多個行。在實際情況中，訂單可能包含數十個甚至數百個訂單項。
由于您已經對 ORDERS 表注冊了查詢，因此不必再創建一個注冊來注冊對 ORDER_ITEMS 表的查詢了。相反，您可以使用現有注冊。為此，您首先需要檢索現有注冊的 ID。可以執行以下查詢來完成此工作：
SELECT regid, table_name FROM user_change_notification_regs; 結果可能如下所示：
REGID TABLE_NAME
----- --------------
241 OE.ORDERS
獲取注冊 ID 后，可以使用 DBMS_CHANGE_NOTIFICATION.ENABLE_REG 函數將一個新對象添加到該注冊，如下所示：
復制代碼 代碼如下:
DECLARE
ord_id NUMBER;
BEGIN
DBMS_CHANGE_NOTIFICATION.ENABLE_REG(241);
SELECT order_id INTO ord_id FROM order_items WHERE ROWNUM < 2;
DBMS_CHANGE_NOTIFICATION.REG_END;
END;
完成了！從現在開始，數據庫將生成一個通知來響應對 ORDERS 和 ORDER_ITEMS 所做的任何更改，并調用 orders_nf_callback 過程來處理通知。因此，下一步就是編輯 orders_nf_callback，以便它可以處理因對 ORDER_ITEMS 表執行 DML 操作而生成的通知。但在重新創建 orders_nf_callback 過程之前，您需要創建以下將在更新過程中引用的表類型：
CREATE TYPE rdesc_tab AS TABLE OF SYS.CHNF$_RDESC; 然后，返回清單，在以下代碼行之后：
復制代碼 代碼如下:
IF (tblname = 'OE.ORDERS') THEN
FOR j IN 1..numrows LOOP
row_id := ntfnds.table_desc_array(i).row_desc_array(j).row_id;
SELECT order_id INTO ord_id FROM orders WHERE rowid = row_id;
sendNotification(url, tblname, ord_id);
END LOOP;
END IF;
插入以下代碼：
復制代碼 代碼如下:
IF (tblname = 'OE.ORDER_ITEMS') THEN
FOR rec IN (SELECT DISTINCT(o.order_id) o_id FROM
TABLE(CAST(ntfnds.table_desc_array(i).row_desc_array AS 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 表中插入了一行 主站蜘蛛池模板： 午夜视频久久久久一区 | 国产精品免费一区二区三区四区 | 中文精品久久久久国产网址 | 国产呦精品一区二区三区网站 | 热久久99影院| 国产一区二区三区手机在线观看 | 国内精品视频一区二区三区 | 黄色大片网站在线观看 | 日本加勒比在线视频 | 91一个人的在线观看www | 亚洲欧美激情视频 | 国产精品伦理久久久久 | 六月激情网| 黄色美女免费看 | 一级一级特黄女人精品毛片 | 日韩激情影院 | 色妇女| 国产亚洲精品激情都市 | 久久久久久亚洲精品中文字幕 | 欧美性xxxx人妖 | 国产精品久久久久久久久鸭 | 国产精品久久久久久久牛牛 | 国产亚洲福利精品一区二区 | 四虎影视永久在线精品免费播放 | 美女视频很黄很a免费国产 美女视频黄.免费网址 | 国产成人精品在视频 | 国产极品在线观看 | 亚洲手机在线 | 中文字幕在线播放一区 | 日本欧美一区二区免费视 | 国产一区二区精品在线观看 | 超91视频| 男人进去女人爽免费视频国产 | 国产原创精品视频 | 中文字幕一级毛片视频 | haodiaocao这里只有精品一 | 九九综合九九综合 | 亚洲精品国产啊女成拍色拍 | 欧美黑人粗硬大在线看 | 亚洲欧美94色 | 欧美激情a∨在线视频播放 欧美激情不卡 |