org.jumpmind.symmetric.service.impl

Class TransformService

java.lang.Object

org.jumpmind.symmetric.service.impl.AbstractService

org.jumpmind.symmetric.service.impl.TransformService

All Implemented Interfaces:

IService, ITransformService

public class TransformService
extends AbstractService
implements ITransformService

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	TransformService.TransformTableNodeGroupLink

Field Summary

Fields inherited from class org.jumpmind.symmetric.service.impl.AbstractService

log, platform, sqlTemplate, sqlTemplateDirty, symmetricDialect, tablePrefix

Constructor Summary

Constructors

Constructor and Description
TransformService(IParameterService parameterService, ISymmetricDialect symmetricDialect, IConfigurationService configurationService, IExtensionService extensionService)

Method Summary

Modifier and Type	Method and Description
void	clearCache()
void	deleteAllTransformTables()
protected void	deleteTransformColumns(org.jumpmind.db.sql.ISqlTransaction transaction, java.lang.String transformTableId)
void	deleteTransformTable(java.lang.String transformTableId)
java.util.List<TransformService.TransformTableNodeGroupLink>	findTransformsFor(NodeGroupLink nodeGroupLink)
java.util.List<TransformService.TransformTableNodeGroupLink>	findTransformsFor(NodeGroupLink nodeGroupLink, org.jumpmind.symmetric.io.data.transform.TransformPoint transformPoint)
java.util.List<TransformService.TransformTableNodeGroupLink>	findTransformsFor(java.lang.String sourceNodeGroupId, java.lang.String targetNodeGroupId, java.lang.String table)
java.util.Map<java.lang.String,org.jumpmind.symmetric.io.data.transform.IColumnTransform<?>>	getColumnTransforms()
java.util.List<TransformService.TransformTableNodeGroupLink>	getConfigExtractTransforms(NodeGroupLink nodeGroupLink)
java.util.List<TransformService.TransformTableNodeGroupLink>	getConfigLoadTransforms(NodeGroupLink nodeGroupLink)
java.util.List<org.jumpmind.symmetric.io.data.transform.TransformColumn>	getTransformColumns()
java.util.List<org.jumpmind.symmetric.io.data.transform.TransformColumn>	getTransformColumnsForTable(java.lang.String transformId)
java.util.List<TransformService.TransformTableNodeGroupLink>	getTransformTables(boolean includeColumns)
java.util.List<TransformService.TransformTableNodeGroupLink>	getTransformTables(boolean includeColumns, boolean replaceTokens)
boolean	refreshFromDatabase()
protected void	saveTransformColumn(org.jumpmind.db.sql.ISqlTransaction transaction, org.jumpmind.symmetric.io.data.transform.TransformColumn transformColumn)
void	saveTransformTable(TransformService.TransformTableNodeGroupLink transformTable, boolean saveTransformColumns)

Methods inherited from class org.jumpmind.symmetric.service.impl.AbstractService

assertNotNull, buildBatchWhere, close, createSqlReplacementTokens, createSqlReplacementTokens, getJdbcTemplate, getParameterService, getSql, getSymmetricDialect, getTablePrefix, getTargetDialect, getTargetPlatform, getTargetPlatform, isCalledFromSymmetricAdminTool, isSet, isStreamClosedByClient, isSymmetricTable, logOnce, maxDate, readAcks, sendAck, setSqlMap, synchronize, toNodeIds, toNodeIds

Methods inherited from class java.lang.Object

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

Constructor Detail

TransformService

public TransformService(IParameterService parameterService,
                        ISymmetricDialect symmetricDialect,
                        IConfigurationService configurationService,
                        IExtensionService extensionService)

Method Detail

getColumnTransforms

public java.util.Map<java.lang.String,org.jumpmind.symmetric.io.data.transform.IColumnTransform<?>> getColumnTransforms()

Specified by:

getColumnTransforms in interface ITransformService

refreshFromDatabase

public boolean refreshFromDatabase()

Specified by:

refreshFromDatabase in interface ITransformService

findTransformsFor

public java.util.List<TransformService.TransformTableNodeGroupLink> findTransformsFor(NodeGroupLink nodeGroupLink)

findTransformsFor

public java.util.List<TransformService.TransformTableNodeGroupLink> findTransformsFor(NodeGroupLink nodeGroupLink,
                                                                                      org.jumpmind.symmetric.io.data.transform.TransformPoint transformPoint)

Specified by:

findTransformsFor in interface ITransformService

findTransformsFor

public java.util.List<TransformService.TransformTableNodeGroupLink> findTransformsFor(java.lang.String sourceNodeGroupId,
                                                                                      java.lang.String targetNodeGroupId,
                                                                                      java.lang.String table)

Specified by:

findTransformsFor in interface ITransformService

clearCache

public void clearCache()

Specified by:

clearCache in interface ITransformService

getConfigExtractTransforms

public java.util.List<TransformService.TransformTableNodeGroupLink> getConfigExtractTransforms(NodeGroupLink nodeGroupLink)

Specified by:

getConfigExtractTransforms in interface ITransformService

getConfigLoadTransforms

public java.util.List<TransformService.TransformTableNodeGroupLink> getConfigLoadTransforms(NodeGroupLink nodeGroupLink)

Specified by:

getConfigLoadTransforms in interface ITransformService

getTransformTables

public java.util.List<TransformService.TransformTableNodeGroupLink> getTransformTables(boolean includeColumns)

Specified by:

getTransformTables in interface ITransformService

getTransformTables

public java.util.List<TransformService.TransformTableNodeGroupLink> getTransformTables(boolean includeColumns,
                                                                                       boolean replaceTokens)

Specified by:

getTransformTables in interface ITransformService

getTransformColumns

public java.util.List<org.jumpmind.symmetric.io.data.transform.TransformColumn> getTransformColumns()

Specified by:

getTransformColumns in interface ITransformService

getTransformColumnsForTable

public java.util.List<org.jumpmind.symmetric.io.data.transform.TransformColumn> getTransformColumnsForTable(java.lang.String transformId)

Specified by:

getTransformColumnsForTable in interface ITransformService

saveTransformTable

public void saveTransformTable(TransformService.TransformTableNodeGroupLink transformTable,
                               boolean saveTransformColumns)

Specified by:

saveTransformTable in interface ITransformService

deleteTransformColumns

protected void deleteTransformColumns(org.jumpmind.db.sql.ISqlTransaction transaction,
                                      java.lang.String transformTableId)

deleteTransformTable

public void deleteTransformTable(java.lang.String transformTableId)

Specified by:

deleteTransformTable in interface ITransformService

deleteAllTransformTables

public void deleteAllTransformTables()

Specified by:

deleteAllTransformTables in interface ITransformService

saveTransformColumn

protected void saveTransformColumn(org.jumpmind.db.sql.ISqlTransaction transaction,
                                   org.jumpmind.symmetric.io.data.transform.TransformColumn transformColumn)