public abstract class AbstractLCR extends java.lang.Object implements LCR
ATTRIBUTE_ROOT_NAME, ATTRIBUTE_ROW_ID, ATTRIBUTE_SERIAL_NUM, ATTRIBUTE_SESSION_NUM, ATTRIBUTE_THREAD_NUM, ATTRIBUTE_TX_NAME, ATTRIBUTE_USERNAME
Constructor and Description |
---|
AbstractLCR() |
Modifier and Type | Method and Description |
---|---|
java.lang.Object |
getAttribute(java.lang.Object attributeName)
Gets the attribute by specifying the attribute name.
|
java.lang.Object |
getAttributeName(int index)
Gets the attribute name in the LCR attributes list by position.
|
java.lang.Object[] |
getAttributesList()
Gets the list of attribute name and value pairs in the LCR.
|
java.lang.Object |
getAttributeValue(int index)
Gets the attribute value in the LCR attributes list by position.
|
java.lang.String |
getCommandType()
Gets the LCR command type executed in the DML or DDL statement.
|
oracle.sql.NUMBER |
getCommitSCN()
Gets the LCR commit system change number (SCN) in the format of oracle.sql.NUMBER.
|
java.lang.String |
getMessageTrackingLabel()
Gets the message tracking label of the LCR.
|
int |
getNumAttributes()
Gets the total number of attributes in the LCR.
|
java.lang.String |
getObjectName()
Gets the name of the object that is changed by the LCR.
|
java.lang.String |
getObjectOwner()
Gets the owner of the object that is changed by the LCR.
|
byte[] |
getPosition()
Gets the position of the current LCR.
|
java.lang.String |
getRootName()
Gets the root name of the LCR.
|
oracle.sql.NUMBER |
getSCN()
Gets the SCN of the current LCR in the format of oracle.sql.NUMBER.
|
java.lang.String |
getSourceDatabaseName()
Gets the global name of the source database.
|
oracle.sql.DATE |
getSourceTime()
Gets the time when the LCR was created.
|
byte[] |
getTag()
Gets the tag for the LCR.
|
java.lang.String |
getTransactionId()
Gets the transaction identifier of the LCR.
|
void |
setAttribute(java.lang.Object attributeName, java.lang.Object attributeValue)
Sets attribute by providing the name and value pair; the name is used as the hash key.
|
void |
setCommandType(java.lang.String commandType)
Sets the command type in the LCR.
|
void |
setMessageTrackingLabel(java.lang.String messageTrackingLabel)
Sets the message tracking label of the LCR.
|
void |
setObjectName(java.lang.String objectName)
Sets the name of the object that is changed by the LCR.
|
void |
setObjectOwner(java.lang.String objectOwner)
Sets the owner of the object that is changed by the LCR .
|
void |
setPosition(byte[] position)
Sets the position in the LCR.
|
void |
setRootName(java.lang.String rootName)
Sets the root name of the LCR.
|
void |
setSourceDatabaseName(java.lang.String name)
Sets the source database name of the object that is changed by the LCR.
|
void |
setSourceTime(oracle.sql.DATE sourceTime)
Sets the source timestamp when the LCR was created.
|
void |
setTag(byte[] tag)
Sets the LCR tag information.
|
void |
setTransactionId(java.lang.String transactionId)
Sets the transaction identifier for the LCR.
|
public void setSourceDatabaseName(java.lang.String name)
setSourceDatabaseName
in interface LCR
name
- The source database name in String format. Set this parameter to a non-NULL value.public void setCommandType(java.lang.String commandType)
setCommandType
in interface LCR
commandType
- The command type of an LCR. Set this parameter to a non-NULL value.public void setObjectOwner(java.lang.String objectOwner)
setObjectOwner
in interface LCR
objectOwner
- The object owner. Set this parameter to a non-NULL value.public void setObjectName(java.lang.String objectName)
setObjectName
in interface LCR
objectName
- The name of the database object. Set this parameter to a non-NULL value.public void setTag(byte[] tag)
public void setPosition(byte[] position)
setPosition
in interface LCR
position
- A byte array that represents the LCR position. Set this parameter to a non-NULL value and ensure that the position is byte comparable and is strictly increasing.public void setTransactionId(java.lang.String transactionId)
setTransactionId
in interface LCR
transactionId
- The identifier of the transactionpublic void setSourceTime(oracle.sql.DATE sourceTime)
setSourceTime
in interface LCR
sourceTime
- The srouce time in the form of oracle.sql.DATEpublic void setAttribute(java.lang.Object attributeName, java.lang.Object attributeValue)
setAttribute
in interface LCR
attributeName
- The name of the attributeattributeValue
- The value of the attributepublic void setMessageTrackingLabel(java.lang.String messageTrackingLabel) throws StreamsException
messageTrackingLabel
- The message tracking labelStreamsException
- If error occurs when obtaining message tracking labelpublic java.lang.String getSourceDatabaseName()
getSourceDatabaseName
in interface LCR
public java.lang.String getCommandType()
getCommandType
in interface LCR
public java.lang.String getObjectOwner()
getObjectOwner
in interface LCR
public java.lang.String getObjectName()
getObjectName
in interface LCR
public byte[] getTag()
public byte[] getPosition()
getPosition
in interface LCR
public java.lang.String getTransactionId()
getTransactionId
in interface LCR
public oracle.sql.DATE getSourceTime()
getSourceTime
in interface LCR
public java.lang.Object getAttribute(java.lang.Object attributeName)
getAttribute
in interface LCR
attributeName
- The attribute namepublic oracle.sql.NUMBER getSCN()
public oracle.sql.NUMBER getCommitSCN()
public int getNumAttributes()
public java.lang.Object[] getAttributesList()
public java.lang.Object getAttributeName(int index)
index
- The atribute name's index.public java.lang.Object getAttributeValue(int index)
index
- The atribute name's index.public java.lang.String getMessageTrackingLabel() throws StreamsException
StreamsException
- If error occurs when obtaining message tracking labelpublic java.lang.String getRootName() throws StreamsException
StreamsException
- If error occurs when obtaining root name.public void setRootName(java.lang.String rootName) throws StreamsException
rootName
- The message tracking labelStreamsException
- If error occurs when obtaining message tracking label