From dd78b08a779a93460626d89f0ef2d33567964abf Mon Sep 17 00:00:00 2001 From: Viktor Seifert Date: Fri, 28 Apr 2023 14:39:34 +0200 Subject: [PATCH] RED-6270: Removed default connection value because it had no effect --- .../v1/processor/utils/jdbc/JDBCUtils.java | 15 ++------------- 1 file changed, 2 insertions(+), 13 deletions(-) diff --git a/persistence-service-v1/persistence-service-processor-v1/src/main/java/com/iqser/red/service/persistence/management/v1/processor/utils/jdbc/JDBCUtils.java b/persistence-service-v1/persistence-service-processor-v1/src/main/java/com/iqser/red/service/persistence/management/v1/processor/utils/jdbc/JDBCUtils.java index 124634ffd..5aecbbbbd 100644 --- a/persistence-service-v1/persistence-service-processor-v1/src/main/java/com/iqser/red/service/persistence/management/v1/processor/utils/jdbc/JDBCUtils.java +++ b/persistence-service-v1/persistence-service-processor-v1/src/main/java/com/iqser/red/service/persistence/management/v1/processor/utils/jdbc/JDBCUtils.java @@ -34,17 +34,7 @@ public class JDBCUtils { private Map getConnectionParameters(DatabaseConnectionEntity databaseConnectionEntity) { - var paramsMap = Optional.ofNullable(databaseConnectionEntity.getParams()); - return getParamsWithDefaults(paramsMap); - } - - - @SuppressWarnings("OptionalUsedAsFieldOrParameterType") - private Map getParamsWithDefaults(Optional> paramsMap) { - - Map params = paramsMap.orElseGet(HashMap::new); - params.put("reWriteBatchedInserts", "true"); - return params; + return Optional.ofNullable(databaseConnectionEntity.getParams()).orElseGet(HashMap::new); } @@ -92,8 +82,7 @@ public class JDBCUtils { private Map getConnectionParameters(DatabaseConnection databaseConnection) { - var params = Optional.ofNullable(databaseConnection.getParams()); - return getParamsWithDefaults(params); + return Optional.ofNullable(databaseConnection.getParams()).orElseGet(HashMap::new); }