| General Information |
| Source |
{ORACLE_HOME}/rdbms/admin/prvtarpp.plb |
| Dependencies |
| DBMS_DEFER |
DBMS_REPCAT_SNA_UTL |
| DBMS_DEFER_QUERY_UTL |
DBMS_REPCAT_UTL |
| DBMS_DEFER_REPCAT |
DBMS_REPCAT_UTL3 |
| DBMS_DEFER_SYS |
DBMS_SYSTEM |
| DBMS_DEFER_SYS_PART1 |
DBMS_SYS_ERROR |
| DBMS_LOCK |
DEF$_DESTINATION |
| DBMS_OFFLINE_RGT |
DEFTRANDEST |
| DBMS_REPCAT_DECL |
REPCAT$_EXTENSION |
|
| Security Model |
Owned by SYS with no privileges granted |
| Subprograms |
|
| |
| CHECK_DATABASE_CAPABILITY |
Undocumented
I don't know what it means ... but it runs and returns FALSE in my tests |
dbms_asyncrpc_push.check_database_capability(
nodename VARCHAR2, -- database link
userid BINARY_INTEGER, -- link owner
capability BINARY_INTEGER) -- value range -999999999 to 999999999
RETURN BOOLEAN; |
CREATE DATABASE LINK fixed_user
CONNECT TO hr IDENTIFIED BY hr
USING 'orabase';
SELECT user_id, username
FROM dba_users
ORDER BY 1;
set serveroutput on
BEGIN
IF dbms_asyncrpc_push.check_database_capability('FIXED_USER', 0, 1) THEN
dbms_output.put_line('TRUE');
ELSE
dbms_output.put_line('FALSE');
END IF;
END;
/ |
| |
| ERROR_CALL_POSITION |
| Undocumented |
dbms_asyncrpc_push.error_call_position(
nodename IN VARCHAR2,
userid IN BINARY_INTEGER,
position OUT BINARY_INTEGER); |
set serveroutput on
DECLARE
pos BINARY_INTEGER;
BEGIN
dbms_asyncrpc_push.error_call_position('FIXED_USER', 0, pos);
dbms_output.put_line(pos);
END;
/ |
| |
| GET_CLOCK_TIME |
| Get current time on system clock |
dbms_asyncrpc_push.get_clock_time RETURN NUMBER; |
SELECT dbms_asyncrpc_push.get_clock_time FROM dual;
SELECT dbms_utility.get_time FROM dual; |
| |
| GET_SCN |
| Returns current system change |
dbms_asyncrpc_push.get_scn RETURN NUMBER; |
SELECT dbms_asyncrpc_push.get_scn FROM dual;
SELECT current_scn FROM v$database; |
| |
| PROPAGATE_PARALLEL |
| Undocumented |
dbms_asyncrpc_push.propagate_parallel(
canon_queue IN VARCHAR2,
userid IN BINARY_INTEGER,
stop_on_error IN BOOLEAN,
new_txn_count IN BINARY_INTEGER,
startup_seconds IN BINARY_INTEGER,
execution_seconds IN BINARY_INTEGER,
delay_seconds IN BINARY_INTEGER,
num_threads IN BINARY_INTEGER,
heap_size IN BINARY_INTEGER,
write_trace IN BOOLEAN,
delivery_order_limit IN NUMBER,
catchup IN RAW)
RETURN BINARY_INTEGER; |
| TBD |
| |
| PROPAGATE_SERIAL |
| Undocumented |
dbms_asyncrpc_push.propagate_serial(
queue IN VARCHAR2,
userid IN BINARY INTEGER,
stop_on_error IN BOOLEAN,
new_txn_count IN BINARY INTEGER,
execution_seconds IN BINARY INTEGER,
delay_seconds IN BINARY INTEGER,
txn_batch_size IN BINARY_INTEGER); |
| TBD |
| |
| PURGE_PARALLEL |
| Undocumented |
dbms_asyncrpc_push.purge_parallel(
method IN BINARY_INTEGER,
rollback_segment IN VARCHAR2,
execution_seconds IN OUT BINARY_INTEGER,
delay_seconds IN BINARY_INTEGER,
write_trace IN BOOLEAN,
transaction_count IN OUT BINARY_INTEGER)
RETURN BINARY_INTEGER; |
| TBD |
| |
| PUSH_PENDING_CALLS |
| Undocumented |
dbms_asyncrpc_push.push_pending_calls(
query_type IN BINARY_INTEGER,
nodename IN VARCHAR2,
userid IN BINARY_INTEGER,
buffer_size IN BINARY_INTEGER,
tid IN VARCHAR2,
call_type IN BINARY_INTEGER)
RETURN BINARY_INTEGER; |
| TBD |
| |
| STAMP_QUEUE_BATCH |
| Undocumented |
dbms_asyncrpc_push.stamp_queue_batch(scn_limit OUT NUMBER); |
set serveroutput on
DECLARE
n NUMBER;
BEGIN
dbms_asyncrpc_push.stamp_queue_batch(n);
dbms_output.put_line(n);
END;
/ |
| |
| UPDATE_PURGE_STATISTICS |
| Undocumented |
dbms_asyncrpc_push.update_purge_statistics(txnspurged IN BINARY_INTEGER); |
SELECT * FROM v$replqueue;
exec dbms_asyncrpc_push.update_purge_statistics(2);
SELECT * FROM v$replqueue; |
