--- dao/DaoAdresseService/src/dk/daoas/daoadresseservice/db/DatabaseLayer.java 2015/02/13 13:48:09 2276 +++ dao/DaoAdresseService/src/dk/daoas/daoadresseservice/db/DatabaseLayer.java 2015/02/15 10:11:13 2296 @@ -6,27 +6,30 @@ import java.sql.SQLException; import java.sql.Statement; import java.util.ArrayList; +import java.util.HashMap; import java.util.List; +import java.util.Map; -import dk.daoas.daoadresseservice.Address; -import dk.daoas.daoadresseservice.AddressUtils; import dk.daoas.daoadresseservice.DaekningsType; -import dk.daoas.daoadresseservice.ExtendedBean; +import dk.daoas.daoadresseservice.beans.Address; +import dk.daoas.daoadresseservice.beans.ExtendedBean; +import dk.daoas.daoadresseservice.beans.HundredePctBean; public class DatabaseLayer { public static List
getAllAdresses() throws SQLException { - String sql = "SELECT id,vejnavn,husnr,husnrbogstav,kommunekode,vejkode,postnr,gadeid,distributor,dbkbane,koreliste,rute " + String sql = "SELECT id,vejnavn,husnr,husnrbogstav,kommunekode,vejkode,postnr,gadeid,upper(distributor) AS distributor,dbkbane,koreliste,rute " + "FROM fulddaekning.adressetabel " - + "WHERE postnr BETWEEN 8700 and 8899 OR POSTNR=8300" //DEBUG only + + "WHERE gadeid IS NOT NULL " + //+ "AND postnr = 8700" //DEBUG only ; Connection conn = DBConnection.getConnection(); Statement stmt = conn.createStatement(java.sql.ResultSet.TYPE_FORWARD_ONLY, java.sql.ResultSet.CONCUR_READ_ONLY); ResultSet res = stmt.executeQuery(sql); - List
list = new ArrayList
(); + List
list = new ArrayList
(2600000);//initial capacity 2.6 mio while (res.next()) { Address a = new Address(); @@ -43,17 +46,13 @@ a.koreliste = res.getString(11); a.rute = res.getString(12); - a.vasketVejnavn = AddressUtils.vaskVejnavn(a.vejnavn); + //a.vasketVejnavn = AddressUtils.vaskVejnavn(a.vejnavn); if (a.rute != null && a.rute.length()> 0) { a.daekningsType = DaekningsType.DAEKNING_DIREKTE; } else { a.daekningsType = DaekningsType.DAEKNING_IKKEDAEKKET; - } - - if (a.distributor != null) { - a.distributor = a.distributor.toUpperCase(); - } + } list.add(a); } @@ -66,8 +65,12 @@ return list; } - public static List getExtendedAdresslistDao() throws SQLException { - String sql = "select orgid, a.id as targetid, afstand,type from fulddaekning.afstand_anden_rute a " + + public static List getExtendedAdresslist() throws SQLException { + //DEBUG + if (true) + return new ArrayList(); + + String sql = "select orgid, a.id as targetid, afstand, LOWER(type) as type from fulddaekning.afstand_anden_rute a " + "join odbc.transporttype t " + "on t.Art = 'Transpost' " + "and ( (t.Type = 'Cykel' and a.Afstand < 1.001) or (t.Type = 'Scooter' and a.Afstand < 1.201) or (t.Type = 'Bil' and a.Afstand < 2.601) ) " + @@ -84,13 +87,13 @@ Statement stmt = conn.createStatement(java.sql.ResultSet.TYPE_FORWARD_ONLY, java.sql.ResultSet.CONCUR_READ_ONLY); ResultSet res = stmt.executeQuery(sql); - List list = new ArrayList(); + List list = new ArrayList( 350000); //Initial capacity 350K while (res.next()) { ExtendedBean eb = new ExtendedBean(); eb.orgId = res.getInt(1); eb.targetId = res.getInt(2); eb.afstand = res.getDouble(3); - eb.transport = res.getString(4).toLowerCase(); + eb.transport = res.getString(4); list.add(eb); } @@ -104,4 +107,36 @@ return list; } + public static Map get100PctList() throws SQLException { + String sql = "SELECT postnr,UPPER(distributor) as distributor,rute,koreliste,dbkbane " + + "FROM bogleveringer.adresser_udenfor_daekning"; + + Connection conn = DBConnection.getConnection(); + Statement stmt = conn.createStatement(java.sql.ResultSet.TYPE_FORWARD_ONLY, java.sql.ResultSet.CONCUR_READ_ONLY); + ResultSet res = stmt.executeQuery(sql); + + Map map = new HashMap(); + + while (res.next()) { + + HundredePctBean bean = new HundredePctBean(); + bean.postnr = res.getInt(1); + bean.distributor = res.getString(2); + bean.rute = res.getString(3); + bean.koreliste = res.getString(4); + bean.dbkBane = res.getInt(5); + + map.put(bean.postnr, bean); + } + + res.close(); + stmt.close(); + conn.close(); + + System.out.println("Loaded " + map.size() + " 100pct beans"); + + return map; + + } + }