/[projects]/dao/DaoAdresseVedligehold/src/main/java/dk/daoas/adressevedligehold/db/DatabaseCoverageUpdate.java
ViewVC logotype

Diff of /dao/DaoAdresseVedligehold/src/main/java/dk/daoas/adressevedligehold/db/DatabaseCoverageUpdate.java

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

revision 2840 by torben, Mon Jan 25 10:25:22 2016 UTC revision 2853 by torben, Wed Jan 27 11:44:12 2016 UTC
# Line 20  import dk.daoas.adressevedligehold.util. Line 20  import dk.daoas.adressevedligehold.util.
20    
21  public class DatabaseLayerImplementation  {  public class DatabaseLayerImplementation  {
22                    
23          static boolean DEBUG = false;          //static boolean DEBUG = false;
24                    
25                    
26          public List<Address> getAllAdresses() throws SQLException {          public List<Address> getAllAdresses() throws SQLException {
27                  TimingHelper timing = new TimingHelper();                  TimingHelper timing = new TimingHelper();
28                                    
29                  String debugFilter = DatabaseLayerImplementation.DEBUG ? " WHERE postnr = 8700 " : "";                  //String debugFilter = DatabaseLayerImplementation.DEBUG ? " WHERE postnr >= 6000 " : "";
30                                    
31                  String sql =                  String sql =
32                                  "SELECT id,vejnavn,husnr,husnrbogstav,kommunekode,vejkode,postnr,gadeid,upper(distributor) AS distributor,dbkbane,latitude,longitude, "                                  "SELECT id,vejnavn,husnr,husnrbogstav,kommunekode,vejkode,postnr,gadeid,upper(distributor) AS distributor,dbkbane,latitude,longitude, "
33                                  + "rutema,korelistema,ruteti,korelisteti,ruteon,korelisteon,ruteto,korelisteto,rutefr,korelistefr,rutelo,korelistelo,ruteso,korelisteso "                                  + "rutema,korelistema,ruteti,korelisteti,ruteon,korelisteon,ruteto,korelisteto,rutefr,korelistefr,rutelo,korelistelo,ruteso,korelisteso "
34                                  + "FROM fulddaekning.adressetabel "                                  + "FROM fulddaekning.adressetabel "
35                                  + debugFilter                                  //+ debugFilter
36                                  ;                                  ;
37                                    
38                  try ( Connection conn = DBConnection.getConnection();                            try ( Connection conn = DBConnection.getConnection();          
# Line 103  public class DatabaseLayerImplementation Line 103  public class DatabaseLayerImplementation
103          }          }
104                    
105          public void updateAddresses(List<Address> addresses) {          public void updateAddresses(List<Address> addresses) {
106                    System.out.println("DB::UpdateAddresses size:" + addresses.size() );
107                                    
108                  String sql = "UPDATE fulddaekning.adressetabel " +                  String sql = "UPDATE fulddaekning.adressetabel " +
109                                          "SET " +                                          "SET " +
# Line 112  public class DatabaseLayerImplementation Line 113  public class DatabaseLayerImplementation
113                                          "RuteTo=?, KorelisteTo=?, " +                                          "RuteTo=?, KorelisteTo=?, " +
114                                          "RuteFr=?, KorelisteFr=?, " +                                          "RuteFr=?, KorelisteFr=?, " +
115                                          "RuteLo=?, KorelisteLo=?, " +                                          "RuteLo=?, KorelisteLo=?, " +
116                                          "RuteSo=?, KorelisteSo=?  " +                                          "RuteSo=?, KorelisteSo=?, " +
117                                          "WHERE id=?";                                      "Distributor=?, " +
118                                        "DBKBane=?, " +
119                                        "Aendret=now() " +
120                                            "WHERE id=? ";
121                                                                                    
122                                                                                    
123                                    
124                  try (Connection con = DBConnection.getConnection()) {                  try (Connection con = DBConnection.getConnection()) {
125                          con.setAutoCommit(false);                          //con.setAutoCommit(false);
126                                                    
127                          try (PreparedStatement stmt = con.prepareStatement(sql)) {                          try (PreparedStatement stmt = con.prepareStatement(sql)) {
128                                  for (Address addr : addresses) {                                  for (Address addr : addresses) {
# Line 137  public class DatabaseLayerImplementation Line 141  public class DatabaseLayerImplementation
141                                          stmt.setString(13, addr.ruteSondag);                                          stmt.setString(13, addr.ruteSondag);
142                                          stmt.setString(14, addr.korelisteSondag);                                          stmt.setString(14, addr.korelisteSondag);
143    
144                                          stmt.setInt(15, addr.id);                                          stmt.setString(15, addr.distributor);
145                                            stmt.setInt(16, addr.dbkBane);
146                                            stmt.setInt(17, addr.id);
147    
148                                                                                    
149                                          stmt.execute();                                          stmt.execute();
# Line 148  public class DatabaseLayerImplementation Line 154  public class DatabaseLayerImplementation
154                                  }                                  }
155                          }                          }
156                                                    
157                          con.commit();                          //con.commit();
158                  } catch (SQLException e) {                  } catch (SQLException e) {
159                          System.out.println("Error updating addresses" + e.getMessage() );                          System.out.println("Error updating addresses" + e.getMessage() );
160                  }                  }
Legend:
Removed from v.2840  
changed lines
  Added in v.2853
  ViewVC Help
Powered by ViewVC 1.1.20