Merge pull request #475 from lonvia/reenable-auto-commit-in-updater

reenable autocommit in Updater

Author: lonvia

src/main/java/de/komoot/photon/nominatim/NominatimConnector.java

@@ -235,20 +235,20 @@ public void processRow(ResultSet rs) throws SQLException {
      * @param password db username's password
      */
     public NominatimConnector(String host, int port, String database, String username, String password) {
-        BasicDataSource dataSource = buildDataSource(host, port, database, username, password);
+        BasicDataSource dataSource = buildDataSource(host, port, database, username, password, false);
 
         template = new JdbcTemplate(dataSource);
         template.setFetchSize(100000);
     }
 
-    static BasicDataSource buildDataSource(String host, int port, String database, String username, String password) {
+    static BasicDataSource buildDataSource(String host, int port, String database, String username, String password, boolean autocommit) {
         BasicDataSource dataSource = new BasicDataSource();
 
         dataSource.setUrl(String.format("jdbc:postgres_jts://%s:%d/%s", host, port, database));
         dataSource.setUsername(username);
         dataSource.setPassword(password);
         dataSource.setDriverClassName(JtsWrapper.class.getCanonicalName());
-        dataSource.setDefaultAutoCommit(false);
+        dataSource.setDefaultAutoCommit(autocommit);
         return dataSource;
     }
 

src/main/java/de/komoot/photon/nominatim/NominatimUpdater.java

@@ -184,7 +184,7 @@ public UpdateRow mapRow(ResultSet rs, int rowNum) throws SQLException {
      * @param password Nominatim database password
      */
     public NominatimUpdater(String host, int port, String database, String username, String password) {
-        BasicDataSource dataSource = NominatimConnector.buildDataSource(host, port, database, username, password);
+        BasicDataSource dataSource = NominatimConnector.buildDataSource(host, port, database, username, password, true);
 
         exporter = new NominatimConnector(host, port, database, username, password);
         template = new JdbcTemplate(dataSource);