summaryrefslogtreecommitdiffstats
path: root/components/datalake-handler/feeder
diff options
context:
space:
mode:
Diffstat (limited to 'components/datalake-handler/feeder')
-rw-r--r--components/datalake-handler/feeder/src/main/java/org/onap/datalake/feeder/controller/DbController.java4
-rw-r--r--components/datalake-handler/feeder/src/main/java/org/onap/datalake/feeder/controller/domain/DbConfig.java1
2 files changed, 3 insertions, 2 deletions
diff --git a/components/datalake-handler/feeder/src/main/java/org/onap/datalake/feeder/controller/DbController.java b/components/datalake-handler/feeder/src/main/java/org/onap/datalake/feeder/controller/DbController.java
index 7ee0e0ae..7e364332 100644
--- a/components/datalake-handler/feeder/src/main/java/org/onap/datalake/feeder/controller/DbController.java
+++ b/components/datalake-handler/feeder/src/main/java/org/onap/datalake/feeder/controller/DbController.java
@@ -108,7 +108,7 @@ public class DbController {
newdb.setEnabled(dbConfig.isEnabled());
newdb.setLogin(dbConfig.getLogin());
newdb.setPass(dbConfig.getPassword());
- newdb.setEncrypt(false);
+ newdb.setEncrypt(dbConfig.isEncrypt());
if(!dbConfig.getName().equals("Elecsticsearch") || !dbConfig.getName().equals("Druid"))
{
@@ -172,7 +172,7 @@ public class DbController {
oldDb.setEnabled(dbConfig.isEnabled());
oldDb.setLogin(dbConfig.getLogin());
oldDb.setPass(dbConfig.getPassword());
- oldDb.setEncrypt(false);
+ oldDb.setEncrypt(dbConfig.isEncrypt());
if(!oldDb.getName().equals("Elecsticsearch") || !oldDb.getName().equals("Druid"))
{
diff --git a/components/datalake-handler/feeder/src/main/java/org/onap/datalake/feeder/controller/domain/DbConfig.java b/components/datalake-handler/feeder/src/main/java/org/onap/datalake/feeder/controller/domain/DbConfig.java
index 10aaba8c..557b545c 100644
--- a/components/datalake-handler/feeder/src/main/java/org/onap/datalake/feeder/controller/domain/DbConfig.java
+++ b/components/datalake-handler/feeder/src/main/java/org/onap/datalake/feeder/controller/domain/DbConfig.java
@@ -38,6 +38,7 @@ public class DbConfig {
private boolean enabled;
private String login;
private String password;
+ private boolean encrypt;
private String database;
private int port;
private String poperties;