Oracle Database 26ai will be available on generic Linux platforms in January and soon on AIX and Windows
Purpose
Streams Internal Utilities
AUTHID
CURRENT_USER
Dependencies
SELECT name FROM dba_dependencies WHERE referenced_name = 'DBMS_STREAMS_ADM_IVK' UNION
SELECT referenced_name FROM dba_dependencies WHERE name = 'DBMS_STREAMS_ADM_IVK'
ORDER BY 1;
dbms_streams_adm_ivk.add_column(
rule_name IN VARCHAR2,
table_name IN VARCHAR2,
column_name IN VARCHAR2,
column_value IN sys.anydata,
value_type IN VARCHAR2,
step_number IN NUMBER,
operation IN VARCHAR2);
TBD
Overload 2
dbms_streams_adm_ivk.add_column(
rule_name IN VARCHAR2,
table_name IN VARCHAR2,
column_name IN VARCHAR2,
column_function IN VARCHAR2,
value_type IN VARCHAR2,
step_number IN NUMBER,
operation IN VARCHAR2);
dbms_streams_adm_ivk.add_global_propagation_rules(
streams_name IN VARCHAR2,
source_queue_name IN VARCHAR2,
destination_queue_name IN VARCHAR2,
include_dml IN BOOLEAN,
include_ddl IN BOOLEAN,
include_tagged_lcr IN BOOLEAN,
source_database IN VARCHAR2,
inclusion_rule IN BOOLEAN,
and_condition IN VARCHAR2,
queue_to_queue IN BOOLEAN);
TBD
Overload 2
dbms_streams_adm_ivk.add_global_propagation_rules(
streams_name IN VARCHAR2,
source_queue_name IN VARCHAR2,
destination_queue_name IN VARCHAR2,
include_dml IN BOOLEAN,
include_ddl IN BOOLEAN,
include_tagged_lcr IN BOOLEAN,
source_database IN VARCHAR2,
dml_rule_name OUT VARCHAR2,
ddl_rule_name OUT VARCHAR2,
inclusion_rule IN BOOLEAN,
and_condition IN VARCHAR2,
queue_to_queue IN BOOLEAN);
dbms_streams_adm_ivk.add_global_rules(
streams_type IN VARCHAR2,
streams_name IN VARCHAR2,
queue_name IN VARCHAR2,
include_dml IN BOOLEAN,
include_ddl IN BOOLEAN,
include_tagged_lcr IN BOOLEAN,
source_database IN VARCHAR2,
inclusion_rule IN BOOLEAN,
and_condition IN VARCHAR2);
TBD
Overload 2
dbms_streams_adm_ivk.add_global_rules(
streams_type IN VARCHAR2,
streams_name IN VARCHAR2,
queue_name IN VARCHAR2,
include_dml IN BOOLEAN,
include_ddl IN BOOLEAN,
include_tagged_lcr IN BOOLEAN,
source_database IN VARCHAR2,
dml_rule_name OUT VARCHAR2,
ddl_rule_name OUT VARCHAR2,
inclusion_rule IN BOOLEAN,
and_condition IN VARCHAR2);
dbms_streams_adm_ivk.add_message_propagation_rule(
message_type IN VARCHAR2,
rule_condition IN VARCHAR2,
streams_name IN VARCHAR2,
source_queue_name IN VARCHAR2,
destination_queue_name IN VARCHAR2,
inclusion_rule IN BOOLEAN,
queue_to_queue IN BOOLEAN);
TBD
Overload 2
dbms_streams_adm_ivk.add_message_propagation_rule(
message_type IN VARCHAR2,
rule_condition IN VARCHAR2,
streams_name IN VARCHAR2,
source_queue_name IN VARCHAR2,
destination_queue_name IN VARCHAR2,
inclusion_rule IN BOOLEAN,
rule_name OUT VARCHAR2,
queue_to_queue IN BOOLEAN);
dbms_streams_adm_ivk.add_message_rule(
message_type IN VARCHAR2,
rule_condition IN VARCHAR2,
streams_type IN VARCHAR2,
streams_name IN VARCHAR2,
queue_name IN VARCHAR2,
inclusion_rule IN BOOLEAN);
TBD
Overload 2
dbms_streams_adm_ivk.add_message_rule(
message_type IN VARCHAR2,
rule_condition IN VARCHAR2,
streams_type IN VARCHAR2,
streams_name IN VARCHAR2,
queue_name IN VARCHAR2,
inclusion_rule IN BOOLEAN,
rule_name OUT VARCHAR2);
dbms_streams_adm_ivk.add_schema_propagation_rules(
schema_name IN VARCHAR2,
streams_name IN VARCHAR2,
source_queue_name IN VARCHAR2,
destination_queue_name IN VARCHAR2,
include_dml IN BOOLEAN,
include_ddl IN BOOLEAN,
include_tagged_lcr IN BOOLEAN,
source_database IN VARCHAR2,
inclusion_rule IN BOOLEAN,
and_condition IN VARCHAR2,
queue_to_queue IN BOOLEAN);
TBD
Overload 2
dbms_streams_adm_ivk.add_schema_propagation_rules(
schema_name IN VARCHAR2,
streams_name IN VARCHAR2,
source_queue_name IN VARCHAR2,
destination_queue_name IN VARCHAR2,
include_dml IN BOOLEAN,
include_ddl IN BOOLEAN,
include_tagged_lcr IN BOOLEAN,
source_database IN VARCHAR2,
dml_rule_name OUT VARCHAR2,
ddl_rule_name OUT VARCHAR2,
inclusion_rule IN BOOLEAN,
and_condition IN VARCHAR2,
queue_to_queue IN BOOLEAN);
dbms_streams_adm_ivk.add_schema_rules(
schema_name IN VARCHAR2,
streams_type IN VARCHAR2,
streams_name IN VARCHAR2,
queue_name IN VARCHAR2,
include_dml IN BOOLEAN,
include_ddl IN BOOLEAN,
include_tagged_lcr IN BOOLEAN,
source_database IN VARCHAR2,
inclusion_rule IN BOOLEAN,
and_condition IN VARCHAR2);
TBD
Overload 2
dbms_streams_adm_ivk.add_schema_rules(
schema_name IN VARCHAR2,
streams_type IN VARCHAR2,
streams_name IN VARCHAR2,
queue_name IN VARCHAR2,
include_dml IN BOOLEAN,
include_ddl IN BOOLEAN,
include_tagged_lcr IN BOOLEAN,
source_database IN VARCHAR2,
dml_rule_name OUT VARCHAR2,
ddl_rule_name OUT VARCHAR2,
inclusion_rule IN BOOLEAN,
and_condition IN VARCHAR2);
dbms_streams_adm_ivk.add_subset_propagation_rules(
table_name IN VARCHAR2,
dml_condition IN VARCHAR2,
streams_name IN VARCHAR2,
source_queue_name IN VARCHAR2,
destination_queue_name IN VARCHAR2,
include_tagged_lcr IN BOOLEAN,
source_database IN VARCHAR2,
queue_to_queue IN BOOLEAN);
TBD
Overload 2
dbms_streams_adm_ivk.add_subset_propagation_rules(
table_name IN VARCHAR2,
dml_condition IN VARCHAR2,
streams_name IN VARCHAR2,
source_queue_name IN VARCHAR2,
destination_queue_name IN VARCHAR2,
include_tagged_lcr IN BOOLEAN,
source_database IN VARCHAR2,
insert_rule_name OUT VARCHAR2,
update_rule_name OUT VARCHAR2,
delete_rule_name OUT VARCHAR2,
queue_to_queue IN BOOLEAN);
dbms_streams_adm_ivk.add_subset_rules(
table_name IN VARCHAR2,
dml_condition IN VARCHAR2,
streams_type IN VARCHAR2,
streams_name IN VARCHAR2,
queue_name IN VARCHAR2,
include_tagged_lcr IN BOOLEAN,
source_database IN VARCHAR2,
source_root_name IN VARCHAR2);
TBD
Overload 2
dbms_streams_adm_ivk.add_subset_rules(
table_name IN VARCHAR2,
dml_condition IN VARCHAR2,
streams_type IN VARCHAR2,
streams_name IN VARCHAR2,
queue_name IN VARCHAR2,
include_tagged_lcr IN BOOLEAN,
source_database IN VARCHAR2,
insert_rule_name OUT VARCHAR2,
update_rule_name OUT VARCHAR2,
delete_rule_name OUT VARCHAR2,
source_root_name IN VARCHAR2);
dbms_streams_adm_ivk.add_table_propagation_rules(
table_name IN VARCHAR2,
streams_name IN VARCHAR2,
source_queue_name IN VARCHAR2,
destination_queue_name IN VARCHAR2,
include_dml IN BOOLEAN,
include_ddl IN BOOLEAN,
include_tagged_lcr IN BOOLEAN,
source_database IN VARCHAR2,
inclusion_rule IN BOOLEAN,
and_condition IN VARCHAR2,
queue_to_queue IN BOOLEAN);
TBD
Overload 2
dbms_streams_adm_ivk.add_table_propagation_rules(
table_name IN VARCHAR2,
streams_name IN VARCHAR2,
source_queue_name IN VARCHAR2,
destination_queue_name IN VARCHAR2,
include_dml IN BOOLEAN,
include_ddl IN BOOLEAN,
include_tagged_lcr IN BOOLEAN,
source_database IN VARCHAR2,
dml_rule_name OUT VARCHAR2,
ddl_rule_name OUT VARCHAR2,
inclusion_rule IN BOOLEAN,
and_condition IN VARCHAR2,
queue_to_queue IN BOOLEAN);
dbms_streams_adm_ivk.add_table_rules(
table_name IN VARCHAR2,
streams_type IN VARCHAR2,
streams_name IN VARCHAR2,
queue_name IN VARCHAR2,
include_dml IN BOOLEAN,
include_ddl IN BOOLEAN,
include_tagged_lcr IN BOOLEAN,
source_database IN VARCHAR2,
inclusion_rule IN BOOLEAN,
and_condition IN VARCHAR2);
TBD
Overload 2
dbms_streams_adm_ivk.add_table_rules(
table_name IN VARCHAR2,
streams_type IN VARCHAR2,
streams_name IN VARCHAR2,
queue_name IN VARCHAR2,
include_dml IN BOOLEAN,
include_ddl IN BOOLEAN,
include_tagged_lcr IN BOOLEAN,
source_database IN VARCHAR2,
dml_rule_name OUT VARCHAR2,
ddl_rule_name OUT VARCHAR2,
inclusion_rule IN BOOLEAN,
and_condition IN VARCHAR2);
dbms_streams_adm_ivk.cleanup_instantiation_setup(
maintain_mode IN VARCHAR2,
tablespace_names IN sys.dbms_streams_tablespace_adm.tablespace_set,
source_database IN VARCHAR2,
destination_database IN VARCHAR2,
perform_actions IN BOOLEAN,
script_name IN VARCHAR2,
script_directory_object IN VARCHAR2,
capture_name IN VARCHAR2,
capture_queue_table IN VARCHAR2,
capture_queue_name IN VARCHAR2,
capture_queue_user IN VARCHAR2,
propagation_name IN VARCHAR2,
apply_name IN VARCHAR2,
apply_queue_table IN VARCHAR2,
apply_queue_name IN VARCHAR2,
apply_queue_user IN VARCHAR2,
bi_directional IN BOOLEAN,
change_global_name IN BOOLEAN);
dbms_streams_adm_ivk.delete_column(
rule_name IN VARCHAR2,
table_name IN VARCHAR2,
column_name IN VARCHAR2,
value_type IN VARCHAR2,
step_number IN NUMBER,
operation IN VARCHAR2);
dbms_streams_adm_ivk.get_scn_mapping(
apply_name IN VARCHAR2,
src_pit_scn IN NUMBER,
dest_instantiation_scn OUT NUMBER,
dest_start_scn OUT NUMBER,
dest_skip_txn_ids OUT sys.dbms_utility.name_array);
dbms_streams_adm_ivk.keep_columns(
rule_name IN VARCHAR2,
table_name IN VARCHAR2,
column_table IN sys.dbms_utility.lname_array,
value_type IN VARCHAR2,
step_number IN NUMBER,
operation IN VARCHAR2);
TBD
Overload 2
dbms_streams_adm_ivk.keep_columns(
rule_name IN VARCHAR2,
table_name IN VARCHAR2,
column_list IN VARCHAR2,
value_type IN VARCHAR2,
step_number IN NUMBER,
operation IN VARCHAR2);
dbms_streams_adm_ivk.maintain_global(
source_directory_object IN VARCHAR2,
destination_directory_object IN VARCHAR2,
source_database IN VARCHAR2,
destination_database IN VARCHAR2,
perform_actions IN BOOLEAN,
script_name IN VARCHAR2,
script_directory_object IN VARCHAR2,
dump_file_name IN VARCHAR2,
capture_name IN VARCHAR2,
capture_queue_table IN VARCHAR2,
capture_queue_name IN VARCHAR2,
capture_queue_user IN VARCHAR2,
propagation_name IN VARCHAR2,
apply_name IN VARCHAR2,
apply_queue_table IN VARCHAR2,
apply_queue_name IN VARCHAR2,
apply_queue_user IN VARCHAR2,
log_file IN VARCHAR2,
bi_directional IN BOOLEAN,
include_ddl IN BOOLEAN,
instantiation IN BINARY_INTEGER);
dbms_streams_adm_ivk.maintain_schemas(
schema_names IN sys.dbms_utility.uncl_array,
source_directory_object IN VARCHAR2,
destination_directory_object IN VARCHAR2,
source_database IN VARCHAR2,
destination_database IN VARCHAR2,
perform_actions IN BOOLEAN,
script_name IN VARCHAR2,
script_directory_object IN VARCHAR2,
dump_file_name IN VARCHAR2,
capture_name IN VARCHAR2,
capture_queue_table IN VARCHAR2,
capture_queue_name IN VARCHAR2,
capture_queue_user IN VARCHAR2,
propagation_name IN VARCHAR2,
apply_name IN VARCHAR2,
apply_queue_table IN VARCHAR2,
apply_queue_name IN VARCHAR2,
apply_queue_user IN VARCHAR2,
log_file IN VARCHAR2,
bi_directional IN BOOLEAN,
include_ddl IN BOOLEAN,
instantiation IN BINARY_INTEGER);
TBD
Overload 2
dbms_streams_adm_ivk.maintain_schemas(
schema_names IN VARCHAR2,
source_directory_object IN VARCHAR2,
destination_directory_object IN VARCHAR2,
source_database IN VARCHAR2,
destination_database IN VARCHAR2,
perform_actions IN BOOLEAN,
script_name IN VARCHAR2,
script_directory_object IN VARCHAR2,
dump_file_name IN VARCHAR2,
capture_name IN VARCHAR2,
capture_queue_table IN VARCHAR2,
capture_queue_name IN VARCHAR2,
capture_queue_user IN VARCHAR2,
propagation_name IN VARCHAR2,
apply_name IN VARCHAR2,
apply_queue_table IN VARCHAR2,
apply_queue_name IN VARCHAR2,
apply_queue_user IN VARCHAR2,
log_file IN VARCHAR2,
bi_directional IN BOOLEAN,
include_ddl IN BOOLEAN,
instantiation IN BINARY_INTEGER);
dbms_streams_adm_ivk.maintain_simple_tablespace(
tablespace_name IN VARCHAR2,
source_directory_object IN VARCHAR2,
destination_directory_object IN VARCHAR2,
destination_database IN VARCHAR2,
setup_streams IN BOOLEAN,
script_name IN VARCHAR2,
script_directory_object IN VARCHAR2,
bi_directional IN BOOLEAN);
dbms_streams_adm_ivk.maintain_simple_tts(
tablespace_name IN VARCHAR2,
source_directory_object IN VARCHAR2,
destination_directory_object IN VARCHAR2,
source_database IN VARCHAR2,
destination_database IN VARCHAR2,
perform_actions IN BOOLEAN,
script_name IN VARCHAR2,
script_directory_object IN VARCHAR2,
bi_directional IN BOOLEAN);
dbms_streams_adm_ivk.maintain_tables(
table_names IN sys.dbms_utility.uncl_array,
source_directory_object IN VARCHAR2,
destination_directory_object IN VARCHAR2,
source_database IN VARCHAR2,
destination_database IN VARCHAR2,
perform_actions IN BOOLEAN,
script_name IN VARCHAR2,
script_directory_object IN VARCHAR2,
dump_file_name IN VARCHAR2,
capture_name IN VARCHAR2,
capture_queue_table IN VARCHAR2,
capture_queue_name IN VARCHAR2,
capture_queue_user IN VARCHAR2,
propagation_name IN VARCHAR2,
apply_name IN VARCHAR2,
apply_queue_table IN VARCHAR2,
apply_queue_name IN VARCHAR2,
apply_queue_user IN VARCHAR2,
log_file IN VARCHAR2,
bi_directional IN BOOLEAN,
include_ddl IN BOOLEAN,
instantiation IN BINARY_INTEGER);
TBD
Overload 2
dbms_streams_adm_ivk.maintain_tables(
table_names IN VARCHAR2,
source_directory_object IN VARCHAR2,
destination_directory_object IN VARCHAR2,
source_database IN VARCHAR2,
destination_database IN VARCHAR2,
perform_actions IN BOOLEAN,
script_name IN VARCHAR2,
script_directory_object IN VARCHAR2,
dump_file_name IN VARCHAR2,
capture_name IN VARCHAR2,
capture_queue_table IN VARCHAR2,
capture_queue_name IN VARCHAR2,
capture_queue_user IN VARCHAR2,
propagation_name IN VARCHAR2,
apply_name IN VARCHAR2,
apply_queue_table IN VARCHAR2,
apply_queue_name IN VARCHAR2,
apply_queue_user IN VARCHAR2,
log_file IN VARCHAR2,
bi_directional IN BOOLEAN,
include_ddl IN BOOLEAN,
instantiation IN BINARY_INTEGER);
dbms_streams_adm_ivk.maintain_tablespaces(
tablespace_names IN sys.dbms_streams_tablespace_adm.tablespace_set,
source_directory_object IN VARCHAR2,
destination_directory_object IN VARCHAR2,
destination_database IN VARCHAR2,
setup_streams IN BOOLEAN,
script_name IN VARCHAR2,
script_directory_object IN VARCHAR2,
dump_file_name IN VARCHAR2,
source_queue_table IN VARCHAR2,
source_queue_name IN VARCHAR2,
source_queue_user IN VARCHAR2,
destination_queue_table IN VARCHAR2,
destination_queue_name IN VARCHAR2,
destination_queue_user IN VARCHAR2,
capture_name IN VARCHAR2,
propagation_name IN VARCHAR2,
apply_name IN VARCHAR2,
log_file IN VARCHAR2,
bi_directional IN BOOLEAN,
include_ddl IN BOOLEAN);
dbms_streams_adm_ivk.maintain_tts(
tablespace_names IN dbms_streams_tablespace_adm.tablespace_set,
source_directory_object IN VARCHAR2,
destination_directory_object IN VARCHAR2,
source_database IN VARCHAR2,
destination_database IN VARCHAR2,
perform_actions IN BOOLEAN,
script_name IN VARCHAR2,
script_directory_object IN VARCHAR2,
dump_file_name IN VARCHAR2,
capture_name IN VARCHAR2,
capture_queue_table IN VARCHAR2,
capture_queue_name IN VARCHAR2,
capture_queue_user IN VARCHAR2,
propagation_name IN VARCHAR2,
apply_name IN VARCHAR2,
apply_queue_table IN VARCHAR2,
apply_queue_name IN VARCHAR2,
apply_queue_user IN VARCHAR2,
log_file IN VARCHAR2,
bi_directional IN BOOLEAN,
include_ddl IN BOOLEAN);
dbms_streams_adm_ivk.merge_streams(
cloned_propagation_name IN VARCHAR2,
propagation_name IN VARCHAR2,
queue_name IN VARCHAR2,
perform_actions IN BOOLEAN,
script_name IN VARCHAR2,
script_directory_object IN VARCHAR2)
dbms_streams_adm_ivk.merge_streams_job(
cloned_propagation_name IN VARCHAR2,
propagation_name IN VARCHAR2,
queue_name IN VARCHAR2,
merge_threshold IN NUMBER,
schedule_name IN VARCHAR2,
merge_job_name IN VARCHAR2);
dbms_streams_adm_ivk.post_instantiation_setup(
maintain_mode IN VARCHAR2,
tablespace_names IN sys.dbms_streams_tablespace_adm.tablespace_set,
source_database IN VARCHAR2,
destination_database IN VARCHAR2,
perform_actions IN BOOLEAN,
script_name IN VARCHAR2,
script_directory_object IN VARCHAR2,
capture_name IN VARCHAR2,
capture_queue_table IN VARCHAR2,
capture_queue_name IN VARCHAR2,
capture_queue_user IN VARCHAR2,
propagation_name IN VARCHAR2,
apply_name IN VARCHAR2,
apply_queue_table IN VARCHAR2,
apply_queue_name IN VARCHAR2,
apply_queue_user IN VARCHAR2,
bi_directional IN BOOLEAN,
include_ddl IN BOOLEAN,
start_processes IN BOOLEAN,
instantiation_scn IN NUMBER,
exclude_schemas IN VARCHAR2,
exclude_flags IN BINARY_INTEGER);
dbms_streams_adm_ivk.pre_instantiation_setup(
maintain_mode IN VARCHAR2,
tablespace_names IN sys.dbms_streams_tablespace_adm.tablespace_set,
source_database IN VARCHAR2,
destination_database IN VARCHAR2,
perform_actions IN BOOLEAN,
script_name IN VARCHAR2,
script_directory_object IN VARCHAR2,
capture_name IN VARCHAR2,
capture_queue_table IN VARCHAR2,
capture_queue_name IN VARCHAR2,
capture_queue_user IN VARCHAR2,
propagation_name IN VARCHAR2,
apply_name IN VARCHAR2,
apply_queue_table IN VARCHAR2,
apply_queue_name IN VARCHAR2,
apply_queue_user IN VARCHAR2,
bi_directional IN BOOLEAN,
include_ddl IN BOOLEAN,
start_processes IN BOOLEAN,
exclude_schemas IN VARCHAR2,
exclude_flags IN BINARY_INTEGER);
dbms_streams_adm_ivk.remove_rule(
rule_name IN VARCHAR2,
streams_type IN VARCHAR2,
streams_name IN VARCHAR2,
drop_unused_rule IN BOOLEAN,
inclusion_rule IN BOOLEAN);
dbms_streams_adm_ivk.rename_column(
rule_name IN VARCHAR2,
table_name IN VARCHAR2,
from_column_name IN VARCHAR2,
to_column_name IN VARCHAR2,
value_type IN VARCHAR2,
step_number IN NUMBER,
operation IN VARCHAR2);
dbms_streams_adm_ivk.rename_schema(
rule_name IN VARCHAR2,
from_schema_name IN VARCHAR2,
to_schema_name IN VARCHAR2,
step_number IN NUMBER,
operation IN VARCHAR2);
dbms_streams_adm_ivk.rename_table(
rule_name IN VARCHAR2,
from_table_name IN VARCHAR2,
to_table_name IN VARCHAR2,
step_number IN NUMBER,
operation IN VARCHAR2);
dbms_streams_adm_ivk.set_message_notification(
streams_name IN VARCHAR2,
notification_action IN VARCHAR2,
notification_type IN VARCHAR2,
notification_context IN sys.anydata,
include_notification IN BOOLEAN,
queue_name IN VARCHAR2);
dbms_streams_adm_ivk.set_up_queue(
queue_table IN VARCHAR2,
storage_clause IN VARCHAR2,
queue_name IN VARCHAR2,
queue_user IN VARCHAR2,
comment IN VARCHAR2)
dbms_streams_adm_ivk.split_streams(
propagation_name IN VARCHAR2,
cloned_propagation_name IN VARCHAR2,
cloned_queue_name IN VARCHAR2,
cloned_capture_name IN VARCHAR2,
perform_actions IN BOOLEAN,
script_name IN VARCHAR2,
script_directory_object IN VARCHAR2,
auto_merge_threshold IN NUMBER,
schedule_name IN OUT VARCHAR2,
merge_job_name IN OUT VARCHAR2
dbms_streams_adm_ivk.verify_and_get_subset_rules(
canon_own_name IN VARCHAR2,
canon_tab_name IN VARCHAR2,
table_name IN VARCHAR2,
type_value IN NUMBER,
inc_tagged_lcr IN NUMBER,
dml_condition IN VARCHAR2,
canon_source_database IN VARCHAR2,
insert_rule OUT VARCHAR2,
update_rule OUT VARCHAR2,
delete_rule OUT VARCHAR2);