New Streams Features in 10G
-
Two functions have been added to the dbms_streams
package. They are: get_streams_name and
get_streams_type. These functions return the name and
type, respectively, of a Streams client that is processing an
LCR.
-
The include_extra_attribute procedure in the
dbms_capture_adm package can be used to
instruct a capture process to include certain extra attributes
in LCRs. These attributes are: ROW_ID, SERIAL#, SESSION#,
THREAD#, TX_NAME, and USERNAME.
-
A procedure called get_scn_mapping
has been added to the dbms_streams_adm package. This
procedure gets information about the scn values to use
for Streams capture and apply processes in order to recover
transactions after a point-in-time recovery is performed on a
source database in a multiple source Streams environment.
Streams Based Oracle AQ
In Oracle 10g, the Oracle Advanced Queuing
system has been integrated with Oracle Streams. The original
Oracle Advanced Queuing system has been renamed as Oracle
Streams AQ (AQ). The new Streams AQ provides message queuing
functionality which is fully integrated into the database
system. It is built on top of Oracle Streams and leverages the
functions of the Oracle Database so that messages can be stored
persistently, propagated between queues on different computers
and databases, and transmitted using Oracle Net Services and
HTTP(S).
Since the AQ is fully integrated, it has
the benefit of high availability, scalability, and reliability
that are applicable to the regular database system. Usual
database features like recovery, security, and access control
are automatically available to the AQ. It is a significant
development from the Oracle’s commitment point of view. The
integration of AQ into Streams and the use of queuing for
replication simplify queuing, and each approach compliments the
other. This integration is a good step in the direction of
providing a comprehensive data management practice. Oracle’s
future product development efforts will likely be designed to
benefit both the Streams and AQ options.
