Difference between revisions of "IX.AQ$STREAMS QUEUE TABLE (view)"
| (2 intermediate revisions by the same user not shown) | |||
| Line 2: | Line 2: | ||
{| border="1" cellpadding="5" cellspacing="0" style="border-collapse:collapse" | {| border="1" cellpadding="5" cellspacing="0" style="border-collapse:collapse" | ||
| − | |- | + | |- valign="top" |
| − | | ''' | + | | '''View |
| IX.AQ$STREAMS_QUEUE_TABLE | | IX.AQ$STREAMS_QUEUE_TABLE | ||
| − | |||
|} | |} | ||
| − | + | === Source === | |
<pre> | <pre> | ||
| − | CREATE OR REPLACE SELECT q_name QUEUE, qt.msgid MSG_ID, corrid CORR_ID, priority MSG_PRIORITY, decode(h.dequeue_time, NULL, | + | CREATE OR REPLACE VIEW IX.AQ$STREAMS_QUEUE_TABLE AS |
| + | SELECT q_name QUEUE, qt.msgid MSG_ID, corrid CORR_ID, priority MSG_PRIORITY, decode(h.dequeue_time, NULL, | ||
(decode(state, 0, 'READY', | (decode(state, 0, 'READY', | ||
1, 'WAIT', | 1, 'WAIT', | ||
Latest revision as of 06:14, 24 June 2010
wikibot[edit]
| View | IX.AQ$STREAMS_QUEUE_TABLE |
Source[edit]
CREATE OR REPLACE VIEW IX.AQ$STREAMS_QUEUE_TABLE AS
SELECT q_name QUEUE, qt.msgid MSG_ID, corrid CORR_ID, priority MSG_PRIORITY, decode(h.dequeue_time, NULL,
(decode(state, 0, 'READY',
1, 'WAIT',
2, 'PROCESSED',
3, 'EXPIRED',
8, 'DEFERRED')),
(decode(h.transaction_id,
NULL, 'UNDELIVERABLE',
'PROCESSED'))) MSG_STATE, cast(FROM_TZ(qt.delay, '-08:00')
at time zone sessiontimezone as date) delay, delay DELAY_TIMESTAMP, expiration, cast(FROM_TZ(qt.enq_time, '-08:00')
at time zone sessiontimezone as date) enq_time, cast(FROM_TZ(qt.enq_time, '-08:00')
at time zone sessiontimezone as timestamp)
enq_timestamp, enq_uid ENQ_USER_ID, enq_tid ENQ_TXN_ID, decode(h.transaction_id, NULL, TO_DATE(NULL),
cast(FROM_TZ(h.dequeue_time, '-08:00')
