--- dao/FuldDaekningWorker/src/dk/daoas/fulddaekning/Database.java 2014/12/09 20:39:45 2238 +++ dao/FuldDaekningWorker/src/dk/daoas/fulddaekning/Database.java 2014/12/15 11:12:21 2247 @@ -7,6 +7,7 @@ import java.sql.ResultSet; import java.sql.SQLException; import java.util.ArrayList; +import java.util.HashMap; import java.util.List; import java.util.Properties; import java.util.Queue; @@ -22,6 +23,8 @@ Connection conn; PreparedStatement saveStmt; + + private HashMap bbCache = new HashMap(); public Database(SafeProperties conf) throws SQLException,IOException { this.conn = getConnection( conf ); @@ -56,11 +59,21 @@ logger.info("Executing: " + sql); conn.createStatement().executeUpdate(sql); - } - + } + public BoundingBox getBoundingbox(String postnr) throws SQLException { - String minPostnr = postnr.replace("x", "0"); - String maxPostnr = postnr.replace("x", "9"); + BoundingBox bb = bbCache.get(postnr); + if ( bb == null ) { + bb = getBoundingboxFromDb(postnr); + bbCache.put(postnr, bb); + } + + return bb.clone();//never return the original / cached object + } + + private BoundingBox getBoundingboxFromDb(String postnr) throws SQLException { + String minPostnr = postnr.replace('x', '0'); + String maxPostnr = postnr.replace('x', '9'); String sql = "SELECT max(latitude) latmax, min(latitude) latmin, max(longitude) lngmax,min(longitude) lngmin " + @@ -84,11 +97,13 @@ return bbox; } + + public Queue hentIkkedaekkedeAdresser(String postnr) throws SQLException { - String minPostnr = postnr.replace("x", "0"); - String maxPostnr = postnr.replace("x", "9"); + String minPostnr = postnr.replace('x', '0'); + String maxPostnr = postnr.replace('x', '9'); ConcurrentLinkedQueue queue = new ConcurrentLinkedQueue(); @@ -124,10 +139,11 @@ */ - String sql = "SELECT concat(left(postnr,3),'x') as postnr2 " + + String sql = "SELECT rpad(left(postnr,?),'4', 'x') as postnr2 " + "FROM fulddaekning.adressetabel " + "WHERE postnr BETWEEN ? AND ? " + - "AND rute is null " + // Træk kun liste på postnumre hvor der er ikke-dækkede adresser + "AND rute is null " + // Trae kun liste paa postnumre hvor der er ikke-daekede adresser + "AND (postnr NOT BETWEEN 3900 and 3999) " + //Skip alle groenlandske postnumre "GROUP BY postnr2 " + "ORDER by postnr2 "; @@ -135,8 +151,11 @@ PreparedStatement stmt = conn.prepareStatement(sql); //stmt.setString(1, Lookup.distributor ); - stmt.setInt(1, consts.getMinPostnr()); - stmt.setInt(2, consts.getMaxPostnr()); + + stmt.setInt(1, consts.getPostnrGroup() ); + + stmt.setInt(2, consts.getMinPostnr()); + stmt.setInt(3, consts.getMaxPostnr()); ResultSet res = stmt.executeQuery(); while (res.next()) { @@ -170,7 +189,7 @@ stmt.setDouble(2, bbox.latitudeMax); stmt.setDouble(3, bbox.longitudeMin); stmt.setDouble(4, bbox.longitudeMax); - stmt.setString(5, Lookup.distributor); + stmt.setString(5, LookupMain.distributor); List list = hentAdresseListe( stmt ); return list.toArray( new Adresse[ list.size() ] ); @@ -192,7 +211,7 @@ PreparedStatement stmt = conn.prepareStatement(sql, java.sql.ResultSet.TYPE_FORWARD_ONLY, java.sql.ResultSet.CONCUR_READ_ONLY); stmt.setFetchSize(Integer.MIN_VALUE); - stmt.setString(1, Lookup.distributor); + stmt.setString(1, LookupMain.distributor); List list = hentAdresseListe( stmt ); return list.toArray( new Adresse[ list.size() ] );