Difference between revisions of "IX.AQ$STREAMS QUEUE TABLE (view)"
(New page: == wikibot == {| border="1" cellpadding="5" cellspacing="0" style="border-collapse:collapse" |- | '''view | IX.AQ$STREAMS_QUEUE_TABLE |- |} <pre> </pre>) |
|||
| (3 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 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') | ||
| + | |||
</pre> | </pre> | ||
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')
