com.continuent.tungsten.replicator.extractor.oracle
Class OracleCommunicator

java.lang.Object
  com.continuent.tungsten.replicator.extractor.oracle.OracleCommunicator

public class OracleCommunicator
extends java.lang.Object

This class defines a OracleCommunicator. This is the interface to the Oracle redo log extractor.

Version:

1.0

Author:

Scott Martin, Stephane Giron

Constructor Summary

OracleCommunicator(java.lang.String hostName, java.lang.String instanceName, int portNumber)
Creates a new OracleCommunicator object

Method Summary

void	connect(java.lang.String userName, java.lang.String password, java.lang.String scn, boolean rowLevel, java.lang.String seq) Connect to the c based dslisten process
void	disconnect() Disconnect from dslisten
java.lang.String	getSQL() Send a getSQL message to dslisten and wait for the result
void	getStatus() Send a getStatus message to dslisten
void	setParameter(java.lang.String parameter, java.lang.String value) Send a set parameter message to dslisten
void	stop() Send stop message to dslisten.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

OracleCommunicator

public OracleCommunicator(java.lang.String hostName,
                          java.lang.String instanceName,
                          int portNumber)

Creates a new OracleCommunicator object

Parameters:

hostName - Name of the host to log into

instanceName - Value of the ORACLE_SID of the instance to connect to

portNumber - Port number of the dslisten process typically 51060

Method Detail

connect

public void connect(java.lang.String userName,
                    java.lang.String password,
                    java.lang.String scn,
                    boolean rowLevel,
                    java.lang.String seq)
             throws ExtractorException

Connect to the c based dslisten process

Parameters:

userName - Oracle username dslisten uses to connect to Oracle

password - Oracle password dslisten uses to connect to Oracle

scn - Starting system commit number to extract from

rowLevel - TRUE IFF performing row level extraction else performing statement level extraction

Throws:

ExtractorException

disconnect

public void disconnect()
                throws ExtractorException

Disconnect from dslisten

Throws:

ExtractorException

stop

public void stop()
          throws ExtractorException

Send stop message to dslisten.

Throws:

ExtractorException

setParameter

public void setParameter(java.lang.String parameter,
                         java.lang.String value)
                  throws ExtractorException

Send a set parameter message to dslisten

Parameters:

parameter - Name of the parameter to set

value - Value of the parameter

Throws:

ExtractorException

getStatus

public void getStatus()
               throws ExtractorException

Send a getStatus message to dslisten

Throws:

ExtractorException

getSQL

public java.lang.String getSQL()
                        throws java.lang.InterruptedException,
                               ExtractorException

Send a getSQL message to dslisten and wait for the result

Returns:

a string containing SQL statement

Throws:

ExtractorException

java.lang.InterruptedException