org.jumpmind.symmetric.service

Interface ITriggerRouterService

All Known Implementing Classes:

TriggerRouterService

public interface ITriggerRouterService

Provides an API to configure TriggerRouters, Triggers and Routers.

Method Summary

Modifier and Type	Method and Description
void	addExtraConfigTable(java.lang.String table)
java.lang.String	buildSymmetricTableRouterId(java.lang.String triggerId, java.lang.String sourceNodeGroupId, java.lang.String targetNodeGroupId)
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.
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)
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)
void	dropTriggers()
void	dropTriggers(java.util.Set<java.lang.String> tables)
void	dropTriggers(TriggerHistory history)
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.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()
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)
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)
Trigger	getTriggerById(java.lang.String triggerId)
Trigger	getTriggerById(java.lang.String triggerId, boolean refreshCache)
Trigger	getTriggerForCurrentNodeById(java.lang.String triggerId)
TriggerHistory	getTriggerHistory(int historyId)
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 catalog, java.lang.String schema, 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.Integer,TriggerRouter>	getTriggerRoutersByTriggerHist(java.lang.String targetNodeGroupId, 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)
java.util.List<Trigger>	getTriggersForCurrentNode(boolean refreshCache) Returns a list of triggers that should be active for the current node.
void	inactivateTriggerHistory(TriggerHistory history)
void	insert(TriggerHistory newAuditRecord)
boolean	isRouterBeingUsed(java.lang.String routerId)
boolean	isTriggerBeingUsed(java.lang.String triggerId)
boolean	refreshFromDatabase()
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 verifyTrigger)
void	syncTriggers()
void	syncTriggers(boolean genAlways)
void	syncTriggers(java.lang.StringBuilder sqlBuffer, boolean genAlways)
void	syncTriggers(org.jumpmind.db.model.Table table, boolean genAlways)

Method Detail

refreshFromDatabase

boolean refreshFromDatabase()

getActiveTriggerHistoriesFromCache

java.util.List<TriggerHistory> getActiveTriggerHistoriesFromCache()

getActiveTriggerHistories

java.util.List<TriggerHistory> getActiveTriggerHistories()

getActiveTriggerHistories

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

getActiveTriggerHistories

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

getTriggerRouters

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

buildTriggerRoutersForSymmetricTables

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.

Parameters:

sourceGroupId - group id of the node being registered with

targetGroupId - group id of the node that is registering

buildSymmetricTableRouterId

java.lang.String buildSymmetricTableRouterId(java.lang.String triggerId,
                                             java.lang.String sourceNodeGroupId,
                                             java.lang.String targetNodeGroupId)

getTriggerForCurrentNodeById

Trigger getTriggerForCurrentNodeById(java.lang.String triggerId)

getTriggerRouterForCurrentNode

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

getTriggersForCurrentNode

java.util.List<Trigger> getTriggersForCurrentNode(boolean refreshCache)

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

Parameters:

refreshCache - Indicates that the cache should be refreshed

getTriggerRoutersByChannel

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

getTriggerRoutersForCurrentNode

java.util.Map<java.lang.String,java.util.List<TriggerRouter>> getTriggerRoutersForCurrentNode(boolean refreshCache)

Returns a map of trigger routers keyed by trigger id.

Parameters:

refreshCache - Indicates that the cache should be refreshed

getTriggerRoutersByTriggerHist

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

getTriggerRouterByTriggerHist

TriggerRouter getTriggerRouterByTriggerHist(java.lang.String targetNodeGroupId,
                                            int triggerHistId,
                                            boolean refreshCache)

getActiveRouterByIdForCurrentNode

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.

Parameters:

routerId - The router_id to retrieve

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

getRouterById

Router getRouterById(java.lang.String routerId)

getRouterById

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

getRouters

java.util.List<Router> getRouters()

getRouters

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

getRoutersByGroupLink

java.util.List<Router> getRoutersByGroupLink(NodeGroupLink link)

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

isRouterBeingUsed

boolean isRouterBeingUsed(java.lang.String routerId)

deleteRouter

void deleteRouter(Router router)

deleteAllRouters

void deleteAllRouters()

saveRouter

void saveRouter(Router router)

getAllTriggerRoutersForCurrentNode

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

getTriggers

java.util.List<Trigger> getTriggers()

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

getTriggers

java.util.List<Trigger> getTriggers(boolean replaceTokens)

saveTrigger

void saveTrigger(Trigger trigger)

deleteTrigger

void deleteTrigger(Trigger trigger)

dropTriggers

void dropTriggers()

dropTriggers

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

createTriggersOnChannelForTables

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)

isTriggerBeingUsed

boolean isTriggerBeingUsed(java.lang.String triggerId)

doesTriggerExist

boolean doesTriggerExist(java.lang.String triggerId)

doesTriggerExistForTable

boolean doesTriggerExistForTable(java.lang.String tableName)

getAllTriggerRoutersForReloadForCurrentNode

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

getTriggerRouterForTableForCurrentNode

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

getTriggerRouterForTableForCurrentNode

java.util.Set<TriggerRouter> getTriggerRouterForTableForCurrentNode(java.lang.String catalog,
                                                                    java.lang.String schema,
                                                                    java.lang.String tableName,
                                                                    boolean refreshCache)

findTriggerRouterById

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

findTriggerRouterById

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

inactivateTriggerHistory

void inactivateTriggerHistory(TriggerHistory history)

getNewestTriggerHistoryForTrigger

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

getTriggerHistory

TriggerHistory getTriggerHistory(int historyId)

findTriggerHistories

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

findTriggerHistory

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

getTriggerById

Trigger getTriggerById(java.lang.String triggerId)

getTriggerById

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

getTriggerName

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)

insert

void insert(TriggerHistory newAuditRecord)

getHistoryRecords

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

deleteTriggerRouter

void deleteTriggerRouter(TriggerRouter triggerRouter)

deleteTriggerRouter

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

deleteAllTriggerRouters

void deleteAllTriggerRouters()

saveTriggerRouter

void saveTriggerRouter(TriggerRouter triggerRouter,
                       boolean updateTriggerRouterTableOnly)

saveTriggerRouter

void saveTriggerRouter(TriggerRouter triggerRouter)

syncTrigger

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

syncTrigger

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

syncTriggers

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

dropTriggers

void dropTriggers(TriggerHistory history)

syncTriggers

void syncTriggers(boolean genAlways)

syncTriggers

void syncTriggers()

syncTriggers

void syncTriggers(java.lang.StringBuilder sqlBuffer,
                  boolean genAlways)

addExtraConfigTable

void addExtraConfigTable(java.lang.String table)

getFailedTriggers

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

fillTriggerRoutersByHistIdAndSortHist

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)

fillTriggerRoutersByHistIdAndSortHist

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

fillTriggerRoutersByHistId

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

findTriggerHistoryForGenericSync

TriggerHistory findTriggerHistoryForGenericSync()

clearCache

void clearCache()

findMatchingTriggers

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

getTablesFor

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

getSortedTablesFor

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