org.jumpmind.symmetric.service.impl
Class DataService

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

All Implemented Interfaces:

IDataService

public class DataService
extends java.lang.Object
implements IDataService

Field Summary

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

Constructor Summary

DataService()

Method Summary

void	addReloadListener(IReloadListener listener)
Data	createData(java.lang.String tableName)
Data	createData(java.lang.String tableName, java.lang.String whereClause)
java.util.Map<java.lang.String,java.lang.String>	getRowDataAsMap(Data data)
protected org.springframework.jdbc.core.simple.SimpleJdbcTemplate	getSimpleTemplate()
java.lang.String	getSql(java.lang.String key)
void	insertCreateEvent(Node targetNode, Trigger trigger, java.lang.String xml)
long	insertData(Data data)
void	insertDataEvent(DataEvent dataEvent)
void	insertDataEvent(Data data, java.lang.String channelId, java.util.List<Node> nodes)
void	insertDataEvent(Data data, java.lang.String channelId, java.lang.String nodeId)
void	insertDataEvent(Data data, java.lang.String channelId, java.lang.String transactionId, java.util.List<Node> nodes)
void	insertHeartbeatEvent(Node node) Because we can't add a trigger on the _node table, we are artificially generating heartbeat events.
void	insertPurgeEvent(Node targetNode, Trigger trigger)
void	insertReloadEvent(Node targetNode)
void	insertReloadEvent(Node targetNode, Trigger trigger)
void	insertReloadEvent(Node targetNode, Trigger trigger, java.lang.String overrideInitialLoadSelect)
void	insertResendConfigEvent(Node targetNode)
void	insertSqlEvent(Node targetNode, java.lang.String sql)
void	insertSqlEvent(Node targetNode, Trigger trigger, java.lang.String sql)
java.lang.String	reloadNode(java.lang.String nodeId)
java.lang.String	reloadTable(java.lang.String nodeId, java.lang.String tableName)
java.lang.String	reloadTable(java.lang.String nodeId, java.lang.String tableName, java.lang.String overrideInitialLoadSelect)
void	removeReloadListener(IReloadListener listener)
java.lang.String	sendSQL(java.lang.String nodeId, java.lang.String tableName, java.lang.String sql)
void	setConfigurationService(IConfigurationService configurationService)
void	setDbDialect(IDbDialect dbDialect)
void	setJdbcTemplate(org.springframework.jdbc.core.JdbcTemplate jdbc)
void	setNodeService(INodeService nodeService)
void	setOutgoingBatchService(IOutgoingBatchService outgoingBatchService)
void	setParameterService(IParameterService parameterService)
void	setPurgeService(IPurgeService purgeService)
void	setReloadListeners(java.util.List<IReloadListener> listeners)
void	setRowDataFromMap(Data data, java.util.Map<java.lang.String,java.lang.String> map)
void	setSql(java.util.Map<java.lang.String,java.lang.String> sql)
void	setTablePrefix(java.lang.String tablePrefix)
java.lang.String[]	tokenizeCsvData(java.lang.String csvData) Deprecated.
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

DataService

public DataService()

Method Detail

insertReloadEvent

public void insertReloadEvent(Node targetNode,
                              Trigger trigger)

Specified by:

insertReloadEvent in interface IDataService

insertReloadEvent

public void insertReloadEvent(Node targetNode,
                              Trigger trigger,
                              java.lang.String overrideInitialLoadSelect)

insertResendConfigEvent

public void insertResendConfigEvent(Node targetNode)

Specified by:

insertResendConfigEvent in interface IDataService

insertPurgeEvent

public void insertPurgeEvent(Node targetNode,
                             Trigger trigger)

Specified by:

insertPurgeEvent in interface IDataService

insertSqlEvent

public void insertSqlEvent(Node targetNode,
                           Trigger trigger,
                           java.lang.String sql)

Specified by:

insertSqlEvent in interface IDataService

insertSqlEvent

public void insertSqlEvent(Node targetNode,
                           java.lang.String sql)

Specified by:

insertSqlEvent in interface IDataService

insertCreateEvent

public void insertCreateEvent(Node targetNode,
                              Trigger trigger,
                              java.lang.String xml)

Specified by:

insertCreateEvent in interface IDataService

insertData

public long insertData(Data data)

Specified by:

insertData in interface IDataService

insertDataEvent

public void insertDataEvent(DataEvent dataEvent)

Specified by:

insertDataEvent in interface IDataService

insertDataEvent

public void insertDataEvent(Data data,
                            java.lang.String channelId,
                            java.util.List<Node> nodes)

Specified by:

insertDataEvent in interface IDataService

insertDataEvent

public void insertDataEvent(Data data,
                            java.lang.String channelId,
                            java.lang.String transactionId,
                            java.util.List<Node> nodes)

Specified by:

insertDataEvent in interface IDataService

insertDataEvent

public void insertDataEvent(Data data,
                            java.lang.String channelId,
                            java.lang.String nodeId)

Specified by:

insertDataEvent in interface IDataService

reloadNode

public java.lang.String reloadNode(java.lang.String nodeId)

Specified by:

reloadNode in interface IDataService

insertReloadEvent

public void insertReloadEvent(Node targetNode)

Specified by:

insertReloadEvent in interface IDataService

sendSQL

public java.lang.String sendSQL(java.lang.String nodeId,
                                java.lang.String tableName,
                                java.lang.String sql)

Specified by:

sendSQL in interface IDataService

reloadTable

public java.lang.String reloadTable(java.lang.String nodeId,
                                    java.lang.String tableName)

Specified by:

reloadTable in interface IDataService

reloadTable

public java.lang.String reloadTable(java.lang.String nodeId,
                                    java.lang.String tableName,
                                    java.lang.String overrideInitialLoadSelect)

Specified by:

reloadTable in interface IDataService

insertHeartbeatEvent

public void insertHeartbeatEvent(Node node)

Because we can't add a trigger on the _node table, we are artificially generating heartbeat events.

Specified by:

insertHeartbeatEvent in interface IDataService

Parameters:

node -

createData

public Data createData(java.lang.String tableName)

Specified by:

createData in interface IDataService

createData

public Data createData(java.lang.String tableName,
                       java.lang.String whereClause)

Specified by:

createData in interface IDataService

getRowDataAsMap

public java.util.Map<java.lang.String,java.lang.String> getRowDataAsMap(Data data)

Specified by:

getRowDataAsMap in interface IDataService

setRowDataFromMap

public void setRowDataFromMap(Data data,
                              java.util.Map<java.lang.String,java.lang.String> map)

Specified by:

setRowDataFromMap in interface IDataService

tokenizeCsvData

@Deprecated
public java.lang.String[] tokenizeCsvData(java.lang.String csvData)

Deprecated.

Specified by:

tokenizeCsvData in interface IDataService

setReloadListeners

public void setReloadListeners(java.util.List<IReloadListener> listeners)

Specified by:

setReloadListeners in interface IDataService

addReloadListener

public void addReloadListener(IReloadListener listener)

Specified by:

addReloadListener in interface IDataService

removeReloadListener

public void removeReloadListener(IReloadListener listener)

Specified by:

removeReloadListener in interface IDataService

setConfigurationService

public void setConfigurationService(IConfigurationService configurationService)

setNodeService

public void setNodeService(INodeService nodeService)

setDbDialect

public void setDbDialect(IDbDialect dbDialect)

setTablePrefix

public void setTablePrefix(java.lang.String tablePrefix)

setPurgeService

public void setPurgeService(IPurgeService purgeService)

setOutgoingBatchService

public void setOutgoingBatchService(IOutgoingBatchService outgoingBatchService)

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)