ヘッダーをスキップ
Oracle Database PL/SQLパッケージ・プロシージャおよびタイプ・リファレンス
11g リリース1(11.1)
E05686-02
  目次
目次
索引
索引

戻る
戻る
 
次へ
次へ
 

33 DBMS_CQ_NOTIFICATION

DBMS_CQ_NOTIFICATIONパッケージは、クライアント・アプリケーションによって指定された問合せに関する登録を作成し、その問合せに関連付けられているオブジェクトでDML変更またはDDL変更が発生した際に通知を受け取る機能を提供するデータベース変更通知機能の一部です。通知は、DMLトランザクションまたはDDLトランザクションのコミット時にデータベースによって発行されます。


関連項目:

データベース変更通知の実装については、『Oracle Databaseアドバンスト・アプリケーション開発者ガイド』を参照してください。

この章では、次の項目について説明します。


DBMS_CQ_NOTIFICATIONの使用方法


概要

DBMS_CQ_NOTIFICATIONパッケージは、PL/SQLベースの登録インタフェースを提供します。クライアントは、このインタフェースを使用して、問合せに関する登録を対象となるオブジェクトに基づいて作成し、通知を受け取るPL/SQLコールバック・ハンドラを指定できます。 オブジェクト・レベルの登録の場合、登録した問合せに関連付けられているオブジェクトのいずれかがトランザクションによって変更され、そのトランザクションがCOMMITされると、それらのオブジェクトの登録時に指定したPL/SQLコールバックが起動されます。このアプリケーションによって、PL/SQLコールバック・ハンドラの実装の内部に、クライアント固有の処理を定義できます。

このインタフェースでは、(BEGIN-ENDブロックと同様の方法で)登録ブロックを定義できます。BEGINフェーズでは、通知の受信者(PL/SQLコールバック・ハンドラの名前)およびその他のいくつかの登録プロパティ(タイムアウトなど)を指定できます。(登録ブロック内で)続いて実行される問合せは優先度が高い問合せとみなされ、問合せの実行時にこれらの問合せによって参照されるオブジェクトが登録されます。登録は、登録ブロックをENDで終了することで完了します。登録ブロックでは、新しい登録の作成および既存の登録へのオブジェクトの追加を行うことができます。

PL/SQLインタフェースで登録を作成すると、RDBMSによって一意の登録IDが割り当てられます。クライアント・アプリケーションは、作成した登録をこの登録IDで追跡できます。RDBMSによって通知が発行されると、この登録IDが通知に含まれます。

通常のアプリケーション

たとえば、この機能は、問合せの結果セットを中間層内の読取り専用のオブジェクトに多くの場合キャッシュして、データベースへのネットワーク上のラウンドトリップを回避するアプリケーションで有効です。このようなアプリケーションでは、キャッシュする必要がある問合せに関する登録を作成できます。それらの問合せ内で参照されているオブジェクトに変更があった場合、元のトランザクションのコミット時に、データベースによって通知が発行されます。この通知に対応して、中間層のアプリケーションは、問合せを再度実行してキャッシュをリフレッシュできます。


セキュリティ・モデル

DBMS_CQ_NOTIFICATIONパッケージを使用して通知を受け取るユーザーは、CHANGE NOTIFICATIONシステム権限およびDBMS_CQ_NOTIFICATIONパッケージに対するEXECUTE権限を付与されている必要があります。

また、このユーザーには、登録するすべてのオブジェクトに対するSELECT権限も必要です。登録の作成時に付与されたオブジェクトに対するSELECT権限を、その後(失効などで)失った場合は、登録がパージされ、そのことが通知されます。


定数

DBMS_CQ_NOTIFICATIONパッケージでは、表33-1に示す定数が使用されます。これらの定数は、登録時または通知受信時のflagパラメータとして使用されます。

DBMS_CQ_NOTIFICATIONパッケージには、次の定数があります。

表33-1 DBMS_CQ_NOTIFICATIONの定数

名前 説明

ALL_OPERATIONS

BINARY_INTEGER

0

すべての操作に対する通知(登録時のパラメータとして指定)。

ALL_ROWS BINARY_INTEGER

BINARY_INTEGER

1

表内のすべての行が変更された可能性があります。

EVENT_STARTUP

BINARY_INTEGER

1

インスタンス起動通知。

EVENT_SHUTDOWN

BINARY_INTEGER

2

インスタンス停止通知。

EVENT_SHUTDOWN_ANY

BINARY_INTEGER

3

RAC実行時のインスタンスの停止。

EVENT_DEREG

BINARY_INTEGER

5

登録が削除されました。

EVENT_OBJCHANGE

BINARY_INTEGER

6

オブジェクト変更通知。

EVENT_QUERYCHANGE CONSTANT

BINARY_INTEGER

7

問合せ結果セットの変更の通知。

INSERTOP

BINARY_INTEGER

2

挿入操作。

UPDATEOP

BINARY_INTEGER

4

更新操作。

DELETEOP

BINARY_INTEGER

8

削除操作。

ALTEROP

BINARY_INTEGER

16

表の変更。

DROPOP

BINARY_INTEGER

32

表の削除。

UNKNOWNOP

BINARY_INTEGER

64

不明な操作。

QOS_RELIABLE

BINARY_INTEGER

1

信頼性(永続性)のある通知。また、コミットするとオブジェクトが変更されるトランザクションによって、通知が最小単位で持続記憶域に挿入されることも示します。

QOS_DEREG_NFY

BINARY_INTEGER

2

最初の通知時での登録のパージ。

QOS_ROWIDS

BINARY_INTEGER

4

変更した行のROWIDの要求。

QOS_QUERY

BINARY_INTEGER

8

問合せの粒度での登録。

QOS_BEST_EFFORT

BINARY_INTEGER

16

ベスト・エフォートの評価。

NTFN_GROUPING_CLASS_TIME

BINARY_INTEGER

1

時間別の通知のグループ化。

NTFN_GROUPING_TYPE_SUMMARY

BINARY_INTEGER

1

通知の要約のグループ化。

NTFN_GROUPING_TYPE_LAST

BINARY_INTEGER

2

グループ内の最後の通知。

NTFN_GROUPING_FOREVER

BINARY_INTEGER

-1

無期限の通知の繰返し。



使用上の注意

オブジェクト・レベルの登録:

問合せ結果の変更の登録:

トラブルシューティング

登録の作成後、元の表の変更時に通知が送られていないと考えられる場合は、次の内容を確認します。


関連項目:

データベース変更通知のトラブルシューティングの詳細は、『Oracle Databaseアドバンスト・アプリケーション開発者ガイド』を参照してください。


オブジェクトの変更の登録例

中間層のアプリケーションに、HR.EMPLOYEES表に関する大量の問合せがあるとします。EMPLOYEES表の更新頻度が低い場合は、表の行をキャッシュすると、バックエンドのデータベース・サーバーに対するラウンドトリップおよびサーバー側での実行待機時間を回避できるため、パフォーマンスが向上します。このアプリケーションによって、通知をリスニングする中間層のHTTPリスナーが実装され、通知に対応して中間層のキャッシュが更新されるとします。

この例では、DBMS_CQ_NOTIFICATIONパッケージを使用し、次の手順で表の変更に関する通知を送信できます。

  1. データベースから送信される通知メッセージをリスニングし、通知に対応して中間層のキャッシュをリフレッシュするキャッシュ管理システムの中間層リスナー・コンポーネント(たとえば、HTTPを使用)を実装します。

  2. 通知を処理する、サーバー側のストアド・プロシージャを作成します。

CONNECT system;
Enter password: password
GRANT CHANGE NOTIFICATION TO hr;
GRANT EXECUTE ON DBMS_CQ_NOTIFICATION TO hr;

Rem Enable job queue processes to receive notifications.
ALTER SYSTEM SET "job_queue_processes"=2;

CONNECT hr;
Enter password: password
Rem Create a table to record notification events
CREATE TABLE nfevents(regid number, event_type number);

Rem create a table to record changes to registered tables
CREATE TABLE nftablechanges(regid number, table_name varchar2(100),
                            table_operation number);

Rem create a table to record rowids of changed rows.
CREATE TABLE nfrowchanges(regid number, table_name varchar2(100),
                          row_id varchar2(30));

Rem Create a PL/SQL callback handler to process notifications.
CREATE OR REPLACE PROCEDURE chnf_callback(ntfnds IN SYS.CHNF$_DESC) IS
   regid           NUMBER;
   tbname          VARCHAR2(60);
   event_type      NUMBER;
   numtables       NUMBER;
   operation_type  NUMBER;
   numrows         NUMBER;
   row_id          VARCHAR2(20);
 BEGIN
     regid      := ntfnds.registration_id;
     numtables  := ntfnds.numtables;
     event_type := ntfnds.event_type;

  INSERT INTO nfevents VALUES(regid, event_type);
  IF (event_type = DBMS_CQ_NOTIFICATION.EVENT_OBJCHANGE) THEN
    FOR i IN 1..numtables LOOP
      tbname          := ntfnds.table_desc_array(i).table_name;
      operation_type  := ntfnds.table_desc_array(I). Opflags;
      INSERT INTO nftablechanges VALUES(regid, tbname, operation_type);
      /* Send the table name and operation_type to client side listener using UTL_HTTP */
      /* If interested in the rowids, obtain them as follows */
      IF (bitand(operation_type, DBMS_CQ_NOTIFICATION.ALL_ROWS) = 0) THEN
        numrows := ntfnds.table_desc_array(i).numrows;
      ELSE
        numrows :=0;   /* ROWID INFO NOT AVAILABLE */
      END IF;

      /* The body of the loop is not executed when numrows is ZERO */
      FOR j IN 1..numrows LOOP
          Row_id := ntfnds.table_desc_array(i).row_desc_array(j).row_id;
          INSERT INTO nfrowchanges VALUES(regid, tbname, Row_id);
         /* optionally Send out row_ids to client side listener using UTL_HTTP; */
      END LOOP;

    END LOOP;
  END IF;
  COMMIT;
END;
/

手順2では、通知記述子で取得される情報に基づいて、中間層アプリケーションで必要な無効化に関する情報を送信できます。

  1. 通知を行う対象となる表の登録を作成します。 以前に定義したプロシージャの名前(chnf_callback)を、通知の生成時に実行するサーバー側のPL/SQLプロシージャの名前として渡します。

Rem Create a REGISTRATION on the EMPLOYEES TABLE
DECLARE
  REGDS      SYS.CHNF$_REG_INFO;
  regid      NUMBER;
  mgr_id     NUMBER;
  dept_id    NUMBER;
  qosflags   NUMBER;
BEGIN
 qosflags := DBMS_CQ_NOTIFICATION.QOS_RELIABLE +
         DBMS_CQ_NOTIFICATION.QOS_ROWIDS;
REGDS := SYS.CHNF$_REG_INFO ('chnf_callback', qosflags, 0,0,0);
regid := DBMS_CQ_NOTIFICATION.NEW_REG_START (REGDS);
SELECT manager_id INTO mgr_id FROM EMPLOYEES WHERE employee_id = 200;
DBMS_CQ_NOTIFICATION.REG_END;
END;
/

前述の手順3で登録を作成すると、手順2で定義したサーバー側のPL/SQLプロシージャが、HR.EMPLOYEES表に対してCOMMITでコミットされた変更に対応して実行されます。たとえば、employees表に対して次の更新が行われるとします。

UPDATE employees SET salary=salary*1.05 WHERE employee_id=203;COMMIT;

通知が処理されると、nfeventsnftablechangesnfrowchangesの各表に、次のような行が挿入されます。

SQL> SELECT * FROM nfevents;

     REGID     EVENT_TYPE
---------------------------
     20045          6


SQL> SELECT * FROM nftablechanges;

  REGID      TABLE_NAME         TABLE_OPERATION
-------------------------------------------
  20045      HR.EMPLOYEES            4


SQL> select * from nfrowchanges;

    REGID      TABLE_NAME          ROW_ID
------------------------------------------------------
    20045     HR.EMPLOYEES    AAAKB/AABAAAJ8zAAF

注意

  1. 前述の例では、'chnf_callback'を通知のPL/SQLハンドラとして使用してEMPLOYEES表に関する登録を作成しました。 登録時に、クライアントによって、信頼性のある通知(QOS_RELIABLE)およびROWIDの通知(QOS_ROWIDS)が指定されました。

  2. ハンドラは、通知タイプがEVENT_OBJCHANGEの場合にのみ、通知記述子の表記述子配列にアクセスします。 他のすべての場合(たとえば、EVENT_DEREGEVENT_SHUTDOWNの場合)、表記述子配列はアクセスされません。

  3. ハンドラは、表操作フラグにALL_ROWSビットがセットされていない場合にのみ、表通知記述子の行記述子配列にアクセスします。 表操作フラグにALL_ROWSビットがセットされている場合は、表内のすべての行が変更された可能性があることを示します。また、このビットは、表内のすべての行に影響するTRUNCATEのような操作の他に、個々のROWIDがFULLタイプの表の無効化にロールアップされた場合にもセットされます。

    これは、ある表で行われた1つのトランザクションで変更された行が多すぎる(80行を超えている)か、またはRDBMSのROWIDが原因で共有メモリーの消費合計が多すぎる(動的共有プール・サイズの1%を超えている)と判断された場合に発生します。この場合、受信者は、表全体が無効になったことを想定し、コールバック/アプリケーションでこの状況に対処できるようにする必要があります。

    また、ユーザー定義のコールバックの実装は、開発者が決定することに注意してください。前述の例では、コールバックを使用してイベントの詳細をデータベース表に記録しました。 また、このアプリケーションでは、(例のように)UTL_HTTPを使用して、通知の詳細をキャッシュ管理システムの中間層HTTPリスナーに送信することもできます。このリスナーは、バックエンドのデータベースから問合せを行ってキャッシュをリフレッシュすることができます。

問合せ結果の変更の登録例

  1. コールバックを作成します。

    CONNECT system;
    Enter password: password
    GRANT CHANGE NOTIFICATION TO hr;
    GRANT EXECUTE ON DBMS_CQ_NOTIFICATION TO hr;
    CONNECT hr;
    Enter password: password
    Rem Create a table to record notification events
    CREATE TABLE nfevents(regid NUMBER, event_type NUMBER);
    
    Rem Create a table to record notification queries
    CREATE TABLE nfqueries (qid NUMBER, qop NUMBER);
    
    Rem Create a table to record changes to registered tables
    CREATE TABLE nftablechanges(
           qid                NUMBER,
           table_name         VARCHAR2(100),
           table_operation    NUMBER);
    
    Rem Create a table to record rowids of changed rows.
    CREATE TABLE nfrowchanges(
           qid                NUMBER,
           table_name         VARCHAR2(100),
           row_id             VARCHAR2(2000));
    
    
    CREATE OR REPLACE PROCEDURE chnf_callback
      (ntfnds IN CQ_NOTIFICATION$_DESCRIPTOR)
    IS
      regid           NUMBER;
      tbname          VARCHAR2(60);
      event_type      NUMBER;
      numtables       NUMBER;
      operation_type  NUMBER;
      numrows         NUMBER;
      row_id          VARCHAR2(2000);
      numqueries      NUMBER;
      qid NUMBER;
      qop NUMBER;
    
    BEGIN
      regid := ntfnds.registration_id;
      event_type := ntfnds.event_type;
      INSERT INTO nfevents VALUES(regid, event_type);
      numqueries :=0;
      IF (event_type = DBMS_CQ_NOTIFICATION.EVENT_QUERYCHANGE) THEN
          numqueries := ntfnds.query_desc_array.count;
          FOR i in 1..numqueries LOOP
             qid := ntfnds.QUERY_DESC_ARRAY(i).queryid;
             qop := ntfnds.QUERY_DESC_ARRAY(i).queryop;
             INSERT INTO nfqueries VALUES(qid, qop);
             numtables := 0;
             numtables := ntfnds.QUERY_DESC_ARRAY(i).table_desc_array.count;
             FOR j IN 1..numtables LOOP
               tbname := ntfnds.QUERY_DESC_ARRAY(i).table_desc_array(j).table_name;
               operation_type := ntfnds.QUERY_DESC_ARRAY(i).table_desc_array(j).Opflags;
               INSERT INTO nftablechanges VALUES(qid, tbname, operation_type);
               IF (bitand(operation_type, DBMS_CQ_NOTIFICATION.ALL_ROWS) = 0)
               THEN
                 numrows := ntfnds.query_desc_array(i).table_desc_array(j).numrows;
               ELSE
                 numrows :=0;   /* ROWID INFO NOT AVAILABLE */
               END IF;
    
                /* The body of the loop is not executed when numrows is ZERO */
                FOR k IN 1..numrows LOOP
                   Row_id := ntfnds.query_desc_array(i).table_desc_array(j).row_desc_array(k).row_id;
                   INSERT INTO nfrowchanges VALUES(qid, tbname, Row_id);
    
                END LOOP;  /* loop over rows */
             END LOOP;     /* loop over tables */
           END LOOP;        /* loop over queries */
      END IF;
      COMMIT;
    END;
    /
    
    
  1. 問合せの登録を作成します。

    DECLARE
      reginfo    cq_notification$_reg_info;
      mgr_id     NUMBER;
      dept_id    NUMBER;
      v_cursor   SYS_REFCURSOR;
      regid      NUMBER;
    BEGIN
      /* Register two queries for result-set-change notifications: */
      /* 1. Construct registration information.
            'chnf_callback' is name of notification handler.
            QOS_QUERY specifies result-set-change notifications. */
    
            reginfo := cq_notification$_reg_info('chnf_callback',
               DBMS_CQ_NOTIFICATION.QOS_QUERY,0, 0, 0);
    
      /* 2. Create registration */
    
            regid := DBMS_CQ_NOTIFICATION.NEW_REG_START(reginfo);
    
            OPEN v_cursor FOR
               SELECT DBMS_CQ_NOTIFICATION.CQ_NOTIFICATION_QUERYID, manager_id
               FROM HR.employees
               WHERE employee_id = 7902;
            CLOSE v_cursor;
    
           OPEN v_cursor for
            SELECT dbms_cq_notification.CQ_NOTIFICATION_QUERYID, department_id
            FROM HR.departments
            WHERE department_name = 'IT';
           CLOSE v_cursor;
    
      DBMS_CQ_NOTIFICATION.REG_END;
    END;
    /
    
  1. 問合せの登録を作成すると、USER_CQ_NOTIFICATION_QUERIESからの出力が次のように表示されます。

    SQL> SELECT queryid, regid, to_char(querytext)
         FROM user_cq_notification_queries;
    
       QUERYID      REGID
    ---------- ----------
    TO_CHAR(QUERYTEXT)
    --------------------------------------------------------------------------------
            22         41
     SELECT HR.DEPARTMENTS.DEPARTMENT_ID  FROM HR.DEPARTMENTS  WHERE HR.DEPARTMENTS.
    DEPARTMENT_NAME  = 'IT'
    
            21         41
     SELECT HR.EMPLOYEES.MANAGER_ID  FROM HR.EMPLOYEES  WHERE HR.EMPLOYEES.EMPLOYEE_
    ID  = 7902
    
    
    Now, let us perform an UPDATE that changes the result of the query with queryid 22
    by renaming the department with name 'IT' to FINANCE.
    
    SQL>  update departments set department_name = 'FINANCE' where department_name = 'IT';
    
    1 row updated.
    
    SQL> commit;
    
    Commit complete.
    
    Now we can query the notifications that we recorded in the callback.
    
    SQL> select * from nfevents;
    
         REGID EVENT_TYPE
    ---------- ----------
            61          7
    
    
    Event type 7 corresponds to EVENT_QUERYCHANGE
    
    SQL> select * from nfqueries;
    
           QID        QOP
    ---------- ----------
            42          7
    
    Event type 7 corresponds to EVENT_QUERYCHANGE
    
    SQL> select * from nftablechanges;
    SQL> select * from nftablechanges;
    
         REGID
    ----------
    TABLE_NAME
    --------------------------------------------------------------------------------
    TABLE_OPERATION
    ---------------
            42
    HR.DEPARTMENTS
                  4
    
    
    TABLE_OPERATION 4 corresponds to UPDATEOP
    
    SQL> select * from nfrowchanges;
         REGID
    ----------
    TABLE_NAME
    --------------------------------------------------------------------------------
    ROW_ID
    --------------------------------------------------------------------------------
            61
    HR.DEPARTMENTS
    AAANkdAABAAALinAAF
    

データ構造

DBMS_CQ_NOTIFICATIONパッケージは、次のOBJECTタイプを定義します。

オブジェクト・タイプ


CQ_NOTIFICATION$_DESCRIPTORオブジェクト・タイプ

これは、トップレベルの変更通知記述子タイプです。 これは、SYS.CHNF$_DESCタイプのシノニムです。

構文

TYPE SYS.CHNF$_DESC IS OBJECT(
   registration_id    NUMBER,
   transaction_id     RAW(8),
   dbname             VARCHAR2(30),
   event_type         NUMBER,
   numtables          NUMBER,
   table_desc_array   CQ_NOTIFICATION$_TABLE_ARRAY,
   query_desc_array   CQ_NOTIFICATION$_QUERY_ARRAY);

属性

表33-2 CQ_NOTIFICATION$_DESCRIPTORオブジェクト・タイプ

属性 説明

registration_id

登録時に戻される登録ID。

transaction_id

トランザクションID。変更を行ったトランザクションのtransaction_id。 event_typeがEVENT_OBJCHANGEまたはEVENT_QUERYCHANGE以外の場合は、NULLになります。

dbname

データベースの名前。

event_type

通知に関連付けられているデータベース・イベント。 EVENT_OBJCHANGE(登録されたオブジェクトへの変更)、EVENT_STARTUPEVENT_QUERYCHANGEEVENT_SHUTDOWNEVENT_DEREG(タイムアウトなどの理由で登録が削除された)のいずれかになります。

numtables

変更された表の数。event_typeEVENT_OBJCHANGE以外の場合は、NULLになります。

table_desc_array

表記述子の配列。event_typeEVENT_OBJCHANGE以外の場合は、NULLになります。

query_desc_array

変更された問合せの配列。 event_typeがEVENT_QUERYCHANGE以外の場合は、NULLになります。



CQ_NOTIFICATION$_QUERYオブジェクト・タイプ

このオブジェクト・タイプは、トランザクションのコミットなどのイベントで発生する問合せ結果への変更を示します。 CQ_NOTIFICATION$_QUERY記述子の配列は、EVENT_QUERYCHANGEタイプのイベントに対するトップレベルの通知記述子(CQ_NOTIFICATION$_DESCRIPTOR)内に埋め込まれます。この配列は、イベントの結果として無効になったqueryidのSETに対応します。

これは、ベース・タイプSYS.CHNF$_QDESCのシノニムです。

構文

TYPE SYS.CHNF$_QDESC IS OBJECT (
  queryid            NUMBER,
  queryop            NUMBER,
  table_desc_array   CQ_NOTIFICATION$_TABLE_ARRAY);

属性

表33-3 TYPE SYS.CQ_NOTIFICATION$_QUERYオブジェクト・タイプ

属性 説明

queryid

変更された問合せのQueryId

queryop

問合せへの変更を示す操作

table_desc_array

問合せ結果セットの変更の原因となる表の変更の配列



CQ_NOTIFICATION$_QUERY_ARRAYオブジェクト(配列)タイプ

このタイプは、CQ_NOTIFICATION$_QUERYオブジェクトの配列に対応します。 これは、SYS.CHNF$_QUERY_ARRAYタイプのシノニムです。

構文

TYPE CQ_NOTIFICATION$_TABLE_ARRAY IS VARRAY (1073741824) OF CQ_NOTIFICATION$_TABLE;

CQ_NOTIFICATION$_TABLEオブジェクト・タイプ

この記述子タイプは表への変更を示し、EVENT_OBJCHANGEタイプのイベントに対するトップレベルの変更通知記述子タイプ内に埋め込まれます。問合せ結果セットの変更の場合(イベント・タイプがEVENT_QUERYCHANGEに設定される場合)、表記述子の配列が各問合せの変更記述子内に埋め込まれます。

これは、SYS.CHNF$_TDESC(以前の名前)タイプのシノニムです。

構文

TYPE SYS.CHNF$_TDESC IS OBJECT (
  opflags            NUMBER,
  table_name         VARCHAR2(2*M_IDEN+1),
  numrows            NUMBER,
  row_desc_array     CQ_NOTIFICATION$_ROW_ARRAY)

属性

表33-4 TYPE SYS.CQ_NOTIFICATION$_TABLEオブジェクト・タイプ

属性 説明

opflags

表レベルの操作フラグ。これは、表に対して行われた操作内容を表すフラグ・フィールド(ビットベクトル)です。 ビット・フィールド(INSERTOPUPDATEOPDELETEOPDROPOPALTEROPおよびALL_ROWS)のORになります。 ALL_ROWS(0x1)ビットがセットされている場合は、表全体が変更されている(DELETE * FROM tなど)こと、あるいは通知で行レベル粒度の情報が要求されていないか、または使用できないため、受信者は表全体が無効になっていると想定する必要があることを示します。

table_name

変更された表の名前。

numrows

表内の変更された行の数。表変更記述子にALL_ROWSビットがセットされている場合、numrowsはNULLになるため、アクセスしないでください。

row_desc_array

行記述子の配列。 opflagsALL_ROWSビットがセットされている場合、このフィールドはNULLになります。



CQ_NOTIFICATION$_TABLE_ARRAYオブジェクト(配列)タイプ

このタイプは、CQ_NOTIFICATION$_TABLEオブジェクトの配列に対応します。 これは、SYS.CHNF$_TDESC_ARRAYタイプのシノニムです。

構文

TYPE CQ_NOTIFICATION$_TABLE_ARRAY IS VARRAY (1073741824) OF CQ_NOTIFICATION$_TABLE;

CQ_NOTIFICATION$_ROWオブジェクト・タイプ

登録時にQOS_ROWIDSオプションを選択し、表変更記述子のopflagsフィールドにALL_ROWSビットがセットされていない場合、CQ_NOTIFICATION$_ROWの配列が、CQ_NOTIFICATION$_TABLE(表変更記述子)内に埋め込まれます。

これは、SYS.CHNF$_RDESC(以前の名前)タイプのシノニムです。

構文

TYPE SYS.CHNF$_RDESC IS OBJECT (
  opflags            NUMBER,
  row_id             VARCAHR2 (2000));

属性

表33-5 TYPE SYS.CQ_NOTIFICATION$_ROWオブジェクト・タイプ

属性 説明

opflags

行レベルの操作フラグ。このフラグ・フィールド(ビットベクトル)は、行の操作内容(INSERTOPUPDATEOPDELETEOPなど)を表します。

row_id

変更した行のROWID。



CQ_NOTIFICATION$_ROW_ARRAYオブジェクト(配列)タイプ

登録時にQOS_ROWIDSオプションを指定し、表変更記述子のopflagsフィールドにALL_ROWSビットがセットされていない場合、このオブジェクト・タイプがCQ_NOTIFICATION$_ROWの配列に対応し、CQ_NOTIFICATION$_TABLE(表変更記述子)内に埋め込まれます。

これは、SYS.CHNF$_RDESC_ARRAYタイプのシノニムです。

構文

TYPE CQ_NOTIFICATION$_ROW_ARRAY IS VARRAY (1073741824) OF CQ_NOTIFICATION$_ROW;

CQ_NOTIFICATION$_REG_INFOオブジェクト・タイプ

このオブジェクト・タイプは、登録の新規作成に関連する属性を表します。 これは、SYS.CHNF$_REG_INFO(以前の名前)タイプのシノニムです。

構文

TYPE SYS.CHNF$_REG_INFO IS OBJECT (
  callback                        VARCHAR2(20),
  quosflags                       NUMBER,
  timeout                         NUMBER,
  operations_filter               NUMBER,
  transaction_lag                 NUMBER,
  ntfn_grouping_class             NUMBER,
  ntfn_grouping_value             NUMBER,
  ntfn_grouping_type              NUMBER,
  ntfn_grouping_start_time        TIMESTAMP WITH TIME ZONE,
  ntfn_grouping_repeat_count      NUMBER);

属性

表33-6 TYPE CQ_NOTIFICATION$_REG_INFOオブジェクト・タイプ

属性 説明

callback

通知時に実行するサーバー側のPL/SQLプロシージャの名前。 プロトタイプは、<call_backname>(ntfnds IN SYS.chnf$_desc)です。

qosflags

サービス品質フラグ。次の値のORに設定できます。

  • QOS_RELIABLE0x1): 通知は信頼性(永続性)があり、インスタンスの停止後も有効です。これは、RACクラスタでインスタンスが停止した場合に、停止していないインスタンスによって、キュー内の無効化情報を配信できることを意味します。同様に、保留になっている無効化情報は、単一インスタンス構成で、インスタンスの再起動時に配信可能です。デメリットは、無効化メッセージを永続ストアに挿入すると発生するCPUコストおよび待機時間です。このパラメータがFALSEの場合は、イン・メモリー・キューに無効化情報がバッファリングされるため、サーバー側のCPUおよび待機時間は最小になりますが、インスタンスの停止時にクライアントが無効化メッセージを失う可能性があります。

  • QOS_DEREG_NFY0x2): 最初の通知時に登録が完全削除されます。

  • QOS_ROWIDS0x4): 変更されたROWIDに関する情報を通知に含める必要があります。

  • QOS_QUERY0x8): オブジェクトの変更通知ではなく、問合せ結果の変更通知を指定します。

  • QOS_BEST_EFFORt0x16): 簡易版の問合せを登録し、評価を最小化できます。一部偽陽性が発生します。

timeout

0(ゼロ)以外の値に設定すると、その時間(秒)の経過後にデータベースによって登録が自動的に完全削除されます。0(ゼロ)またはNULLに設定すると、登録は、明示的に登録解除するまで存在します。 timeoutオプションは、通知時にパージするオプション(QOS_DEREG_NFY)と組み合せて設定することもできます。

operations_filter

0(ゼロ)以外の場合は、特定の操作を選択して通知するフィルタを指定します。次のフラグを使用すると、特定の操作のタイプに基づいてフィルタ処理を行うことができます。

  • 0: すべての操作について通知(DBMS_CQ_NOTIFICATION.ALL_OPERATIONS

  • 0x2: すべてのINSERTについて通知(DBMS_CQ_NOTIFICATION.INSERTOP

  • 0x4: すべてのUPDATEについて通知(DBMS_CQ_NOTIFICATION.UPDATEOP

  • 0x8: すべてのDELETEについて通知(DBMS_CQ_NOTIFICATION.DELETEOP

ビット単位のORを使用すると、操作を組み合せて指定できます。

注意: このパラメータはオブジェクト・レベルの登録には有効ですが、問合せ結果の変更の登録では無視されます。11gで通知フロー制御を実装するために、アプリケーションではGROUPING通知オプションを使用できます。

transaction_lag

トランザクション単位で指定する、連続する通知間のタイム・ラグ。トランザクション数/データベース変更数の指定に使用できます。これによって、クライアントによるデータベースに対する遅れを指定できます。0(ゼロ)の場合は、生成後すぐに無効化メッセージをクライアントが受信する必要があることを示します。

注意: このパラメータはオブジェクト・レベルの登録には有効ですが、問合せ結果の変更通知の登録では無視されます。

ntfn_grouping_class

通知をグループ化するときに、このクラスに基づきグループが導出されます。 現在、使用できる値は、通知を時間別にグループ化するDBMS_CQ_NOTIFICATION.NTFN_GROUPING_CLASS_TIMEのみです。

ntfn_grouping_value

グループ化の値。グループを定義する時間間隔を秒単位で指定します。たとえば、この値を900に設定した場合、生成された通知は15分間隔でグループ化されます。

ntfn_grouping_type

指定するグループ化のタイプ。使用できる2つの値のいずれかを指定します。

  • DBMS_CQ_NOTIFICATION.NTFN_GROUPING_TYPE_SUMMARY: グループ内のすべての通知が、単一の通知に要約されます。

  • DBMS_CQ_NOTIFICATION.NTFN_GROUPING_TYPE_LAST: グループ内の最後の通知のみが公開され、それより前の通知は破棄されます。

ntfn_grouping_start_time

通知の生成を開始する時間。NULLを指定すると、現行のシステムで生成される時間がデフォルトとなります。

ntfn_grouping_repeat_count

通知が繰り返される回数。 登録の存続期間を通して通知を受け取り続けるには、この値をDBMS_CQ_NOTIFICATION.NTFN_GROUPING_FOREVERに設定します。登録の存続期間に対して特定の回数の通知のみを要求する場合は、0(ゼロ)以外の値に設定します。


使用上の注意


DBMS_CQ_NOTIFICATIONサブプログラムの要約

表33-7 DBMS_CQ_NOTIFICATIONパッケージのサブプログラム

サブプログラム 説明

CQ_NOTIFICATION_QUERYIDファンクション


登録ブロックへの登録が試行された最新の問合せのqueryidを戻します。

DEREGISTERプロシージャ


指定した登録識別子(ID)のクライアントのサブスクライブを解除します。

ENABLE_REGプロシージャ


既存の登録識別子(ID)を使用して、登録ブロックを開始します。

NEW_REG_STARTファンクション


新しい登録ブロックを開始します。

REG_ENDプロシージャ


登録範囲を終了します。



CQ_NOTIFICATION_QUERYIDファンクション

このファンクションは、登録ブロックへの登録が試行された最新の問合せのqueryidを戻します。

構文

DBMS_CQ_NOTIFICATION.CQ_NOTIFICATION_QUERYID
 RETURN NUMBER;

戻り値

登録された最新の問合せのqueryidを戻します。


DEREGISTERプロシージャ

このプロシージャは、指定した登録識別子(ID)のクライアントのサブスクライブを解除します。

構文

DBMS_CQ_NOTIFICATION.DEREGISTER (
  regid IN NUMBER);

パラメータ

表33-8 DEREGISTERプロシージャのパラメータ

パラメータ 説明

regid

クライアントの登録ID。


使用上の注意

登録を作成したユーザー(またはSYSユーザー)のみが、その登録のサブスクライブを解除できます。


ENABLE_REGプロシージャ

このプロシージャは、既存の登録識別子(ID)にオブジェクトを追加します。 このプロシージャは、オブジェクトの追加に既存のregidを使用することを除くと、新規登録の作成に使用するインタフェースに似ています。このプロシージャの後に続けて問合せを実行すると、その問合せで参照されるオブジェクトが、指定したregidに追加されます。REG_ENDプロシージャを起動すると、登録が終了します。

構文

DBMS_CQ_NOTIFICATION.ENABLE_REG (
  regid IN NUMBER);

パラメータ

表33-9 ENABLE_REGプロシージャのパラメータ

パラメータ 説明

regid

クライアントの登録ID。


使用上の注意

登録を作成したユーザーのみが、その登録にオブジェクトを追加できます。


NEW_REG_STARTファンクション

このプロシージャは、新しい登録ブロックを開始します。この登録ブロック内で実行する問合せによって参照されるすべてのオブジェクトは、優先度が高いオブジェクトとみなされ、登録に追加されます。 登録ブロックは、REG_ENDプロシージャをコールすると終了します。

構文

DBMS_CQ_NOTIFICATION.NEW_REG_START (
  regds IN sys.chnf$_reg_info)
 RETURN NUMBER;

パラメータ

表33-10 NEW_REG_STARTファンクションのパラメータ

パラメータ 説明

sys.chnf$_reg_info

通知ハンドラなどの登録プロパティを示す登録記述子。


戻り値

このプロシージャは、登録ID(データベースによってこの登録に割り当てられた一意の整数)を戻します。登録IDは、この登録に関して受け取るすべての通知でエコーバックされます。

使用上の注意


REG_ENDプロシージャ

このプロシージャは、登録ブロックの終了を示します。これ以降に実行される問合せは追跡されません。

構文

DBMS_CQ_NOTIFICATION.REG_END;