org.jumpmind.symmetric.model

Class Trigger

java.lang.Object

org.jumpmind.symmetric.model.Trigger

All Implemented Interfaces:

java.io.Serializable

public class Trigger
extends java.lang.Object
implements java.io.Serializable

Defines the trigger via which a table will be synchronized.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
Trigger()
Trigger(java.lang.String tableName, java.lang.String channelId)
Trigger(java.lang.String tableName, java.lang.String channelId, boolean syncOnIncomingBatch)

Method Summary

Modifier and Type	Method and Description
boolean	equals(java.lang.Object obj)
org.jumpmind.db.model.Column[]	filterExcludedAndIncludedColumns(org.jumpmind.db.model.Column[] src)
org.jumpmind.db.model.Column[]	filterExcludedColumns(org.jumpmind.db.model.Column[] src)
org.jumpmind.db.model.Column[]	filterIncludedColumns(org.jumpmind.db.model.Column[] src)
java.lang.String	getChannelExpression()
java.lang.String	getChannelId()
java.util.Date	getCreateTime()
java.lang.String	getCustomBeforeDeleteText()
java.lang.String	getCustomBeforeInsertText()
java.lang.String	getCustomBeforeUpdateText()
java.lang.String	getCustomOnDeleteText()
java.lang.String	getCustomOnInsertText()
java.lang.String	getCustomOnUpdateText()
java.lang.String	getExcludedColumnNames()
java.lang.String	getExternalSelect()
java.lang.String	getFullyQualifiedSourceTableName()
java.lang.String	getIncludedColumnNames()
java.lang.String	getLastUpdateBy()
java.util.Date	getLastUpdateTime()
java.lang.String	getNameForDeleteTrigger()
java.lang.String	getNameForInsertTrigger()
java.lang.String	getNameForUpdateTrigger()
java.lang.String	getReloadChannelId()
java.lang.String	getSourceCatalogName()
java.lang.String	getSourceCatalogNameUnescaped()
java.lang.String	getSourceSchemaName()
java.lang.String	getSourceSchemaNameUnescaped()
java.lang.String	getSourceTableName()
java.lang.String	getSourceTableNameLowerCase()
java.lang.String	getSourceTableNameUnescaped()
java.lang.String	getSyncKeyNames()
org.jumpmind.db.model.Column[]	getSyncKeysColumnsForTable(org.jumpmind.db.model.Table table)
java.lang.String	getSyncOnDeleteCondition()
java.lang.String	getSyncOnInsertCondition()
java.lang.String	getSyncOnUpdateCondition()
java.lang.String	getTriggerId()
java.lang.String	getTxIdExpression()
boolean	hasChangedSinceLastTriggerBuild(java.util.Date lastTriggerBuildTime)
int	hashCode()
boolean	isSourceCatalogNameWildCarded()
boolean	isSourceSchemaNameWildCarded()
boolean	isSourceTableNameWildCarded()
boolean	isSourceWildCarded()
boolean	isStreamRow()
boolean	isSyncOnDelete()
boolean	isSyncOnIncomingBatch()
boolean	isSyncOnInsert()
boolean	isSyncOnUpdate()
boolean	isUseCaptureLobs()
boolean	isUseCaptureOldData()
boolean	isUseHandleKeyUpdates()
boolean	isUseStreamLobs()
protected boolean	matches(java.lang.String match, java.lang.String target, boolean ignoreCase)
boolean	matches(org.jumpmind.db.model.Table table, java.lang.String defaultCatalog, java.lang.String defaultSchema, boolean ignoreCase)
boolean	matches(Trigger trigger)
boolean	matchesCatalogName(java.lang.String catalogName, boolean ignoreCase)
boolean	matchesSchemaName(java.lang.String schemaName, boolean ignoreCase)
void	nullOutBlankFields()
org.jumpmind.db.model.Column[]	orderColumnsForTable(org.jumpmind.db.model.Table table) When dealing with columns, always use this method to order the columns so that the primary keys are first.
java.lang.String	qualifiedSourceTableName()
java.lang.String	qualifiedSourceTablePrefix()
void	setChannelExpression(java.lang.String channelExpression)
void	setChannelId(java.lang.String channelId)
void	setCreateTime(java.util.Date createdOn)
void	setCustomBeforeDeleteText(java.lang.String customBeforeDeleteText)
void	setCustomBeforeInsertText(java.lang.String customBeforeInsertText)
void	setCustomBeforeUpdateText(java.lang.String customBeforeUpdateText)
void	setCustomOnDeleteText(java.lang.String customOnDeleteText)
void	setCustomOnInsertText(java.lang.String customOnInsertText)
void	setCustomOnUpdateText(java.lang.String customOnUpdateText)
void	setExcludedColumnNames(java.lang.String excludedColumnNames)
void	setExternalSelect(java.lang.String externalSelect)
void	setIncludedColumnNames(java.lang.String includedColumnNames)
void	setLastUpdateBy(java.lang.String updatedBy)
void	setLastUpdateTime(java.util.Date lastModifiedOn)
void	setNameForDeleteTrigger(java.lang.String nameForDeleteTrigger)
void	setNameForInsertTrigger(java.lang.String nameForInsertTrigger)
void	setNameForUpdateTrigger(java.lang.String nameForUpdateTrigger)
void	setReloadChannelId(java.lang.String reloadChannelId)
void	setSourceCatalogName(java.lang.String sourceCatalogName)
void	setSourceSchemaName(java.lang.String sourceSchemaName)
void	setSourceTableName(java.lang.String sourceTableName)
void	setStreamRow(boolean streamRow)
void	setSyncKeyNames(java.lang.String syncKeys)
void	setSyncOnDelete(boolean syncOnDelete)
void	setSyncOnDeleteCondition(java.lang.String syncOnDeleteCondition)
void	setSyncOnIncomingBatch(boolean syncOnIncomingBatch)
void	setSyncOnInsert(boolean syncOnInsert)
void	setSyncOnInsertCondition(java.lang.String syncOnInsertCondition)
void	setSyncOnUpdate(boolean syncOnUpdate)
void	setSyncOnUpdateCondition(java.lang.String syncOnUpdateCondition)
void	setTriggerId(java.lang.String triggerId)
void	setTxIdExpression(java.lang.String txIdExpression)
void	setUseCaptureLobs(boolean useCaptureLobs)
void	setUseCaptureOldData(boolean useCaptureOldData)
void	setUseHandleKeyUpdates(boolean useHandleKeyUpdates)
void	setUseStreamLobs(boolean useStreamLobs)
long	toHashedValue()
java.lang.String	toString()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

Trigger

public Trigger()

Trigger

public Trigger(java.lang.String tableName,
               java.lang.String channelId)

Trigger

public Trigger(java.lang.String tableName,
               java.lang.String channelId,
               boolean syncOnIncomingBatch)

Method Detail

qualifiedSourceTableName

public final java.lang.String qualifiedSourceTableName()

qualifiedSourceTablePrefix

public final java.lang.String qualifiedSourceTablePrefix()

nullOutBlankFields

public void nullOutBlankFields()

filterExcludedAndIncludedColumns

public org.jumpmind.db.model.Column[] filterExcludedAndIncludedColumns(org.jumpmind.db.model.Column[] src)

filterExcludedColumns

public org.jumpmind.db.model.Column[] filterExcludedColumns(org.jumpmind.db.model.Column[] src)

filterIncludedColumns

public org.jumpmind.db.model.Column[] filterIncludedColumns(org.jumpmind.db.model.Column[] src)

getSyncKeysColumnsForTable

public org.jumpmind.db.model.Column[] getSyncKeysColumnsForTable(org.jumpmind.db.model.Table table)

orderColumnsForTable

public org.jumpmind.db.model.Column[] orderColumnsForTable(org.jumpmind.db.model.Table table)

When dealing with columns, always use this method to order the columns so that the primary keys are first.

hasChangedSinceLastTriggerBuild

public boolean hasChangedSinceLastTriggerBuild(java.util.Date lastTriggerBuildTime)

getTriggerId

public java.lang.String getTriggerId()

setTriggerId

public void setTriggerId(java.lang.String triggerId)

getSourceTableName

public java.lang.String getSourceTableName()

getSourceTableNameLowerCase

public java.lang.String getSourceTableNameLowerCase()

getSourceTableNameUnescaped

public java.lang.String getSourceTableNameUnescaped()

isSourceWildCarded

public boolean isSourceWildCarded()

isSourceTableNameWildCarded

public boolean isSourceTableNameWildCarded()

isSourceCatalogNameWildCarded

public boolean isSourceCatalogNameWildCarded()

isSourceSchemaNameWildCarded

public boolean isSourceSchemaNameWildCarded()

getChannelExpression

public java.lang.String getChannelExpression()

setChannelExpression

public void setChannelExpression(java.lang.String channelExpression)

setSourceTableName

public void setSourceTableName(java.lang.String sourceTableName)

getSourceSchemaName

public java.lang.String getSourceSchemaName()

getSourceSchemaNameUnescaped

public java.lang.String getSourceSchemaNameUnescaped()

setSourceSchemaName

public void setSourceSchemaName(java.lang.String sourceSchemaName)

getSourceCatalogName

public java.lang.String getSourceCatalogName()

getSourceCatalogNameUnescaped

public java.lang.String getSourceCatalogNameUnescaped()

setSourceCatalogName

public void setSourceCatalogName(java.lang.String sourceCatalogName)

getChannelId

public java.lang.String getChannelId()

setChannelId

public void setChannelId(java.lang.String channelId)

getReloadChannelId

public java.lang.String getReloadChannelId()

setReloadChannelId

public void setReloadChannelId(java.lang.String reloadChannelId)

isSyncOnUpdate

public boolean isSyncOnUpdate()

setSyncOnUpdate

public void setSyncOnUpdate(boolean syncOnUpdate)

isSyncOnInsert

public boolean isSyncOnInsert()

setSyncOnInsert

public void setSyncOnInsert(boolean syncOnInsert)

isSyncOnDelete

public boolean isSyncOnDelete()

setSyncOnDelete

public void setSyncOnDelete(boolean syncOnDelete)

isSyncOnIncomingBatch

public boolean isSyncOnIncomingBatch()

setSyncOnIncomingBatch

public void setSyncOnIncomingBatch(boolean syncOnIncomingBatch)

getNameForInsertTrigger

public java.lang.String getNameForInsertTrigger()

setNameForInsertTrigger

public void setNameForInsertTrigger(java.lang.String nameForInsertTrigger)

getNameForUpdateTrigger

public java.lang.String getNameForUpdateTrigger()

setNameForUpdateTrigger

public void setNameForUpdateTrigger(java.lang.String nameForUpdateTrigger)

getNameForDeleteTrigger

public java.lang.String getNameForDeleteTrigger()

setNameForDeleteTrigger

public void setNameForDeleteTrigger(java.lang.String nameForDeleteTrigger)

getSyncOnUpdateCondition

public java.lang.String getSyncOnUpdateCondition()

setSyncOnUpdateCondition

public void setSyncOnUpdateCondition(java.lang.String syncOnUpdateCondition)

getSyncOnInsertCondition

public java.lang.String getSyncOnInsertCondition()

setSyncOnInsertCondition

public void setSyncOnInsertCondition(java.lang.String syncOnInsertCondition)

getSyncOnDeleteCondition

public java.lang.String getSyncOnDeleteCondition()

setSyncOnDeleteCondition

public void setSyncOnDeleteCondition(java.lang.String syncOnDeleteCondition)

getCustomBeforeUpdateText

public java.lang.String getCustomBeforeUpdateText()

setCustomBeforeUpdateText

public void setCustomBeforeUpdateText(java.lang.String customBeforeUpdateText)

getCustomBeforeInsertText

public java.lang.String getCustomBeforeInsertText()

setCustomBeforeInsertText

public void setCustomBeforeInsertText(java.lang.String customBeforeInsertText)

getCustomBeforeDeleteText

public java.lang.String getCustomBeforeDeleteText()

setCustomBeforeDeleteText

public void setCustomBeforeDeleteText(java.lang.String customBeforeDeleteText)

getCustomOnUpdateText

public java.lang.String getCustomOnUpdateText()

setCustomOnUpdateText

public void setCustomOnUpdateText(java.lang.String customOnUpdateText)

getCustomOnInsertText

public java.lang.String getCustomOnInsertText()

setCustomOnInsertText

public void setCustomOnInsertText(java.lang.String customOnInsertText)

getCustomOnDeleteText

public java.lang.String getCustomOnDeleteText()

setCustomOnDeleteText

public void setCustomOnDeleteText(java.lang.String customOnDeleteText)

getExcludedColumnNames

public java.lang.String getExcludedColumnNames()

setExcludedColumnNames

public void setExcludedColumnNames(java.lang.String excludedColumnNames)

getIncludedColumnNames

public java.lang.String getIncludedColumnNames()

setIncludedColumnNames

public void setIncludedColumnNames(java.lang.String includedColumnNames)

getTxIdExpression

public java.lang.String getTxIdExpression()

setTxIdExpression

public void setTxIdExpression(java.lang.String txIdExpression)

getExternalSelect

public java.lang.String getExternalSelect()

setExternalSelect

public void setExternalSelect(java.lang.String externalSelect)

setLastUpdateBy

public void setLastUpdateBy(java.lang.String updatedBy)

getLastUpdateBy

public java.lang.String getLastUpdateBy()

getLastUpdateTime

public java.util.Date getLastUpdateTime()

setLastUpdateTime

public void setLastUpdateTime(java.util.Date lastModifiedOn)

getCreateTime

public java.util.Date getCreateTime()

setCreateTime

public void setCreateTime(java.util.Date createdOn)

setUseStreamLobs

public void setUseStreamLobs(boolean useStreamLobs)

isUseStreamLobs

public boolean isUseStreamLobs()

setUseCaptureLobs

public void setUseCaptureLobs(boolean useCaptureLobs)

isUseCaptureLobs

public boolean isUseCaptureLobs()

isUseHandleKeyUpdates

public boolean isUseHandleKeyUpdates()

setUseHandleKeyUpdates

public void setUseHandleKeyUpdates(boolean useHandleKeyUpdates)

setUseCaptureOldData

public void setUseCaptureOldData(boolean useCaptureOldData)

isUseCaptureOldData

public boolean isUseCaptureOldData()

setSyncKeyNames

public void setSyncKeyNames(java.lang.String syncKeys)

getSyncKeyNames

public java.lang.String getSyncKeyNames()

isStreamRow

public boolean isStreamRow()

setStreamRow

public void setStreamRow(boolean streamRow)

getFullyQualifiedSourceTableName

public java.lang.String getFullyQualifiedSourceTableName()

toHashedValue

public long toHashedValue()

matchesCatalogName

public boolean matchesCatalogName(java.lang.String catalogName,
                                  boolean ignoreCase)

matchesSchemaName

public boolean matchesSchemaName(java.lang.String schemaName,
                                 boolean ignoreCase)

matches

protected boolean matches(java.lang.String match,
                          java.lang.String target,
                          boolean ignoreCase)

matches

public boolean matches(org.jumpmind.db.model.Table table,
                       java.lang.String defaultCatalog,
                       java.lang.String defaultSchema,
                       boolean ignoreCase)

matches

public boolean matches(Trigger trigger)

equals

public boolean equals(java.lang.Object obj)

Overrides:

equals in class java.lang.Object

hashCode

public int hashCode()

Overrides:

hashCode in class java.lang.Object

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object