org.jumpmind.symmetric.service.impl
Class ConfigurationService

java.lang.Object
  org.jumpmind.symmetric.service.impl.ConfigurationService

All Implemented Interfaces:

IConfigurationService

public class ConfigurationService
extends java.lang.Object
implements IConfigurationService

Field Summary

protected org.springframework.jdbc.core.JdbcTemplate	jdbcTemplate
protected IParameterService	parameterService

Constructor Summary

ConfigurationService()

Method Summary

void	deleteChannel(Channel channel)
void	flushChannels()
java.util.List<Trigger>	getActiveTriggersForReload(java.lang.String sourceNodeGroupId, java.lang.String targetNodeGroupId)
java.util.List<Trigger>	getActiveTriggersForSourceNodeGroup(java.lang.String sourceNodeGroupId)
java.util.List<NodeChannel>	getChannels()
java.util.List<NodeChannel>	getChannelsFor(boolean failIfTableDoesNotExist) Deprecated.
java.util.List<Trigger>	getConfigurationTriggers(java.lang.String sourceGroupId, java.lang.String targetGroupId, boolean includeNodes)
DataEventAction	getDataEventActionsByGroupId(java.lang.String sourceGroupId, java.lang.String targetGroupId)
java.util.List<NodeGroupLink>	getGroupLinks()
java.util.List<NodeGroupLink>	getGroupLinksFor(java.lang.String nodeGroupId)
TriggerHistory	getHistoryRecordFor(int histId)
java.util.Map<java.lang.Long,TriggerHistory>	getHistoryRecords()
java.util.List<Trigger>	getInactiveTriggersForSourceNodeGroup(java.lang.String sourceNodeGroupId)
TriggerHistory	getLatestHistoryRecordFor(int triggerId)
java.util.List<java.lang.String>	getRootConfigChannelTableNames()
protected org.springframework.jdbc.core.simple.SimpleJdbcTemplate	getSimpleTemplate()
java.lang.String	getSql(java.lang.String key)
Trigger	getTriggerById(int triggerId)
Trigger	getTriggerFor(java.lang.String table, java.lang.String sourceNodeGroupId)
Trigger	getTriggerForTarget(java.lang.String table, java.lang.String sourceNodeGroupId, java.lang.String targetNodeGroupId, java.lang.String channel)
java.util.Map<java.lang.String,java.util.List<Trigger>>	getTriggersByChannelFor(java.lang.String nodeGroupId)
void	inactivateTriggerHistory(TriggerHistory history)
void	insert(Trigger trigger)
void	insert(TriggerHistory newHistRecord)
boolean	isRegistrationServer()
void	saveChannel(Channel channel)
void	setDbDialect(IDbDialect dbDialect)
void	setJdbcTemplate(org.springframework.jdbc.core.JdbcTemplate jdbc)
void	setParameterService(IParameterService parameterService)
void	setRootConfigChannelInitialLoadSelect(java.util.Map<java.lang.String,java.lang.String> rootConfigChannelInitialLoadSelect)
void	setRootConfigChannelTableNames(java.util.List<java.lang.String> configChannelTableNames)
void	setSql(java.util.Map<java.lang.String,java.lang.String> sql)
void	setTablePrefix(java.lang.String tablePrefix)
protected java.sql.SQLException	unwrapSqlException(java.lang.Throwable e)

Methods inherited from class java.lang.Object

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

Field Detail

parameterService

protected IParameterService parameterService

jdbcTemplate

protected org.springframework.jdbc.core.JdbcTemplate jdbcTemplate

Constructor Detail

ConfigurationService

public ConfigurationService()

Method Detail

inactivateTriggerHistory

public void inactivateTriggerHistory(TriggerHistory history)

Specified by:

inactivateTriggerHistory in interface IConfigurationService

getGroupLinks

public java.util.List<NodeGroupLink> getGroupLinks()

Specified by:

getGroupLinks in interface IConfigurationService

getGroupLinksFor

public java.util.List<NodeGroupLink> getGroupLinksFor(java.lang.String nodeGroupId)

Specified by:

getGroupLinksFor in interface IConfigurationService

getRootConfigChannelTableNames

public java.util.List<java.lang.String> getRootConfigChannelTableNames()

Specified by:

getRootConfigChannelTableNames in interface IConfigurationService

saveChannel

public void saveChannel(Channel channel)

Specified by:

saveChannel in interface IConfigurationService

deleteChannel

public void deleteChannel(Channel channel)

Specified by:

deleteChannel in interface IConfigurationService

getConfigurationTriggers

public java.util.List<Trigger> getConfigurationTriggers(java.lang.String sourceGroupId,
                                                        java.lang.String targetGroupId,
                                                        boolean includeNodes)

Specified by:

getConfigurationTriggers in interface IConfigurationService

getChannelsFor

@Deprecated
public java.util.List<NodeChannel> getChannelsFor(boolean failIfTableDoesNotExist)

Deprecated.

Specified by:

getChannelsFor in interface IConfigurationService

getChannels

public java.util.List<NodeChannel> getChannels()

Specified by:

getChannels in interface IConfigurationService

flushChannels

public void flushChannels()

Specified by:

flushChannels in interface IConfigurationService

getDataEventActionsByGroupId

public DataEventAction getDataEventActionsByGroupId(java.lang.String sourceGroupId,
                                                    java.lang.String targetGroupId)

Specified by:

getDataEventActionsByGroupId in interface IConfigurationService

getTriggerFor

public Trigger getTriggerFor(java.lang.String table,
                             java.lang.String sourceNodeGroupId)

Specified by:

getTriggerFor in interface IConfigurationService

getActiveTriggersForSourceNodeGroup

public java.util.List<Trigger> getActiveTriggersForSourceNodeGroup(java.lang.String sourceNodeGroupId)

Specified by:

getActiveTriggersForSourceNodeGroup in interface IConfigurationService

getActiveTriggersForReload

public java.util.List<Trigger> getActiveTriggersForReload(java.lang.String sourceNodeGroupId,
                                                          java.lang.String targetNodeGroupId)

Specified by:

getActiveTriggersForReload in interface IConfigurationService

getInactiveTriggersForSourceNodeGroup

public java.util.List<Trigger> getInactiveTriggersForSourceNodeGroup(java.lang.String sourceNodeGroupId)

Specified by:

getInactiveTriggersForSourceNodeGroup in interface IConfigurationService

getTriggerForTarget

public Trigger getTriggerForTarget(java.lang.String table,
                                   java.lang.String sourceNodeGroupId,
                                   java.lang.String targetNodeGroupId,
                                   java.lang.String channel)

Specified by:

getTriggerForTarget in interface IConfigurationService

getTriggerById

public Trigger getTriggerById(int triggerId)

Specified by:

getTriggerById in interface IConfigurationService

getTriggersByChannelFor

public java.util.Map<java.lang.String,java.util.List<Trigger>> getTriggersByChannelFor(java.lang.String nodeGroupId)

Specified by:

getTriggersByChannelFor in interface IConfigurationService

insert

public void insert(TriggerHistory newHistRecord)

Specified by:

insert in interface IConfigurationService

insert

public void insert(Trigger trigger)

Specified by:

insert in interface IConfigurationService

getHistoryRecords

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

Specified by:

getHistoryRecords in interface IConfigurationService

getHistoryRecordFor

public TriggerHistory getHistoryRecordFor(int histId)

Specified by:

getHistoryRecordFor in interface IConfigurationService

getLatestHistoryRecordFor

public TriggerHistory getLatestHistoryRecordFor(int triggerId)

Specified by:

getLatestHistoryRecordFor in interface IConfigurationService

isRegistrationServer

public boolean isRegistrationServer()

Specified by:

isRegistrationServer in interface IConfigurationService

setRootConfigChannelTableNames

public void setRootConfigChannelTableNames(java.util.List<java.lang.String> configChannelTableNames)

setRootConfigChannelInitialLoadSelect

public void setRootConfigChannelInitialLoadSelect(java.util.Map<java.lang.String,java.lang.String> rootConfigChannelInitialLoadSelect)

setDbDialect

public void setDbDialect(IDbDialect dbDialect)

setTablePrefix

public void setTablePrefix(java.lang.String tablePrefix)

setJdbcTemplate

public void setJdbcTemplate(org.springframework.jdbc.core.JdbcTemplate jdbc)

getSimpleTemplate

protected org.springframework.jdbc.core.simple.SimpleJdbcTemplate getSimpleTemplate()

unwrapSqlException

protected java.sql.SQLException unwrapSqlException(java.lang.Throwable e)

setSql

public void setSql(java.util.Map<java.lang.String,java.lang.String> sql)

getSql

public java.lang.String getSql(java.lang.String key)

setParameterService

public void setParameterService(IParameterService parameterService)