Oracle DBMS_STREAMS_MT Version 21c

612-476-5707 / 952-595-5916

General Information
Library Note	ACE Director Alum Daniel Morgan, founder of Morgan's Library, is scheduling complimentary technical Workshops on Database Security for the first 30 Oracle Database customers located anywhere in North America, EMEA, LATAM, or APAC that send an email to asra_us@oracle.com. Request a Workshop for your organization today.
Purpose	Streams internal utilities. It has been suggested that MT may stand for "Maintain Tables" but that is far from certain.
AUTHID	CURRENT_USER
Dependencies	DBA_RECOVERABLE_SCRIPT DBMS_RECO_SCRIPT_INVOK DBMS_STREAMS_TABLESPACE_ADM DBA_RECOVERABLE_SCRIPT_PARAMS DBMS_STANDARD DBMS_STREAMS_TBS_INT DBMS_APPLY_ADM DBMS_STREAMS_ADM DBMS_STREAMS_TBS_INT_INVOK DBMS_ASSERT DBMS_STREAMS_ADM_IVK DBMS_SYS_ERROR DBMS_CAPTURE_ADM_INTERNAL DBMS_STREAMS_ADM_UTL DBMS_UTILITY DBMS_LOB DBMS_STREAMS_ADM_UTL_INVOK GLOBAL_NAME DBMS_LOGREP_UTIL DBMS_STREAMS_DATAPUMP_UTIL PLITBLM DBMS_LOGREP_UTIL_INVOK DBMS_STREAMS_DECL UTL_FILE DBMS_RECOVERABLE_SCRIPT DBMS_STREAMS_RPC V$DATABASE
Data Types	TYPE schema_object_set ....; TYPE schema_table_array ....; TYPE script_t ....; TYPE sql_rec ....; TYPE table_object_set ....;
Documented	No
First Available	Not known
Security Model	Owned by SYS with EXECUTE granted to the EXECUTE_CATALOG_ROLE role.
Source	{ORACLE_HOME}/rdbms/admin/prvthsmt.plb {ORACLE_HOME}/rdbms/admin/prvtbsmt.plb
Subprograms	ALTER_APPLY_SETUP DROP_TABLESPACE_SETUP PROCESS_SQL_SCRIPT ALTER_CAPTURE_SETUP ENABLE_PROPAGATION PROPAGATION_SETUP ALTER_PROPAGATION_SETUP EXECUTING_MAINTAIN_API QUEUE_SETUP APPLY_SETUP GENERATE_HEADER_STMT RECOVER_OPERATION BUILD_AND_PREPARE GET_CRASH_COUNTER REMOTE_STATE_BLOCK CANONICALIZE_TABLEPACES GET_CRASH_POINT REMOVE_RULE_RULESET_SETUP CAPTURE_SETUP GET_SETUP_STREAMS SETUP_REMOTE_SESSION_STATE CLEANUP_INSTANTIATION_SETUP GET_SRC_DB SET_CRASH_COUNTER CLOSE_SQL_SCRIPT GET_TABLES_IN_TABLESPACES SET_CRASH_POINT CONSTRUCT_SQL_REC GET_TARGET_DB SET_INSTANTIATION_SCN CONVERT_TAB_OBJS_TO_ARRAYS INSERT_PARAM SET_SETUP_STREAMS CRASH_TEST IS_IN SET_SRC_DB CREATE_CAPTURE_SETUP MAINTAIN_STREAMS SET_TARGET_DB DROP_QUEUE_SETUP OPEN_SQL_SCRIPT START_APPLY DROP_QUEUE_TABLE_SETUP POST_INSTANTIATION_SETUP START_CAPTURE DROP_RULESET_SETUP PRE_INSTANTIATION_SETUP STOP_QUEUE_SETUP DROP_RULE_SETUP PROCESS_SQL_REC STOP_STREAMS_PROCESS_SETUP
ALTER_APPLY_SETUP
Undocumented	dbms_streams_mt.alter_apply_setup( canon_apply_name    IN     VARCHAR2, remove_rule_set     IN     BOOLEAN, remove_neg_rule_set IN     BOOLEAN, script              IN OUT sys.dbms_streams_mt.script_t);
	TBD
ALTER_CAPTURE_SETUP
Undocumented	dbms_streams_mt.alter_capture_setup( canon_capture_name  IN     VARCHAR2, remove_rule_set     IN     BOOLEAN, remove_neg_rule_set IN     BOOLEAN, script              IN OUT sys.dbms_streams_mt.script_t);
	TBD
ALTER_PROPAGATION_SETUP
Undocumented	dbms_streams_mt.alter_propagation_setup( canon_propagation_name IN     VARCHAR2, remove_rule_set        IN     BOOLEAN, remove_neg_rule_set    IN     BOOLEAN, script                 IN OUT sys.dbms_streams_mt.script_t);
	TBD
APPLY_SETUP
Undocumented	dbms_streams_mt.apply_setup( maintain_mode          IN     VARCHAR2, canon_apply_name       IN     VARCHAR2, canon_source_db        IN     VARCHAR2, canon_qown             IN     VARCHAR2, canon_qname            IN     VARCHAR2, table_objects          IN     sys.dbms_streams_mt.table_object_set, schema_objects         IN     sys.dbms_streams_mt.schema_object_set, exclude_unsupported    IN     BOOLEAN, set_tag                IN     BOOLEAN, apply_tagged_lcrs      IN     BOOLEAN, excl_tag_apply_name    IN     VARCHAR2, excl_tag_apply_src_db  IN     VARCHAR2, excl_tag_apply_dblink  IN     VARCHAR2, dblink                 IN     VARCHAR2, include_ddl            IN     BOOLEAN, script                 IN OUT sys.dbms_streams_mt.script_t);
	TBD
BUILD_AND_PREPARE
Undocumented	dbms_streams_mt.build_and_prepare( maintain_mode  IN     VARCHAR2, table_objects  IN     dbms_streams_mt.table_object_set, schema_objects IN     dbms_streams_mt.schema_object_set, dblink         IN     VARCHAR2, script         IN OUT sys.dbms_streams_mt.script_t);
	TBD
CANONICALIZE_TABLEPACES
Undocumented	dbms_streams_mt.canonicalize_tablepaces( tablespace_names IN sys.dbms_streams_tablespace_adm.tablespace_set) RETURN sys.dbms_streams_tablespace_adm.tablespace_set;
	TBD
CAPTURE_SETUP
Undocumented	dbms_streams_mt.capture_setup( maintain_mode       IN     VARCHAR2, canon_capture_name  IN     VARCHAR2, canon_source_db     IN     VARCHAR2, canon_qown          IN     VARCHAR2, canon_qname         IN     VARCHAR2, table_objects       IN     sys.dbms_streams_mt.table_object_set, schema_objects      IN     sys.dbms_streams_mt.schema_object_set, capture_tagged_lcrs IN     BOOLEAN, exclude_unsupported IN     BOOLEAN, dblink              IN     VARCHAR2, include_dml         IN     BOOLEAN, include_ddl         IN     BOOLEAN, inclusion_rule      IN     BOOLEAN, script              IN OUT sys.dbms_streams_mt.script_t);
	TBD
CLEANUP_INSTANTIATION_SETUP
Undocumented	dbms_streams_mt.cleanup_instantiation_setup( maintain_mode           IN VARCHAR2, tablespace_names        IN sys.dbms_sterams_tablespace_adm.tablespace_set, source_database         IN VARCHAR2, destination_database    IN VARCHAR2, setup_streams           IN BOOLEAN, script_name             IN VARCHAR2, script_directory_object IN VARCHAR2, capture_queue_table     IN VARCHAR2, capture_queue_name      IN VARCHAR2, capture_queue_user      IN VARCHAR2, apply_queue_table       IN VARCHAR2, apply_queue_name        IN VARCHAR2, apply_queue_user        IN VARCHAR2, capture_name            IN VARCHAR2, propagation_name        IN VARCHAR2, apply_name              IN VARCHAR2, bi_directional          IN BOOLEAN, change_global_name      IN BOOLEAN);
	TBD
CLOSE_SQL_SCRIPT
Undocumented	dbms_streams_mt.close_sql_script(script IN OUT sys.dbms_steams_mt.script_t);
	TBD
CONSTRUCT_SQL_REC
Undocumented Overload 1	dbms_streams_mt.construct_sql_rec( stmt     IN CLOB, dblink   IN VARCHAR2, arg_name IN VARCHAR2, flags    IN NUMBER) RETURN dbms_streams_mt.sql_rec;
	TBD
Overload 2	dbms_streams_mt.construct_sql_rec( str1     IN CLOB, str2     IN CLOB, str3     IN CLOB, str4     IN CLOB, str5     IN CLOB, str6     IN CLOB, str7     IN CLOB, str8     IN CLOB, str9     IN CLOB, str10    IN CLOB, str11    IN CLOB, str12    IN CLOB, str13    IN CLOB, str14    IN CLOB, str15    IN CLOB, str16    IN CLOB, str17    IN CLOB, str18    IN CLOB, str19    IN CLOB, str20    IN CLOB, dblink   IN VARCHAR2, arg_name IN VARCHAR2, flags    IN NUMBER) RETURN dbms_streams_mt.sql_rec;
	TBD
CONVERT_TAB_OBJS_TO_ARRAYS
Undocumented	dbms_streams_mt.convert_tab_objs_to_arrays( table_objects IN     sys.dbms_streams_mt.table_object_set, dp_obj_names  IN OUT sys.dbms_streams_mt.schema_table_array, dp_obj_owners IN OUT sys.dbms_utility.uncl_array);
	TBD
CRASH_TEST
Undocumented	dbms_streams_mt.crash_test;
	exec dbms_streams_mt.crash_test; PL/SQL procedure successfully completed.
CREATE_CAPTURE_SETUP
Undocumented	dbms_streams_mt.create_capture_setup( canon_capture_name IN     VARCHAR2, canon_source_db    IN     VARCHAR2, canon_qown         IN     VARCHAR2, canon_qname        IN     VARCHAR2, dblink             IN     VARCHAR2, script             IN OUT sys.dbms_streams_mt.script_t);
	TBD
DROP_QUEUE_SETUP
Undocumented	dbms_streams_mt.drop_queue_setup( canon_qown  IN     VARCHAR2, canon_qname IN     VARCHAR2, script      IN OUT sys.dbms_streams_mt.script_t);
	TBD
DROP_QUEUE_TABLE_SETUP
Undocumented	dbms_streams_mt.drop_queue_table_setup( canon_qtown  IN     VARCHAR2, canon_qtname IN     VARCHAR2, script       IN OUT sys.dbms_streams_mt.script_t);
	TBD
DROP_RULESET_SETUP
Undocumented	dbms_streams_mt.drop_ruleset_setup( canon_ruleset_name IN     VARCHAR2, script             IN OUT sys.dbms_streams_mt.script_t);
	TBD
DROP_RULE_SETUP
Undocumented	dbms_streams_mt.drop_rule_setup( canon_rule_name IN     VARCHAR2, script          IN OUT sys.dbms_streams_mt.script_t);
	TBD
DROP_TABLESPACE_SETUP
Undocumented	dbms_streams_mt.drop_tablespace_setup( tablespace_names IN     sys.dbms_streams_tablespace_adm.tablespace_set, dblink           IN     VARCHAR2, script           IN OUT sys.dbms_streams_mt.script_t);
	TBD
ENABLE_PROPAGATION
Undocumented	dbms_streams_mt.enable_propagation( canon_dest_db      IN     VARCHAR2, canon_source_qown  IN     VARCHAR2, canon_source_qname IN     VARCHAR2, canon_dest_qown    IN     VARCHAR2, canon_dest_qname   IN     VARCHAR2, dblink             IN     VARCHAR2, script             IN OUT sys.dbms_streams_mt.script_t);
	TBD
EXECUTING_MAINTAIN_API
Undocumented	dbms_streams_mt.executing_maintain_api RETURN BOOLEAN;
	BEGIN   IF dbms_streams_mt.executing_maintain_api THEN     dbms_output.put_line('T');   ELSE     dbms_output.put_line('F');   END IF; END; / F PL/SQL procedure successfully completed.
GENERATE_HEADER_STMT
Undocumented	dbms_streams_mt.generate_header_stmt( downstream_capture IN     BOOLEAN, comment            IN     CLOB, script             IN OUT sys.dbms_streams_mt.script_t);
	TBD
GET_CRASH_COUNTER
Returns the crash counter set with SET_CRASH_COUNTER (below)	dbms_streams_mt.get_crash_counter RETURN NUMBER
	SELECT dbms_streams_mt.get_crash_counter FROM dual; GET_CRASH_COUNTER -----------------                42
GET_CRASH_POINT
Returns the crash point set with SET_CRASH_POINT (below)	dbms_streams_mt.get_crash_point RETURN NUMBER;
	SELECT dbms_streams_mt.get_crash_point FROM dual; GET_CRASH_POINT ---------------              99
GET_SETUP_STREAMS
Undocumented	dbms_streams_mt.get_setup_streams RETURN TRUE;
	BEGIN   IF dbms_streams_mt.get_setup_streams THEN     dbms_output.put_line('T');   ELSE     dbms_output.put_line('F');   END IF; END; / F PL/SQL procedure successfully completed.
GET_SRC_DB
Returns the source database name set with SET_SRC_DB (below)	dbms_streams_mt.get_src_db RETURN VARCHAR2;
	SELECT dbms_streams_mt.get_src_db FROM dual; GET_SRC_DB ----------- ORABASE21
GET_TABLES_IN_TABLESPACES
Undocumented	dbms_streams_mt.get_tables_in_tablespaces( canon_tablespace_names IN sys.dbms_streams_tablespaces_adm.tablespace_set, canon_source_db        IN VARCHAR2) RETURN sys.dbms_streams_mt.table_object_set;
	TBD
GET_TARGET_DB
Returns the target database name set with SET_TARGET_DB (below)	dbms_streams_mt.get_target_db RETURN VARCHAR2;
	SELECT dbms_streams_mt.get_target_db FROM dual; GET_TARGET_DB -------------- ORABASE23
INSERT_PARAM
Undocumented	dbms_streams_mt.insert_param( oid     IN RAW, p_name  IN VARCHAR2, p_value IN VARCHAR2, p_ind   IN NUMBER);
	TBD
IS_IN
Undocumented	dbms_streams_mt.is_in( table_objects    IN sys.dbms_streams_mt.table_object_set, canon_owner_name IN VARCHAR2, canon_table_name IN VARCHAR2, last_ddl_time    IN DATE) RETURN TRUE;
	TBD
MAINTAIN_STREAMS
Undocumented	dbms_streams_mt.maintain_streams( maintain_mode                IN VARCHAR2, tablespace_names             IN sys.dbms_streams_tablespace_adm.tablespace_set, canon_object_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, script_name                  IN VARCHAR2, script_directory_object      IN VARCHAR2, dump_file_name               IN VARCHAR2, setup_streams                IN BOOLEAN, capture_queue_table          IN VARCHAR2, capture_queue_name           IN VARCHAR2, capture_queue_user           IN VARCHAR2, apply_queue_name             IN VARCHAR2, apply_queue_user             IN VARCHAR2, apply_queue_table            IN VARCHAR2, capture_name                 IN VARCHAR2, propagation_name             IN VARCHAR2, apply_name                   IN VARCHAR2, log_file                     IN VARCHAR2, simple                       IN BOOLEAN, bi_directional               IN BOOLEAN, include_ddl                  IN BOOLEAN, single_queue                 IN BOOLEAN, instantiation                IN BINARY_INTEGER, invoking_pkg_owner           IN VARCHAR2, invoking_pkg                 IN VARCHAR2, invoking_proc                IN VARCHAR2);
	TBD
OPEN_SQL_SCRIPT
Undocumented	dbms_streams_mt.open_sql_script( execute_script      IN     BOOLEAN, write_to_file       IN     BOOLEAN, canon_script_dirobj IN     VARCHAR2, script_name         IN     VARCHAR2, script              IN OUT sys.dbms_streams_mt.script_t);
	TBD
POST_INSTANTIATION_SETUP
Undocumented	dbms_streams_mt.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, setup_streams           IN BOOLEAN, script_name             IN VARCHAR2, script_directory_object IN VARCHAR2, capture_queue_table     IN VARCHAR2, capture_queue_name      IN VARCHAR2, capture_queue_user      IN VARCHAR2, apply_queue_table       IN VARCHAR2, apply_queue_name        IN VARCHAR2, apply_queue_user        IN VARCHAR2, capture_name            IN VARCHAR2, propagation_name        IN VARCHAR2, apply_name              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);
	TBD
PRE_INSTANTIATION_SETUP
Undocumented	dbms_streams_mt.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, setup_streams           IN BOOLEAN, script_name             IN VARCHAR2, script_directory_object IN VARCHAR2, capture_queue_table     IN VARCHAR2, capture_queue_name      IN VARCHAR2, capture_queue_user      IN VARCHAR2, apply_queue_table       IN VARCHAR2, apply_queue_name        IN VARCHAR2, apply_queue_user        IN VARCHAR2, capture_name            IN VARCHAR2, propagation_name        IN VARCHAR2, apply_name              IN VARCHAR2, bi_directional          IN BOOLEAN, include_ddl             IN BOOLEAN, start_processes         IN BOOLEAN, exclude_schemas         IN VARCHAR2, exclude_flags           IN BINARY_INTEGER);
	TBD
PROCESS_SQL_REC
Undocumented	dbms_streams_mt.process_sql_rec( rec           IN     sys.dbms_streams_mt.sql_rec, execute_stmt  IN     BOOLEAN, write_to_file IN     BOOLEAN, script_id     IN     RAW, outfile       IN OUT sys.util_file.file_type);
	TBD
PROCESS_SQL_SCRIPT
Undocumented	dbms_streams_mt.process_sql_script(script IN OUT sys.dbms_steams_mt.script_t);
	TBD
PROPAGATION_SETUP
Undocumented	dbms_streams_mt.propagation_setup( maintain_mode          IN     VARCHAR2, canon_propagation_name IN     VARCHAR2, canon_source_db        IN     VARCHAR2, canon_dest_db          IN     VARCHAR2, canon_source_qown      IN     VARCHAR2, canon_source_qname     IN     VARCHAR2, canon_dest_qown        IN     VARCHAR2, canon_dest_qname       IN     VARCHAR2, table_objects          IN     sys.dbms_streams_mt.table_object_set, schema_objects         IN     sys.dbms_streams_mt.schema_object_set, exclude_tag            IN     BOOLEAN, canon_apply_name       IN     VARCHAR2, dblink                 IN     VARCHAR2, include_ddl            IN     BOOLEAN, script                 IN OUT sys.dbms_steams_mt.script_t);
	TBD
QUEUE_SETUP
Undocumented	dbms_streams_mt.queue_setup( canon_qtown  IN     VARCHAR2, canon_qtname IN     VARCHAR2, canon_qown   IN     VARCHAR2, canon_qname  IN     VARCHAR2, canon_quser  IN     VARCHAR2, dblink       IN     VARCHAR2, script       IN OUT sys.dbms_streams_mt.script_t);
	TBD
RECOVER_OPERATION
Undocumented	dbms_streams_mt.recover_operation( oid            IN RAW, operation_mode IN VARCHAR2);
	TBD
REMOTE_STATE_BLOCK
Undocumented	dbms_streams_mt.remote_state_block(oid IN RAW) RETURN CLOB;
	TBD
REMOVE_RULE_RULESET_SETUP
Undocumented	dbms_streams_mt.remove_rule_ruleset_setup( canon_ruleset_name IN     VARCHAR2, canon_rule_name    IN     VARCHAR2, script             IN OUT sys.dbms_steams_mt.script_t);
	TBD
SETUP_REMOTE_SESSION_STATE
Undocumented	dbms_streams_mt.setup_remote_session_state( script_id IN RAW, crash_pt  IN NUMBER);
	TBD
SET_CRASH_COUNTER
Undocumented	dbms_streams_mt.set_crash_counter(crash_counter IN NUMBER);
	exec dbms_streams_mt.set_crash_counter(42); PL/SQL procedure successfully completed.
SET_CRASH_POINT
Undocumented	dbms_streams_mt.set_crash_point(crash_point IN NUMBER);
	exec dbms_streams_mt.set_crash_point(99); PL/SQL procedure successfully completed.
SET_INSTANTIATION_SCN
Undocumented	dbms_streams_mt.set_instantiation_scn( table_objects IN     sys.dbms_streams_mt.table_object_set, canon_from_db IN     VARCHAR2, canon_to_db   IN     VARCHAR2, dblink        IN     VARCHAR2, script        IN OUT sys.dbms_steams_mt.script_t);
	TBD
SET_SETUP_STREAMS
Undocumented	dbms_streams_mt.set_setup_streams(setup_streams IN BOOLEAN);
	exec dbms_streams_mt.set_setup_streams(TRUE); PL/SQL procedure successfully completed.
SET_SRC_DB
Undocumented	dbms_streams_mt.set_src_db(canon_db IN VARCHAR2);
	exec dbms_streams_mt.set_src_db('ORABASE21'); PL/SQL procedure successfully completed.
SET_TARGET_DB
Undocumented	dbms_streams_mt.set_target_db(canon_db IN VARCHAR2);
	exec dbms_streams_mt.set_target_db('ORABASE23'); PL/SQL procedure successfully completed.
START_APPLY
Undocumented	dbms_streams_mt.start_apply( canon_apply_name    IN     VARCHAR2, canon_apply_from_db IN     VARCHAR2, dblink              IN     VARCHAR2, script              IN OUT sys.dbms_steams_mt.script_t);
	TBD
START_CAPTURE
Undocumented	dbms_streams_mt.start_capture( canon_capture_name IN     VARCHAR2, dblink             IN    VARCHAR2, script             IN OUT sys.dbms_steams_mt.script_t);
	TBD
STOP_QUEUE_SETUP
Undocumented	dbms_streams_mt.stop_queue_setup( canon_qown  IN     VARCHAR2, canon_qname IN     VARCHAR2, script      IN OUT sys.dbms_steams_mt.script_t);
	TBD
STOP_STREAMS_PROCESS_SETUP
Undocumented	dbms_streams_mt.stop_streams_process_setup( canon_proc_name IN     VARCHAR2, proc_flag       IN     NUMBER, script          IN OUT sys.dbms_steams_mt.script_t);
	TBD