PolarDB:DBMS_AQADM

ALTER_QUEUE

ALTER_QUEUEストアドプロシージャを使用して、既存のキューを変更できます。 構文：

ALTER_QUEUE(
  max_retries IN NUMBER DEFAULT NULL,
  retry_delay IN NUMBER DEFAULT 0
  retention_time IN NUMBER DEFAULT 0,
  auto_commit IN BOOLEAN DEFAULT TRUE)
  comment IN VARCHAR2 DEFAULT NULL,

Parameters

例

次のコードブロックは、retry_delayという名前のキューを変更し、retry_delayパラメーターを5秒に設定します。

EXEC DBMS_AQADM.ALTER_QUEUE(queue_name => 'work_order', retry_delay => 5);

ALTER_QUEUE_TABLE

ALTER_QUEUE_TABLEストアドプロシージャを使用して、既存のキューテーブルを変更できます。 構文：

ALTER_QUEUE_TABLE (
  queue_table IN VARCHAR2,
  comment IN VARCHAR2 DEFAULT NULL,
  primary_instance IN BINARY_INTEGER DEFAULT 0,
  secondary_instance IN BINARY_INTEGER DEFAULT 0,

Parameters

例

次のコードブロックは、work_order_tableという名前のキューテーブルを変更します。

EXEC DBMS_AQADM.ALTER_QUEUE_TABLE
      (queue_table => 'work_order_table', comment => 'This queue table contains work orders for the shipping department.');

CREATE_QUEUE

CREATE_QUEUEストアドプロシージャを使用して、既存のキューテーブルにキューを作成できます。 構文：

CREATE_QUEUE(
  queue_name IN VARCHAR2
  queue_table IN VARCHAR2,
  queue_type IN BINARY_INTEGER DEFAULT NORMAL_QUEUE,
  max_retries IN NUMBER DEFAULT 5,
  retry_delay IN NUMBER DEFAULT 0
  retention_time IN NUMBER DEFAULT 0,
  dependency_tracking IN BOOLEAN DEFAULT FALSE,
  comment IN VARCHAR2 DEFAULT NULL,
  auto_commit IN BOOLEAN DEFAULT TRUE)

Parameters

例

次の匿名ブロックは、work_order_tableテーブルにwork_orderという名前のキューを作成します。

BEGIN
DBMS_AQADM.CREATE_QUEUE ( queue_name => 'work_order', queue_table => 'work_order_table', comment => 'This queue contains pending work orders.');
END;

CREATE_QUEUE_TABLE

CREATE_QUEUE_TABLEストアドプロシージャを使用して、キューテーブルを作成できます。 プロシージャには次の署名があります。構文:

CREATE_QUEUE_TABLE (
  queue_table IN VARCHAR2,
  queue_payload_type IN VARCHAR2,
  storage_clause IN VARCHAR2 DEFAULT NULL,
  sort_list IN VARCHAR2 DEFAULT NULL,
  multiple_consumers IN BOOLEAN DEFAULT FALSE,
  message_grouping IN BINARY_INTEGER DEFAULT NONE,
  comment IN VARCHAR2 DEFAULT NULL,
  auto_commit IN BOOLEAN DEFAULT TRUE,
  primary_instance IN BINARY_INTEGER DEFAULT 0,
  secondary_instance IN BINARY_INTEGER DEFAULT 0,
  compatible IN VARCHAR2 DEFAULT NULL,
  secure IN BOOLEAN DEFAULT FALSE)

Parameters

例

次の匿名ブロックは、VARCHAR2名とプロジェクトの説明を保持する属性を持つwork_order型を作成します。 ブロックはこの型を使用してキューテーブルを作成します。

BEGIN

CREATE TYPE work_order AS (name VARCHAR2, project TEXT, completed BOOLEAN);

EXEC DBMS_AQADM.CREATE_QUEUE_TABLE
      (queue_table => 'work_order_table',
       queue_payload_type => 'work_order',
       comment => 'Work order message queue table');
END;

キューテーブルの名前はwork_order_tableで、work_order型のペイロードが含まれます。 これが作業順序メッセージキューテーブルであることを示すコメントが追加されます。

DROP_QUEUE

DROP_QUEUEストアドプロシージャを使用して、キューを削除できます。 構文：

DROP_QUEUE(
  queue_name  IN VARCHAR2,
  auto_commit IN BOOLEAN DEFAULT TRUE)

Parameters

例

次の匿名ブロックは、work_orderという名前のキューを削除します。

BEGIN
DBMS_AQADM.DROP_QUEUE(queue_name => 'work_order');
END;

DROP_QUEUE_TABLE

DROP_QUEUE_TABLEストアドプロシージャを使用して、キューテーブルを削除できます。 構文：

DROP_QUEUE_TABLE(
  queue_table IN VARCHAR2,
  force IN BOOLEAN default FALSE,
  auto_commit IN BOOLEAN default TRUE)

Parameters

例

次の匿名ブロックは、work_order_tableという名前のテーブルを削除します。

BEGIN
   DBMS_AQADM.DROP_QUEUE_TABLE ('work_order_table', force => TRUE);
END;

PURGE_QUEUE_TABLE

PURGE_QUEUE_TABLEストアドプロシージャを使用して、キューテーブルからメッセージを削除できます。 構文：

PURGE_QUEUE_TABLE(
  queue_table IN VARCHAR2,
  purge_condition IN VARCHAR2,
  purge_options IN aq$_purge_options_t)

Parameters

例

次の匿名ブロックは、completedという名前の列の値がYESの場合、work_order_tableからメッセージを削除します。

DECLARE
   purge_options dbms_aqadm.aq$_purge_options_t;
BEGIN
   dbms_aqadm.purge_queue_table('work_order_table', 'completed = YES', purge_options);
  END;

START_QUEUE

START_QUEUEストアドプロシージャを使用して、指定したキューのエンキューまたはデキューを有効にできます。 構文：

START_QUEUE(
  queue_name IN VARCHAR2,
  enqueue IN BOOLEAN DEFAULT TRUE,
  dequeue IN BOOLEAN DEFAULT TRUE)

Parameters

例

次の匿名ブロックは、work_orderという名前のキューをエンキューに使用できるようにします。

BEGIN
DBMS_AQADM.START_QUEUE
(queue_name => 'work_order);
END;

STOP_QUEUE

STOP_QUEUEストアドプロシージャを使用して、指定したキューのエンキューまたはデキューを無効にできます。 構文：

STOP_QUEUE(
  queue_name IN VARCHAR2,
  enqueue IN BOOLEAN DEFAULT TRUE,
  dequeue IN BOOLEAN DEFAULT TRUE,
  wait IN BOOLEAN DEFAULT TRUE)

Parameters

例

次の匿名ブロックは、work_orderという名前のキューのエンキューとデキューを無効にします。

BEGIN
DBMS_AQADM.STOP_QUEUE(queue_name =>'work_order', enqueue=>TRUE, dequeue=>TRUE, wait=>TRUE);
END;

すべての保留中のトランザクションが完了すると、エンキューとデキューは無効になります。