/[projects]/dao/DaoAdresseService/src/main/java/dk/daoas/daoadresseservice/db/DatabaseLayer.java
ViewVC logotype

Contents of /dao/DaoAdresseService/src/main/java/dk/daoas/daoadresseservice/db/DatabaseLayer.java

Parent Directory Parent Directory | Revision Log Revision Log


Revision 2607 - (show annotations) (download)
Tue Jul 14 08:48:33 2015 UTC (8 years, 10 months ago) by torben
File size: 10766 byte(s)
marker sammenlignings funktion som deprecated
1 package dk.daoas.daoadresseservice.db;
2
3
4 import java.sql.Connection;
5 import java.sql.PreparedStatement;
6 import java.sql.ResultSet;
7 import java.sql.SQLException;
8 import java.sql.Statement;
9 import java.util.ArrayList;
10 import java.util.HashMap;
11 import java.util.List;
12 import java.util.Map;
13
14 import dk.daoas.daoadresseservice.DaekningsType;
15 import dk.daoas.daoadresseservice.beans.Address;
16 import dk.daoas.daoadresseservice.beans.AliasBean;
17 import dk.daoas.daoadresseservice.beans.ExtendedBean;
18 import dk.daoas.daoadresseservice.beans.HundredePctBean;
19 import dk.daoas.daoadresseservice.beans.LoggedAddress;
20 import dk.daoas.daoadresseservice.beans.SearchResult;
21 import dk.daoas.daoadresseservice.util.DeduplicateHelper;
22
23 public class DatabaseLayer {
24
25 static boolean DEBUG = false;
26
27 public static List<Address> getAllAdresses() throws SQLException {
28 String debugFilter = DatabaseLayer.DEBUG ? " AND postnr = 8700 " : "";
29
30 String sql =
31 "SELECT id,vejnavn,husnr,husnrbogstav,kommunekode,vejkode,postnr,gadeid,upper(distributor) AS distributor,dbkbane,koreliste,rute,korelisteloerdag,ruteloerdag,korelistesoendag,rutesoendag,latitude,longitude "
32 + "FROM fulddaekning.adressetabel "
33 + "WHERE gadeid IS NOT NULL "
34 + debugFilter
35 ;
36
37 try ( Connection conn = DBConnection.getConnection();
38 Statement stmt = conn.createStatement(java.sql.ResultSet.TYPE_FORWARD_ONLY, java.sql.ResultSet.CONCUR_READ_ONLY);
39 ) {
40 stmt.setFetchSize(Integer.MIN_VALUE);
41 ResultSet res = stmt.executeQuery(sql);
42
43 List<Address> list = new ArrayList<Address>(2600000);//initial capacity 2.6 mio
44
45 DeduplicateHelper<String> vejnavnCache = new DeduplicateHelper<String>();
46 DeduplicateHelper<String> husnrbogstavCache = new DeduplicateHelper<String>();
47 DeduplicateHelper<String> distributorCache = new DeduplicateHelper<String>();
48 DeduplicateHelper<String> korelisteCache = new DeduplicateHelper<String>();
49 DeduplicateHelper<String> ruteCache = new DeduplicateHelper<String>();
50
51
52 while (res.next()) {
53
54 Address a = new Address();
55 a.id = res.getInt(1);
56 a.vejnavn = vejnavnCache.getInstance( res.getString(2) );
57 a.husnr = (short) res.getInt(3);
58 a.husnrbogstav = husnrbogstavCache.getInstance( res.getString(4) );
59 a.kommunekode = (short) res.getInt(5);
60 a.vejkode = (short)res.getInt(6);
61 a.postnr = (short)res.getInt(7);
62 a.gadeid = res.getInt(8);
63 a.distributor = distributorCache.getInstance(res.getString(9));
64 a.dbkBane = (short) res.getInt(10);
65
66 a.koreliste = korelisteCache.getInstance( res.getString(11) );
67 a.rute = ruteCache.getInstance( res.getString(12) );
68 a.korelisteLordag = korelisteCache.getInstance( res.getString(13) );
69 a.ruteLordag = ruteCache.getInstance( res.getString(14) );
70 a.korelisteSondag = korelisteCache.getInstance( res.getString(15) );
71 a.ruteSondag = ruteCache.getInstance( res.getString(16) );
72
73 a.latitude = (float) res.getDouble(17);
74 a.longitude = (float) res.getDouble(18);
75
76 //a.vasketVejnavn = AddressUtils.vaskVejnavn(a.vejnavn);
77
78 if (a.rute != null && a.rute.length()> 0) {
79 a.daekningsType = DaekningsType.DAEKNING_DIREKTE;
80 } else {
81 a.daekningsType = DaekningsType.DAEKNING_IKKEDAEKKET;
82 }
83
84 list.add(a);
85 }
86 res.close();
87 stmt.close();
88 conn.close();
89
90 System.out.println("Loaded " + list.size() + " adresses");
91
92 return list;
93 }
94 }
95
96 public static List<AliasBean> getAliasList() throws SQLException {
97
98
99 String sql = "SELECT postnr,vejnavn,aliasvejnavn " +
100 "FROM bogleveringer.vejtabelprod "
101 ;
102
103 try ( Connection conn = DBConnection.getConnection();
104 Statement stmt = conn.createStatement(java.sql.ResultSet.TYPE_FORWARD_ONLY, java.sql.ResultSet.CONCUR_READ_ONLY);
105 ) {
106
107 stmt.setFetchSize(Integer.MIN_VALUE);
108
109 ResultSet res = stmt.executeQuery(sql);
110
111 DeduplicateHelper<String> vejCache = new DeduplicateHelper<String>();
112
113 List<AliasBean> list = new ArrayList<AliasBean>( 5000);
114 while (res.next()) {
115
116 AliasBean ab = new AliasBean();
117 ab.postnr = res.getShort(1);
118 ab.vejnavn = vejCache.getInstance( res.getString(2) );
119 ab.aliasVejnavn = vejCache.getInstance( res.getString(3) );
120
121 list.add(ab);
122 }
123
124 res.close();
125
126 System.out.println("Loaded " + list.size() + " aliase beans");
127
128 return list;
129 }
130
131 }
132
133 public static List<ExtendedBean> getExtendedAdresslist() throws SQLException {
134 String debugFilter1 = DatabaseLayer.DEBUG ? " WHERE orgPostnr = 8700 " : "";
135 String debugFilter2 = DatabaseLayer.DEBUG ? " AND orgPostnr = 8700 " : "";
136
137
138 String sql = "select orgid, a.id as targetid, afstand, LOWER(type) as type from fulddaekning.afstand_anden_rute a " +
139 "join odbc.transporttype t " +
140 "on t.Art = 'Transpost' " +
141 "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) ) " +
142 "and t.Rute = a.Rute " +
143 debugFilter1 +
144
145 "UNION ALL " +
146
147 "SELECT orgid, a.id as targetid, afstand,'' as type FROM fulddaekning.afstand_anden_rute_bk a " +
148 "left join bogleveringer.postnummerdistributor d on d.PostNr = a.orgPostnr " +
149 "WHERE d.Distributor <> 10057 " +
150 debugFilter2
151 ;
152
153 try ( Connection conn = DBConnection.getConnection();
154 Statement stmt = conn.createStatement(java.sql.ResultSet.TYPE_FORWARD_ONLY, java.sql.ResultSet.CONCUR_READ_ONLY);
155 ) {
156
157
158 stmt.setFetchSize(Integer.MIN_VALUE);
159
160 ResultSet res = stmt.executeQuery(sql);
161
162 DeduplicateHelper<String> transportCache = new DeduplicateHelper<String>();
163
164 List<ExtendedBean> list = new ArrayList<ExtendedBean>( 350000); //Initial capacity 350K
165 while (res.next()) {
166
167 ExtendedBean eb = new ExtendedBean();
168 eb.orgId = res.getInt(1);
169 eb.targetId = res.getInt(2);
170 eb.afstand = (float) res.getDouble(3);
171 eb.transport = transportCache.getInstance(res.getString(4));
172
173 list.add(eb);
174 }
175
176 res.close();
177
178 System.out.println("Loaded " + list.size() + " extendedbeans");
179
180 return list;
181 }
182 }
183
184 public static Map<Short,HundredePctBean> get100PctList() throws SQLException {
185 String sql = "SELECT postnr,UPPER(distributor) as distributor,rute,koreliste,dbkbane " +
186 "FROM bogleveringer.adresser_udenfor_daekning";
187
188 try ( Connection conn = DBConnection.getConnection();
189 Statement stmt = conn.createStatement(java.sql.ResultSet.TYPE_FORWARD_ONLY, java.sql.ResultSet.CONCUR_READ_ONLY);
190 ) {
191 ResultSet res = stmt.executeQuery(sql);
192
193 Map<Short, HundredePctBean> map = new HashMap<Short,HundredePctBean>();
194
195 DeduplicateHelper<String> distributorCache = new DeduplicateHelper<String>();
196
197 while (res.next()) {
198
199
200 HundredePctBean bean = new HundredePctBean();
201 bean.postnr = (short) res.getInt(1);
202 bean.distributor = distributorCache.getInstance(res.getString(2));
203 bean.rute = res.getString(3);
204 bean.koreliste = res.getString(4);
205 bean.dbkBane = (short)res.getInt(5);
206
207 map.put(bean.postnr, bean);
208 }
209
210 res.close();
211
212 System.out.println("Loaded " + map.size() + " 100pct beans");
213
214 return map;
215 }
216
217 }
218
219 public static void saveRequestLog(String brugerid, String postnr, String adresse, SearchResult result) throws SQLException {
220 String setVar = "set sql_mode = 'NO_AUTO_CREATE_USER,NO_ENGINE_SUBSTITUTION' ";
221
222 String sql = "INSERT INTO logs.hentruteinformation (postnr,adresse,vejnavn,googlevejnavn,husnr,husnr_bogstav,etage,lejlighed,rest,brugerid,status, indlast) " +
223 "VALUES ( ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, NOW() )";
224
225
226
227 try ( Connection conn = DBConnection.getConnection();
228 Statement setStmt = conn.createStatement();
229 PreparedStatement stmt = conn.prepareStatement(sql);
230 ) {
231
232 setStmt.execute(setVar);
233
234
235 stmt.setInt( 1, safeInt(postnr) );
236 stmt.setString( 2, adresse);
237 stmt.setString( 3, result.splitResult.vej);
238 stmt.setString( 4, coalesce(result.googleVej,result.osmVej) );
239 stmt.setString( 5, nullify(result.splitResult.husnr) );
240 stmt.setString( 6, result.splitResult.litra);
241 stmt.setString( 7, result.splitResult.etage);
242 stmt.setString( 8, result.splitResult.lejlighed);
243 stmt.setString( 9, result.splitResult.resten);
244 stmt.setString(10, brugerid);
245 stmt.setInt(11, getStatusInt(result.status) );
246
247 stmt.executeUpdate();
248
249 }
250 }
251
252 /*
253 * Bruges til at sammenligne gammel og ny adresse service - kan fjernes engang efter at vi er skiftet til ny service
254 */
255 @Deprecated
256 public static List<LoggedAddress> getLoggedAdresses(int antaldage) throws SQLException {
257 String sql = "select postnr,adresse,status from logs.hentruteinformation where indlast>=date_sub(curdate(), interval " + antaldage + " day) " +
258 "and status IN (10,11,12) " +
259 "group by postnr,adresse "
260 ;
261
262 try ( Connection conn = DBConnection.getConnection();
263 Statement stmt = conn.createStatement(java.sql.ResultSet.TYPE_FORWARD_ONLY, java.sql.ResultSet.CONCUR_READ_ONLY);
264 ) {
265
266
267 stmt.setFetchSize(Integer.MIN_VALUE);
268
269 ResultSet res = stmt.executeQuery(sql);
270
271 List<LoggedAddress> result = new ArrayList<LoggedAddress>();
272
273 while (res.next()) {
274 LoggedAddress a = new LoggedAddress();
275 a.postnr = res.getInt(1);
276 a.adresse = res.getString(2);
277 a.status = res.getInt(3);
278
279 result.add(a);
280 }
281
282 res.close();
283
284 return result;
285 }
286 }
287
288 private static int getStatusInt(SearchResult.Status status) {
289
290 switch (status) {
291 case ERROR_UNKNOWN_POSTAL:
292 return 20;
293 case ERROR_MISSING_HOUSENUMBER:
294 return 21;
295 case ERROR_POSTBOX:
296 return 22;
297 case ERROR_UNKNOWN_STREETNAME:
298 return 23;
299 case ERROR_UNKNOWN_ADDRESSPOINT:
300 return 24;
301 case STATUS_NOT_COVERED:
302 return 25;
303 case ERROR_INTERNAL: //
304 return 26;
305
306 case STATUS_OK:
307 return 30;
308
309 default:
310 return 31;
311 }
312 }
313
314 private static int safeInt(String str) {
315 try {
316 return Integer.parseInt( str );
317 } catch (NumberFormatException e) {
318 return 0;
319 }
320 }
321
322 private static String nullify(String str) {
323 if (str == null)
324 return null;
325
326 if (str.equals("")) {
327 return null;
328 } else {
329 return str;
330 }
331 }
332
333 private static String coalesce(String s1, String s2) {
334 if (s1 != null)
335 return s1;
336
337 return s2;
338 }
339
340
341 }

  ViewVC Help
Powered by ViewVC 1.1.20