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

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

Parent Directory Parent Directory | Revision Log Revision Log | View Patch Patch

revision 2383 by torben, Tue Feb 24 20:38:56 2015 UTC revision 2384 by torben, Thu Feb 26 13:11:45 2015 UTC
# Line 15  import dk.daoas.daoadresseservice.Daekni Line 15  import dk.daoas.daoadresseservice.Daekni
15  import dk.daoas.daoadresseservice.beans.Address;  import dk.daoas.daoadresseservice.beans.Address;
16  import dk.daoas.daoadresseservice.beans.ExtendedBean;  import dk.daoas.daoadresseservice.beans.ExtendedBean;
17  import dk.daoas.daoadresseservice.beans.HundredePctBean;  import dk.daoas.daoadresseservice.beans.HundredePctBean;
18    import dk.daoas.daoadresseservice.beans.LoggedAddress;
19  import dk.daoas.daoadresseservice.beans.SearchResult;  import dk.daoas.daoadresseservice.beans.SearchResult;
20  import dk.daoas.daoadresseservice.util.DeduplicateHelper;  import dk.daoas.daoadresseservice.util.DeduplicateHelper;
21    
# Line 195  public class DatabaseLayer { Line 196  public class DatabaseLayer {
196                  }                                }              
197          }          }
198                    
199            /*
200             * Bruges til at sammenligne gammel og ny adresse service - kan fjernes engang efter at vi er skiftet til ny service
201             */
202            public static List<LoggedAddress> getLoggedAdresses(int antaldage) throws SQLException {
203                    String sql = "select postnr,adresse,status from logs.hentruteinformation where indlast>=date_sub(curdate(), interval " + antaldage + " day) " +
204                                    "and status IN (10,11,12) " +
205                                    "group by postnr,adresse "
206                                    ;
207    
208                    try ( Connection conn = DBConnection.getConnection();          
209                                    Statement stmt = conn.createStatement(java.sql.ResultSet.TYPE_FORWARD_ONLY, java.sql.ResultSet.CONCUR_READ_ONLY);
210                                    ) {
211    
212    
213                            stmt.setFetchSize(Integer.MIN_VALUE);
214    
215                            ResultSet res = stmt.executeQuery(sql);
216    
217                            List<LoggedAddress> result = new ArrayList<LoggedAddress>();
218    
219                            while (res.next()) {
220                                    LoggedAddress a = new LoggedAddress();                          
221                                    a.postnr = res.getInt(1);                              
222                                    a.adresse = res.getString(2);
223                                    a.status = res.getInt(3);
224    
225                                    result.add(a);
226                            }
227    
228                            res.close();
229    
230                            return result;
231                    }
232            }
233            
234          private static int getStatusInt(SearchResult.Status status) {          private static int getStatusInt(SearchResult.Status status) {
235    
236                  switch (status) {                  switch (status) {
Legend:
Removed from v.2383  
changed lines
  Added in v.2384
  ViewVC Help
Powered by ViewVC 1.1.20