Oracle DBMS_STREAMS_MT
Version 21c

612-476-5707 / 952-595-5916
General Information
Library Note Morgan's Library Page Header
Which has the higher priority in your organization: Deploying a new database or securing the ones you already have? Looking for a website, and resources, dedicated solely to securing Oracle databases? Check out DBSecWorx.
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
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

Related Topics
Built-in Functions
Built-in Packages
Database Security
DBMS_CAPTURE_ADM
DBMS_PROPAGATION_ADM
DBMS_RECOVERABLE_SCRIPT
DBMS_STREAMS
DBMS_STREAMS_ADM
DBMS_STREAMS_ADM_IVK
DBMS_STREAMS_ADM_UTIL_INT
DBMS_STREAMS_ADM_UTIL_INVOK
DBMS_STREAMS_AUTH
DBMS_STREAMS_CONTROL_ADM
DBMS_STREAMS_PUB_RPC
DBMS_STREAMS_RPC_INTERNAL
DBMS_STREAMS_TABLESPACE_ADM
What's New In 19c
What's New In 20c-21c

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-2021 Daniel A. Morgan All Rights Reserved
  DBSecWorx