Fixed commit upon deletion of centroids
This commit is contained in:
parent
38a8b89963
commit
cd04e5f49e
|
@ -108,9 +108,14 @@ public class PostgisDBManager implements PostgisDBManagerI {
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
public int deleteByFieldValue(PostgisTable target, PostgisTable.Field field, Object value) throws SQLException {
|
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);
|
target.setObjectInPreparedStatement(field, value, stmt, 1);
|
||||||
return stmt.executeUpdate();
|
int result=stmt.executeUpdate();
|
||||||
|
log.debug("DELETED {} rows ",result);
|
||||||
|
return result;
|
||||||
}
|
}
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
|
|
|
@ -105,7 +105,8 @@ public class PostgisIndex {
|
||||||
PostgisTable centroidsTable=getCentroidsTable();
|
PostgisTable centroidsTable=getCentroidsTable();
|
||||||
log.debug("Deleting centroid if present. ID is "+record.getMongo_id());
|
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());
|
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) {
|
}catch(Exception e) {
|
||||||
log.warn("Unable to remove centroid ",e);
|
log.warn("Unable to remove centroid ",e);
|
||||||
}
|
}
|
||||||
|
|
Reference in New Issue