/[projects]/dao/DaoAdresseVedligehold/src/main/java/dk/daoas/adressevedligehold/afstandandenrute/Database.java
ViewVC logotype

Diff of /dao/DaoAdresseVedligehold/src/main/java/dk/daoas/adressevedligehold/afstandandenrute/Database.java

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

revision 2880 by torben, Sat Jan 30 14:15:53 2016 UTC revision 2922 by torben, Thu Feb 4 15:37:14 2016 UTC
# Line 14  import java.util.Queue; Line 14  import java.util.Queue;
14  import java.util.Set;  import java.util.Set;
15  import java.util.TreeSet;  import java.util.TreeSet;
16  import java.util.concurrent.ConcurrentLinkedQueue;  import java.util.concurrent.ConcurrentLinkedQueue;
 import java.util.logging.Logger;  
17    
18  import dk.daoas.adressevedligehold.beans.Address;  import dk.daoas.adressevedligehold.beans.Address;
19    import dk.daoas.adressevedligehold.tasks.TaskLogger;
20  import dk.daoas.adressevedligehold.util.DeduplicateHelper;  import dk.daoas.adressevedligehold.util.DeduplicateHelper;
21    import edu.umd.cs.findbugs.annotations.SuppressFBWarnings;
22    
23    
24    
25  public class Database {  public class Database {
26          Logger logger = Logger.getLogger(Database.class.getName());          private TaskLogger logger = TaskLogger.getInstance();
27    
28          int batchCount = 0;          int batchCount = 0;
29    
# Line 52  public class Database { Line 53  public class Database {
53          public Database(Connection conn)  throws SQLException,IOException {          public Database(Connection conn)  throws SQLException,IOException {
54                  this.conn = conn;                  this.conn = conn;
55    
56                  String sql = "INSERT INTO fulddaekning.afstand_anden_rute_ny (orgId,orgPostnr, orgAddress,orgGadeid,orgHusnr,orgHusnrBogstav,orgRute,id,postnr,Address,gadeid,husnr,husnrbogstav,rute,afstand,`timestamp`) "+                  String sql = "INSERT INTO fulddaekning.afstand_anden_rute_ny (orgId,orgPostnr, orgAdresse,orgGadeid,orgHusnr,orgHusnrBogstav,orgRute,id,postnr,adresse,gadeid,husnr,husnrbogstav,rute,afstand,`timestamp`) "+
57                                  "VALUES (?,?,?,?,?,?,?,?,?,?,?,?,?,?,?, now() )";                                  "VALUES (?,?,?,?,?,?,?,?,?,?,?,?,?,?,?, now() )";
58    
59                  saveStmt = conn.prepareStatement(sql);                            saveStmt = conn.prepareStatement(sql);          
# Line 72  public class Database { Line 73  public class Database {
73                  }                  }
74          }                }      
75                    
76            @SuppressFBWarnings("SQL_NONCONSTANT_STRING_PASSED_TO_EXECUTE")
77          public void renameResultTables() throws SQLException {          public void renameResultTables() throws SQLException {
78                  if (AfstandAndenRuteTask.test_mode == true) {                  if (AfstandAndenRuteTask.test_mode == true) {
79                          throw new RuntimeException("Can not rename tables in test mode");                          throw new RuntimeException("Can not rename tables in test mode");
# Line 99  public class Database { Line 101  public class Database {
101                    
102          public BoundingBox getBoundingbox(short postnr)  {          public BoundingBox getBoundingbox(short postnr)  {
103                  BoundingBox bb = bbCache.get(postnr);                  BoundingBox bb = bbCache.get(postnr);
104                  return bb.clone();//never return the original / cached object                  return new BoundingBox(bb); //never return the original / cached object
105          }          }
106                    
107                    
# Line 113  public class Database { Line 115  public class Database {
115                  logger.info("Henter alle IKKE-daekkede Addressr");                  logger.info("Henter alle IKKE-daekkede Addressr");
116    
117                  String sql = "SELECT id,a.postnr,vejnavn,gadeid,husnr,husnrbogstav,latitude,longitude,ruteMa,p.distributor as ho " +                  String sql = "SELECT id,a.postnr,vejnavn,gadeid,husnr,husnrbogstav,latitude,longitude,ruteMa,p.distributor as ho " +
118                                  "FROM fulddaekning.Addresstabel a " +                                  "FROM fulddaekning.adressetabel a " +
119                                  "LEFT JOIN bogleveringer.postnummerdistributor p on (a.postnr=p.postnr) " +                                  "LEFT JOIN bogleveringer.postnummerdistributor p on (a.postnr=p.postnr) " +
120                                  "WHERE ruteMa IS NULL " +  //Ingen dækning                                  "WHERE ruteMa IS NULL " +  //Ingen dækning
121                                  "AND a.postnr BETWEEN ? AND ? " +                                  "AND a.postnr BETWEEN ? AND ? " +
122                                  "AND latitude IS NOT NULL " +                                  "AND latitude IS NOT NULL " +
123                                  "AND longitude IS NOT NULL " +                                  "AND longitude IS NOT NULL " +
124                                  "AND gadeid IS NOT NULL " +                                  "AND gadeid IS NOT NULL " +
125                                  "AND (a.distributor IS NULL OR a.distributor<>'LUKKET') "                                  "AND (a.distributor IS NULL OR a.distributor<>'LUKKET') " +
126                                    "ORDER BY gadeid "
127                                  ;                                                ;              
128                                    
129                  if (AfstandAndenRuteTask.test_mode == true) {                  if (AfstandAndenRuteTask.test_mode == true) {
# Line 176  public class Database { Line 179  public class Database {
179                                    
180                  if ( alleAddressr == null ) {                  if ( alleAddressr == null ) {
181                          String sql = "SELECT id,a.postnr,vejnavn,gadeid,husnr,husnrbogstav,latitude,longitude,ruteMa,p.distributor as ho " +                          String sql = "SELECT id,a.postnr,vejnavn,gadeid,husnr,husnrbogstav,latitude,longitude,ruteMa,p.distributor as ho " +
182                                          "FROM fulddaekning.Addresstabel a " +                                          "FROM fulddaekning.adressetabel a " +
183                                          "LEFT JOIN bogleveringer.postnummerdistributor p on (a.postnr=p.postnr) " +                                          "LEFT JOIN bogleveringer.postnummerdistributor p on (a.postnr=p.postnr) " +
184                                          "WHERE ruteMa IS NOT NULL " +                                          "WHERE ruteMa IS NOT NULL " +
185                                          "AND latitude IS NOT NULL " +                                          "AND latitude IS NOT NULL " +
# Line 296  public class Database { Line 299  public class Database {
299                                  list.add(adr);                                  list.add(adr);
300                    
301                                  if (consts.doCheckHO() == true && adr.ho == 0) {                                  if (consts.doCheckHO() == true && adr.ho == 0) {
302                                          System.out.println( "Mangler HO" );                                          logger.info( "Mangler HO: " + adr );
303                                          System.out.println( adr );                                          throw new RuntimeException("Mangler HO: "+ adr);
                                         System.exit(0);  
304                                  }                                  }
305                    
306                                  //logger.info( "Adress:" + adr);                                  //logger.info( "Adress:" + adr);
Legend:
Removed from v.2880  
changed lines
  Added in v.2922
  ViewVC Help
Powered by ViewVC 1.1.20