Package org.jumpmind.symmetric.service.impl

Class TriggerRouterService

java.lang.Object

org.jumpmind.symmetric.service.impl.AbstractService

org.jumpmind.symmetric.service.impl.TriggerRouterService

All Implemented Interfaces:

IService, ITriggerRouterService

public class TriggerRouterService
extends AbstractService
implements ITriggerRouterService

See Also:

• ITriggerRouterService

Field Summary

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

log, platform, sqlTemplate, sqlTemplateDirty, symmetricDialect, tablePrefix

Constructor Summary

Constructors

Constructor	Description
TriggerRouterService(ISymmetricEngine engine)

Method Summary

Modifier and Type	Method	Description
protected void	awaitTermination(ExecutorService executor, List<Future<?>> futures)
String	buildSymmetricTableRouterId(String triggerId, String sourceNodeGroupId, String targetNodeGroupId)
protected Trigger	buildTriggerForSymmetricTable(String tableName, Set<String> configTablesWithoutCapture)
List<TriggerRouter>	buildTriggerRoutersForSymmetricTables(String version, NodeGroupLink nodeGroupLink, String... tablesToExclude)	Return a list of triggers used when extraction configuration data during the registration process.
protected TriggerRouter	buildTriggerRoutersForSymmetricTables(String version, Trigger trigger, NodeGroupLink nodeGroupLink)
List<Trigger>	buildTriggersForSymmetricTables(String version, String... tablesToExclude)
void	clearCache()
void	createTriggersOnChannelForTables(String channelId, String catalogName, String schemaName, List<String> tables, String lastUpdateBy)
void	deleteAllRouters()
void	deleteAllTriggerRouters()
void	deleteAllTriggers()
void	deleteRouter(Router router)
void	deleteTrigger(Trigger trigger)
protected void	deleteTriggerHistory(TriggerHistory history)
void	deleteTriggerRouter(String triggerId, String routerId)
void	deleteTriggerRouter(TriggerRouter triggerRouter)
void	deleteTriggerRouters(Collection<TriggerRouter> triggerRouters)
protected void	deleteTriggerRouters(ISqlTransaction transaction, Collection<TriggerRouter> triggerRouters)
void	deleteTriggers(Collection<Trigger> triggers)
boolean	doesTriggerExist(String triggerId)
boolean	doesTriggerExistForTable(String tableName)
boolean	doesTriggerExistForTable(String tableName, boolean useTriggerHist)
protected boolean	doesTriggerRouterExistInList(List<TriggerRouter> triggerRouters, TriggerRouter triggerRouter)
protected void	dropTrigger(StringBuilder sqlBuffer, String catalog, String schema, String triggerName, String tableName)
void	dropTriggers()
void	dropTriggers(boolean includeSymTriggers)
void	dropTriggers(Set<String> tables)
void	dropTriggers(TriggerHistory history)
protected void	dropTriggers(TriggerHistory history, StringBuilder sqlBuffer)
protected void	dropTriggers(TriggerHistory history, StringBuilder sqlBuffer, TriggerRouterContext context)
protected void	dropTriggersIfNeeded(TriggerHistory history, StringBuilder sqlBuffer, TriggerRouterContext triggerRouterContext, boolean foundTable)
Map<Integer,List<TriggerRouter>>	fillTriggerRoutersByHistId(String sourceNodeGroupId, String targetNodeGroupId, String targetExternalId, List<TriggerHistory> triggerHistories)
protected Map<Integer,List<TriggerRouter>>	fillTriggerRoutersByHistId(String sourceNodeGroupId, String targetNodeGroupId, String targetExternalId, List<TriggerHistory> triggerHistories, List<TriggerRouter> triggerRouters)
Map<Integer,List<TriggerRouter>>	fillTriggerRoutersByHistIdAndSortHist(String sourceNodeGroupId, String targetNodeGroupId, String targetExternalId, List<TriggerHistory> triggerHistories, boolean sortByFk)
Map<Integer,List<TriggerRouter>>	fillTriggerRoutersByHistIdAndSortHist(String sourceNodeGroupId, String targetNodeGroupId, String targetExternalId, List<TriggerHistory> triggerHistories, List<TriggerRouter> triggerRouters, boolean sortByFk)
Collection<Trigger>	findMatchingTriggers(List<Trigger> triggers, String catalog, String schema, String table)
List<TriggerHistory>	findTriggerHistories(String catalogName, String schemaName, String tableName)
TriggerHistory	findTriggerHistory(String catalogName, String schemaName, String tableName)
TriggerHistory	findTriggerHistoryForGenericSync()
TriggerRouter	findTriggerRouterById(String triggerId, String routerId)
TriggerRouter	findTriggerRouterById(String triggerId, String routerId, boolean refreshCache)
List<TriggerRouter>	findTriggerRoutersByRouterId(String routerId, boolean refreshCache)
List<TriggerRouter>	findTriggerRoutersByTriggerId(String triggerId, boolean refreshCache)
protected void	fixMultipleActiveTriggerHistories(TriggerRouterContext triggerRouterContext)
Router	getActiveRouterByIdForCurrentNode(String routerId, boolean refreshCache)	Get router that is currently in use by a trigger router at the node that is hosting this call.
List<TriggerHistory>	getActiveTriggerHistories()	Get a list of trigger histories that are currently active
List<TriggerHistory>	getActiveTriggerHistories(String tableName)
List<TriggerHistory>	getActiveTriggerHistories(Trigger trigger)
List<TriggerHistory>	getActiveTriggerHistoriesFromCache()
List<TriggerRouter>	getAllTriggerRoutersForCurrentNode(String sourceNodeGroupId)
List<TriggerRouter>	getAllTriggerRoutersForReloadForCurrentNode(String sourceNodeGroupId, String targetNodeGroupId)
protected List<TriggerRouter>	getConfigurationTablesTriggerRoutersForCurrentNode(String sourceNodeGroupId)	Create a list of TriggerRouter for the SymmetricDS tables that should have triggers created for them on the current node.
Map<Trigger,Exception>	getFailedTriggers()
protected String	getFullyQualifiedTableName(Table table)
Map<Long,TriggerHistory>	getHistoryRecords()
Map<String,TriggerHistory>	getLastErrorTriggerHistories()
protected List<TriggerHistory>	getMultipleActiveTriggerHistories()
TriggerHistory	getNewestTriggerHistoryForTrigger(String triggerId, String catalogName, String schemaName, String tableName)
TriggerHistory	getNewestTriggerHistoryForTrigger(List<TriggerHistory> activeTriggerHistories, String triggerId, String catalogName, String schemaName, String tableName)
Router	getRouterById(String routerId)
Router	getRouterById(String routerId, boolean refreshCache)
List<Router>	getRouters()
List<Router>	getRouters(boolean replaceVariables)
List<Router>	getRoutersByGroupLink(NodeGroupLink link)	Get a list of routers for a specific node group link.
List<Table>	getSortedTablesFor(List<TriggerHistory> histories)
protected TriggerHistory	getTableNotFoundTriggerHistory(Trigger trigger)
List<Table>	getTablesFor(List<TriggerHistory> histories)
protected Set<Table>	getTablesForTrigger(Trigger trigger, List<Trigger> triggers, boolean useTableCache, TriggerRouterContext triggerRouterContext)
protected Set<Table>	getTablesForTriggerWithException(Trigger trigger, List<Trigger> triggers, boolean useTableCache, TriggerRouterContext triggerRouterContext)
Trigger	getTriggerById(String triggerId)
Trigger	getTriggerById(String triggerId, boolean refreshCache)
Trigger	getTriggerForCurrentNodeById(String triggerId)
protected Trigger	getTriggerFromList(String triggerId, List<Trigger> triggersThatShouldBeActive)
TriggerHistory	getTriggerHistory(int histId)
protected List<TriggerHistory>	getTriggerHistoryIds(TriggerHistory triggerHistory)
protected Set<String>	getTriggerIdsFrom(List<Trigger> triggersThatShouldBeActive)
String	getTriggerName(DataEventType dml, int maxTriggerNameLength, Trigger trigger, Table table, List<TriggerHistory> activeTriggerHistories, TriggerHistory oldhist, List<String> triggerNamesGeneratedThisSession)
String	getTriggerName(DataEventType dml, org.jumpmind.symmetric.service.impl.TriggerRouterService.TriggerTableSupportingInfo triggerTableSupportingInfo)
TriggerRouter	getTriggerRouterByTriggerHist(String targetNodeGroupId, int triggerHistId, boolean refreshCache)
TriggerRouter	getTriggerRouterForCurrentNode(String triggerId, String routerId, boolean refreshCache)
Set<TriggerRouter>	getTriggerRouterForTableForCurrentNode(String catalogName, String schemaName, String tableName, boolean refreshCache)
Set<TriggerRouter>	getTriggerRouterForTableForCurrentNode(NodeGroupLink link, String catalogName, String schemaName, String tableName, boolean refreshCache)
List<TriggerRouter>	getTriggerRouters(boolean refreshCache)
Map<String,List<TriggerRouter>>	getTriggerRoutersByChannel(String nodeGroupId)
Map<String,List<TriggerRouter>>	getTriggerRoutersByChannel(String nodeGroupId, boolean refreshCache)
Map<String,List<TriggerRouter>>	getTriggerRoutersByChannelFromDatabase(String nodeGroupId)
Map<Integer,TriggerRouter>	getTriggerRoutersByTriggerHist(String targetNodeGroupId, boolean refreshCache)
Map<String,Map<Integer,TriggerRouter>>	getTriggerRoutersByTriggerHistFromDatabase()
Map<String,TriggerRouterRoutersCache>	getTriggerRoutersCacheByNodeGroupIdFromDatabase()
protected TriggerRouterRoutersCache	getTriggerRoutersCacheForCurrentNode(boolean refreshCache)
Map<String,List<TriggerRouter>>	getTriggerRoutersForCurrentNode(boolean refreshCache)	Returns a map of trigger routers keyed by trigger id.
List<TriggerRouter>	getTriggerRoutersForSourceAndTargetNodes(String sourceNodeGroupId, String targetNodeGroupId)
List<TriggerRouter>	getTriggerRoutersForTargetNode(String targetNodeGroupId)
List<TriggerRouter>	getTriggerRoutersFromDatabase()
protected int[]	getTriggerRouterSqlTypes()
protected Object[]	getTriggerRouterSqlValues(TriggerRouter triggerRouter)
List<Trigger>	getTriggers()	Get a list of all the triggers that have been defined for the system.
List<Trigger>	getTriggers(boolean replaceTokens)
protected List<Trigger>	getTriggersForCurrentNode()
List<Trigger>	getTriggersForCurrentNode(boolean refreshCache)	Returns a list of triggers that should be active for the current node.
protected int[]	getTriggerSqlTypes()
protected Object[]	getTriggerSqlValues(Trigger trigger)
protected void	handleTableNotFound(Trigger trigger, List<TriggerHistory> activeTriggerHistories, TriggerRouterContext context)
void	inactivateTriggerHistory(TriggerHistory history)
protected void	inactivateTriggers(List<Trigger> triggersThatShouldBeActive, StringBuilder sqlBuffer, List<TriggerHistory> activeTriggerHistories, TriggerRouterContext triggerRouterContext)
void	insert(TriggerHistory newHistRecord)
void	insertTriggerRouters(Collection<TriggerRouter> triggerRouters)
void	insertTriggers(Collection<Trigger> triggers)
void	insertTriggersAndTriggerRouters(Collection<Trigger> triggers, Collection<TriggerRouter> triggerRouters)
protected void	insertUpdateTriggerRouters(Collection<TriggerRouter> triggerRouters, boolean isInsert, Collection<Trigger> triggers)
protected void	insertUpdateTriggers(Collection<Trigger> triggers, boolean isInsert)
protected void	insertUpdateTriggers(ISqlTransaction transaction, Collection<Trigger> triggers, boolean isInsert)
protected void	invalidateTriggerHistory(TriggerHistory history, Exception ex)
protected boolean	isEqual(String one, String two, boolean ignoreCase)
protected boolean	isMatch(String catalogName, String schemaName, String tableName, Trigger trigger)
protected boolean	isMatch(NodeGroupLink link, TriggerRouter router)
boolean	isRouterBeingUsed(String routerId)
boolean	isTriggerBeingUsed(String triggerId)
protected boolean	isTriggerNameInUse(List<TriggerHistory> activeTriggerHistories, Trigger trigger, String triggerName, TriggerHistory oldhist, List<String> triggerNamesGeneratedThisSession)
protected void	logTriggerRouterContextAnomalies(TriggerRouterContext triggerRouterContext)
protected void	logTriggerRouterContextTimings(TriggerRouterContext triggerRouterContext)
protected void	mergeInConfigurationTablesTriggerRoutersForCurrentNode(String sourceNodeGroupId, List<TriggerRouter> configuredInDatabase)
protected TriggerHistory	rebuildTriggerIfNecessary(StringBuilder sqlBuffer, boolean forceRebuild, Trigger trigger, DataEventType dmlType, TriggerReBuildReason reason, TriggerHistory oldhist, TriggerHistory hist, boolean triggerIsActive, Table table, List<TriggerHistory> activeTriggerHistories, org.jumpmind.symmetric.service.impl.TriggerRouterService.TriggerTableSupportingInfo triggerTableSupportingInfo)
protected TriggerHistory	rebuildTriggerIfNecessaryWithException(StringBuilder sqlBuffer, boolean forceRebuild, Trigger trigger, DataEventType dmlType, TriggerReBuildReason reason, TriggerHistory oldhist, TriggerHistory hist, boolean triggerIsActive, Table table, List<TriggerHistory> activeTriggerHistories, org.jumpmind.symmetric.service.impl.TriggerRouterService.TriggerTableSupportingInfo triggerTableSupportingInfo)
boolean	refreshFromDatabase()
void	renameRouter(String oldId, Router router)
void	renameTrigger(String oldId, Trigger trigger)
void	renameTriggerRouter(String oldTriggerId, String oldRouterId, TriggerRouter triggerRouter)
protected void	resetTriggerRouterCacheByNodeGroupId()
void	saveRouter(Router router)
Router	saveRouterAsCopy(Router router)
void	saveTrigger(Trigger trigger)
void	saveTriggerAsCopy(String originalId, Trigger trigger)
void	saveTriggerRouter(TriggerRouter triggerRouter)
void	saveTriggerRouter(TriggerRouter triggerRouter, boolean updateTriggerRouterTableOnly)
void	syncTrigger(Trigger trigger, ITriggerCreationListener listener, boolean force)
void	syncTrigger(Trigger trigger, ITriggerCreationListener listener, boolean force, boolean verifyInDatabase)
boolean	syncTriggers()
boolean	syncTriggers(boolean force)
boolean	syncTriggers(StringBuilder sqlBuffer, boolean force)
boolean	syncTriggers(String targetExternalId, boolean force)
boolean	syncTriggers(List<Table> tables, boolean force)
boolean	syncTriggers(List<Trigger> triggers, ITriggerCreationListener listener, boolean force, boolean verifyInDatabase)
boolean	syncTriggers(Table table, boolean force)
protected List<TriggerRouter>	toList(Collection<List<TriggerRouter>> source)
protected void	updateOrCreateDatabaseTrigger(Trigger trigger, List<Trigger> triggers, StringBuilder sqlBuffer, boolean force, boolean verifyInDatabase, List<TriggerHistory> activeTriggerHistories, boolean useTableCache, Map<String,List<org.jumpmind.symmetric.service.impl.TriggerRouterService.TriggerTableSupportingInfo>> triggerToTableSupportingInfo, TriggerRouterContext context)
protected void	updateOrCreateDatabaseTriggers(List<Trigger> triggers, StringBuilder sqlBuffer, boolean force, boolean verifyInDatabase, List<TriggerHistory> activeTriggerHistories, boolean useTableCache, TriggerRouterContext triggerRouterContext)
protected void	updateOrCreateDatabaseTriggers(Trigger trigger, Table table, StringBuilder sqlBuffer, boolean force, boolean verifyInDatabase, List<TriggerHistory> activeTriggerHistories, org.jumpmind.symmetric.service.impl.TriggerRouterService.TriggerTableSupportingInfo triggerTableSupportingInfo, TriggerRouterContext context)
protected void	updateOrCreateDdlTriggers(StringBuilder sqlBuffer)
void	updateTriggerRouters(Collection<TriggerRouter> triggerRouters)
void	updateTriggers(Collection<Trigger> triggers)

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

Constructor Details

TriggerRouterService

public TriggerRouterService(ISymmetricEngine engine)

Method Details

refreshFromDatabase

public boolean refreshFromDatabase()

Specified by:

refreshFromDatabase in interface ITriggerRouterService

getTriggers

public List<Trigger> getTriggers()

Description copied from interface: ITriggerRouterService

Get a list of all the triggers that have been defined for the system.

Specified by:

getTriggers in interface ITriggerRouterService

getTriggers

public List<Trigger> getTriggers(boolean replaceTokens)

Specified by:

getTriggers in interface ITriggerRouterService

isTriggerBeingUsed

public boolean isTriggerBeingUsed(String triggerId)

Specified by:

isTriggerBeingUsed in interface ITriggerRouterService

doesTriggerExist

public boolean doesTriggerExist(String triggerId)

Specified by:

doesTriggerExist in interface ITriggerRouterService

doesTriggerExistForTable

public boolean doesTriggerExistForTable(String tableName)

Specified by:

doesTriggerExistForTable in interface ITriggerRouterService

doesTriggerExistForTable

public boolean doesTriggerExistForTable(String tableName,
 boolean useTriggerHist)

deleteTrigger

public void deleteTrigger(Trigger trigger)

Specified by:

deleteTrigger in interface ITriggerRouterService

deleteTriggers

public void deleteTriggers(Collection<Trigger> triggers)

Specified by:

deleteTriggers in interface ITriggerRouterService

deleteAllTriggers

public void deleteAllTriggers()

Specified by:

deleteAllTriggers in interface ITriggerRouterService

dropTriggers

public void dropTriggers()

Specified by:

dropTriggers in interface ITriggerRouterService

dropTriggers

public void dropTriggers(boolean includeSymTriggers)

Specified by:

dropTriggers in interface ITriggerRouterService

dropTriggers

public void dropTriggers(Set<String> tables)

Specified by:

dropTriggers in interface ITriggerRouterService

deleteTriggerHistory

protected void deleteTriggerHistory(TriggerHistory history)

createTriggersOnChannelForTables

public void createTriggersOnChannelForTables(String channelId,
 String catalogName,
 String schemaName,
 List<String> tables,
 String lastUpdateBy)

Specified by:

createTriggersOnChannelForTables in interface ITriggerRouterService

findMatchingTriggers

public Collection<Trigger> findMatchingTriggers(List<Trigger> triggers,
 String catalog,
 String schema,
 String table)

Specified by:

findMatchingTriggers in interface ITriggerRouterService

invalidateTriggerHistory

protected void invalidateTriggerHistory(TriggerHistory history,
 Exception ex)

inactivateTriggerHistory

public void inactivateTriggerHistory(TriggerHistory history)

Specified by:

inactivateTriggerHistory in interface ITriggerRouterService

getHistoryRecords

public Map<Long,TriggerHistory> getHistoryRecords()

Specified by:

getHistoryRecords in interface ITriggerRouterService

isTriggerNameInUse

protected boolean isTriggerNameInUse(List<TriggerHistory> activeTriggerHistories,
 Trigger trigger,
 String triggerName,
 TriggerHistory oldhist,
 List<String> triggerNamesGeneratedThisSession)

findTriggerHistory

public TriggerHistory findTriggerHistory(String catalogName,
 String schemaName,
 String tableName)

Specified by:

findTriggerHistory in interface ITriggerRouterService

findTriggerHistories

public List<TriggerHistory> findTriggerHistories(String catalogName,
 String schemaName,
 String tableName)

Specified by:

findTriggerHistories in interface ITriggerRouterService

getTriggerHistory

public TriggerHistory getTriggerHistory(int histId)

Specified by:

getTriggerHistory in interface ITriggerRouterService

getActiveTriggerHistories

public List<TriggerHistory> getActiveTriggerHistories(Trigger trigger)

Specified by:

getActiveTriggerHistories in interface ITriggerRouterService

getNewestTriggerHistoryForTrigger

public TriggerHistory getNewestTriggerHistoryForTrigger(List<TriggerHistory> activeTriggerHistories,
 String triggerId,
 String catalogName,
 String schemaName,
 String tableName)

Specified by:

getNewestTriggerHistoryForTrigger in interface ITriggerRouterService

getNewestTriggerHistoryForTrigger

public TriggerHistory getNewestTriggerHistoryForTrigger(String triggerId,
 String catalogName,
 String schemaName,
 String tableName)

Specified by:

getNewestTriggerHistoryForTrigger in interface ITriggerRouterService

getActiveTriggerHistoriesFromCache

public List<TriggerHistory> getActiveTriggerHistoriesFromCache()

Specified by:

getActiveTriggerHistoriesFromCache in interface ITriggerRouterService

getActiveTriggerHistories

public List<TriggerHistory> getActiveTriggerHistories()

Get a list of trigger histories that are currently active

Specified by:

getActiveTriggerHistories in interface ITriggerRouterService

getLastErrorTriggerHistories

public Map<String,TriggerHistory> getLastErrorTriggerHistories()

Specified by:

getLastErrorTriggerHistories in interface ITriggerRouterService

getActiveTriggerHistories

public List<TriggerHistory> getActiveTriggerHistories(String tableName)

Specified by:

getActiveTriggerHistories in interface ITriggerRouterService

buildTriggersForSymmetricTables

public List<Trigger> buildTriggersForSymmetricTables(String version,
 String... tablesToExclude)

Specified by:

buildTriggersForSymmetricTables in interface ITriggerRouterService

buildTriggerForSymmetricTable

protected Trigger buildTriggerForSymmetricTable(String tableName,
 Set<String> configTablesWithoutCapture)

buildTriggerRoutersForSymmetricTables

public List<TriggerRouter> buildTriggerRoutersForSymmetricTables(String version,
 NodeGroupLink nodeGroupLink,
 String... tablesToExclude)

Description copied from interface: ITriggerRouterService

Return a list of triggers used when extraction configuration data during the registration process.

Specified by:

buildTriggerRoutersForSymmetricTables in interface ITriggerRouterService

buildSymmetricTableRouterId

public String buildSymmetricTableRouterId(String triggerId,
 String sourceNodeGroupId,
 String targetNodeGroupId)

Specified by:

buildSymmetricTableRouterId in interface ITriggerRouterService

buildTriggerRoutersForSymmetricTables

protected TriggerRouter buildTriggerRoutersForSymmetricTables(String version,
 Trigger trigger,
 NodeGroupLink nodeGroupLink)

getTriggerRouterForTableForCurrentNode

public Set<TriggerRouter> getTriggerRouterForTableForCurrentNode(String catalogName,
 String schemaName,
 String tableName,
 boolean refreshCache)

Specified by:

getTriggerRouterForTableForCurrentNode in interface ITriggerRouterService

getTriggerRouterForTableForCurrentNode

public Set<TriggerRouter> getTriggerRouterForTableForCurrentNode(NodeGroupLink link,
 String catalogName,
 String schemaName,
 String tableName,
 boolean refreshCache)

Specified by:

getTriggerRouterForTableForCurrentNode in interface ITriggerRouterService

isMatch

protected boolean isMatch(NodeGroupLink link,
 TriggerRouter router)

isMatch

protected boolean isMatch(String catalogName,
 String schemaName,
 String tableName,
 Trigger trigger)

getConfigurationTablesTriggerRoutersForCurrentNode

protected List<TriggerRouter> getConfigurationTablesTriggerRoutersForCurrentNode(String sourceNodeGroupId)

Create a list of TriggerRouter for the SymmetricDS tables that should have triggers created for them on the current node.

mergeInConfigurationTablesTriggerRoutersForCurrentNode

protected void mergeInConfigurationTablesTriggerRoutersForCurrentNode(String sourceNodeGroupId,
 List<TriggerRouter> configuredInDatabase)

doesTriggerRouterExistInList

protected boolean doesTriggerRouterExistInList(List<TriggerRouter> triggerRouters,
 TriggerRouter triggerRouter)

getTriggerRouterForCurrentNode

public TriggerRouter getTriggerRouterForCurrentNode(String triggerId,
 String routerId,
 boolean refreshCache)

Specified by:

getTriggerRouterForCurrentNode in interface ITriggerRouterService

getTriggerRoutersForCurrentNode

public Map<String,List<TriggerRouter>> getTriggerRoutersForCurrentNode(boolean refreshCache)

Description copied from interface: ITriggerRouterService

Returns a map of trigger routers keyed by trigger id.

Specified by:

getTriggerRoutersForCurrentNode in interface ITriggerRouterService

Parameters:

refreshCache - Indicates that the cache should be refreshed

getTriggersForCurrentNode

public List<Trigger> getTriggersForCurrentNode(boolean refreshCache)

Description copied from interface: ITriggerRouterService

Returns a list of triggers that should be active for the current node.

Specified by:

getTriggersForCurrentNode in interface ITriggerRouterService

Parameters:

refreshCache - Indicates that the cache should be refreshed

getTriggerRouterByTriggerHist

public TriggerRouter getTriggerRouterByTriggerHist(String targetNodeGroupId,
 int triggerHistId,
 boolean refreshCache)

Specified by:

getTriggerRouterByTriggerHist in interface ITriggerRouterService

getTriggerRoutersByTriggerHist

public Map<Integer,TriggerRouter> getTriggerRoutersByTriggerHist(String targetNodeGroupId,
 boolean refreshCache)

Specified by:

getTriggerRoutersByTriggerHist in interface ITriggerRouterService

getTriggerRoutersByTriggerHistFromDatabase

public Map<String,Map<Integer,TriggerRouter>> getTriggerRoutersByTriggerHistFromDatabase()

Specified by:

getTriggerRoutersByTriggerHistFromDatabase in interface ITriggerRouterService

getTriggerRoutersCacheForCurrentNode

protected TriggerRouterRoutersCache getTriggerRoutersCacheForCurrentNode(boolean refreshCache)

getTriggerRoutersCacheByNodeGroupIdFromDatabase

public Map<String,TriggerRouterRoutersCache> getTriggerRoutersCacheByNodeGroupIdFromDatabase()

Specified by:

getTriggerRoutersCacheByNodeGroupIdFromDatabase in interface ITriggerRouterService

getActiveRouterByIdForCurrentNode

public Router getActiveRouterByIdForCurrentNode(String routerId,
 boolean refreshCache)

Description copied from interface: ITriggerRouterService

Get router that is currently in use by a trigger router at the node that is hosting this call.

Specified by:

getActiveRouterByIdForCurrentNode in interface ITriggerRouterService

Parameters:

routerId - The router_id to retrieve

refreshCache - Whether to force the router to be re-retrieved from the database

See Also:

• ITriggerRouterService.getActiveRouterByIdForCurrentNode(String, boolean)

getRoutersByGroupLink

public List<Router> getRoutersByGroupLink(NodeGroupLink link)

Description copied from interface: ITriggerRouterService

Get a list of routers for a specific node group link.

Specified by:

getRoutersByGroupLink in interface ITriggerRouterService

See Also:

• ITriggerRouterService.getRoutersByGroupLink(NodeGroupLink)

getTriggerForCurrentNodeById

public Trigger getTriggerForCurrentNodeById(String triggerId)

Specified by:

getTriggerForCurrentNodeById in interface ITriggerRouterService

getTriggerById

public Trigger getTriggerById(String triggerId)

Specified by:

getTriggerById in interface ITriggerRouterService

getTriggerById

public Trigger getTriggerById(String triggerId,
 boolean refreshCache)

Specified by:

getTriggerById in interface ITriggerRouterService

getRouterById

public Router getRouterById(String routerId)

Specified by:

getRouterById in interface ITriggerRouterService

getRouterById

public Router getRouterById(String routerId,
 boolean refreshCache)

Specified by:

getRouterById in interface ITriggerRouterService

getRouters

public List<Router> getRouters()

Specified by:

getRouters in interface ITriggerRouterService

getRouters

public List<Router> getRouters(boolean replaceVariables)

Specified by:

getRouters in interface ITriggerRouterService

getTriggerRouters

public List<TriggerRouter> getTriggerRouters(boolean refreshCache)

Specified by:

getTriggerRouters in interface ITriggerRouterService

getTriggerRoutersFromDatabase

public List<TriggerRouter> getTriggerRoutersFromDatabase()

Specified by:

getTriggerRoutersFromDatabase in interface ITriggerRouterService

getAllTriggerRoutersForCurrentNode

public List<TriggerRouter> getAllTriggerRoutersForCurrentNode(String sourceNodeGroupId)

Specified by:

getAllTriggerRoutersForCurrentNode in interface ITriggerRouterService

getTriggerRoutersForTargetNode

public List<TriggerRouter> getTriggerRoutersForTargetNode(String targetNodeGroupId)

Specified by:

getTriggerRoutersForTargetNode in interface ITriggerRouterService

getTriggerRoutersForSourceAndTargetNodes

public List<TriggerRouter> getTriggerRoutersForSourceAndTargetNodes(String sourceNodeGroupId,
 String targetNodeGroupId)

Specified by:

getTriggerRoutersForSourceAndTargetNodes in interface ITriggerRouterService

getAllTriggerRoutersForReloadForCurrentNode

public List<TriggerRouter> getAllTriggerRoutersForReloadForCurrentNode(String sourceNodeGroupId,
 String targetNodeGroupId)

Specified by:

getAllTriggerRoutersForReloadForCurrentNode in interface ITriggerRouterService

findTriggerRouterById

public TriggerRouter findTriggerRouterById(String triggerId,
 String routerId)

Specified by:

findTriggerRouterById in interface ITriggerRouterService

findTriggerRouterById

public TriggerRouter findTriggerRouterById(String triggerId,
 String routerId,
 boolean refreshCache)

Specified by:

findTriggerRouterById in interface ITriggerRouterService

findTriggerRoutersByTriggerId

public List<TriggerRouter> findTriggerRoutersByTriggerId(String triggerId,
 boolean refreshCache)

Specified by:

findTriggerRoutersByTriggerId in interface ITriggerRouterService

findTriggerRoutersByRouterId

public List<TriggerRouter> findTriggerRoutersByRouterId(String routerId,
 boolean refreshCache)

Specified by:

findTriggerRoutersByRouterId in interface ITriggerRouterService

getTriggerRoutersByChannel

public Map<String,List<TriggerRouter>> getTriggerRoutersByChannel(String nodeGroupId)

Specified by:

getTriggerRoutersByChannel in interface ITriggerRouterService

getTriggerRoutersByChannel

public Map<String,List<TriggerRouter>> getTriggerRoutersByChannel(String nodeGroupId,
 boolean refreshCache)

getTriggerRoutersByChannelFromDatabase

public Map<String,List<TriggerRouter>> getTriggerRoutersByChannelFromDatabase(String nodeGroupId)

Specified by:

getTriggerRoutersByChannelFromDatabase in interface ITriggerRouterService

handleTableNotFound

protected void handleTableNotFound(Trigger trigger,
 List<TriggerHistory> activeTriggerHistories,
 TriggerRouterContext context)

getTableNotFoundTriggerHistory

protected TriggerHistory getTableNotFoundTriggerHistory(Trigger trigger)

insert

public void insert(TriggerHistory newHistRecord)

Specified by:

insert in interface ITriggerRouterService

deleteTriggerRouter

public void deleteTriggerRouter(String triggerId,
 String routerId)

Specified by:

deleteTriggerRouter in interface ITriggerRouterService

deleteTriggerRouter

public void deleteTriggerRouter(TriggerRouter triggerRouter)

Specified by:

deleteTriggerRouter in interface ITriggerRouterService

deleteTriggerRouters

public void deleteTriggerRouters(Collection<TriggerRouter> triggerRouters)

Specified by:

deleteTriggerRouters in interface ITriggerRouterService

deleteTriggerRouters

protected void deleteTriggerRouters(ISqlTransaction transaction,
 Collection<TriggerRouter> triggerRouters)

deleteAllTriggerRouters

public void deleteAllTriggerRouters()

Specified by:

deleteAllTriggerRouters in interface ITriggerRouterService

saveTriggerRouter

public void saveTriggerRouter(TriggerRouter triggerRouter)

Specified by:

saveTriggerRouter in interface ITriggerRouterService

saveTriggerRouter

public void saveTriggerRouter(TriggerRouter triggerRouter,
 boolean updateTriggerRouterTableOnly)

Specified by:

saveTriggerRouter in interface ITriggerRouterService

renameTriggerRouter

public void renameTriggerRouter(String oldTriggerId,
 String oldRouterId,
 TriggerRouter triggerRouter)

Specified by:

renameTriggerRouter in interface ITriggerRouterService

insertTriggerRouters

public void insertTriggerRouters(Collection<TriggerRouter> triggerRouters)

Specified by:

insertTriggerRouters in interface ITriggerRouterService

insertTriggersAndTriggerRouters

public void insertTriggersAndTriggerRouters(Collection<Trigger> triggers,
 Collection<TriggerRouter> triggerRouters)

Specified by:

insertTriggersAndTriggerRouters in interface ITriggerRouterService

updateTriggerRouters

public void updateTriggerRouters(Collection<TriggerRouter> triggerRouters)

Specified by:

updateTriggerRouters in interface ITriggerRouterService

insertUpdateTriggerRouters

protected void insertUpdateTriggerRouters(Collection<TriggerRouter> triggerRouters,
 boolean isInsert,
 Collection<Trigger> triggers)

getTriggerRouterSqlTypes

protected int[] getTriggerRouterSqlTypes()

getTriggerRouterSqlValues

protected Object[] getTriggerRouterSqlValues(TriggerRouter triggerRouter)

resetTriggerRouterCacheByNodeGroupId

protected void resetTriggerRouterCacheByNodeGroupId()

saveRouter

public void saveRouter(Router router)

Specified by:

saveRouter in interface ITriggerRouterService

saveRouterAsCopy

public Router saveRouterAsCopy(Router router)

Specified by:

saveRouterAsCopy in interface ITriggerRouterService

renameRouter

public void renameRouter(String oldId,
 Router router)

Specified by:

renameRouter in interface ITriggerRouterService

isRouterBeingUsed

public boolean isRouterBeingUsed(String routerId)

Specified by:

isRouterBeingUsed in interface ITriggerRouterService

deleteRouter

public void deleteRouter(Router router)

Specified by:

deleteRouter in interface ITriggerRouterService

deleteAllRouters

public void deleteAllRouters()

Specified by:

deleteAllRouters in interface ITriggerRouterService

saveTrigger

public void saveTrigger(Trigger trigger)

Specified by:

saveTrigger in interface ITriggerRouterService

saveTriggerAsCopy

public void saveTriggerAsCopy(String originalId,
 Trigger trigger)

Specified by:

saveTriggerAsCopy in interface ITriggerRouterService

renameTrigger

public void renameTrigger(String oldId,
 Trigger trigger)

Specified by:

renameTrigger in interface ITriggerRouterService

insertTriggers

public void insertTriggers(Collection<Trigger> triggers)

Specified by:

insertTriggers in interface ITriggerRouterService

updateTriggers

public void updateTriggers(Collection<Trigger> triggers)

Specified by:

updateTriggers in interface ITriggerRouterService

insertUpdateTriggers

protected void insertUpdateTriggers(Collection<Trigger> triggers,
 boolean isInsert)

insertUpdateTriggers

protected void insertUpdateTriggers(ISqlTransaction transaction,
 Collection<Trigger> triggers,
 boolean isInsert)

getTriggerSqlTypes

protected int[] getTriggerSqlTypes()

getTriggerSqlValues

protected Object[] getTriggerSqlValues(Trigger trigger)

syncTriggers

public boolean syncTriggers()

Specified by:

syncTriggers in interface ITriggerRouterService

syncTriggers

public boolean syncTriggers(boolean force)

Specified by:

syncTriggers in interface ITriggerRouterService

syncTriggers

public boolean syncTriggers(StringBuilder sqlBuffer,
 boolean force)

Specified by:

syncTriggers in interface ITriggerRouterService

clearCache

public void clearCache()

Specified by:

clearCache in interface ITriggerRouterService

getTriggerIdsFrom

protected Set<String> getTriggerIdsFrom(List<Trigger> triggersThatShouldBeActive)

getTriggerFromList

protected Trigger getTriggerFromList(String triggerId,
 List<Trigger> triggersThatShouldBeActive)

inactivateTriggers

protected void inactivateTriggers(List<Trigger> triggersThatShouldBeActive,
 StringBuilder sqlBuffer,
 List<TriggerHistory> activeTriggerHistories,
 TriggerRouterContext triggerRouterContext)

isEqual

protected boolean isEqual(String one,
 String two,
 boolean ignoreCase)

dropTriggersIfNeeded

protected void dropTriggersIfNeeded(TriggerHistory history,
 StringBuilder sqlBuffer,
 TriggerRouterContext triggerRouterContext,
 boolean foundTable)

dropTriggers

public void dropTriggers(TriggerHistory history)

Specified by:

dropTriggers in interface ITriggerRouterService

dropTriggers

protected void dropTriggers(TriggerHistory history,
 StringBuilder sqlBuffer)

dropTriggers

protected void dropTriggers(TriggerHistory history,
 StringBuilder sqlBuffer,
 TriggerRouterContext context)

dropTrigger

protected void dropTrigger(StringBuilder sqlBuffer,
 String catalog,
 String schema,
 String triggerName,
 String tableName)

toList

protected List<TriggerRouter> toList(Collection<List<TriggerRouter>> source)

getTriggersForCurrentNode

protected List<Trigger> getTriggersForCurrentNode()

getTablesForTrigger

protected Set<Table> getTablesForTrigger(Trigger trigger,
 List<Trigger> triggers,
 boolean useTableCache,
 TriggerRouterContext triggerRouterContext)

getTablesForTriggerWithException

protected Set<Table> getTablesForTriggerWithException(Trigger trigger,
 List<Trigger> triggers,
 boolean useTableCache,
 TriggerRouterContext triggerRouterContext)

syncTriggers

public boolean syncTriggers(String targetExternalId,
 boolean force)

Specified by:

syncTriggers in interface ITriggerRouterService

syncTriggers

public boolean syncTriggers(Table table,
 boolean force)

Specified by:

syncTriggers in interface ITriggerRouterService

syncTriggers

public boolean syncTriggers(List<Table> tables,
 boolean force)

Specified by:

syncTriggers in interface ITriggerRouterService

getFullyQualifiedTableName

protected String getFullyQualifiedTableName(Table table)

updateOrCreateDdlTriggers

protected void updateOrCreateDdlTriggers(StringBuilder sqlBuffer)

updateOrCreateDatabaseTriggers

protected void updateOrCreateDatabaseTriggers(List<Trigger> triggers,
 StringBuilder sqlBuffer,
 boolean force,
 boolean verifyInDatabase,
 List<TriggerHistory> activeTriggerHistories,
 boolean useTableCache,
 TriggerRouterContext triggerRouterContext)

updateOrCreateDatabaseTrigger

protected void updateOrCreateDatabaseTrigger(Trigger trigger,
 List<Trigger> triggers,
 StringBuilder sqlBuffer,
 boolean force,
 boolean verifyInDatabase,
 List<TriggerHistory> activeTriggerHistories,
 boolean useTableCache,
 Map<String,List<org.jumpmind.symmetric.service.impl.TriggerRouterService.TriggerTableSupportingInfo>> triggerToTableSupportingInfo,
 TriggerRouterContext context)

syncTrigger

public void syncTrigger(Trigger trigger,
 ITriggerCreationListener listener,
 boolean force)

Specified by:

syncTrigger in interface ITriggerRouterService

syncTrigger

public void syncTrigger(Trigger trigger,
 ITriggerCreationListener listener,
 boolean force,
 boolean verifyInDatabase)

Specified by:

syncTrigger in interface ITriggerRouterService

syncTriggers

public boolean syncTriggers(List<Trigger> triggers,
 ITriggerCreationListener listener,
 boolean force,
 boolean verifyInDatabase)

Specified by:

syncTriggers in interface ITriggerRouterService

updateOrCreateDatabaseTriggers

protected void updateOrCreateDatabaseTriggers(Trigger trigger,
 Table table,
 StringBuilder sqlBuffer,
 boolean force,
 boolean verifyInDatabase,
 List<TriggerHistory> activeTriggerHistories,
 org.jumpmind.symmetric.service.impl.TriggerRouterService.TriggerTableSupportingInfo triggerTableSupportingInfo,
 TriggerRouterContext context)

rebuildTriggerIfNecessary

protected TriggerHistory rebuildTriggerIfNecessary(StringBuilder sqlBuffer,
 boolean forceRebuild,
 Trigger trigger,
 DataEventType dmlType,
 TriggerReBuildReason reason,
 TriggerHistory oldhist,
 TriggerHistory hist,
 boolean triggerIsActive,
 Table table,
 List<TriggerHistory> activeTriggerHistories,
 org.jumpmind.symmetric.service.impl.TriggerRouterService.TriggerTableSupportingInfo triggerTableSupportingInfo)

rebuildTriggerIfNecessaryWithException

protected TriggerHistory rebuildTriggerIfNecessaryWithException(StringBuilder sqlBuffer,
 boolean forceRebuild,
 Trigger trigger,
 DataEventType dmlType,
 TriggerReBuildReason reason,
 TriggerHistory oldhist,
 TriggerHistory hist,
 boolean triggerIsActive,
 Table table,
 List<TriggerHistory> activeTriggerHistories,
 org.jumpmind.symmetric.service.impl.TriggerRouterService.TriggerTableSupportingInfo triggerTableSupportingInfo)

getTriggerName

public String getTriggerName(DataEventType dml,
 int maxTriggerNameLength,
 Trigger trigger,
 Table table,
 List<TriggerHistory> activeTriggerHistories,
 TriggerHistory oldhist,
 List<String> triggerNamesGeneratedThisSession)

Specified by:

getTriggerName in interface ITriggerRouterService

getTriggerName

public String getTriggerName(DataEventType dml,
 org.jumpmind.symmetric.service.impl.TriggerRouterService.TriggerTableSupportingInfo triggerTableSupportingInfo)

getFailedTriggers

public Map<Trigger,Exception> getFailedTriggers()

Specified by:

getFailedTriggers in interface ITriggerRouterService

findTriggerHistoryForGenericSync

public TriggerHistory findTriggerHistoryForGenericSync()

Specified by:

findTriggerHistoryForGenericSync in interface ITriggerRouterService

fillTriggerRoutersByHistIdAndSortHist

public Map<Integer,List<TriggerRouter>> fillTriggerRoutersByHistIdAndSortHist(String sourceNodeGroupId,
 String targetNodeGroupId,
 String targetExternalId,
 List<TriggerHistory> triggerHistories,
 boolean sortByFk)

Specified by:

fillTriggerRoutersByHistIdAndSortHist in interface ITriggerRouterService

fillTriggerRoutersByHistIdAndSortHist

public Map<Integer,List<TriggerRouter>> fillTriggerRoutersByHistIdAndSortHist(String sourceNodeGroupId,
 String targetNodeGroupId,
 String targetExternalId,
 List<TriggerHistory> triggerHistories,
 List<TriggerRouter> triggerRouters,
 boolean sortByFk)

Specified by:

fillTriggerRoutersByHistIdAndSortHist in interface ITriggerRouterService

fillTriggerRoutersByHistId

public Map<Integer,List<TriggerRouter>> fillTriggerRoutersByHistId(String sourceNodeGroupId,
 String targetNodeGroupId,
 String targetExternalId,
 List<TriggerHistory> triggerHistories)

Specified by:

fillTriggerRoutersByHistId in interface ITriggerRouterService

fillTriggerRoutersByHistId

protected Map<Integer,List<TriggerRouter>> fillTriggerRoutersByHistId(String sourceNodeGroupId,
 String targetNodeGroupId,
 String targetExternalId,
 List<TriggerHistory> triggerHistories,
 List<TriggerRouter> triggerRouters)

getSortedTablesFor

public List<Table> getSortedTablesFor(List<TriggerHistory> histories)

Specified by:

getSortedTablesFor in interface ITriggerRouterService

getTablesFor

public List<Table> getTablesFor(List<TriggerHistory> histories)

Specified by:

getTablesFor in interface ITriggerRouterService

awaitTermination

protected void awaitTermination(ExecutorService executor,
 List<Future<?>> futures)

fixMultipleActiveTriggerHistories

protected void fixMultipleActiveTriggerHistories(TriggerRouterContext triggerRouterContext)

getMultipleActiveTriggerHistories

protected List<TriggerHistory> getMultipleActiveTriggerHistories()

getTriggerHistoryIds

protected List<TriggerHistory> getTriggerHistoryIds(TriggerHistory triggerHistory)

logTriggerRouterContextAnomalies

protected void logTriggerRouterContextAnomalies(TriggerRouterContext triggerRouterContext)

logTriggerRouterContextTimings

protected void logTriggerRouterContextTimings(TriggerRouterContext triggerRouterContext)