200 |
//con.setAutoCommit(false); |
//con.setAutoCommit(false); |
201 |
|
|
202 |
try (PreparedStatement stmt = con.prepareStatement(sql)) { |
try (PreparedStatement stmt = con.prepareStatement(sql)) { |
203 |
|
int count = 0; |
204 |
|
|
205 |
for (Address addr : addresses) { |
for (Address addr : addresses) { |
206 |
stmt.setString(1, addr.ruteMandag); |
stmt.setString(1, addr.ruteMandag); |
207 |
stmt.setString(2, addr.korelisteMandag); |
stmt.setString(2, addr.korelisteMandag); |
221 |
stmt.setString(15, addr.distributor); |
stmt.setString(15, addr.distributor); |
222 |
stmt.setInt(16, addr.dbkBane); |
stmt.setInt(16, addr.dbkBane); |
223 |
stmt.setInt(17, addr.id); |
stmt.setInt(17, addr.id); |
|
|
|
224 |
|
|
|
stmt.execute(); |
|
|
if (stmt.getUpdateCount() != 1) { |
|
|
logger.warning("Error executing update: " + addr); |
|
|
} |
|
225 |
|
|
226 |
|
stmt.addBatch(); |
227 |
|
count++; |
228 |
|
if (count >= 100) { |
229 |
|
stmt.executeBatch(); |
230 |
|
count = 0; |
231 |
|
} |
232 |
} |
} |
233 |
|
|
234 |
|
stmt.executeBatch(); //update remainding queries |
235 |
|
|
236 |
} |
} |
237 |
|
|
238 |
//con.commit(); |
//con.commit(); |