summaryrefslogtreecommitdiffstats
path: root/appc-directed-graph/dg-loader/provider/src/main/java/org/onap/sdnc/dg/loader/DGXMLActivate.java
diff options
context:
space:
mode:
Diffstat (limited to 'appc-directed-graph/dg-loader/provider/src/main/java/org/onap/sdnc/dg/loader/DGXMLActivate.java')
-rw-r--r--appc-directed-graph/dg-loader/provider/src/main/java/org/onap/sdnc/dg/loader/DGXMLActivate.java61
1 files changed, 34 insertions, 27 deletions
diff --git a/appc-directed-graph/dg-loader/provider/src/main/java/org/onap/sdnc/dg/loader/DGXMLActivate.java b/appc-directed-graph/dg-loader/provider/src/main/java/org/onap/sdnc/dg/loader/DGXMLActivate.java
index 6af447742..9050fa061 100644
--- a/appc-directed-graph/dg-loader/provider/src/main/java/org/onap/sdnc/dg/loader/DGXMLActivate.java
+++ b/appc-directed-graph/dg-loader/provider/src/main/java/org/onap/sdnc/dg/loader/DGXMLActivate.java
@@ -22,12 +22,11 @@
* ============LICENSE_END=========================================================
*/
-package org.openecomp.sdnc.dg.loader;
+package org.onap.sdnc.dg.loader;
import java.io.File;
import java.util.ArrayList;
import java.util.List;
-
import org.apache.commons.io.FileUtils;
import org.apache.commons.lang.StringUtils;
import org.onap.ccsdk.sli.core.sli.SvcLogicGraph;
@@ -44,63 +43,70 @@ public class DGXMLActivate {
private final SvcLogicStore store;
public static String STRING_ENCODING = "utf-8";
- public DGXMLActivate(String propfile) throws Exception{
- if(StringUtils.isBlank(propfile)){
+ public DGXMLActivate(String propfile) throws Exception {
+ if (StringUtils.isBlank(propfile)) {
throw new Exception(propfile + " Profile file is not defined");
}
this.store = SvcLogicStoreFactory.getSvcLogicStore(propfile);
}
-
+
protected DGXMLActivate(SvcLogicStore store) {
this.store = store;
}
public void activateDg(String activateFilePath) throws Exception {
- logger.info("******************** Activating DG into Database *****************************");
+ logger.info(
+ "******************** Activating DG into Database *****************************");
try {
List<String> errors = new ArrayList<String>();
- if(this.store != null){
+ if (this.store != null) {
File activateFile = new File(activateFilePath);
- if(activateFile != null && activateFile.isFile()){
- List<String> fileLines = FileUtils.readLines(activateFile,STRING_ENCODING);
- if(fileLines != null ){
+ if (activateFile != null && activateFile.isFile()) {
+ List<String> fileLines = FileUtils.readLines(activateFile, STRING_ENCODING);
+ if (fileLines != null) {
for (String line : fileLines) {
- if(line != null && ! line.trim().startsWith("#")){
+ if (line != null && !line.trim().startsWith("#")) {
String lineArray[] = line.trim().split(":");
try {
- if(lineArray != null && lineArray.length >= 4){
+ if (lineArray != null && lineArray.length >= 4) {
String module = lineArray[0];
String rpc = lineArray[1];
String version = lineArray[2];
String mode = lineArray[3];
- if(StringUtils.isNotBlank(module) && StringUtils.isNotBlank(rpc)
- && StringUtils.isNotBlank(version) && StringUtils.isNotBlank(mode)){
+ if (StringUtils.isNotBlank(module)
+ && StringUtils.isNotBlank(rpc)
+ && StringUtils.isNotBlank(version)
+ && StringUtils.isNotBlank(mode)) {
logger.info("Activating DG :" + line);
- SvcLogicGraph graph = this.store.fetch(module, rpc, version, mode);
- if(graph != null){
- logger.info("Found Graph :" + line + " Activating ...");
+ SvcLogicGraph graph =
+ this.store.fetch(module, rpc, version, mode);
+ if (graph != null) {
+ logger.info(
+ "Found Graph :" + line + " Activating ...");
this.store.activate(graph);
- }else{
- throw new Exception("Failed to fetch from Database");
+ } else {
+ throw new Exception(
+ "Failed to fetch from Database");
}
}
}
} catch (Exception e) {
e.printStackTrace();
- errors.add("Failed to Activate "+line + ", "+e.getMessage());
+ errors.add(
+ "Failed to Activate " + line + ", " + e.getMessage());
}
}
}
}
- }else{
+ } else {
throw new Exception(activateFile + " is not a valid Activate file Path");
}
- }else{
+ } else {
throw new Exception("Failed to initialise SvcLogicStore");
}
- if(errors.size() > 0){
+ if (errors.size() > 0) {
throw new Exception(errors.toString());
}
} catch (Exception e) {
@@ -114,18 +120,19 @@ public class DGXMLActivate {
String activateFile = null;
String propertyPath = null;
- if(args != null && args.length >= 2){
+ if (args != null && args.length >= 2) {
activateFile = args[0];
propertyPath = args[1];
- }else{
- throw new Exception("Sufficient inputs for DGXMLActivate are missing <activatefile> <dbPropertyfile>");
+ } else {
+ throw new Exception(
+ "Sufficient inputs for DGXMLActivate are missing <activatefile> <dbPropertyfile>");
}
DGXMLActivate dgXmlActivate = new DGXMLActivate(propertyPath);
dgXmlActivate.activateDg(activateFile);
} catch (Exception e) {
e.printStackTrace();
- }finally {
+ } finally {
System.exit(1);
}
}