org.jumpmind.symmetric.service
Interface IDataService

All Known Implementing Classes:

DataService

public interface IDataService

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)
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)
void	insertPurgeEvent(Node targetNode, Trigger trigger)
void	insertReloadEvent(Node targetNode)
void	insertReloadEvent(Node targetNode, Trigger trigger)
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	setReloadListeners(java.util.List<IReloadListener> listeners)
void	setRowDataFromMap(Data data, java.util.Map<java.lang.String,java.lang.String> map)
java.lang.String[]	tokenizeCsvData(java.lang.String csvData)

Method Detail

reloadNode

@Transactional
java.lang.String reloadNode(java.lang.String nodeId)

reloadTable

@Transactional
java.lang.String reloadTable(java.lang.String nodeId,
                                           java.lang.String tableName)

reloadTable

@Transactional
java.lang.String reloadTable(java.lang.String nodeId,
                                           java.lang.String tableName,
                                           java.lang.String overrideInitialLoadSelect)

sendSQL

@Transactional
java.lang.String sendSQL(java.lang.String nodeId,
                                       java.lang.String tableName,
                                       java.lang.String sql)

insertReloadEvent

@Transactional
void insertReloadEvent(Node targetNode)

insertReloadEvent

@Transactional
void insertReloadEvent(Node targetNode,
                                     Trigger trigger)

insertResendConfigEvent

@Transactional
void insertResendConfigEvent(Node targetNode)

insertHeartbeatEvent

void insertHeartbeatEvent(Node node)

insertData

long insertData(Data data)

insertDataEvent

void insertDataEvent(DataEvent dataEvent)

insertDataEvent

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

insertDataEvent

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

insertDataEvent

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

insertPurgeEvent

void insertPurgeEvent(Node targetNode,
                      Trigger trigger)

insertSqlEvent

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

insertSqlEvent

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

insertCreateEvent

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

createData

Data createData(java.lang.String tableName)

createData

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

tokenizeCsvData

java.lang.String[] tokenizeCsvData(java.lang.String csvData)

getRowDataAsMap

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

setRowDataFromMap

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

addReloadListener

void addReloadListener(IReloadListener listener)

setReloadListeners

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

removeReloadListener

void removeReloadListener(IReloadListener listener)