--- dao/DaoAdresseVedligehold/src/main/java/dk/daoas/adressevedligehold/db/DatabaseLayerImplementation.java 2016/02/01 09:09:31 2898 +++ dao/DaoAdresseVedligehold/src/main/java/dk/daoas/adressevedligehold/db/DatabaseLayerImplementation.java 2016/02/03 18:45:33 2903 @@ -9,8 +9,10 @@ import java.util.List; + import dk.daoas.adressevedligehold.beans.Address; import dk.daoas.adressevedligehold.beans.Address.AddressState; +import dk.daoas.adressevedligehold.tasks.TaskLogger; import dk.daoas.adressevedligehold.util.DeduplicateHelper; import dk.daoas.adressevedligehold.util.TimingHelper; @@ -24,6 +26,8 @@ //static boolean DEBUG = false; + private TaskLogger logger = TaskLogger.getInstance(); + public List
getAllAdresses() throws SQLException { TimingHelper timing = new TimingHelper(); @@ -94,14 +98,14 @@ res.close(); - System.out.println("DB Loaded " + list.size() + " adresses in " + timing.getElapsed() + "ms"); + logger.info("DB Loaded " + list.size() + " adresses in " + timing.getElapsed() + "ms"); return list; } } public void saveNewAddresses(List
addresses) { - System.out.println("DB::saveNewAddresses size:" + addresses.size() ); + logger.info("DB::saveNewAddresses size:" + addresses.size() ); String sql = "INSERT IGNORE INTO fulddaekning.adressetabel " + "(vejnavn,husnr,husnrbogstav,kommunekode,vejkode,postnr,gadeid,dbkbane,indlast,aendret,david,googlechecked," + @@ -147,7 +151,7 @@ stmt.execute(); if (stmt.getUpdateCount() != 1) { - System.out.println("Error executing insert: " + addr); + logger.info("Error executing insert: " + addr); addr.state = AddressState.CREATE_FAIL; } @@ -156,12 +160,12 @@ //con.commit(); } catch (SQLException e) { - System.out.println("Error inserting addresses" + e.getMessage() ); + logger.warning("Error inserting addresses", e ); } } public void updateAddresses(List
addresses) { - System.out.println("DB::UpdateAddresses size:" + addresses.size() ); + logger.info("DB::UpdateAddresses size:" + addresses.size() ); String sql = "UPDATE fulddaekning.adressetabel " + "SET " + @@ -214,7 +218,7 @@ //con.commit(); } catch (SQLException e) { - System.out.println("Error updating addresses" + e.getMessage() ); + logger.warning("Error updating addresses", e ); } }