From cd04e5f49ee2c0c486484eb682b16460c895fe22 Mon Sep 17 00:00:00 2001 From: Fabio Sinibaldi Date: Wed, 4 Aug 2021 17:09:30 +0200 Subject: [PATCH] Fixed commit upon deletion of centroids --- .../service/engine/postgis/PostgisDBManager.java | 9 +++++++-- .../geoportal/service/engine/postgis/PostgisIndex.java | 3 ++- 2 files changed, 9 insertions(+), 3 deletions(-) diff --git a/src/main/java/org/gcube/application/geoportal/service/engine/postgis/PostgisDBManager.java b/src/main/java/org/gcube/application/geoportal/service/engine/postgis/PostgisDBManager.java index 106669a..0df70fe 100644 --- a/src/main/java/org/gcube/application/geoportal/service/engine/postgis/PostgisDBManager.java +++ b/src/main/java/org/gcube/application/geoportal/service/engine/postgis/PostgisDBManager.java @@ -108,9 +108,14 @@ public class PostgisDBManager implements PostgisDBManagerI { @Override public int deleteByFieldValue(PostgisTable target, PostgisTable.Field field, Object value) throws SQLException { - PreparedStatement stmt = conn.prepareStatement(target.getDeleteByFieldStatement(field)); + String query=target.getDeleteByFieldStatement(field); + log.debug("Preparing DELETE SQL {} with field {} = {} ",query,field,value); + + PreparedStatement stmt = conn.prepareStatement(query); target.setObjectInPreparedStatement(field, value, stmt, 1); - return stmt.executeUpdate(); + int result=stmt.executeUpdate(); + log.debug("DELETED {} rows ",result); + return result; } @Override diff --git a/src/main/java/org/gcube/application/geoportal/service/engine/postgis/PostgisIndex.java b/src/main/java/org/gcube/application/geoportal/service/engine/postgis/PostgisIndex.java index c2640db..235c7da 100644 --- a/src/main/java/org/gcube/application/geoportal/service/engine/postgis/PostgisIndex.java +++ b/src/main/java/org/gcube/application/geoportal/service/engine/postgis/PostgisIndex.java @@ -105,7 +105,8 @@ public class PostgisIndex { PostgisTable centroidsTable=getCentroidsTable(); log.debug("Deleting centroid if present. ID is "+record.getMongo_id()); int result= db.deleteByFieldValue(centroidsTable, new Field(DBConstants.Concessioni.PRODUCT_ID,FieldType.TEXT), record.getMongo_id()); - log.info("Removed {} entries from gif Index with mongo id {} ",record.getMongo_id()); + db.commit(); + log.info("Removed {} entries from gif Index with mongo id {} ",result,record.getMongo_id()); }catch(Exception e) { log.warn("Unable to remove centroid ",e); }