16 |
import dk.daoas.adressevedligehold.util.DeduplicateHelper; |
import dk.daoas.adressevedligehold.util.DeduplicateHelper; |
17 |
import dk.daoas.adressevedligehold.util.TimingHelper; |
import dk.daoas.adressevedligehold.util.TimingHelper; |
18 |
|
|
19 |
/* |
/* |
|
* TODO: Batched skrivning af updates |
|
|
* TODO: Skrivning af nye adresser |
|
20 |
* |
* |
21 |
*/ |
*/ |
22 |
|
|
23 |
public class DatabaseLayerImplementation { |
public class DatabaseCoverageUpdate { |
24 |
|
|
25 |
//static boolean DEBUG = false; |
//static boolean DEBUG = false; |
26 |
|
|
40 |
; |
; |
41 |
|
|
42 |
try ( Connection conn = DBConnection.getConnection(); |
try ( Connection conn = DBConnection.getConnection(); |
43 |
Statement stmt = conn.createStatement(java.sql.ResultSet.TYPE_FORWARD_ONLY, java.sql.ResultSet.CONCUR_READ_ONLY); |
Statement stmt = conn.createStatement(ResultSet.TYPE_FORWARD_ONLY, ResultSet.CONCUR_READ_ONLY); |
44 |
) { |
) { |
45 |
stmt.setFetchSize(Integer.MIN_VALUE); |
stmt.setFetchSize(Integer.MIN_VALUE); |
46 |
ResultSet res = stmt.executeQuery(sql); |
ResultSet res = stmt.executeQuery(sql); |
114 |
|
|
115 |
|
|
116 |
try (Connection con = DBConnection.getConnection()) { |
try (Connection con = DBConnection.getConnection()) { |
117 |
//con.setAutoCommit(false); |
|
118 |
|
|
119 |
try (PreparedStatement stmt = con.prepareStatement(sql)) { |
try (PreparedStatement stmt = con.prepareStatement(sql)) { |
120 |
for (Address addr : addresses) { |
for (Address addr : addresses) { |
208 |
|
|
209 |
stmt.execute(); |
stmt.execute(); |
210 |
if (stmt.getUpdateCount() != 1) { |
if (stmt.getUpdateCount() != 1) { |
211 |
System.out.println("Error executing update"); |
logger.warning("Error executing update: " + addr); |
212 |
} |
} |
213 |
|
|
214 |
} |
} |