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

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

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

revision 2151 by torben, Wed May 7 07:59:03 2014 UTC revision 2153 by torben, Wed May 7 16:07:46 2014 UTC
# Line 2  package dk.daoas.fulddaekning; Line 2  package dk.daoas.fulddaekning;
2    
3  import java.io.File;  import java.io.File;
4  import java.io.FileReader;  import java.io.FileReader;
 import java.io.IOException;  
 import java.sql.Connection;  
 import java.sql.DriverManager;  
 import java.sql.SQLException;  
5  import java.util.ArrayList;  import java.util.ArrayList;
6  import java.util.List;  import java.util.List;
7  import java.util.Map;  import java.util.Map;
# Line 32  public class Lookup { Line 28  public class Lookup {
28                    
29          Map<Integer, LookupWorker> workers = new ConcurrentHashMap<Integer, LookupWorker>();          Map<Integer, LookupWorker> workers = new ConcurrentHashMap<Integer, LookupWorker>();
30    
31            static int flestDaekkedeAntal = 0;
32            static int flestDaekkedePostnr;
33            
34            static int flestIkkeDaekkedeAntal = 0;
35            static int flestIkkeDaekkedePostnr;
36                    
37                    
38          public Lookup(int postnr, Database db) {          public Lookup(int postnr, Database db) {
# Line 64  public class Lookup { Line 65  public class Lookup {
65                          queue = db.hentIkkedaekkedeAdresser(postnr);                          queue = db.hentIkkedaekkedeAdresser(postnr);
66                          queueSize = queue.size();                          queueSize = queue.size();
67                                                    
68                            if (daekkedeAdresser.size() > flestDaekkedeAntal) {
69                                    flestDaekkedeAntal = daekkedeAdresser.size();
70                                    flestDaekkedePostnr = postnr;
71                            }
72                            
73                            if (queueSize > flestIkkeDaekkedeAntal) {
74                                    flestIkkeDaekkedeAntal = queueSize;
75                                    flestIkkeDaekkedePostnr = postnr;
76                            }
77                            
78                                                    
79                          logger.info("Starter beregning for " + postnr);                          logger.info("Starter beregning for " + postnr);
80                          start2 = System.currentTimeMillis();                          start2 = System.currentTimeMillis();
# Line 92  public class Lookup { Line 103  public class Lookup {
103                  }                  }
104                  long now = System.currentTimeMillis();                  long now = System.currentTimeMillis();
105                                    
106                  logger.info("Antal daekkede:" + daekkedeAdresser.size() );                  logger.info("Antal daekkede:" + daekkedeAdresser.size() + "  postnr=" + postnr);
107                  logger.info("Antal ikke-daekkede:" + queueSize );                  logger.info("Antal ikke-daekkede:" + queueSize + "  postnr=" + postnr);
108                                    
109                  logger.info("Done! elapsed=" + (now-start1) + "/" +  (now-start2) );                  logger.info("Done! elapsed=" + (now-start1) + "/" +  (now-start2) + "  postnr=" + postnr);
110          }          }
111                    
112          public void shutdownWorker(int workerid) {          public void shutdownWorker(int workerid) {
# Line 148  public class Lookup { Line 159  public class Lookup {
159                  verbose = Boolean.parseBoolean( conf.getProperty("VERBOSE") );                  verbose = Boolean.parseBoolean( conf.getProperty("VERBOSE") );
160                  logger.info("Starting with VERBOSE:" + verbose);                  logger.info("Starting with VERBOSE:" + verbose);
161                                    
162                  Connection conn = getConnection();                  Database db = new Database(conf);
                 Database db = new Database(conn);  
163                                    
164                  db.resetResultTable();                  db.resetResultTable();
165    
# Line 168  public class Lookup { Line 178  public class Lookup {
178                  }                  }
179                                    
180                  long now = System.currentTimeMillis();                  long now = System.currentTimeMillis();
181                                                    
182                  logger.info("Fuld load done : " + (now-start) );                  logger.info("Fuld load done : " + (now-start) );
183                    logger.info("Flest Ikke-dækkede, " + flestIkkeDaekkedePostnr + ": " + flestIkkeDaekkedeAntal);
184                    logger.info("Flest Dækkede, " + flestDaekkedePostnr + ": " + flestDaekkedeAntal);
185                                    
186                                    
187                  //Lookup lookup = new Lookup(7400, db);                  //Lookup lookup = new Lookup(7400, db);
188                  //lookup.doLookup();                              //lookup.doLookup();            
189          }          }
           
         public static Connection getConnection() throws SQLException, IOException {  
                                   
                 String db_host = conf.getProperty("DB_HOST");  
                 String db_user = conf.getProperty("DB_USER");  
                 String db_pass = conf.getProperty("DB_PASS");  
   
190                                    
                   
   
             Connection conn = null;  
             Properties connectionProps = new Properties();  
             connectionProps.put("user", db_user);  
             connectionProps.put("password", db_pass);  
   
                 conn = DriverManager.getConnection(  
                            "jdbc:mysql://" +  
                            db_host +  
                            ":3306/",  
                            connectionProps);  
             logger.info("Connected to database");  
             return conn;  
         }  
           
191  }  }
Legend:
Removed from v.2151  
changed lines
  Added in v.2153
  ViewVC Help
Powered by ViewVC 1.1.20