Package 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	Description
static class	TransformService.TransformTableNodeGroupLink

Field Summary

Fields

Modifier and Type	Field	Description
static final Map<String,IColumnTransform<?>>	columnTransformMap

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

log, platform, sqlTemplate, sqlTemplateDirty, symmetricDialect, tablePrefix

Constructor Summary

Constructors

Constructor	Description
TransformService(ISymmetricEngine engine, ISymmetricDialect symmetricDialect)

Method Summary

Modifier and Type	Method	Description
void	clearCache()
void	deleteAllTransformColumns()
void	deleteAllTransformTables()
protected void	deleteTransformColumns(ISqlTransaction transaction, String transformTableId)
void	deleteTransformTable(String transformTableId)
List<TransformService.TransformTableNodeGroupLink>	findTransformsFor(String sourceNodeGroupId, String targetNodeGroupId, String table)
List<TransformService.TransformTableNodeGroupLink>	findTransformsFor(NodeGroupLink nodeGroupLink)
List<TransformService.TransformTableNodeGroupLink>	findTransformsFor(NodeGroupLink nodeGroupLink, TransformPoint transformPoint)
Map<String,IColumnTransform<?>>	getColumnTransforms()
List<TransformService.TransformTableNodeGroupLink>	getConfigExtractTransforms(NodeGroupLink nodeGroupLink)
List<TransformService.TransformTableNodeGroupLink>	getConfigLoadTransforms(NodeGroupLink nodeGroupLink)
List<TransformColumn>	getTransformColumns()
List<TransformColumn>	getTransformColumnsForTable(String transformId)
List<TransformService.TransformTableNodeGroupLink>	getTransformTables(boolean includeColumns)
List<TransformService.TransformTableNodeGroupLink>	getTransformTables(boolean includeColumns, boolean replaceTokens)
Map<NodeGroupLink,Map<TransformPoint,List<TransformService.TransformTableNodeGroupLink>>>	readInCacheIfExpiredFromDb()
boolean	refreshFromDatabase()
void	renameTransformTable(String oldId, TransformService.TransformTableNodeGroupLink transformTable)
protected void	saveTransformColumn(ISqlTransaction transaction, TransformColumn transformColumn)
void	saveTransformTable(TransformService.TransformTableNodeGroupLink transformTable, boolean saveTransformColumns)
void	saveTransformTableAsCopy(String originalId, TransformService.TransformTableNodeGroupLink transformTable)

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

assertNotNull, buildBatchOrderBy, buildBatchParams, buildBatchWhere, buildBatchWhereFromFilter, close, 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

Field Details

columnTransformMap

public static final Map<String,IColumnTransform<?>> columnTransformMap

Constructor Details

TransformService

public TransformService(ISymmetricEngine engine,
 ISymmetricDialect symmetricDialect)

Method Details

getColumnTransforms

public Map<String,IColumnTransform<?>> getColumnTransforms()

Specified by:

getColumnTransforms in interface ITransformService

refreshFromDatabase

public boolean refreshFromDatabase()

Specified by:

refreshFromDatabase in interface ITransformService

findTransformsFor

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

findTransformsFor

public List<TransformService.TransformTableNodeGroupLink> findTransformsFor(NodeGroupLink nodeGroupLink,
 TransformPoint transformPoint)

Specified by:

findTransformsFor in interface ITransformService

findTransformsFor

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

Specified by:

findTransformsFor in interface ITransformService

clearCache

public void clearCache()

Specified by:

clearCache in interface ITransformService

readInCacheIfExpiredFromDb

public Map<NodeGroupLink,Map<TransformPoint,List<TransformService.TransformTableNodeGroupLink>>> readInCacheIfExpiredFromDb()

Specified by:

readInCacheIfExpiredFromDb in interface ITransformService

getConfigExtractTransforms

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

Specified by:

getConfigExtractTransforms in interface ITransformService

getConfigLoadTransforms

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

Specified by:

getConfigLoadTransforms in interface ITransformService

getTransformTables

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

Specified by:

getTransformTables in interface ITransformService

getTransformTables

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

Specified by:

getTransformTables in interface ITransformService

getTransformColumns

public List<TransformColumn> getTransformColumns()

Specified by:

getTransformColumns in interface ITransformService

getTransformColumnsForTable

public List<TransformColumn> getTransformColumnsForTable(String transformId)

Specified by:

getTransformColumnsForTable in interface ITransformService

saveTransformTable

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

Specified by:

saveTransformTable in interface ITransformService

saveTransformTableAsCopy

public void saveTransformTableAsCopy(String originalId,
 TransformService.TransformTableNodeGroupLink transformTable)

Specified by:

saveTransformTableAsCopy in interface ITransformService

renameTransformTable

public void renameTransformTable(String oldId,
 TransformService.TransformTableNodeGroupLink transformTable)

Specified by:

renameTransformTable in interface ITransformService

deleteTransformColumns

protected void deleteTransformColumns(ISqlTransaction transaction,
 String transformTableId)

deleteAllTransformColumns

public void deleteAllTransformColumns()

Specified by:

deleteAllTransformColumns in interface ITransformService

deleteTransformTable

public void deleteTransformTable(String transformTableId)

Specified by:

deleteTransformTable in interface ITransformService

deleteAllTransformTables

public void deleteAllTransformTables()

Specified by:

deleteAllTransformTables in interface ITransformService

saveTransformColumn

protected void saveTransformColumn(ISqlTransaction transaction,
 TransformColumn transformColumn)