Mercurial > dive4elements > river

comparison flys-aft/src/main/java/de/intevation/aft/SyncContext.java @ 4771:e21acb4f5c62

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
Simplified code.
author Sascha L. Teichmann <teichmann@intevation.de>
date Sat, 05 Jan 2013 12:13:16 +0100
parents b195fede1c3b
children f939e1e6cfa4
comparison
equal deleted inserted replaced
4770:28fa48986ae9 4771:e21acb4f5c62
118 boolean debug = log.isDebugEnabled(); 118 boolean debug = log.isDebugEnabled();
119 119
120 Map<TimeInterval, TimeInterval> intervals = 120 Map<TimeInterval, TimeInterval> intervals =
121 new TreeMap<TimeInterval, TimeInterval>(); 121 new TreeMap<TimeInterval, TimeInterval>();
122 122
123 ResultSet rs = null; 123 ResultSet rs = flysStatements
124 .getStatement("select.timeintervals")
125 .executeQuery();
124 126
125 try { 127 try {
126 rs = flysStatements
127 .getStatement("select.timeintervals")
128 .executeQuery();
129
130 while (rs.next()) { 128 while (rs.next()) {
131 int id = rs.getInt("id"); 129 int id = rs.getInt("id");
132 Date start = rs.getDate("start_time"); 130 Date start = rs.getDate("start_time");
133 Date stop = rs.getDate("stop_time"); 131 Date stop = rs.getDate("stop_time");
134 132
141 TimeInterval ti = new TimeInterval(id, start, stop); 139 TimeInterval ti = new TimeInterval(id, start, stop);
142 intervals.put(ti, ti); 140 intervals.put(ti, ti);
143 } 141 }
144 } 142 }
145 finally { 143 finally {
146 if (rs != null) { 144 rs.close();
147 rs.close();
148 }
149 } 145 }
150 146
151 if (debug) { 147 if (debug) {
152 log.debug("loaded time intervals: " + intervals.size()); 148 log.debug("loaded time intervals: " + intervals.size());
153 } 149 }
161 TimeInterval old = flysTimeIntervals.get(key); 157 TimeInterval old = flysTimeIntervals.get(key);
162 if (old != null) { 158 if (old != null) {
163 return old; 159 return old;
164 } 160 }
165 161
166 ResultSet rs = null; 162 ResultSet rs = flysStatements
163 .getStatement("next.timeinterval.id")
164 .executeQuery();
165
167 try { 166 try {
168 rs = flysStatements.getStatement("next.timeinterval.id")
169 .executeQuery();
170 rs.next(); 167 rs.next();
171 key.setId(rs.getInt("time_interval_id")); 168 key.setId(rs.getInt("time_interval_id"));
172 rs.close(); rs = null;
173
174 if (log.isDebugEnabled()) {
175 log.debug("FLYS: Created time interval id: " + key.getId());
176 log.debug("FLYS: " + key);
177 }
178
179 flysStatements.getStatement("insert.timeinterval")
180 .clearParameters()
181 .setInt("id", key.getId())
182 .setObject("start_time", key.getStart())
183 .setObject("stop_time", key.getStop())
184 .execute();
185 } 169 }
186 finally { 170 finally {
187 if (rs != null) { 171 rs.close();
188 rs.close();
189 }
190 } 172 }
173
174 if (log.isDebugEnabled()) {
175 log.debug("FLYS: Created time interval id: " + key.getId());
176 log.debug("FLYS: " + key);
177 }
178
179 flysStatements.getStatement("insert.timeinterval")
180 .clearParameters()
181 .setInt("id", key.getId())
182 .setObject("start_time", key.getStart())
183 .setObject("stop_time", key.getStop())
184 .execute();
191 185
192 flysTimeIntervals.put(key, key); 186 flysTimeIntervals.put(key, key);
193 187
194 return key; 188 return key;
195 } 189 }
196
197 } 190 }
198 // vim:set ts=4 sw=4 si et sta sts=4 fenc=utf8 : 191 // vim:set ts=4 sw=4 si et sta sts=4 fenc=utf8 :
199 192
http://dive4elements.wald.intevation.org