Oracle Database 26ai is now availble. If you haven't you downloaded already: Why?
Purpose
Log file replication support utilities
Eight of the objects in this package, APPLY_ERROR, APPLY_ERROR_TXN, APPLY_MULESTONE, APPLY_PROGRESS, INSTANTIATE,
INSTANTIATE_SCHEMA, PREPARE_DDL, PRIVILEGED_USER, and STREAMS_RULES are also present in the DBMS_LOGREP_IMP package.
dbms_logrep_imp.apply_error(
local_tid IN VARCHAR2,
source_tid IN VARCHAR2,
source_db IN VARCHAR2,
queue_owner IN VARCHAR2,
queue_name IN VARCHAR2,
apply_name IN VARCHAR2,
message_number IN NUMBER,
message_count IN NUMBER,
min_step_no IN NUMBER,
recipient_name IN VARCHAR2,
source_commit_scn IN NUMBER,
error_number IN NUMBER,
error_message IN VARCHAR2,
aq_tid IN VARCHAR2,
spare1 IN NUMBER,
spare2 IN NUMBER,
spare3 IN NUMBER,
error_creation_time IN DATE);
dbms_logrep_imp.apply_error_txn(
local_tid IN VARCHAR2,
msgid IN RAW,
txn_message_number IN NUMBER,
error_number IN NUMBER,
error_message IN VARCHAR2,
flags IN NUMBER,
spare1 IN NUMBER,
spare2 IN NUMBER,
spare3 IN VARCHAR2,
spare4 IN VARCHAR2,
spare5 IN RAW,
spare6 IN DATE,
src_obj_owner IN VARCHAR2,
src_obj_name IN VARCHAR2,
dest_obj_owner IN VARCHAR2,
dest_obj_name IN VARCHAR2,
primary_key IN VARCHAR2,
position IN RAW,
message_flags IN NUMBER,
operation IN VARCHAR2);
dbms_logrep_imp.apply_milestone(
apply_name IN VARCHAR2,
source_db IN VARCHAR2,
oldest_scn IN NUMBER,
commit_scn IN NUMBER,
synch_scn IN NUMBER,
epoch IN NUMBER,
processed_scn IN NUMBER,
apply_time IN VARCHAR2,
msg_create_time IN VARCHAR2,
spare1 IN NUMBER,
start_scn IN NUMBER,
oldest_transaction_id IN VARCHAR2,
spill_lwm_scn IN NUMBER,
lwm_external_pos IN VARCHAR2,
spare2 IN NUMBER,
spare3 IN VARCHAR2);
dbms_logrep_imp.apply_progress(
apply_name IN VARCHAR2,
source_db IN VARCHAR2,
xidusn IN NUMBER,
xidslt IN NUMBER,
xidsqn IN NUMBER,
commit_scn IN NUMBER,
spare1 IN NUMBER);
dbms_logrep_imp.create_apply(
apply_name IN VARCHAR2,
queue_owner IN VARCHAR2,
queue_name IN VARCHAR2,
apply_captured IN BINARY_INTEGER,
ruleset_owner IN VARCHAR2,
ruleset_name IN VARCHAR2,
apply_user IN VARCHAR2,
apply_dblink IN VARCHAR2,
apply_tag IN VARCHAR2,
ddl_handler IN VARCHAR2,
message_handler IN VARCHAR2,
precommit_handler IN VARCHAR2,
start_date IN DATE,
end_date IN DATE,
negative_ruleset_owner IN VARCHAR2,
negative_ruleset_name IN VARCHAR2,
error_number IN NUMBER,
error_message IN VARCHAR2,
i_customer_id IN BINARY_INTEGER,
uan_handler IN VARCHAR2,
ua_ruleset_owner IN VARCHAR2,
ua_ruleset_name IN VARCHAR2);
dbms_logrep_imp.create_capture(
queue_owner IN VARCHAR2,
queue_name IN VARCHAR2,
capture_name IN VARCHAR2,
ruleset_owner IN VARCHAR2,
ruleset_name IN VARCHAR2,
capture_username IN VARCHAR2,
start_date IN DATE,
end_date IN DATE,
source_database IN VARCHAR2,
logfile_assignment IN VARCHAR2,
use_database_link IN VARCHAR2,
negative_ruleset_owner IN VARCHAR2,
negative_ruleset_name IN VARCHAR2,
i_customer_id IN BINARY_INTEGER);
dbms_logrep_imp.create_propagation(
propagation_name IN VARCHAR2,
src_queue_owner IN VARCHAR2,
src_queue_name IN VARCHAR2,
dest_queue_owner IN VARCHAR2,
dest_queue_name IN VARCHAR2,
dest_dblink IN VARCHAR2,
ruleset_owner IN VARCHAR2,
ruleset_name IN VARCHAR2,
negative_ruleset_owner IN VARCHAR2,
negative_ruleset_name IN VARCHAR2,
queue_to_queue IN BOOLEAN);
dbms_logrep_imp.instantiate(
object_owner IN VARCHAR2,
object_name IN VARCHAR2,
object_type IN BINARY_INTEGER,
export_db_name IN VARCHAR2,
inst_scn IN NUMBER,
ignore_scn IN NUMBER);
dbms_logrep_imp.message_consumers(
canon_streams_name IN VARCHAR2,
canon_queue_owner IN VARCHAR2,
canon_queue_name IN VARCHAR2,
canon_rset_owner IN VARCHAR2,
canon_rset_name IN VARCHAR2,
canon_neg_rset_owner IN VARCHAR2,
canon_neg_rset_name IN VARCHAR);
dbms_logrep_imp.message_rules(
canon_streams_name IN VARCHAR2,
streams_type IN NUMBER,
canon_msg_type_owner IN VARCHAR2,
canon_msg_type_name IN VARCHAR2,
canon_msg_rule_var IN VARCHAR2,
canon_rule_owner IN VARCHAR2,
canon_rule_name IN VARCHAR2,
rule_condition IN VARCHAR2);
dbms_logrep_imp.set_apply_source_obj(
source_db IN VARCHAR2,
owner IN VARCHAR2,
name IN VARCHAR2,
type IN BINARY_INTEGER,
inst_scn IN NUMBER,
ignore_scn IN NUMBER,
dblink IN VARCHAR2,
spare1 IN NUMBER);
dbms_logrep_imp.set_apply_source_schema(
source_db IN VARCHAR2,
global_flag IN BINARY_INTEGER,
name IN VARCHAR2,
dblink IN VARCHAR2,
inst_scn IN NUMBER,
spare1 IN NUMBER);
dbms_logrep_imp.set_dml_handler(
object_owner IN VARCHAR2,
object_name IN VARCHAR2,
operation_name IN VARCHAR2,
user_procedure IN VARCHAR2,
error_handler IN NUMBER,
apply_dblink IN VARCHAR2,
apply_name IN VARCHAR2,
assemble_lobs IN NUMBER);
dbms_logrep_imp.set_update_conflict_handler(
object_owner IN VARCHAR2,
object_name IN VARCHAR2,
resolution_id IN BINARY_INTEGER,
method_name IN VARCHAR2,
resolution_column IN VARCHAR2,
column_name IN VARCHAR2,
dblink IN VARCHAR2);
dbms_logrep_imp.streams_rules(
streams_name IN VARCHAR2,
streams_type IN BINARY_INTEGER,
rule_type IN BINARY_INTEGER,
include_tagged_lcr IN BINARY_INTEGER,
source_database IN VARCHAR2,
rule_owner IN VARCHAR2,
rule_name IN VARCHAR2,
rule_condition IN VARCHAR2,
dml_condition IN VARCHAR2,
subsetting_operation IN BINARY_INTEGER,
schema_name IN VARCHAR2,
object_name IN VARCHAR2,
object_type IN BINARY_INTEGER,
spare1 IN NUMBER,
spare2 IN NUMBER,
spare3 IN NUMBER,
source_root_name IN VARCHAR2);