org.jumpmind.symmetric.db
Class AbstractEmbeddedTrigger

java.lang.Object
  org.jumpmind.symmetric.db.AbstractEmbeddedTrigger

Direct Known Subclasses:

HsqlDbTrigger

public abstract class AbstractEmbeddedTrigger
extends java.lang.Object

This class implements the functionality needed by (most) java-based symmetric triggers.

Field Summary

protected IBootstrapService	bootstrapService
protected IConfigurationService	configurationService
protected IDataService	dataService
protected static org.apache.commons.lang.time.FastDateFormat	dateFormatter
protected IDbDialect	dbDialect
protected java.util.Set<java.lang.String>	excludedColumns
protected java.util.List<java.lang.String>	includedColumns
protected static org.apache.commons.logging.Log	logger
protected INodeService	nodeService
protected org.apache.ddlutils.model.Table	table
protected java.lang.String	tableName
protected Trigger	trigger
protected TriggerHistory	triggerHistory
protected DataEventType	triggerType

Constructor Summary

AbstractEmbeddedTrigger()

Method Summary

protected Data	createData(java.lang.Object[] oldRow, java.lang.Object[] newRow)
protected java.lang.String	formatAsCsv(java.lang.Object[] data)
protected java.lang.String	formatPkRowData(java.lang.Object[] oldRow, java.lang.Object[] newRow)
protected java.lang.String	formatRowData(java.lang.Object[] oldRow, java.lang.Object[] newRow)
protected abstract java.lang.String	getEngineName()
protected java.lang.Object[]	getOrderedColumnValues(java.lang.Object[] allValues)
protected java.lang.Object[]	getPrimaryKeys(java.lang.Object[] allValues)
protected abstract java.lang.String	getTransactionId(java.lang.Object[] oldRow, java.lang.Object[] newRow)
protected abstract int	getTriggerHistId()
protected boolean	initialize(DataEventType triggerType, java.lang.String tableName)

Methods inherited from class java.lang.Object

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

Field Detail

logger

protected static final org.apache.commons.logging.Log logger

dateFormatter

protected static final org.apache.commons.lang.time.FastDateFormat dateFormatter

dataService

protected IDataService dataService

configurationService

protected IConfigurationService configurationService

bootstrapService

protected IBootstrapService bootstrapService

nodeService

protected INodeService nodeService

dbDialect

protected IDbDialect dbDialect

table

protected org.apache.ddlutils.model.Table table

triggerHistory

protected TriggerHistory triggerHistory

trigger

protected Trigger trigger

triggerType

protected DataEventType triggerType

tableName

protected java.lang.String tableName

excludedColumns

protected java.util.Set<java.lang.String> excludedColumns

includedColumns

protected java.util.List<java.lang.String> includedColumns

Constructor Detail

AbstractEmbeddedTrigger

public AbstractEmbeddedTrigger()

Method Detail

initialize

protected boolean initialize(DataEventType triggerType,
                             java.lang.String tableName)

getEngineName

protected abstract java.lang.String getEngineName()

getTriggerHistId

protected abstract int getTriggerHistId()

getTransactionId

protected abstract java.lang.String getTransactionId(java.lang.Object[] oldRow,
                                                     java.lang.Object[] newRow)

formatRowData

protected java.lang.String formatRowData(java.lang.Object[] oldRow,
                                         java.lang.Object[] newRow)

formatPkRowData

protected java.lang.String formatPkRowData(java.lang.Object[] oldRow,
                                           java.lang.Object[] newRow)

formatAsCsv

protected java.lang.String formatAsCsv(java.lang.Object[] data)

createData

protected Data createData(java.lang.Object[] oldRow,
                          java.lang.Object[] newRow)

getPrimaryKeys

protected java.lang.Object[] getPrimaryKeys(java.lang.Object[] allValues)

getOrderedColumnValues

protected java.lang.Object[] getOrderedColumnValues(java.lang.Object[] allValues)