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

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

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

revision 2844 by torben, Mon Jan 25 21:43:59 2016 UTC revision 2845 by torben, Tue Jan 26 08:21:22 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 = true;          static boolean DEBUG = false;
24                    
25                    
26          public List<Address> getAllAdresses() throws SQLException {          public List<Address> getAllAdresses() throws SQLException {
# 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                                        "Distributor=? " +
118                                          "WHERE id=?";                                          "WHERE id=?";
119                                                                                    
120                                                                                    
121                                    
122                  try (Connection con = DBConnection.getConnection()) {                  try (Connection con = DBConnection.getConnection()) {
123                          con.setAutoCommit(false);                          //con.setAutoCommit(false);
124                                                    
125                          try (PreparedStatement stmt = con.prepareStatement(sql)) {                          try (PreparedStatement stmt = con.prepareStatement(sql)) {
126                                  for (Address addr : addresses) {                                  for (Address addr : addresses) {
# Line 137  public class DatabaseLayerImplementation Line 139  public class DatabaseLayerImplementation
139                                          stmt.setString(13, addr.ruteSondag);                                          stmt.setString(13, addr.ruteSondag);
140                                          stmt.setString(14, addr.korelisteSondag);                                          stmt.setString(14, addr.korelisteSondag);
141    
142                                          stmt.setInt(15, addr.id);                                          stmt.setString(15, addr.distributor);
143                                            stmt.setInt(16, addr.id);
144    
145                                                                                    
146                                          stmt.execute();                                          stmt.execute();
# Line 148  public class DatabaseLayerImplementation Line 151  public class DatabaseLayerImplementation
151                                  }                                  }
152                          }                          }
153                                                    
154                          con.commit();                          //con.commit();
155                  } catch (SQLException e) {                  } catch (SQLException e) {
156                          System.out.println("Error updating addresses" + e.getMessage() );                          System.out.println("Error updating addresses" + e.getMessage() );
157                  }                  }

Legend:
Removed from v.2844  
changed lines
  Added in v.2845

  ViewVC Help
Powered by ViewVC 1.1.20