summaryrefslogtreecommitdiffstats
path: root/components/datalake-handler/feeder/src/main/java/org
diff options
context:
space:
mode:
authorGuobiao Mo <guobiaomo@chinamobile.com>2019-11-21 17:06:57 -0800
committerGuobiao Mo <guobiaomo@chinamobile.com>2019-11-22 10:51:59 -0800
commita8a31129d5e32fccdbf123a99043b32077453cdf (patch)
treeea7a6e62b278fd1250ecbaa54422e087203778e9 /components/datalake-handler/feeder/src/main/java/org
parentfd2b9d440d736ec55d4734d95fba58ceec6d329b (diff)
Fix UI bugs
Issue-ID: DCAEGEN2-1716 Change-Id: I01a5a3c69ff65afde37650e559619723f100e69a Signed-off-by: Guobiao Mo <guobiaomo@chinamobile.com>
Diffstat (limited to 'components/datalake-handler/feeder/src/main/java/org')
-rw-r--r--components/datalake-handler/feeder/src/main/java/org/onap/datalake/feeder/controller/DbController.java8
-rw-r--r--components/datalake-handler/feeder/src/main/java/org/onap/datalake/feeder/domain/Db.java4
-rw-r--r--components/datalake-handler/feeder/src/main/java/org/onap/datalake/feeder/service/db/MongodbService.java4
3 files changed, 8 insertions, 8 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 6d43300d..54f46e6f 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
@@ -86,10 +86,10 @@ public class DbController {
@GetMapping("/list")
@ResponseBody
- @ApiOperation(value="Get all dbs by tool")
- public List<DbConfig> dblistByTool(@RequestParam boolean tool) {
+ @ApiOperation(value="Get all tools or dbs")
+ public List<DbConfig> dblistByTool(@RequestParam boolean isDb) {
log.info("Search dbs by tool start......");
- Iterable<DbType> dbType = dbTypeRepository.findByTool(tool);
+ Iterable<DbType> dbType = dbTypeRepository.findByTool(!isDb);
List<DbConfig> retDbConfig = new ArrayList<>();
for (DbType item : dbType) {
for (Db d : item.getDbs()) {
@@ -148,7 +148,7 @@ public class DbController {
if(!dbConfig.getName().equals("Elecsticsearch") || dbConfig.getName().equals("Druid"))
{
- newdb.setDatabase(new String(dbConfig.getDatabase()));
+ newdb.setDatabase(dbConfig.getDatabase());
}
dbRepository.save(newdb);
log.info("Db save ....... name: " + dbConfig.getName());
diff --git a/components/datalake-handler/feeder/src/main/java/org/onap/datalake/feeder/domain/Db.java b/components/datalake-handler/feeder/src/main/java/org/onap/datalake/feeder/domain/Db.java
index ff2b87ad..2c235990 100644
--- a/components/datalake-handler/feeder/src/main/java/org/onap/datalake/feeder/domain/Db.java
+++ b/components/datalake-handler/feeder/src/main/java/org/onap/datalake/feeder/domain/Db.java
@@ -79,7 +79,7 @@ public class Db {
private String database;
@Column(name="`encrypt`")
- private Boolean encrypt;
+ private boolean encrypt;
@Column(name="`property1`")
private String property1;
@@ -162,7 +162,7 @@ public class Db {
dbConfig.setPort(getPort());
dbConfig.setPass(getPass());
dbConfig.setLogin(getLogin());
- dbConfig.setEncrypt(getEncrypt());
+ dbConfig.setEncrypt(isEncrypt());
dbConfig.setEnabled(isEnabled());
dbConfig.setDatabase(getDatabase());
dbConfig.setDbTypeId(getDbType().getId());
diff --git a/components/datalake-handler/feeder/src/main/java/org/onap/datalake/feeder/service/db/MongodbService.java b/components/datalake-handler/feeder/src/main/java/org/onap/datalake/feeder/service/db/MongodbService.java
index eb8a3a16..689f83cf 100644
--- a/components/datalake-handler/feeder/src/main/java/org/onap/datalake/feeder/service/db/MongodbService.java
+++ b/components/datalake-handler/feeder/src/main/java/org/onap/datalake/feeder/service/db/MongodbService.java
@@ -106,7 +106,7 @@ public class MongodbService implements DbStoreService {
//http://mongodb.github.io/mongo-java-driver/3.0/driver/reference/connecting/ssl/
if (config.isEnableSSL()) {
- builder.sslEnabled(Boolean.TRUE.equals(mongodb.getEncrypt()));// getEncrypt() can be null
+ builder.sslEnabled(Boolean.TRUE.equals(mongodb.isEncrypt()));// getEncrypt() can be null
}
MongoClientOptions options = builder.build();
List<ServerAddress> addrs = new ArrayList<>();
@@ -162,7 +162,7 @@ public class MongodbService implements DbStoreService {
documents.add(doc);
}
- String collectionName = effectiveTopic.getName().replaceAll("[^a-zA-Z0-9]", "");//remove - _ .
+ String collectionName = effectiveTopic.getName().replaceAll("[^a-zA-Z0-9]", "").toLowerCase();//remove - _ .
MongoCollection<Document> collection = mongoCollectionMap.computeIfAbsent(collectionName, k -> database.getCollection(k));
try {