org.jumpmind.symmetric.db

Class AbstractTriggerTemplate

java.lang.Object

org.jumpmind.symmetric.db.AbstractTriggerTemplate

Direct Known Subclasses:

SqliteTriggerTemplate

public abstract class AbstractTriggerTemplate
extends java.lang.Object

Responsible for generating dialect specific SQL such as trigger bodies and functions

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected static class	AbstractTriggerTemplate.ColumnString

Field Summary

Fields

Modifier and Type	Field and Description
protected java.lang.String	arrayColumnTemplate
protected java.lang.String	binaryColumnTemplate
protected java.lang.String	blobColumnTemplate
protected java.lang.String	booleanColumnTemplate
protected java.lang.String	clobColumnTemplate
protected java.lang.String	dateColumnTemplate
protected java.lang.String	datetimeColumnTemplate
protected java.lang.String	dateTimeWithLocalTimeZoneColumnTemplate
protected java.lang.String	dateTimeWithTimeZoneColumnTemplate
protected java.lang.String	emptyColumnTemplate
protected java.lang.String	geographyColumnTemplate
protected java.lang.String	geometryColumnTemplate
protected java.lang.String	imageColumnTemplate
protected org.slf4j.Logger	log
protected java.lang.String	longColumnTemplate
protected java.lang.String	newColumnPrefix
protected java.lang.String	newTriggerValue
protected java.lang.String	numberColumnTemplate
protected java.lang.String	oldColumnPrefix
protected java.lang.String	oldTriggerValue
protected static java.lang.String	ORIG_TABLE_ALIAS
protected java.lang.String	otherColumnTemplate
protected java.util.Map<java.lang.String,java.lang.String>	sqlTemplates
protected java.lang.String	stringColumnTemplate
protected ISymmetricDialect	symmetricDialect
protected java.lang.String	timeColumnTemplate
protected java.lang.String	triggerConcatCharacter
protected java.lang.String	wrappedBlobColumnTemplate
protected java.lang.String	xmlColumnTemplate

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	AbstractTriggerTemplate(ISymmetricDialect symmetricDialect)

Method Summary

Modifier and Type	Method and Description
protected java.lang.String	aliasedPrimaryKeyJoin(java.lang.String aliasOne, java.lang.String aliasTwo, org.jumpmind.db.model.Column[] columns)
protected java.lang.String	aliasedPrimaryKeyJoinVar(java.lang.String alias, java.lang.String prefix, org.jumpmind.db.model.Column[] columns)
protected java.lang.String	buildColumnNameString(java.lang.String tableAlias, boolean quote, Trigger trigger, org.jumpmind.db.model.Column[] columns)
protected AbstractTriggerTemplate.ColumnString	buildColumnsString(java.lang.String origTableAlias, java.lang.String tableAlias, java.lang.String columnPrefix, org.jumpmind.db.model.Table table, org.jumpmind.db.model.Column[] columns, org.jumpmind.symmetric.io.data.DataEventType dml, boolean isOld, Channel channel, Trigger trigger)
protected java.lang.String	buildKeyVariablesDeclare(org.jumpmind.db.model.Column[] columns, java.lang.String prefix)
protected java.lang.String	buildKeyVariablesString(org.jumpmind.db.model.Column[] columns, java.lang.String prefix)
protected java.lang.String	buildVirtualTableSql(java.lang.String oldTriggerValue, java.lang.String newTriggerValue, org.jumpmind.db.model.Column[] columns)
protected java.lang.String	castDatetimeColumnToString(java.lang.String columnName)
java.lang.String	createCsvDataSql(Trigger trigger, TriggerHistory triggerHistory, org.jumpmind.db.model.Table originalTable, Channel channel, java.lang.String whereClause)
java.lang.String	createCsvPrimaryKeySql(Trigger trigger, TriggerHistory triggerHistory, org.jumpmind.db.model.Table table, Channel channel, java.lang.String whereClause)
java.lang.String	createDdlTrigger(java.lang.String tablePrefix, java.lang.String defaultCatalog, java.lang.String defaultSchema, java.lang.String triggerName)
java.lang.String	createInitalLoadSql(Node node, TriggerRouter triggerRouter, org.jumpmind.db.model.Table originalTable, TriggerHistory triggerHistory, Channel channel, java.lang.String overrideSelectSql)
java.lang.String	createPostTriggerDDL(org.jumpmind.symmetric.io.data.DataEventType dml, Trigger trigger, TriggerHistory history, Channel channel, java.lang.String tablePrefix, org.jumpmind.db.model.Table originalTable, java.lang.String defaultCatalog, java.lang.String defaultSchema)
java.lang.String	createTriggerDDL(org.jumpmind.symmetric.io.data.DataEventType dml, Trigger trigger, TriggerHistory history, Channel channel, java.lang.String tablePrefix, org.jumpmind.db.model.Table originalTable, java.lang.String defaultCatalog, java.lang.String defaultSchema)
protected java.lang.String	eval(boolean condition, java.lang.String prop, java.lang.String ddl)
protected AbstractTriggerTemplate.ColumnString	fillOutColumnTemplate(java.lang.String origTableAlias, java.lang.String tableAlias, java.lang.String columnPrefix, org.jumpmind.db.model.Table table, org.jumpmind.db.model.Column column, org.jumpmind.symmetric.io.data.DataEventType dml, boolean isOld, Channel channel, Trigger trigger)
java.lang.String	getBlobColumnTemplate()
protected java.lang.String	getChannelExpression(Trigger trigger, TriggerHistory history, org.jumpmind.db.model.Table originalTable)
java.lang.String	getClobColumnTemplate()
protected java.lang.String	getClobType(org.jumpmind.db.model.Table table)
boolean[]	getColumnPositionUsingTemplate(org.jumpmind.db.model.Table originalTable, TriggerHistory triggerHistory)
protected java.lang.String	getColumnSize(org.jumpmind.db.model.Table table, org.jumpmind.db.model.Column column)
java.lang.String	getDateColumnTemplate()
protected java.lang.String	getDefaultTargetTableName(Trigger trigger, TriggerHistory history)
protected java.lang.String	getHasPrimaryKeysDefinedString(org.jumpmind.db.model.Table table)
java.lang.String	getImageColumnTemplate()
java.lang.String	getNewTriggerValue()
java.lang.String	getOldTriggerValue()
java.lang.String	getOtherColumnTemplate()
protected java.lang.String	getPrimaryKeysUpdatedString(org.jumpmind.db.model.Table table)
protected java.lang.String	getPrimaryKeyWhereString(java.lang.String alias, org.jumpmind.db.model.Column[] columns) Deprecated.
protected java.lang.String	getSourceTablePrefix(org.jumpmind.db.model.Table table)
protected java.lang.String	getSourceTablePrefix(TriggerHistory triggerHistory)
protected java.lang.String	getSourceTableSchema(org.jumpmind.db.model.Table table)
protected java.lang.String	getSourceTableSchema(TriggerHistory triggerHistory)
java.lang.String	getTimeColumnTemplate()
java.lang.String	getWrappedBlobColumnTemplate()
protected boolean	noDateColumnTemplate()
protected boolean	noTimeColumnTemplate()
protected java.lang.String	replaceDefaultCatalog(java.lang.String ddl, java.lang.String defaultCatalog)
protected java.lang.String	replaceDefaultSchema(java.lang.String ddl, java.lang.String defaultSchema)
protected java.lang.String	replaceDefaultSchemaAndCatalog(java.lang.String sql)
java.lang.String	replaceOracleQueryHint(java.lang.String sql)
protected java.lang.String	replaceTemplateVariables(org.jumpmind.symmetric.io.data.DataEventType dml, Trigger trigger, TriggerHistory history, Channel channel, java.lang.String tablePrefix, org.jumpmind.db.model.Table originalTable, org.jumpmind.db.model.Table table, java.lang.String defaultCatalog, java.lang.String defaultSchema, java.lang.String ddl)
protected boolean	requiresEmptyLobTemplateForDeletes()
protected boolean	requiresWrappedBlobTemplateForBlobType()
void	setBooleanColumnTemplate(java.lang.String booleanColumnTemplate)
void	setDateColumnTemplate(java.lang.String dateColumnTemplate)
void	setImageColumnTemplate(java.lang.String imageColumnTemplate)
void	setTimeColumnTemplate(java.lang.String timeColumnTemplate)
protected java.lang.String	toClobExpression(org.jumpmind.db.model.Table table)
int	toHashedValue()
boolean	useTriggerTemplateForColumnTemplatesDuringInitialLoad() When ParameterConstants.INITIAL_LOAD_CONCAT_CSV_IN_SQL_ENABLED is false most dialects are going to want to still use the trigger templates because they have type translation details (like geometry templates).
protected boolean	useTriggerTemplateForColumnTemplatesDuringInitialLoad(org.jumpmind.db.model.Column column) When INITIAL_LOAD_USE_COLUMN_TEMPLATES_ENABLED is true, column templates are used for all columns.

Methods inherited from class java.lang.Object

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

Field Detail

log

protected final org.slf4j.Logger log

ORIG_TABLE_ALIAS

protected static final java.lang.String ORIG_TABLE_ALIAS

See Also:

Constant Field Values

sqlTemplates

protected java.util.Map<java.lang.String,java.lang.String> sqlTemplates

emptyColumnTemplate

protected java.lang.String emptyColumnTemplate

stringColumnTemplate

protected java.lang.String stringColumnTemplate

xmlColumnTemplate

protected java.lang.String xmlColumnTemplate

arrayColumnTemplate

protected java.lang.String arrayColumnTemplate

numberColumnTemplate

protected java.lang.String numberColumnTemplate

datetimeColumnTemplate

protected java.lang.String datetimeColumnTemplate

timeColumnTemplate

protected java.lang.String timeColumnTemplate

dateColumnTemplate

protected java.lang.String dateColumnTemplate

dateTimeWithTimeZoneColumnTemplate

protected java.lang.String dateTimeWithTimeZoneColumnTemplate

dateTimeWithLocalTimeZoneColumnTemplate

protected java.lang.String dateTimeWithLocalTimeZoneColumnTemplate

geometryColumnTemplate

protected java.lang.String geometryColumnTemplate

geographyColumnTemplate

protected java.lang.String geographyColumnTemplate

clobColumnTemplate

protected java.lang.String clobColumnTemplate

blobColumnTemplate

protected java.lang.String blobColumnTemplate

longColumnTemplate

protected java.lang.String longColumnTemplate

binaryColumnTemplate

protected java.lang.String binaryColumnTemplate

imageColumnTemplate

protected java.lang.String imageColumnTemplate

wrappedBlobColumnTemplate

protected java.lang.String wrappedBlobColumnTemplate

booleanColumnTemplate

protected java.lang.String booleanColumnTemplate

triggerConcatCharacter

protected java.lang.String triggerConcatCharacter

newTriggerValue

protected java.lang.String newTriggerValue

oldTriggerValue

protected java.lang.String oldTriggerValue

oldColumnPrefix

protected java.lang.String oldColumnPrefix

newColumnPrefix

protected java.lang.String newColumnPrefix

otherColumnTemplate

protected java.lang.String otherColumnTemplate

symmetricDialect

protected ISymmetricDialect symmetricDialect

Constructor Detail

AbstractTriggerTemplate

protected AbstractTriggerTemplate(ISymmetricDialect symmetricDialect)

Method Detail

useTriggerTemplateForColumnTemplatesDuringInitialLoad

public boolean useTriggerTemplateForColumnTemplatesDuringInitialLoad()

When ParameterConstants.INITIAL_LOAD_CONCAT_CSV_IN_SQL_ENABLED is false most dialects are going to want to still use the trigger templates because they have type translation details (like geometry templates). However, some dialects cannot handle the complex SQL generated (Firebird). We needed a way to tell the dialect that we want to select the columns straight up.

useTriggerTemplateForColumnTemplatesDuringInitialLoad

protected boolean useTriggerTemplateForColumnTemplatesDuringInitialLoad(org.jumpmind.db.model.Column column)

When INITIAL_LOAD_USE_COLUMN_TEMPLATES_ENABLED is true, column templates are used for all columns. When false, only specific column types have been implemented to format data in code.

createInitalLoadSql

public java.lang.String createInitalLoadSql(Node node,
                                            TriggerRouter triggerRouter,
                                            org.jumpmind.db.model.Table originalTable,
                                            TriggerHistory triggerHistory,
                                            Channel channel,
                                            java.lang.String overrideSelectSql)

getColumnPositionUsingTemplate

public boolean[] getColumnPositionUsingTemplate(org.jumpmind.db.model.Table originalTable,
                                                TriggerHistory triggerHistory)

castDatetimeColumnToString

protected java.lang.String castDatetimeColumnToString(java.lang.String columnName)

getSourceTablePrefix

protected java.lang.String getSourceTablePrefix(org.jumpmind.db.model.Table table)

getSourceTableSchema

protected java.lang.String getSourceTableSchema(org.jumpmind.db.model.Table table)

getSourceTablePrefix

protected java.lang.String getSourceTablePrefix(TriggerHistory triggerHistory)

getSourceTableSchema

protected java.lang.String getSourceTableSchema(TriggerHistory triggerHistory)

replaceDefaultSchemaAndCatalog

protected java.lang.String replaceDefaultSchemaAndCatalog(java.lang.String sql)

createCsvDataSql

public java.lang.String createCsvDataSql(Trigger trigger,
                                         TriggerHistory triggerHistory,
                                         org.jumpmind.db.model.Table originalTable,
                                         Channel channel,
                                         java.lang.String whereClause)

createCsvPrimaryKeySql

public java.lang.String createCsvPrimaryKeySql(Trigger trigger,
                                               TriggerHistory triggerHistory,
                                               org.jumpmind.db.model.Table table,
                                               Channel channel,
                                               java.lang.String whereClause)

createTriggerDDL

public java.lang.String createTriggerDDL(org.jumpmind.symmetric.io.data.DataEventType dml,
                                         Trigger trigger,
                                         TriggerHistory history,
                                         Channel channel,
                                         java.lang.String tablePrefix,
                                         org.jumpmind.db.model.Table originalTable,
                                         java.lang.String defaultCatalog,
                                         java.lang.String defaultSchema)

createPostTriggerDDL

public java.lang.String createPostTriggerDDL(org.jumpmind.symmetric.io.data.DataEventType dml,
                                             Trigger trigger,
                                             TriggerHistory history,
                                             Channel channel,
                                             java.lang.String tablePrefix,
                                             org.jumpmind.db.model.Table originalTable,
                                             java.lang.String defaultCatalog,
                                             java.lang.String defaultSchema)

createDdlTrigger

public java.lang.String createDdlTrigger(java.lang.String tablePrefix,
                                         java.lang.String defaultCatalog,
                                         java.lang.String defaultSchema,
                                         java.lang.String triggerName)

getDefaultTargetTableName

protected java.lang.String getDefaultTargetTableName(Trigger trigger,
                                                     TriggerHistory history)

replaceTemplateVariables

protected java.lang.String replaceTemplateVariables(org.jumpmind.symmetric.io.data.DataEventType dml,
                                                    Trigger trigger,
                                                    TriggerHistory history,
                                                    Channel channel,
                                                    java.lang.String tablePrefix,
                                                    org.jumpmind.db.model.Table originalTable,
                                                    org.jumpmind.db.model.Table table,
                                                    java.lang.String defaultCatalog,
                                                    java.lang.String defaultSchema,
                                                    java.lang.String ddl)

toClobExpression

protected java.lang.String toClobExpression(org.jumpmind.db.model.Table table)

getClobType

protected java.lang.String getClobType(org.jumpmind.db.model.Table table)

getChannelExpression

protected java.lang.String getChannelExpression(Trigger trigger,
                                                TriggerHistory history,
                                                org.jumpmind.db.model.Table originalTable)

buildVirtualTableSql

protected java.lang.String buildVirtualTableSql(java.lang.String oldTriggerValue,
                                                java.lang.String newTriggerValue,
                                                org.jumpmind.db.model.Column[] columns)

eval

protected java.lang.String eval(boolean condition,
                                java.lang.String prop,
                                java.lang.String ddl)

aliasedPrimaryKeyJoin

protected java.lang.String aliasedPrimaryKeyJoin(java.lang.String aliasOne,
                                                 java.lang.String aliasTwo,
                                                 org.jumpmind.db.model.Column[] columns)

aliasedPrimaryKeyJoinVar

protected java.lang.String aliasedPrimaryKeyJoinVar(java.lang.String alias,
                                                    java.lang.String prefix,
                                                    org.jumpmind.db.model.Column[] columns)

getPrimaryKeyWhereString

@Deprecated
protected java.lang.String getPrimaryKeyWhereString(java.lang.String alias,
                                                                org.jumpmind.db.model.Column[] columns)

Deprecated.

Specific to Derby. Needs to be removed when the initial load is refactored to concat in Java vs. in SQL

requiresWrappedBlobTemplateForBlobType

protected boolean requiresWrappedBlobTemplateForBlobType()

requiresEmptyLobTemplateForDeletes

protected boolean requiresEmptyLobTemplateForDeletes()

buildColumnNameString

protected java.lang.String buildColumnNameString(java.lang.String tableAlias,
                                                 boolean quote,
                                                 Trigger trigger,
                                                 org.jumpmind.db.model.Column[] columns)

buildColumnsString

protected AbstractTriggerTemplate.ColumnString buildColumnsString(java.lang.String origTableAlias,
                                                                  java.lang.String tableAlias,
                                                                  java.lang.String columnPrefix,
                                                                  org.jumpmind.db.model.Table table,
                                                                  org.jumpmind.db.model.Column[] columns,
                                                                  org.jumpmind.symmetric.io.data.DataEventType dml,
                                                                  boolean isOld,
                                                                  Channel channel,
                                                                  Trigger trigger)

fillOutColumnTemplate

protected AbstractTriggerTemplate.ColumnString fillOutColumnTemplate(java.lang.String origTableAlias,
                                                                     java.lang.String tableAlias,
                                                                     java.lang.String columnPrefix,
                                                                     org.jumpmind.db.model.Table table,
                                                                     org.jumpmind.db.model.Column column,
                                                                     org.jumpmind.symmetric.io.data.DataEventType dml,
                                                                     boolean isOld,
                                                                     Channel channel,
                                                                     Trigger trigger)

getColumnSize

protected java.lang.String getColumnSize(org.jumpmind.db.model.Table table,
                                         org.jumpmind.db.model.Column column)

getOtherColumnTemplate

public java.lang.String getOtherColumnTemplate()

noTimeColumnTemplate

protected boolean noTimeColumnTemplate()

noDateColumnTemplate

protected boolean noDateColumnTemplate()

buildKeyVariablesDeclare

protected java.lang.String buildKeyVariablesDeclare(org.jumpmind.db.model.Column[] columns,
                                                    java.lang.String prefix)

buildKeyVariablesString

protected java.lang.String buildKeyVariablesString(org.jumpmind.db.model.Column[] columns,
                                                   java.lang.String prefix)

getClobColumnTemplate

public java.lang.String getClobColumnTemplate()

setBooleanColumnTemplate

public void setBooleanColumnTemplate(java.lang.String booleanColumnTemplate)

getNewTriggerValue

public java.lang.String getNewTriggerValue()

getOldTriggerValue

public java.lang.String getOldTriggerValue()

getBlobColumnTemplate

public java.lang.String getBlobColumnTemplate()

getWrappedBlobColumnTemplate

public java.lang.String getWrappedBlobColumnTemplate()

replaceDefaultSchema

protected java.lang.String replaceDefaultSchema(java.lang.String ddl,
                                                java.lang.String defaultSchema)

replaceDefaultCatalog

protected java.lang.String replaceDefaultCatalog(java.lang.String ddl,
                                                 java.lang.String defaultCatalog)

getTimeColumnTemplate

public java.lang.String getTimeColumnTemplate()

setTimeColumnTemplate

public void setTimeColumnTemplate(java.lang.String timeColumnTemplate)

getDateColumnTemplate

public java.lang.String getDateColumnTemplate()

setDateColumnTemplate

public void setDateColumnTemplate(java.lang.String dateColumnTemplate)

getImageColumnTemplate

public java.lang.String getImageColumnTemplate()

setImageColumnTemplate

public void setImageColumnTemplate(java.lang.String imageColumnTemplate)

toHashedValue

public int toHashedValue()

replaceOracleQueryHint

public java.lang.String replaceOracleQueryHint(java.lang.String sql)

getHasPrimaryKeysDefinedString

protected java.lang.String getHasPrimaryKeysDefinedString(org.jumpmind.db.model.Table table)

getPrimaryKeysUpdatedString

protected java.lang.String getPrimaryKeysUpdatedString(org.jumpmind.db.model.Table table)