121 |
} |
} |
122 |
} |
} |
123 |
|
|
124 |
public void saveNewAddresses(List<Address> addresses) throws Exception { |
public int saveNewAddresses(List<Address> addresses) throws Exception { |
125 |
|
|
126 |
logger.info("DB::saveNewAddresses size:" + addresses.size() ); |
logger.info("DB::saveNewAddresses size:" + addresses.size() ); |
127 |
|
|
134 |
|
|
135 |
|
|
136 |
try (PreparedStatement stmt = con.prepareStatement(SQL_INSERT_NEW_ADDRESS)) { |
try (PreparedStatement stmt = con.prepareStatement(SQL_INSERT_NEW_ADDRESS)) { |
137 |
|
int insertCount = 0; |
138 |
for (Address addr : addresses) { |
for (Address addr : addresses) { |
139 |
|
|
140 |
String david = String.format("%04d%03d%04d", addr.postnr, addr.kommunekode, addr.vejkode); |
String david = String.format("%04d%03d%04d", addr.postnr, addr.kommunekode, addr.vejkode); |
179 |
|
|
180 |
|
|
181 |
stmt.execute(); |
stmt.execute(); |
182 |
if (stmt.getUpdateCount() != 1) { |
if (stmt.getUpdateCount() == 1) { |
183 |
|
insertCount++; |
184 |
|
} else { |
185 |
logger.info("Error executing insert: " + addr); |
logger.info("Error executing insert: " + addr); |
186 |
addr.state = AddressState.CREATE_FAIL; |
addr.state = AddressState.CREATE_FAIL; |
187 |
} |
} |
188 |
|
|
189 |
} |
} |
190 |
|
|
191 |
|
return insertCount; |
192 |
} |
} |
193 |
|
|
194 |
//con.commit(); |
//con.commit(); |
198 |
} |
} |
199 |
} |
} |
200 |
|
|
201 |
public void updateAddresses(List<Address> addresses) throws Exception{ |
public int updateAddresses(List<Address> addresses) throws Exception{ |
202 |
logger.info("DB::UpdateAddresses size:" + addresses.size() ); |
logger.info("DB::UpdateAddresses size:" + addresses.size() ); |
203 |
|
|
204 |
|
|
247 |
} |
} |
248 |
|
|
249 |
stmt.executeBatch(); //update remainding queries |
stmt.executeBatch(); //update remainding queries |
250 |
|
return count; |
251 |
} |
} |
252 |
|
|
253 |
//con.commit(); |
//con.commit(); |
255 |
logger.warning("Error updating addresses", e ); |
logger.warning("Error updating addresses", e ); |
256 |
throw e; |
throw e; |
257 |
} |
} |
258 |
|
|
259 |
} |
} |
260 |
|
|
261 |
} |
} |