/
FileSyncServiceSqlMap.java
120 lines (93 loc) · 7.38 KB
/
FileSyncServiceSqlMap.java
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
package org.jumpmind.symmetric.service.impl;
import java.util.Map;
import org.jumpmind.db.platform.IDatabasePlatform;
public class FileSyncServiceSqlMap extends AbstractSqlMap {
public FileSyncServiceSqlMap(IDatabasePlatform platform, Map<String, String> replacementTokens) {
super(platform, replacementTokens);
// @formatter:off
putSql("selectFileTriggersSql",
" select trigger_id, base_dir, recurse, " +
" includes_files, excludes_files, " +
" sync_on_create, sync_on_modified, sync_on_delete, " +
" before_copy_script, " +
" after_copy_script, " +
" create_time, last_update_by, " +
" last_update_time " +
" from $(file_trigger) ");
putSql("triggerIdWhere", "where trigger_id=?");
putSql("updateFileTriggerSql",
" update $(file_trigger) set base_dir=?, recurse=?, includes_files=?, " +
" excludes_files=?, sync_on_create=?, sync_on_modified=?, sync_on_delete=?, " +
" before_copy_script=?, after_copy_script=?, " +
" last_update_by=?, last_update_time=? where trigger_id=? ");
putSql("insertFileTriggerSql",
" insert into $(file_trigger) (base_dir, recurse, includes_files, " +
" excludes_files, sync_on_create, sync_on_modified, sync_on_delete, " +
" before_copy_script, after_copy_script, " +
" last_update_by, last_update_time, trigger_id, create_time) " +
" values(?,?,?,?,?,?,?,?,?,?,?,?,?) ");
putSql("selectFileSnapshotSql",
" select trigger_id, router_id, file_path, file_name, last_event_type, crc32_checksum, " +
" file_size, file_modified_time, create_time, last_update_time, last_update_by " +
" from $(file_snapshot) where trigger_id=? and router_id=? ");
putSql("updateFileSnapshotSql",
" update $(file_snapshot) set " +
" last_event_type=?, crc32_checksum=?, " +
" file_size=?, file_modified_time=?, last_update_time=?, " +
" last_update_by=? " +
" where " +
" trigger_id=? and router_id=? and file_path=? and file_name=? ");
putSql("updateFileIncoming",
" update $(file_incoming) set " +
" node_id=?, " +
" file_modified_time=?, " +
" last_event_type=? " +
" where " +
" file_path=? and file_name=? ");
putSql("insertFileIncoming",
" insert into $(file_incoming) (node_id, file_modified_time, last_event_type, file_path, file_name) " +
" values(?,?,?,?,?) ");
putSql("deleteFileIncoming",
" delete from $(file_incoming)");
putSql("findNodeIdFromFileIncoming",
" select node_id from $(file_incoming) where file_path=? and file_name=? and file_modified_time=?");
putSql("deleteFileSnapshotSql",
" delete from $(file_snapshot) " +
" where " +
" trigger_id=? and router_id=? and file_path=? and file_name=? ");
putSql("insertFileSnapshotSql",
" insert into $(file_snapshot) ( " +
" last_event_type, crc32_checksum, " +
" file_size, file_modified_time, create_time, last_update_time, " +
" last_update_by, trigger_id, router_id, file_path, file_name " +
" ) values(?,?,?,?,?,?,?,?,?,?,?) ");
putSql("selectFileTriggerRoutersSql",
" select " +
" tr.trigger_id as trigger_id, tr.router_id as router_id, enabled, " +
" initial_load_enabled, target_base_dir, target_file_path, " +
" conflict_strategy, tr.create_time as create_time, " +
" tr.last_update_by as last_update_by, tr.last_update_time as last_update_time " +
" from $(file_trigger_router) tr ");
putSql("whereTriggerRouterId", "where trigger_id=? and router_id=?");
putSql("fileTriggerRoutersForCurrentNodeWhere", " " +
" inner join $(router) r on " +
" tr.router_id=r.router_id " +
" where r.source_node_group_id=?");
putSql("updateFileTriggerRouterSql",
" update $(file_trigger_router) set " +
" enabled=?, initial_load_enabled=?, target_base_dir=?, " +
" target_file_path=?, " +
" conflict_strategy=?, last_update_by=?, last_update_time=? " +
" where trigger_id=? and router_id=? ");
putSql("insertFileTriggerRouterSql",
" insert into $(file_trigger_router) ( " +
" enabled, initial_load_enabled, target_base_dir, " +
" target_file_path, " +
" conflict_strategy, create_time, last_update_by, " +
" last_update_time, trigger_id, router_id " +
" ) values(?,?,?,?,?,?,?,?,?,?) ");
putSql("deleteFileTriggerRouterSql", ""
+ "delete from $(file_trigger_router) where trigger_id=? and router_id=? ");
putSql("deleteFileTriggerSql", "" + "delete from $(file_trigger) where trigger_id=? ");
}
}