Oracle DBMS_ASYNCRPC_PUSH
Version 12.1.0.1

General Information
Library Note Morgan's Library Page Footer
The Library is currently in the process of being upgraded from Oracle Database Version 12.1.0.1 to 12.1.0.2. Demos are being upgraded to reflect the new Container paradigm as well as EBR (Edition Based Redefinition) and may contain references to CDBs, PDBs, and other objects you may not be familiar with such as CDB_OBJECTS_AE: Welcome to 12c.

Interested in Oracle GoldenGate? Check out the IGGOUG,
Purpose Undocumented
AUTHID DEFINER
Dependencies
DBMS_DEFER DBMS_OFFLINE_RGT DBMS_SYSTEM
DBMS_DEFER_QUERY_UTL DBMS_REPCAT_DECL DBMS_SYS_ERROR
DBMS_DEFER_REPCAT DBMS_REPCAT_SNA_UTL DEF$_DESTINATION
DBMS_DEFER_SYS DBMS_REPCAT_UTL DEFTRANDEST
DBMS_DEFER_SYS_PART1 DBMS_REPCAT_UTL3 REPCAT$_EXTENSION
DBMS_LOCK    
Documented No
First Available Not known
Security Model Owned by SYS with no privileges granted
Source {ORACLE_HOME}/rdbms/admin/prvtarpp.plb
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 but "nodename" refers to a database link 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;

Related Topics
Packages

Morgan's Library Page Footer
This site is maintained by Dan Morgan. Last Updated: This site is protected by copyright and trademark laws under U.S. and International law. © 1998-2014 Daniel A. Morgan All Rights Reserved