1 package org.jumpmind.symmetric.service;
2
3 import java.util.List;
4 import java.util.Map;
5
6 import org.jumpmind.symmetric.load.IReloadListener;
7 import org.jumpmind.symmetric.model.Data;
8 import org.jumpmind.symmetric.model.DataEvent;
9 import org.jumpmind.symmetric.model.Node;
10 import org.jumpmind.symmetric.model.Trigger;
11 import org.springframework.transaction.annotation.Transactional;
12
13 public interface IDataService {
14
15 @Transactional
16 public String reloadNode(String nodeId);
17
18 @Transactional
19 public String reloadTable(String nodeId, String tableName);
20
21 @Transactional
22 public String reloadTable(String nodeId, String tableName, String overrideInitialLoadSelect);
23
24 @Transactional
25 public String sendSQL(String nodeId, String tableName, String sql);
26
27 @Transactional
28 public void insertReloadEvent(Node targetNode);
29
30 @Transactional
31 public void insertReloadEvent(final Node targetNode, final Trigger trigger);
32
33 @Transactional
34 public void insertResendConfigEvent(final Node targetNode);
35
36 public void insertHeartbeatEvent(Node node);
37
38 public long insertData(final Data data);
39
40 public void insertDataEvent(DataEvent dataEvent);
41
42 public void insertDataEvent(Data data, String channelId, List<Node> nodes);
43
44 public void insertDataEvent(Data data, String channelId, String transactionId, List<Node> nodes);
45
46 public void insertDataEvent(Data data, String channelId, String nodeId);
47
48 public void insertPurgeEvent(Node targetNode, Trigger trigger);
49
50 public void insertSqlEvent(Node targetNode, Trigger trigger, String sql);
51
52 public void insertSqlEvent(final Node targetNode, String sql);
53
54 public void insertCreateEvent(Node targetNode, Trigger trigger, String xml);
55
56 public Data createData(String tableName);
57
58 public Data createData(String tableName, String whereClause);
59
60 public String[] tokenizeCsvData(String csvData);
61
62 public Map<String, String> getRowDataAsMap(Data data);
63
64 public void setRowDataFromMap(Data data, Map<String, String> map);
65
66 public void addReloadListener(IReloadListener listener);
67
68 public void setReloadListeners(List<IReloadListener> listeners);
69
70 public void removeReloadListener(IReloadListener listener);
71
72 }