DBA Data[Home] [Help]

SYS.AQ$_GET_SUBSCRIBERS dependencies on DBMS_ASSERT

Line 40: || dbms_assert.enquote_name('"'||queue_schema||'"') || '.'

36: -- 8.1 style secure queue, join with agent mapping table
37: sel_txt := 'select qs.name, qs.address, qs.protocol, qs.trans_name, '
38: || ' qs.subscriber_type, qs.rule_name from '
39: || 'dba_aq_agent_privs dp, '
40: || dbms_assert.enquote_name('"'||queue_schema||'"') || '.'
41: || dbms_assert.enquote_name('"AQ$_' || queue_table || '_S"')
42: || ' qs where dp.db_username = :1 and ' ||
43: 'dp.agent_name = qs.name and bitand(qs.subscriber_type, 1)=1'
44: || ' and qs.queue_name = :2';

Line 41: || dbms_assert.enquote_name('"AQ$_' || queue_table || '_S"')

37: sel_txt := 'select qs.name, qs.address, qs.protocol, qs.trans_name, '
38: || ' qs.subscriber_type, qs.rule_name from '
39: || 'dba_aq_agent_privs dp, '
40: || dbms_assert.enquote_name('"'||queue_schema||'"') || '.'
41: || dbms_assert.enquote_name('"AQ$_' || queue_table || '_S"')
42: || ' qs where dp.db_username = :1 and ' ||
43: 'dp.agent_name = qs.name and bitand(qs.subscriber_type, 1)=1'
44: || ' and qs.queue_name = :2';
45: OPEN sqlrc FOR sel_txt using deq_user, queue_name;

Line 66: sub_trans := dbms_assert.enquote_name(sub_trans_sch, FALSE) ||'.' ||

62: LOOP
63: FETCH sqlrc INTO sub_name, sub_addr, sub_proto, sub_trans_sch,
64: sub_trans_nm, sub_type, sub_rule, sub_id, sub_bpos;
65: if sub_trans_sch is not null then
66: sub_trans := dbms_assert.enquote_name(sub_trans_sch, FALSE) ||'.' ||
67: dbms_assert.enquote_name(sub_trans_nm, FALSE);
68: end if;
69: EXIT WHEN sqlrc%NOTFOUND;
70: PIPE ROW (aq$_subscriber(sub_name, sub_addr, sub_proto,

Line 67: dbms_assert.enquote_name(sub_trans_nm, FALSE);

63: FETCH sqlrc INTO sub_name, sub_addr, sub_proto, sub_trans_sch,
64: sub_trans_nm, sub_type, sub_rule, sub_id, sub_bpos;
65: if sub_trans_sch is not null then
66: sub_trans := dbms_assert.enquote_name(sub_trans_sch, FALSE) ||'.' ||
67: dbms_assert.enquote_name(sub_trans_nm, FALSE);
68: end if;
69: EXIT WHEN sqlrc%NOTFOUND;
70: PIPE ROW (aq$_subscriber(sub_name, sub_addr, sub_proto,
71: sub_trans, sub_type,

Line 78: dbms_assert.enquote_name('"'||queue_schema||'"') || '.' ||

74: ELSE
75: -- 8.1 style normal queue, return all subscribers
76: sel_txt := 'select name, address, protocol, trans_name, ' ||
77: 'subscriber_type, rule_name from ' ||
78: dbms_assert.enquote_name('"'||queue_schema||'"') || '.' ||
79: dbms_assert.enquote_name('"AQ$_' || queue_table || '_S"') ||
80: ' where ' ||
81: 'bitand(subscriber_type, 1)=1 and queue_name = :1';
82: OPEN sqlrc FOR sel_txt using queue_name;

Line 79: dbms_assert.enquote_name('"AQ$_' || queue_table || '_S"') ||

75: -- 8.1 style normal queue, return all subscribers
76: sel_txt := 'select name, address, protocol, trans_name, ' ||
77: 'subscriber_type, rule_name from ' ||
78: dbms_assert.enquote_name('"'||queue_schema||'"') || '.' ||
79: dbms_assert.enquote_name('"AQ$_' || queue_table || '_S"') ||
80: ' where ' ||
81: 'bitand(subscriber_type, 1)=1 and queue_name = :1';
82: OPEN sqlrc FOR sel_txt using queue_name;
83: LOOP