--- dao/DaoAdresseVedligehold/src/main/java/dk/daoas/adressevedligehold/db/DatabaseLayerImplementation.java 2016/01/25 10:25:22 2840 +++ dao/DaoAdresseVedligehold/src/main/java/dk/daoas/adressevedligehold/db/DatabaseLayerImplementation.java 2016/01/26 08:21:22 2845 @@ -26,7 +26,7 @@ public List
getAllAdresses() throws SQLException { TimingHelper timing = new TimingHelper(); - String debugFilter = DatabaseLayerImplementation.DEBUG ? " WHERE postnr = 8700 " : ""; + String debugFilter = DatabaseLayerImplementation.DEBUG ? " WHERE postnr >= 6000 " : ""; String sql = "SELECT id,vejnavn,husnr,husnrbogstav,kommunekode,vejkode,postnr,gadeid,upper(distributor) AS distributor,dbkbane,latitude,longitude, " @@ -103,6 +103,7 @@ } public void updateAddresses(List
addresses) { + System.out.println("DB::UpdateAddresses size:" + addresses.size() ); String sql = "UPDATE fulddaekning.adressetabel " + "SET " + @@ -112,13 +113,14 @@ "RuteTo=?, KorelisteTo=?, " + "RuteFr=?, KorelisteFr=?, " + "RuteLo=?, KorelisteLo=?, " + - "RuteSo=?, KorelisteSo=? " + + "RuteSo=?, KorelisteSo=?, " + + "Distributor=? " + "WHERE id=?"; try (Connection con = DBConnection.getConnection()) { - con.setAutoCommit(false); + //con.setAutoCommit(false); try (PreparedStatement stmt = con.prepareStatement(sql)) { for (Address addr : addresses) { @@ -137,7 +139,8 @@ stmt.setString(13, addr.ruteSondag); stmt.setString(14, addr.korelisteSondag); - stmt.setInt(15, addr.id); + stmt.setString(15, addr.distributor); + stmt.setInt(16, addr.id); stmt.execute(); @@ -148,7 +151,7 @@ } } - con.commit(); + //con.commit(); } catch (SQLException e) { System.out.println("Error updating addresses" + e.getMessage() ); }