/[projects]/dao/FuldDaekningWorker/src/dk/daoas/fulddaekning/Database.java
ViewVC logotype

Diff of /dao/FuldDaekningWorker/src/dk/daoas/fulddaekning/Database.java

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

revision 2223 by torben, Sat Sep 20 11:15:58 2014 UTC revision 2230 by torben, Mon Sep 29 18:15:48 2014 UTC
# Line 52  public class Database { Line 52  public class Database {
52                  conn.createStatement().executeUpdate(sql);                  conn.createStatement().executeUpdate(sql);
53                                    
54                  logger.info("Rename tables");                  logger.info("Rename tables");
55                  sql = "RENAME TABLE fulddaekning.afstand_anden_rute" + ext + " TO fulddaekning.afstand_anden_rute_old " + ext + ", fulddaekning.afstand_anden_rute_ny TO fulddaekning.afstand_anden_rute" + ext;                  sql = "RENAME TABLE fulddaekning.afstand_anden_rute" + ext + " TO fulddaekning.afstand_anden_rute_old" + ext + ", fulddaekning.afstand_anden_rute_ny TO fulddaekning.afstand_anden_rute" + ext;
56    
57                    logger.info("Executing: " + sql);
58                  conn.createStatement().executeUpdate(sql);                                conn.createStatement().executeUpdate(sql);              
59          }                }      
60    
# Line 149  public class Database { Line 151  public class Database {
151    
152                  List<Adresse> list = hentAdresseListe( stmt );                  List<Adresse> list = hentAdresseListe( stmt );
153                  return list.toArray( new Adresse[ list.size() ] );                  return list.toArray( new Adresse[ list.size() ] );
   
154          }          }
155            
156            
157            public Adresse[] hentAlleDaekkedeAdresser() throws SQLException {
158                    String sql = "SELECT id,postnr,adresse,gadeid,husnr,husnrbogstav,latitude,longitude,rute " +
159                                    "FROM fulddaekning.adressetabel " +
160                                    "WHERE rute IS NOT NULL " +
161                                    "AND latitude IS NOT NULL " +
162                                    "AND longitude IS NOT NULL " +
163                                    "AND distributor = ? ";
164    
165                    // Forward only + concur_read_only + fetchsize tvinger driver til at hente en række af gangen (bedre performance ved store result sets)
166                    // Se http://dev.mysql.com/doc/connector-j/en/connector-j-reference-implementation-notes.html
167                    //PreparedStatement stmt = conn.prepareStatement(sql);
168                    PreparedStatement stmt = conn.prepareStatement(sql, java.sql.ResultSet.TYPE_FORWARD_ONLY, java.sql.ResultSet.CONCUR_READ_ONLY);
169                    stmt.setFetchSize(Integer.MIN_VALUE);
170    
171                    stmt.setString(1, Lookup.distributor);
172    
173                    List<Adresse> list = hentAdresseListe( stmt );
174                    return list.toArray( new Adresse[ list.size() ] );
175            }
176            
177            
178    
179          public synchronized void gemResultat(Adresse orgAdresse, Adresse bedsteAdresse, double bedsteAfstand) throws SQLException {          public synchronized void gemResultat(Adresse orgAdresse, Adresse bedsteAdresse, double bedsteAfstand) throws SQLException {
180                  /*String sql = "INSERT INTO fulddaekning.afstand_anden_rute_thn (orgId,orgPostnr, orgAdresse,orgGadeid,orgHusnr,orgHusnrBogstav,orgLatitude,orgLongitude,orgRute,id,postnr,adresse,gadeid,husnr,husnrbogstav,latitude,longitude,rute,afstand,`timestamp`) "+                  /*String sql = "INSERT INTO fulddaekning.afstand_anden_rute_thn (orgId,orgPostnr, orgAdresse,orgGadeid,orgHusnr,orgHusnrBogstav,orgLatitude,orgLongitude,orgRute,id,postnr,adresse,gadeid,husnr,husnrbogstav,latitude,longitude,rute,afstand,`timestamp`) "+
Legend:
Removed from v.2223  
changed lines
  Added in v.2230
  ViewVC Help
Powered by ViewVC 1.1.20