--- dao/DaoAdresseVedligehold/src/main/java/dk/daoas/adressevedligehold/db/DatabaseCoverageUpdate.java	2016/09/21 08:30:24	3114
+++ dao/DaoAdresseVedligehold/src/main/java/dk/daoas/adressevedligehold/db/DatabaseCoverageUpdate.java	2016/09/21 09:10:40	3115
@@ -121,7 +121,7 @@
 		}
 	}
 	
-	public void saveNewAddresses(List<Address> addresses) throws Exception {
+	public int saveNewAddresses(List<Address> addresses) throws Exception {
 		
 		logger.info("DB::saveNewAddresses size:" + addresses.size() );
 		
@@ -134,6 +134,7 @@
 
 			
 			try (PreparedStatement stmt = con.prepareStatement(SQL_INSERT_NEW_ADDRESS)) {
+				int insertCount = 0;
 				for (Address addr : addresses) {
 					
 					String david = String.format("%04d%03d%04d", addr.postnr, addr.kommunekode, addr.vejkode);
@@ -178,12 +179,16 @@
 
 					
 					stmt.execute();
-					if (stmt.getUpdateCount() != 1) {
+					if (stmt.getUpdateCount() == 1) {
+						insertCount++;
+					} else {
 						logger.info("Error executing insert: " + addr);
 						addr.state = AddressState.CREATE_FAIL;
 					}
 					
 				}
+				
+				return insertCount;
 			}
 			
 			//con.commit();
@@ -193,7 +198,7 @@
 		}
 	}
 	
-	public void updateAddresses(List<Address> addresses) throws Exception{
+	public int updateAddresses(List<Address> addresses) throws Exception{
 		logger.info("DB::UpdateAddresses size:" + addresses.size() );
 		
 
@@ -242,7 +247,7 @@
 				}
 				
 				stmt.executeBatch(); //update remainding queries
-				
+				return count;
 			}
 			
 			//con.commit();
@@ -250,6 +255,7 @@
 			logger.warning("Error updating addresses", e );
 			throw e;
 		}
+				
 	}
 	
 }