/[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 3114 by torben, Fri Sep 9 09:26:55 2016 UTC revision 3115 by torben, Wed Sep 21 09:10:40 2016 UTC
# Line 121  public class DatabaseCoverageUpdate  { Line 121  public class DatabaseCoverageUpdate  {
121                  }                  }
122          }          }
123                    
124          public void saveNewAddresses(List<Address> addresses) throws Exception {          public int saveNewAddresses(List<Address> addresses) throws Exception {
125                                    
126                  logger.info("DB::saveNewAddresses size:" + addresses.size() );                  logger.info("DB::saveNewAddresses size:" + addresses.size() );
127                                    
# Line 134  public class DatabaseCoverageUpdate  { Line 134  public class DatabaseCoverageUpdate  {
134    
135                                                    
136                          try (PreparedStatement stmt = con.prepareStatement(SQL_INSERT_NEW_ADDRESS)) {                          try (PreparedStatement stmt = con.prepareStatement(SQL_INSERT_NEW_ADDRESS)) {
137                                    int insertCount = 0;
138                                  for (Address addr : addresses) {                                  for (Address addr : addresses) {
139                                                                                    
140                                          String david = String.format("%04d%03d%04d", addr.postnr, addr.kommunekode, addr.vejkode);                                          String david = String.format("%04d%03d%04d", addr.postnr, addr.kommunekode, addr.vejkode);
# Line 178  public class DatabaseCoverageUpdate  { Line 179  public class DatabaseCoverageUpdate  {
179    
180                                                                                    
181                                          stmt.execute();                                          stmt.execute();
182                                          if (stmt.getUpdateCount() != 1) {                                          if (stmt.getUpdateCount() == 1) {
183                                                    insertCount++;
184                                            } else {
185                                                  logger.info("Error executing insert: " + addr);                                                  logger.info("Error executing insert: " + addr);
186                                                  addr.state = AddressState.CREATE_FAIL;                                                  addr.state = AddressState.CREATE_FAIL;
187                                          }                                          }
188                                                                                    
189                                  }                                  }
190                                    
191                                    return insertCount;
192                          }                          }
193                                                    
194                          //con.commit();                          //con.commit();
# Line 193  public class DatabaseCoverageUpdate  { Line 198  public class DatabaseCoverageUpdate  {
198                  }                  }
199          }          }
200                    
201          public void updateAddresses(List<Address> addresses) throws Exception{          public int updateAddresses(List<Address> addresses) throws Exception{
202                  logger.info("DB::UpdateAddresses size:" + addresses.size() );                  logger.info("DB::UpdateAddresses size:" + addresses.size() );
203                                    
204    
# Line 242  public class DatabaseCoverageUpdate  { Line 247  public class DatabaseCoverageUpdate  {
247                                  }                                  }
248                                                                    
249                                  stmt.executeBatch(); //update remainding queries                                  stmt.executeBatch(); //update remainding queries
250                                                                    return count;
251                          }                          }
252                                                    
253                          //con.commit();                          //con.commit();
# Line 250  public class DatabaseCoverageUpdate  { Line 255  public class DatabaseCoverageUpdate  {
255                          logger.warning("Error updating addresses", e );                          logger.warning("Error updating addresses", e );
256                          throw e;                          throw e;
257                  }                  }
258                                    
259          }          }
260                    
261  }  }
Legend:
Removed from v.3114  
changed lines
  Added in v.3115
  ViewVC Help
Powered by ViewVC 1.1.20