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 and Description
TriggerRouterService(ISymmetricEngine engine)

Method Summary

Modifier and Type	Method and Description
void	addExtraConfigTable(java.lang.String table)
protected void	awaitTermination(java.util.concurrent.ExecutorService executor, java.util.List<java.util.concurrent.Future<?>> futures)
java.lang.String	buildSymmetricTableRouterId(java.lang.String triggerId, java.lang.String sourceNodeGroupId, java.lang.String targetNodeGroupId)
protected Trigger	buildTriggerForSymmetricTable(java.lang.String tableName)
java.util.List<TriggerRouter>	buildTriggerRoutersForSymmetricTables(java.lang.String version, NodeGroupLink nodeGroupLink, java.lang.String... tablesToExclude) Return a list of triggers used when extraction configuration data during the registration process.
protected TriggerRouter	buildTriggerRoutersForSymmetricTables(java.lang.String version, Trigger trigger, NodeGroupLink nodeGroupLink)
protected java.util.List<Trigger>	buildTriggersForSymmetricTables(java.lang.String version, java.lang.String... tablesToExclude)
void	clearCache()
void	createTriggersOnChannelForTables(java.lang.String channelId, java.lang.String catalogName, java.lang.String schemaName, java.util.List<java.lang.String> tables, java.lang.String lastUpdateBy)
void	deleteAllRouters()
void	deleteAllTriggerRouters()
void	deleteRouter(Router router)
void	deleteTrigger(Trigger trigger)
protected void	deleteTriggerHistory(TriggerHistory history)
void	deleteTriggerRouter(java.lang.String triggerId, java.lang.String routerId)
void	deleteTriggerRouter(TriggerRouter triggerRouter)
boolean	doesTriggerExist(java.lang.String triggerId)
boolean	doesTriggerExistForTable(java.lang.String tableName)
protected boolean	doesTriggerRouterExistInList(java.util.List<TriggerRouter> triggerRouters, TriggerRouter triggerRouter)
protected void	dropTrigger(java.lang.StringBuilder sqlBuffer, java.lang.String catalog, java.lang.String schema, java.lang.String triggerName, java.lang.String tableName)
void	dropTriggers()
void	dropTriggers(java.util.Set<java.lang.String> tables)
void	dropTriggers(TriggerHistory history)
protected void	dropTriggers(TriggerHistory history, java.lang.StringBuilder sqlBuffer)
java.util.Map<java.lang.Integer,java.util.List<TriggerRouter>>	fillTriggerRoutersByHistId(java.lang.String sourceNodeGroupId, java.lang.String targetNodeGroupId, java.util.List<TriggerHistory> triggerHistories)
protected java.util.Map<java.lang.Integer,java.util.List<TriggerRouter>>	fillTriggerRoutersByHistId(java.lang.String sourceNodeGroupId, java.lang.String targetNodeGroupId, java.util.List<TriggerHistory> triggerHistories, java.util.List<TriggerRouter> triggerRouters)
java.util.Map<java.lang.Integer,java.util.List<TriggerRouter>>	fillTriggerRoutersByHistIdAndSortHist(java.lang.String sourceNodeGroupId, java.lang.String targetNodeGroupId, java.util.List<TriggerHistory> triggerHistories)
java.util.Map<java.lang.Integer,java.util.List<TriggerRouter>>	fillTriggerRoutersByHistIdAndSortHist(java.lang.String sourceNodeGroupId, java.lang.String targetNodeGroupId, java.util.List<TriggerHistory> triggerHistories, java.util.List<TriggerRouter> triggerRouters)
java.util.Collection<Trigger>	findMatchingTriggers(java.util.List<Trigger> triggers, java.lang.String catalog, java.lang.String schema, java.lang.String table)
java.util.List<TriggerHistory>	findTriggerHistories(java.lang.String catalogName, java.lang.String schemaName, java.lang.String tableName)
TriggerHistory	findTriggerHistory(java.lang.String catalogName, java.lang.String schemaName, java.lang.String tableName)
TriggerHistory	findTriggerHistoryForGenericSync()
TriggerRouter	findTriggerRouterById(java.lang.String triggerId, java.lang.String routerId)
TriggerRouter	findTriggerRouterById(java.lang.String triggerId, java.lang.String routerId, boolean refreshCache)
Router	getActiveRouterByIdForCurrentNode(java.lang.String routerId, boolean refreshCache) Get router that is currently in use by a trigger router at the node that is hosting this call.
java.util.List<TriggerHistory>	getActiveTriggerHistories() Get a list of trigger histories that are currently active
java.util.List<TriggerHistory>	getActiveTriggerHistories(java.lang.String tableName)
java.util.List<TriggerHistory>	getActiveTriggerHistories(Trigger trigger)
java.util.List<TriggerHistory>	getActiveTriggerHistoriesFromCache()
java.util.List<TriggerRouter>	getAllTriggerRoutersForCurrentNode(java.lang.String sourceNodeGroupId)
java.util.List<TriggerRouter>	getAllTriggerRoutersForReloadForCurrentNode(java.lang.String sourceNodeGroupId, java.lang.String targetNodeGroupId)
protected java.util.List<TriggerRouter>	getConfigurationTablesTriggerRoutersForCurrentNode(java.lang.String sourceNodeGroupId) Create a list of TriggerRouter for the SymmetricDS tables that should have triggers created for them on the current node.
java.util.Map<Trigger,java.lang.Exception>	getFailedTriggers()
java.util.Map<java.lang.Long,TriggerHistory>	getHistoryRecords()
TriggerHistory	getNewestTriggerHistoryForTrigger(java.lang.String triggerId, java.lang.String catalogName, java.lang.String schemaName, java.lang.String tableName)
Router	getRouterById(java.lang.String routerId)
Router	getRouterById(java.lang.String routerId, boolean refreshCache)
java.util.List<Router>	getRouters()
java.util.List<Router>	getRouters(boolean replaceVariables)
java.util.List<Router>	getRoutersByGroupLink(NodeGroupLink link) Get a list of routers for a specific node group link.
java.util.List<org.jumpmind.db.model.Table>	getSortedTablesFor(java.util.List<TriggerHistory> histories)
java.util.List<org.jumpmind.db.model.Table>	getTablesFor(java.util.List<TriggerHistory> histories)
protected java.util.Set<org.jumpmind.db.model.Table>	getTablesForTrigger(Trigger trigger, java.util.List<Trigger> triggers, boolean useTableCache)
Trigger	getTriggerById(java.lang.String triggerId)
Trigger	getTriggerById(java.lang.String triggerId, boolean refreshCache)
Trigger	getTriggerForCurrentNodeById(java.lang.String triggerId)
protected Trigger	getTriggerFromList(java.lang.String triggerId, java.util.List<Trigger> triggersThatShouldBeActive)
TriggerHistory	getTriggerHistory(int histId)
protected java.util.Set<java.lang.String>	getTriggerIdsFrom(java.util.List<Trigger> triggersThatShouldBeActive)
java.lang.String	getTriggerName(org.jumpmind.symmetric.io.data.DataEventType dml, int maxTriggerNameLength, Trigger trigger, org.jumpmind.db.model.Table table, java.util.List<TriggerHistory> activeTriggerHistories, TriggerHistory oldhist)
TriggerRouter	getTriggerRouterByTriggerHist(java.lang.String targetNodeGroupId, int triggerHistId, boolean refreshCache)
TriggerRouter	getTriggerRouterForCurrentNode(java.lang.String triggerId, java.lang.String routerId, boolean refreshCache)
java.util.Set<TriggerRouter>	getTriggerRouterForTableForCurrentNode(NodeGroupLink link, java.lang.String catalogName, java.lang.String schemaName, java.lang.String tableName, boolean refreshCache)
java.util.Set<TriggerRouter>	getTriggerRouterForTableForCurrentNode(java.lang.String catalogName, java.lang.String schemaName, java.lang.String tableName, boolean refreshCache)
java.util.List<TriggerRouter>	getTriggerRouters(boolean refreshCache)
java.util.Map<java.lang.String,java.util.List<TriggerRouter>>	getTriggerRoutersByChannel(java.lang.String nodeGroupId)
java.util.Map<java.lang.String,java.util.List<TriggerRouter>>	getTriggerRoutersByChannel(java.lang.String nodeGroupId, boolean refreshCache)
java.util.Map<java.lang.Integer,TriggerRouter>	getTriggerRoutersByTriggerHist(java.lang.String targetNodeGroupId, boolean refreshCache)
protected org.jumpmind.symmetric.service.impl.TriggerRouterService.TriggerRoutersCache	getTriggerRoutersCacheForCurrentNode(boolean refreshCache)
java.util.Map<java.lang.String,java.util.List<TriggerRouter>>	getTriggerRoutersForCurrentNode(boolean refreshCache) Returns a map of trigger routers keyed by trigger id.
java.util.List<Trigger>	getTriggers() Get a list of all the triggers that have been defined for the system.
java.util.List<Trigger>	getTriggers(boolean replaceTokens)
protected java.util.List<Trigger>	getTriggersForCurrentNode()
java.util.List<Trigger>	getTriggersForCurrentNode(boolean refreshCache) Returns a list of triggers that should be active for the current node.
void	inactivateTriggerHistory(TriggerHistory history)
protected void	inactivateTriggers(java.util.List<Trigger> triggersThatShouldBeActive, java.lang.StringBuilder sqlBuffer, java.util.List<TriggerHistory> activeTriggerHistories)
void	insert(TriggerHistory newHistRecord)
protected boolean	isEqual(java.lang.String one, java.lang.String two, boolean ignoreCase)
protected boolean	isMatch(NodeGroupLink link, TriggerRouter router)
protected boolean	isMatch(java.lang.String catalogName, java.lang.String schemaName, java.lang.String tableName, Trigger trigger)
boolean	isRouterBeingUsed(java.lang.String routerId)
boolean	isTriggerBeingUsed(java.lang.String triggerId)
protected boolean	isTriggerNameInUse(java.util.List<TriggerHistory> activeTriggerHistories, Trigger trigger, java.lang.String triggerName, TriggerHistory oldhist)
protected void	mergeInConfigurationTablesTriggerRoutersForCurrentNode(java.lang.String sourceNodeGroupId, java.util.List<TriggerRouter> configuredInDatabase)
protected TriggerHistory	rebuildTriggerIfNecessary(java.lang.StringBuilder sqlBuffer, boolean forceRebuild, Trigger trigger, org.jumpmind.symmetric.io.data.DataEventType dmlType, TriggerReBuildReason reason, TriggerHistory oldhist, TriggerHistory hist, boolean triggerIsActive, org.jumpmind.db.model.Table table, java.util.List<TriggerHistory> activeTriggerHistories)
boolean	refreshFromDatabase()
protected void	resetTriggerRouterCacheByNodeGroupId()
void	saveRouter(Router router)
void	saveTrigger(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)
void	syncTriggers()
void	syncTriggers(boolean force)
void	syncTriggers(java.lang.StringBuilder sqlBuffer, boolean force)
void	syncTriggers(org.jumpmind.db.model.Table table, boolean force)
protected java.util.List<TriggerRouter>	toList(java.util.Collection<java.util.List<TriggerRouter>> source)
protected void	updateOrCreateDatabaseTrigger(Trigger trigger, java.util.List<Trigger> triggers, java.lang.StringBuilder sqlBuffer, boolean force, boolean verifyInDatabase, java.util.List<TriggerHistory> activeTriggerHistories, boolean useTableCache)
protected void	updateOrCreateDatabaseTriggers(java.util.List<Trigger> triggers, java.lang.StringBuilder sqlBuffer, boolean force, boolean verifyInDatabase, java.util.List<TriggerHistory> activeTriggerHistories, boolean useTableCache)
protected void	updateOrCreateDatabaseTriggers(Trigger trigger, org.jumpmind.db.model.Table table, java.lang.StringBuilder sqlBuffer, boolean force, boolean verifyInDatabase, java.util.List<TriggerHistory> activeTriggerHistories)
protected void	updateOrCreateDdlTriggers(java.lang.StringBuilder sqlBuffer)

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

TriggerRouterService

public TriggerRouterService(ISymmetricEngine engine)

Method Detail

refreshFromDatabase

public boolean refreshFromDatabase()

Specified by:

refreshFromDatabase in interface ITriggerRouterService

getTriggers

public java.util.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 java.util.List<Trigger> getTriggers(boolean replaceTokens)

Specified by:

getTriggers in interface ITriggerRouterService

isTriggerBeingUsed

public boolean isTriggerBeingUsed(java.lang.String triggerId)

Specified by:

isTriggerBeingUsed in interface ITriggerRouterService

doesTriggerExist

public boolean doesTriggerExist(java.lang.String triggerId)

Specified by:

doesTriggerExist in interface ITriggerRouterService

doesTriggerExistForTable

public boolean doesTriggerExistForTable(java.lang.String tableName)

Specified by:

doesTriggerExistForTable in interface ITriggerRouterService

deleteTrigger

public void deleteTrigger(Trigger trigger)

Specified by:

deleteTrigger in interface ITriggerRouterService

dropTriggers

public void dropTriggers()

Specified by:

dropTriggers in interface ITriggerRouterService

dropTriggers

public void dropTriggers(java.util.Set<java.lang.String> tables)

Specified by:

dropTriggers in interface ITriggerRouterService

deleteTriggerHistory

protected void deleteTriggerHistory(TriggerHistory history)

createTriggersOnChannelForTables

public void createTriggersOnChannelForTables(java.lang.String channelId,
                                             java.lang.String catalogName,
                                             java.lang.String schemaName,
                                             java.util.List<java.lang.String> tables,
                                             java.lang.String lastUpdateBy)

Specified by:

createTriggersOnChannelForTables in interface ITriggerRouterService

findMatchingTriggers

public java.util.Collection<Trigger> findMatchingTriggers(java.util.List<Trigger> triggers,
                                                          java.lang.String catalog,
                                                          java.lang.String schema,
                                                          java.lang.String table)

Specified by:

findMatchingTriggers in interface ITriggerRouterService

inactivateTriggerHistory

public void inactivateTriggerHistory(TriggerHistory history)

Specified by:

inactivateTriggerHistory in interface ITriggerRouterService

getHistoryRecords

public java.util.Map<java.lang.Long,TriggerHistory> getHistoryRecords()

Specified by:

getHistoryRecords in interface ITriggerRouterService

isTriggerNameInUse

protected boolean isTriggerNameInUse(java.util.List<TriggerHistory> activeTriggerHistories,
                                     Trigger trigger,
                                     java.lang.String triggerName,
                                     TriggerHistory oldhist)

findTriggerHistory

public TriggerHistory findTriggerHistory(java.lang.String catalogName,
                                         java.lang.String schemaName,
                                         java.lang.String tableName)

Specified by:

findTriggerHistory in interface ITriggerRouterService

findTriggerHistories

public java.util.List<TriggerHistory> findTriggerHistories(java.lang.String catalogName,
                                                           java.lang.String schemaName,
                                                           java.lang.String tableName)

Specified by:

findTriggerHistories in interface ITriggerRouterService

getTriggerHistory

public TriggerHistory getTriggerHistory(int histId)

Specified by:

getTriggerHistory in interface ITriggerRouterService

getActiveTriggerHistories

public java.util.List<TriggerHistory> getActiveTriggerHistories(Trigger trigger)

Specified by:

getActiveTriggerHistories in interface ITriggerRouterService

getNewestTriggerHistoryForTrigger

public TriggerHistory getNewestTriggerHistoryForTrigger(java.lang.String triggerId,
                                                        java.lang.String catalogName,
                                                        java.lang.String schemaName,
                                                        java.lang.String tableName)

Specified by:

getNewestTriggerHistoryForTrigger in interface ITriggerRouterService

getActiveTriggerHistoriesFromCache

public java.util.List<TriggerHistory> getActiveTriggerHistoriesFromCache()

Specified by:

getActiveTriggerHistoriesFromCache in interface ITriggerRouterService

getActiveTriggerHistories

public java.util.List<TriggerHistory> getActiveTriggerHistories()

Get a list of trigger histories that are currently active

Specified by:

getActiveTriggerHistories in interface ITriggerRouterService

getActiveTriggerHistories

public java.util.List<TriggerHistory> getActiveTriggerHistories(java.lang.String tableName)

Specified by:

getActiveTriggerHistories in interface ITriggerRouterService

buildTriggersForSymmetricTables

protected java.util.List<Trigger> buildTriggersForSymmetricTables(java.lang.String version,
                                                                  java.lang.String... tablesToExclude)

buildTriggerForSymmetricTable

protected Trigger buildTriggerForSymmetricTable(java.lang.String tableName)

buildTriggerRoutersForSymmetricTables

public java.util.List<TriggerRouter> buildTriggerRoutersForSymmetricTables(java.lang.String version,
                                                                           NodeGroupLink nodeGroupLink,
                                                                           java.lang.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 java.lang.String buildSymmetricTableRouterId(java.lang.String triggerId,
                                                    java.lang.String sourceNodeGroupId,
                                                    java.lang.String targetNodeGroupId)

Specified by:

buildSymmetricTableRouterId in interface ITriggerRouterService

buildTriggerRoutersForSymmetricTables

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

getTriggerRouterForTableForCurrentNode

public java.util.Set<TriggerRouter> getTriggerRouterForTableForCurrentNode(java.lang.String catalogName,
                                                                           java.lang.String schemaName,
                                                                           java.lang.String tableName,
                                                                           boolean refreshCache)

Specified by:

getTriggerRouterForTableForCurrentNode in interface ITriggerRouterService

getTriggerRouterForTableForCurrentNode

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

Specified by:

getTriggerRouterForTableForCurrentNode in interface ITriggerRouterService

isMatch

protected boolean isMatch(NodeGroupLink link,
                          TriggerRouter router)

isMatch

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

getConfigurationTablesTriggerRoutersForCurrentNode

protected java.util.List<TriggerRouter> getConfigurationTablesTriggerRoutersForCurrentNode(java.lang.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(java.lang.String sourceNodeGroupId,
                                                                      java.util.List<TriggerRouter> configuredInDatabase)

doesTriggerRouterExistInList

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

getTriggerRouterForCurrentNode

public TriggerRouter getTriggerRouterForCurrentNode(java.lang.String triggerId,
                                                    java.lang.String routerId,
                                                    boolean refreshCache)

Specified by:

getTriggerRouterForCurrentNode in interface ITriggerRouterService

getTriggerRoutersForCurrentNode

public java.util.Map<java.lang.String,java.util.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 java.util.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(java.lang.String targetNodeGroupId,
                                                   int triggerHistId,
                                                   boolean refreshCache)

Specified by:

getTriggerRouterByTriggerHist in interface ITriggerRouterService

getTriggerRoutersByTriggerHist

public java.util.Map<java.lang.Integer,TriggerRouter> getTriggerRoutersByTriggerHist(java.lang.String targetNodeGroupId,
                                                                                     boolean refreshCache)

Specified by:

getTriggerRoutersByTriggerHist in interface ITriggerRouterService

getTriggerRoutersCacheForCurrentNode

protected org.jumpmind.symmetric.service.impl.TriggerRouterService.TriggerRoutersCache getTriggerRoutersCacheForCurrentNode(boolean refreshCache)

getActiveRouterByIdForCurrentNode

public Router getActiveRouterByIdForCurrentNode(java.lang.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 java.util.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(java.lang.String triggerId)

Specified by:

getTriggerForCurrentNodeById in interface ITriggerRouterService

getTriggerById

public Trigger getTriggerById(java.lang.String triggerId)

Specified by:

getTriggerById in interface ITriggerRouterService

getTriggerById

public Trigger getTriggerById(java.lang.String triggerId,
                              boolean refreshCache)

Specified by:

getTriggerById in interface ITriggerRouterService

getRouterById

public Router getRouterById(java.lang.String routerId)

Specified by:

getRouterById in interface ITriggerRouterService

getRouterById

public Router getRouterById(java.lang.String routerId,
                            boolean refreshCache)

Specified by:

getRouterById in interface ITriggerRouterService

getRouters

public java.util.List<Router> getRouters()

Specified by:

getRouters in interface ITriggerRouterService

getRouters

public java.util.List<Router> getRouters(boolean replaceVariables)

Specified by:

getRouters in interface ITriggerRouterService

getTriggerRouters

public java.util.List<TriggerRouter> getTriggerRouters(boolean refreshCache)

Specified by:

getTriggerRouters in interface ITriggerRouterService

getAllTriggerRoutersForCurrentNode

public java.util.List<TriggerRouter> getAllTriggerRoutersForCurrentNode(java.lang.String sourceNodeGroupId)

Specified by:

getAllTriggerRoutersForCurrentNode in interface ITriggerRouterService

getAllTriggerRoutersForReloadForCurrentNode

public java.util.List<TriggerRouter> getAllTriggerRoutersForReloadForCurrentNode(java.lang.String sourceNodeGroupId,
                                                                                 java.lang.String targetNodeGroupId)

Specified by:

getAllTriggerRoutersForReloadForCurrentNode in interface ITriggerRouterService

findTriggerRouterById

public TriggerRouter findTriggerRouterById(java.lang.String triggerId,
                                           java.lang.String routerId)

Specified by:

findTriggerRouterById in interface ITriggerRouterService

findTriggerRouterById

public TriggerRouter findTriggerRouterById(java.lang.String triggerId,
                                           java.lang.String routerId,
                                           boolean refreshCache)

Specified by:

findTriggerRouterById in interface ITriggerRouterService

getTriggerRoutersByChannel

public java.util.Map<java.lang.String,java.util.List<TriggerRouter>> getTriggerRoutersByChannel(java.lang.String nodeGroupId)

Specified by:

getTriggerRoutersByChannel in interface ITriggerRouterService

getTriggerRoutersByChannel

public java.util.Map<java.lang.String,java.util.List<TriggerRouter>> getTriggerRoutersByChannel(java.lang.String nodeGroupId,
                                                                                                boolean refreshCache)

insert

public void insert(TriggerHistory newHistRecord)

Specified by:

insert in interface ITriggerRouterService

deleteTriggerRouter

public void deleteTriggerRouter(java.lang.String triggerId,
                                java.lang.String routerId)

Specified by:

deleteTriggerRouter in interface ITriggerRouterService

deleteTriggerRouter

public void deleteTriggerRouter(TriggerRouter triggerRouter)

Specified by:

deleteTriggerRouter in interface ITriggerRouterService

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

resetTriggerRouterCacheByNodeGroupId

protected void resetTriggerRouterCacheByNodeGroupId()

saveRouter

public void saveRouter(Router router)

Specified by:

saveRouter in interface ITriggerRouterService

isRouterBeingUsed

public boolean isRouterBeingUsed(java.lang.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

syncTriggers

public void syncTriggers()

Specified by:

syncTriggers in interface ITriggerRouterService

syncTriggers

public void syncTriggers(boolean force)

Specified by:

syncTriggers in interface ITriggerRouterService

syncTriggers

public void syncTriggers(java.lang.StringBuilder sqlBuffer,
                         boolean force)

Specified by:

syncTriggers in interface ITriggerRouterService

clearCache

public void clearCache()

Specified by:

clearCache in interface ITriggerRouterService

getTriggerIdsFrom

protected java.util.Set<java.lang.String> getTriggerIdsFrom(java.util.List<Trigger> triggersThatShouldBeActive)

getTriggerFromList

protected Trigger getTriggerFromList(java.lang.String triggerId,
                                     java.util.List<Trigger> triggersThatShouldBeActive)

inactivateTriggers

protected void inactivateTriggers(java.util.List<Trigger> triggersThatShouldBeActive,
                                  java.lang.StringBuilder sqlBuffer,
                                  java.util.List<TriggerHistory> activeTriggerHistories)

isEqual

protected boolean isEqual(java.lang.String one,
                          java.lang.String two,
                          boolean ignoreCase)

dropTriggers

public void dropTriggers(TriggerHistory history)

Specified by:

dropTriggers in interface ITriggerRouterService

dropTriggers

protected void dropTriggers(TriggerHistory history,
                            java.lang.StringBuilder sqlBuffer)

dropTrigger

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

toList

protected java.util.List<TriggerRouter> toList(java.util.Collection<java.util.List<TriggerRouter>> source)

getTriggersForCurrentNode

protected java.util.List<Trigger> getTriggersForCurrentNode()

getTablesForTrigger

protected java.util.Set<org.jumpmind.db.model.Table> getTablesForTrigger(Trigger trigger,
                                                                         java.util.List<Trigger> triggers,
                                                                         boolean useTableCache)

syncTriggers

public void syncTriggers(org.jumpmind.db.model.Table table,
                         boolean force)

Specified by:

syncTriggers in interface ITriggerRouterService

updateOrCreateDdlTriggers

protected void updateOrCreateDdlTriggers(java.lang.StringBuilder sqlBuffer)

updateOrCreateDatabaseTriggers

protected void updateOrCreateDatabaseTriggers(java.util.List<Trigger> triggers,
                                              java.lang.StringBuilder sqlBuffer,
                                              boolean force,
                                              boolean verifyInDatabase,
                                              java.util.List<TriggerHistory> activeTriggerHistories,
                                              boolean useTableCache)

updateOrCreateDatabaseTrigger

protected void updateOrCreateDatabaseTrigger(Trigger trigger,
                                             java.util.List<Trigger> triggers,
                                             java.lang.StringBuilder sqlBuffer,
                                             boolean force,
                                             boolean verifyInDatabase,
                                             java.util.List<TriggerHistory> activeTriggerHistories,
                                             boolean useTableCache)

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

updateOrCreateDatabaseTriggers

protected void updateOrCreateDatabaseTriggers(Trigger trigger,
                                              org.jumpmind.db.model.Table table,
                                              java.lang.StringBuilder sqlBuffer,
                                              boolean force,
                                              boolean verifyInDatabase,
                                              java.util.List<TriggerHistory> activeTriggerHistories)

rebuildTriggerIfNecessary

protected TriggerHistory rebuildTriggerIfNecessary(java.lang.StringBuilder sqlBuffer,
                                                   boolean forceRebuild,
                                                   Trigger trigger,
                                                   org.jumpmind.symmetric.io.data.DataEventType dmlType,
                                                   TriggerReBuildReason reason,
                                                   TriggerHistory oldhist,
                                                   TriggerHistory hist,
                                                   boolean triggerIsActive,
                                                   org.jumpmind.db.model.Table table,
                                                   java.util.List<TriggerHistory> activeTriggerHistories)

getTriggerName

public java.lang.String getTriggerName(org.jumpmind.symmetric.io.data.DataEventType dml,
                                       int maxTriggerNameLength,
                                       Trigger trigger,
                                       org.jumpmind.db.model.Table table,
                                       java.util.List<TriggerHistory> activeTriggerHistories,
                                       TriggerHistory oldhist)

Specified by:

getTriggerName in interface ITriggerRouterService

addExtraConfigTable

public void addExtraConfigTable(java.lang.String table)

Specified by:

addExtraConfigTable in interface ITriggerRouterService

getFailedTriggers

public java.util.Map<Trigger,java.lang.Exception> getFailedTriggers()

Specified by:

getFailedTriggers in interface ITriggerRouterService

findTriggerHistoryForGenericSync

public TriggerHistory findTriggerHistoryForGenericSync()

Specified by:

findTriggerHistoryForGenericSync in interface ITriggerRouterService

fillTriggerRoutersByHistIdAndSortHist

public java.util.Map<java.lang.Integer,java.util.List<TriggerRouter>> fillTriggerRoutersByHistIdAndSortHist(java.lang.String sourceNodeGroupId,
                                                                                                            java.lang.String targetNodeGroupId,
                                                                                                            java.util.List<TriggerHistory> triggerHistories)

Specified by:

fillTriggerRoutersByHistIdAndSortHist in interface ITriggerRouterService

fillTriggerRoutersByHistIdAndSortHist

public java.util.Map<java.lang.Integer,java.util.List<TriggerRouter>> fillTriggerRoutersByHistIdAndSortHist(java.lang.String sourceNodeGroupId,
                                                                                                            java.lang.String targetNodeGroupId,
                                                                                                            java.util.List<TriggerHistory> triggerHistories,
                                                                                                            java.util.List<TriggerRouter> triggerRouters)

Specified by:

fillTriggerRoutersByHistIdAndSortHist in interface ITriggerRouterService

fillTriggerRoutersByHistId

public java.util.Map<java.lang.Integer,java.util.List<TriggerRouter>> fillTriggerRoutersByHistId(java.lang.String sourceNodeGroupId,
                                                                                                 java.lang.String targetNodeGroupId,
                                                                                                 java.util.List<TriggerHistory> triggerHistories)

Specified by:

fillTriggerRoutersByHistId in interface ITriggerRouterService

fillTriggerRoutersByHistId

protected java.util.Map<java.lang.Integer,java.util.List<TriggerRouter>> fillTriggerRoutersByHistId(java.lang.String sourceNodeGroupId,
                                                                                                    java.lang.String targetNodeGroupId,
                                                                                                    java.util.List<TriggerHistory> triggerHistories,
                                                                                                    java.util.List<TriggerRouter> triggerRouters)

getSortedTablesFor

public java.util.List<org.jumpmind.db.model.Table> getSortedTablesFor(java.util.List<TriggerHistory> histories)

Specified by:

getSortedTablesFor in interface ITriggerRouterService

getTablesFor

public java.util.List<org.jumpmind.db.model.Table> getTablesFor(java.util.List<TriggerHistory> histories)

Specified by:

getTablesFor in interface ITriggerRouterService

awaitTermination

protected void awaitTermination(java.util.concurrent.ExecutorService executor,
                                java.util.List<java.util.concurrent.Future<?>> futures)