diff options
2 files changed, 304 insertions, 342 deletions
diff --git a/appc-inbound/appc-design-services/provider/src/main/java/org/onap/appc/design/dbervices/DBDesignException.java b/appc-inbound/appc-design-services/provider/src/main/java/org/onap/appc/design/dbervices/DBDesignException.java new file mode 100644 index 000000000..f7ae77cb4 --- /dev/null +++ b/appc-inbound/appc-design-services/provider/src/main/java/org/onap/appc/design/dbervices/DBDesignException.java @@ -0,0 +1,8 @@ +package org.onap.appc.design.dbervices; + +public class DBDesignException extends Exception { + + public DBDesignException(String message) { + super(message); + } +} diff --git a/appc-inbound/appc-design-services/provider/src/main/java/org/onap/appc/design/dbervices/DesignDBService.java b/appc-inbound/appc-design-services/provider/src/main/java/org/onap/appc/design/dbervices/DesignDBService.java index 7bb5a5f35..5a20c063f 100644 --- a/appc-inbound/appc-design-services/provider/src/main/java/org/onap/appc/design/dbervices/DesignDBService.java +++ b/appc-inbound/appc-design-services/provider/src/main/java/org/onap/appc/design/dbervices/DesignDBService.java @@ -24,44 +24,47 @@ package org.onap.appc.design.dbervices; -import java.io.IOException; +import com.att.eelf.configuration.EELFLogger; +import com.att.eelf.configuration.EELFManager; +import com.fasterxml.jackson.core.JsonParser; +import com.fasterxml.jackson.databind.JsonNode; +import com.fasterxml.jackson.databind.ObjectMapper; import java.sql.ResultSet; import java.sql.SQLException; import java.util.ArrayList; import java.util.List; -import java.util.Properties; - import org.onap.appc.design.data.ArtifactInfo; import org.onap.appc.design.data.DesignInfo; import org.onap.appc.design.data.DesignResponse; import org.onap.appc.design.data.StatusInfo; import org.onap.appc.design.services.util.ArtifactHandlerClient; import org.onap.appc.design.services.util.DesignServiceConstants; -import org.onap.ccsdk.sli.core.sli.SvcLogicResource; -import org.onap.ccsdk.sli.core.dblib.DBResourceManager; import org.onap.ccsdk.sli.adaptors.resource.sql.SqlResource; -import com.att.eelf.configuration.EELFLogger; -import com.att.eelf.configuration.EELFManager; -import com.fasterxml.jackson.core.JsonParser; -import com.fasterxml.jackson.core.JsonProcessingException; -import com.fasterxml.jackson.databind.JsonNode; -import com.fasterxml.jackson.databind.ObjectMapper; +import org.onap.ccsdk.sli.core.sli.SvcLogicResource; public class DesignDBService { private static final EELFLogger log = EELFManager.getInstance().getLogger(DesignDBService.class); + private static DesignDBService dgGeneralDBService; + + private static final String SUCCESS_JSON = "{\"update\" : \"success\" } "; + private static final String STATUS = "STATUS"; + private static final String INFO_STR = "Info : "; + private static final String DB_OPERATION_ERROR = "Error while DB operation : "; + private static final String VNFC_TYPE = "vnfc-type"; + private static final String QUERY_STR = "Query String :"; + private static final String USER_ID = "userID"; + private SvcLogicResource serviceLogic; - private static DesignDBService dgGeneralDBService = null; - private static DBResourceManager jdbcDataSource; + private DbService dbservice; - DbService dbservice = null; - private static Properties props; public static DesignDBService initialise() { if (dgGeneralDBService == null) { dgGeneralDBService = new DesignDBService(); } return dgGeneralDBService; } + private DesignDBService() { if (serviceLogic == null) { serviceLogic = new SqlResource(); @@ -70,312 +73,317 @@ public class DesignDBService { public String execute(String action, String payload, String requestID) throws Exception { - log.info("Received execute request for action : " + action + " with Payload : "+ payload ); + log.info("Received execute request for action : " + action + " with Payload : " + payload); RequestValidator.validate(action, payload); - String response = null; - dbservice = new DbService(); + String response; + dbservice = new DbService(); switch (action) { - case DesignServiceConstants.GETDESIGNS: - response = getDesigns(payload,requestID ); - break; - case DesignServiceConstants.ADDINCART: - response= setInCart(payload, requestID); - break ; - case DesignServiceConstants.GETARTIFACTREFERENCE: - response= getArtifactReference(payload, requestID); - break; - case DesignServiceConstants.GETARTIFACT: - response= getArtifact(payload, requestID); - break; - case DesignServiceConstants.GETGUIREFERENCE: - response= getGuiReference(payload, requestID); - break; - case DesignServiceConstants.GETSTATUS: - response= getStatus(payload, requestID); - break; - case DesignServiceConstants.SETSTATUS: - response= setStatus(payload, requestID); - break; - case DesignServiceConstants.UPLOADARTIFACT: - response= uploadArtifact(payload, requestID); - break; - case DesignServiceConstants.SETPROTOCOLREFERENCE: - response= setProtocolReference(payload, requestID); - break; - default: - throw new Exception(" Action " + action + " not found while processing request "); + case DesignServiceConstants.GETDESIGNS: + response = getDesigns(payload, requestID); + break; + case DesignServiceConstants.ADDINCART: + response = setInCart(payload, requestID); + break; + case DesignServiceConstants.GETARTIFACTREFERENCE: + response = getArtifactReference(payload, requestID); + break; + case DesignServiceConstants.GETARTIFACT: + response = getArtifact(payload, requestID); + break; + case DesignServiceConstants.GETGUIREFERENCE: + response = getGuiReference(payload, requestID); + break; + case DesignServiceConstants.GETSTATUS: + response = getStatus(payload, requestID); + break; + case DesignServiceConstants.SETSTATUS: + response = setStatus(payload, requestID); + break; + case DesignServiceConstants.UPLOADARTIFACT: + response = uploadArtifact(payload, requestID); + break; + case DesignServiceConstants.SETPROTOCOLREFERENCE: + response = setProtocolReference(payload, requestID); + break; + default: + throw new DBDesignException(" Action " + action + " not found while processing request "); } - return response; + return response; } private String setInCart(String payload, String requestID) throws Exception { - + ObjectMapper objectMapper = new ObjectMapper(); JsonNode payloadObject = objectMapper.readTree(payload); - ArrayList<String> argList = new ArrayList<>(); + ArrayList<String> argList = new ArrayList<>(); argList.add(payloadObject.get(DesignServiceConstants.INCART).textValue()); argList.add(payloadObject.get(DesignServiceConstants.VNF_TYPE).textValue()); - - String queryString = "UPDATE DT_ARTIFACT_TRACKING SET INCART= ? WHERE ASDC_REFERENCE_ID IN " - + " (SELECT ASDC_REFERENCE_ID FROM ASDC_REFERENCE_ID WHERE VNF_TYPE = ? " ; - - if(payloadObject.get(DesignServiceConstants.VNF_TYPE) != null &&! payloadObject.get(DesignServiceConstants.VNF_TYPE).textValue().isEmpty()) { - queryString = queryString + " AND VNFC_TYPE = ? ) AND USER = ? " ; + + String queryString = "UPDATE DT_ARTIFACT_TRACKING SET INCART= ? WHERE ASDC_REFERENCE_ID IN " + + " (SELECT ASDC_REFERENCE_ID FROM ASDC_REFERENCE_ID WHERE VNF_TYPE = ? "; + + if (payloadObject.get(DesignServiceConstants.VNF_TYPE) != null && !payloadObject + .get(DesignServiceConstants.VNF_TYPE).textValue().isEmpty()) { + queryString = queryString + " AND VNFC_TYPE = ? ) AND USER = ? "; argList.add(payloadObject.get(DesignServiceConstants.VNFC_TYPE).textValue()); + } else { + queryString = queryString + " ) AND USER = ? "; } - else{ - queryString = queryString + " ) AND USER = ? " ; - } - argList.add(payloadObject.get(DesignServiceConstants.USER_ID).textValue()); - - log.info("Query String :" + queryString); - boolean data = dbservice.updateDBData(queryString, argList); - - if(!data) - throw new Exception("Error while updating ProtocolReference"); - - return "{\"update\" : \"success\" } "; - + log.info(QUERY_STR + queryString); + boolean data = dbservice.updateDBData(queryString, argList); + + if (!data) { + throw new DBDesignException("Error while updating ProtocolReference"); + } + return SUCCESS_JSON; } + private String setProtocolReference(String payload, String requestID) throws Exception { - + ObjectMapper objectMapper = new ObjectMapper(); JsonNode payloadObject = objectMapper.readTree(payload); - ArrayList<String> argList = new ArrayList<>(); - + ArrayList<String> argList = new ArrayList<>(); + argList.add(payloadObject.get(DesignServiceConstants.ACTION).textValue()); argList.add(payloadObject.get(DesignServiceConstants.ACTION_LEVEL).textValue()); argList.add(payloadObject.get(DesignServiceConstants.VNF_TYPE).textValue()); argList.add(payloadObject.get(DesignServiceConstants.PROTOCOL).textValue()); - String queryString = " DELETE FROM PROTOCOL_REFERENCE WHERE ACTION = ? AND ACTION_LEVEL AND VNF_TYPE= ? AND PROTOCOL = ? " ; - + String queryString = " DELETE FROM PROTOCOL_REFERENCE WHERE ACTION = ? AND ACTION_LEVEL AND VNF_TYPE= ? AND PROTOCOL = ? "; + log.info("Delete Query String :" + queryString); - boolean data = dbservice.updateDBData(queryString, argList); - + boolean data; + log.info("Record Deleted"); - if((payloadObject.get(DesignServiceConstants.TEMPLATE) != null && !payloadObject.get(DesignServiceConstants.TEMPLATE).textValue().isEmpty())) + if (payloadObject.get(DesignServiceConstants.TEMPLATE) != null && + !payloadObject.get(DesignServiceConstants.TEMPLATE).textValue().isEmpty()) { + argList.add(payloadObject.get(DesignServiceConstants.TEMPLATE).textValue()); - else + } else { argList.add("NO"); - - String insertString = "INSERT INTO PROTOCOL_REFERENCE VALUES (?,?,?,?,?,SYSDATE()) "; - - if(payloadObject.get(DesignServiceConstants.VNFC_TYPE) != null && ! payloadObject.get(DesignServiceConstants.VNFC_TYPE).textValue().isEmpty()){ - queryString = queryString + " AND VNFC_TYPE = ? )" ; } - else{ + + if (payloadObject.get(DesignServiceConstants.VNFC_TYPE) != null && + !payloadObject.get(DesignServiceConstants.VNFC_TYPE).textValue().isEmpty()) { + + queryString = queryString + " AND VNFC_TYPE = ? )"; + } else { queryString = queryString + " ) "; } - log.info("Query String :" + queryString); - data = dbservice.updateDBData(queryString, argList); + log.info(QUERY_STR + queryString); + data = dbservice.updateDBData(queryString, argList); - if(!data) - throw new Exception("Error while updating ProtocolReference"); - return "{\"update\" : \"success\" } "; + if (!data) { + throw new DBDesignException("Error while updating ProtocolReference"); + } + return SUCCESS_JSON; } + private String uploadArtifact(String payload, String requestID) throws Exception { ObjectMapper objectMapper = new ObjectMapper(); objectMapper.configure(JsonParser.Feature.ALLOW_COMMENTS, true); JsonNode payloadObject = objectMapper.readTree(payload); log.info("Got upload Aritfact with Payload : " + payloadObject.asText()); - try{ + try { ArtifactHandlerClient ac = new ArtifactHandlerClient(); String requestString = ac.createArtifactData(payload, requestID); ac.execute(requestString, "POST"); - int sdc_artifact_id = getSDCArtifactIDbyRequestID(requestID); - int sdc_reference_id = getSDCReferenceID(payload); - createArtifactTrackingRecord(payload, requestID,sdc_artifact_id, sdc_reference_id ); - String status = getDataFromActionStatus(payload, "STATUS"); - if(status == null || status.isEmpty()) + int sdcArtifactId = getSDCArtifactIDbyRequestID(requestID); + int sdcReferenceId = getSDCReferenceID(payload); + createArtifactTrackingRecord(payload, requestID, sdcArtifactId, sdcReferenceId); + String status = getDataFromActionStatus(payload, STATUS); + if (status == null || status.isEmpty()) { setActionStatus(payload, "Not Tested"); - linkstatusRelationShip(sdc_artifact_id,sdc_reference_id, payload); + } + linkstatusRelationShip(sdcArtifactId, sdcReferenceId, payload); - } - catch(Exception e){ - e.printStackTrace(); + } catch (Exception e) { + log.error("An error occured in uploadArtifact", e); throw e; } - return "{\"update\" : \"success\" } "; + return SUCCESS_JSON; } - private void linkstatusRelationShip(int sdc_artifact_id, int sdc_reference_id, String payload) throws Exception { + private void linkstatusRelationShip(int sdcArtifactId, int sdcReferenceId, String payload) throws Exception { ObjectMapper objectMapper = new ObjectMapper(); JsonNode payloadObject = objectMapper.readTree(payload); - ArrayList<String> argList = new ArrayList<>(); - argList.add(String.valueOf(sdc_artifact_id)); - argList.add(String.valueOf(sdc_reference_id)); + ArrayList<String> argList = new ArrayList<>(); + argList.add(String.valueOf(sdcArtifactId)); + argList.add(String.valueOf(sdcReferenceId)); argList.add(payloadObject.get(DesignServiceConstants.VNF_TYPE).textValue()); argList.add(payloadObject.get(DesignServiceConstants.ACTION).textValue()); argList.add(payloadObject.get(DesignServiceConstants.USER_ID).textValue()); - String queryString = "INSERT INTO DT_STATUS_RELATIONSHIP (DT_ARTIFACT_TRACKING_ID,DT_ACTION_STATUS_ID) VALUES " + - "(( SELECT DT_ARTIFACT_TRACKING_ID FROM DT_ARTIFACT_TRACKING WHERE ASDC_ARTIFACTS_ID = ? AND ASDC_REFERENCE_ID = ? ) , " - + "( SELECT DT_ACTION_STATUS_ID FROM DT_ACTION_STATUS WHERE VNF_TYPE = ? AND ACTION = ? AND USER = ? " ; + String queryString = + "INSERT INTO DT_STATUS_RELATIONSHIP (DT_ARTIFACT_TRACKING_ID,DT_ACTION_STATUS_ID) VALUES " + + "(( SELECT DT_ARTIFACT_TRACKING_ID FROM DT_ARTIFACT_TRACKING WHERE ASDC_ARTIFACTS_ID = ? AND ASDC_REFERENCE_ID = ? ) , " + + "( SELECT DT_ACTION_STATUS_ID FROM DT_ACTION_STATUS WHERE VNF_TYPE = ? AND ACTION = ? AND USER = ? "; - if(payloadObject.get(DesignServiceConstants.VNFC_TYPE) != null && ! payloadObject.get(DesignServiceConstants.VNFC_TYPE).textValue().isEmpty()){ - queryString = queryString + " AND VNFC_TYPE = ? ) )" ; - } - else{ + if (payloadObject.get(DesignServiceConstants.VNFC_TYPE) != null && !payloadObject + .get(DesignServiceConstants.VNFC_TYPE).textValue().isEmpty()) { + queryString = queryString + " AND VNFC_TYPE = ? ) )"; + } else { queryString = queryString + " ) ) "; } - log.info("Query String :" + queryString); - boolean data = dbservice.updateDBData(queryString, argList); + log.info(QUERY_STR + queryString); + boolean data = dbservice.updateDBData(queryString, argList); - if(!data) - throw new Exception("Error while updating RealtionShip table"); + if (!data) { + throw new DBDesignException("Error while updating RelationShip table"); + } } + private int getSDCReferenceID(String payload) throws Exception { - String vnfc_type = null; ObjectMapper objectMapper = new ObjectMapper(); JsonNode payloadObject = objectMapper.readTree(payload); - ArrayList<String> argList = new ArrayList<>(); + ArrayList<String> argList = new ArrayList<>(); argList.add(payloadObject.get(DesignServiceConstants.VNF_TYPE).textValue()); - + argList.add(payloadObject.get(DesignServiceConstants.ARTIFACT_TYPE).textValue()); argList.add(payloadObject.get(DesignServiceConstants.ARTIFACT_NAME).textValue()); String queryString = " SELECT ASDC_REFERENCE_ID FROM ASDC_REFERENCE WHERE VNF_TYPE = ? " - + " AND ARTIFACT_TYPE = ? AND ARTIFACT_NAME = ? " ; - - if(payloadObject.get(DesignServiceConstants.ACTION) != null && !payloadObject.get(DesignServiceConstants.ACTION).textValue().isEmpty()){ + + " AND ARTIFACT_TYPE = ? AND ARTIFACT_NAME = ? "; + + if (payloadObject.get(DesignServiceConstants.ACTION) != null && !payloadObject + .get(DesignServiceConstants.ACTION).textValue().isEmpty()) { argList.add(payloadObject.get(DesignServiceConstants.ACTION).textValue()); queryString = queryString + " AND ACTION = ? "; } - if(payloadObject.get(DesignServiceConstants.VNFC_TYPE) !=null && !payloadObject.get(DesignServiceConstants.VNFC_TYPE).textValue().isEmpty()){ + if (payloadObject.get(DesignServiceConstants.VNFC_TYPE) != null && !payloadObject + .get(DesignServiceConstants.VNFC_TYPE).textValue().isEmpty()) { argList.add(payloadObject.get(DesignServiceConstants.VNFC_TYPE).textValue()); queryString = queryString + " AND VNFC_TYPE = ? "; } - log.info("Query String :" + queryString); + log.info(QUERY_STR + queryString); ResultSet data = dbservice.getDBData(queryString, argList); - int sdc_reference_id = 0; - while(data.next()) { - sdc_reference_id = data.getInt("ASDC_REFERENCE_ID"); - } - log.info("Got sdc_reference_id = " + sdc_reference_id ); - return sdc_reference_id; - + int sdcReferenceId = 0; + while (data.next()) { + sdcReferenceId = data.getInt("ASDC_REFERENCE_ID"); + } + log.info("Got sdcReferenceId= " + sdcReferenceId); + return sdcReferenceId; } private String getDataFromActionStatus(String payload, String dataValue) throws Exception { - String status = null ; + String status = null; ObjectMapper objectMapper = new ObjectMapper(); JsonNode payloadObject = objectMapper.readTree(payload); - ArrayList<String> argList = new ArrayList<>(); + ArrayList<String> argList = new ArrayList<>(); argList.add(payloadObject.get(DesignServiceConstants.VNF_TYPE).textValue()); argList.add(payloadObject.get(DesignServiceConstants.ACTION).textValue()); argList.add(payloadObject.get(DesignServiceConstants.USER_ID).textValue()); - String queryString = " SELECT " + dataValue + " FROM DT_ACTION_STATUS WHERE VNF_TYPE = ? AND ACTION = ? AND USER = ? "; - if(payloadObject.get(DesignServiceConstants.VNFC_TYPE) !=null && !payloadObject.get(DesignServiceConstants.VNFC_TYPE).textValue().isEmpty()){ + String queryString = + " SELECT " + dataValue + " FROM DT_ACTION_STATUS WHERE VNF_TYPE = ? AND ACTION = ? AND USER = ? "; + if (payloadObject.get(DesignServiceConstants.VNFC_TYPE) != null && !payloadObject + .get(DesignServiceConstants.VNFC_TYPE).textValue().isEmpty()) { argList.add(payloadObject.get(DesignServiceConstants.VNFC_TYPE).textValue()); queryString = queryString + " AND VNFC_TYPE = ? "; } - log.info("Query String :" + queryString); + log.info(QUERY_STR + queryString); ResultSet data = dbservice.getDBData(queryString, argList); - while(data.next()) { - status = data.getString("STATUS"); - } - log.info("DT_ACTION_STATUS Status = " + status ); + while (data.next()) { + status = data.getString(STATUS); + } + log.info("DT_ACTION_STATUS Status = " + status); return status; - } + } - private boolean setActionStatus(String payload, String status) throws Exception { + private void setActionStatus(String payload, String status) throws Exception { ObjectMapper objectMapper = new ObjectMapper(); JsonNode payloadObject = objectMapper.readTree(payload); - ArrayList<String> argList = new ArrayList<>(); + ArrayList<String> argList = new ArrayList<>(); argList.add(payloadObject.get(DesignServiceConstants.ACTION).textValue()); argList.add(payloadObject.get(DesignServiceConstants.VNF_TYPE).textValue()); - String insertQuery = " INSERT INTO DT_ACTION_STATUS (ACTION, VNF_TYPE, VNFC_TYPE, USER, TECHNOLOGY, UPDATED_DATE, STATUS) VALUES (?,?,?,?,?,sysdate() , ?); "; - if(payloadObject.get(DesignServiceConstants.VNFC_TYPE) !=null && !payloadObject.get(DesignServiceConstants.VNFC_TYPE).textValue().isEmpty()){ + if (payloadObject.get(DesignServiceConstants.VNFC_TYPE) != null && !payloadObject + .get(DesignServiceConstants.VNFC_TYPE).textValue().isEmpty()) { argList.add(payloadObject.get(DesignServiceConstants.VNFC_TYPE).textValue()); - } - else{ + } else { argList.add(null); } argList.add(payloadObject.get(DesignServiceConstants.USER_ID).textValue()); - if(payloadObject.get(DesignServiceConstants.TECHNOLOGY) !=null && !payloadObject.get(DesignServiceConstants.TECHNOLOGY).textValue().isEmpty()){ + if (payloadObject.get(DesignServiceConstants.TECHNOLOGY) != null && !payloadObject + .get(DesignServiceConstants.TECHNOLOGY).textValue().isEmpty()) { argList.add(payloadObject.get(DesignServiceConstants.TECHNOLOGY).textValue()); - } - else{ + } else { argList.add(null); } argList.add(status); boolean updateStatus = dbservice.updateDBData(insertQuery, argList); - if(!updateStatus) - throw new Exception("Error while updating Action Status"); - return updateStatus; + if (!updateStatus) + throw new DBDesignException("Error while updating Action Status"); } - private void createArtifactTrackingRecord(String payload, String requestID, int sdc_artifact_id, int sdc_reference_id) throws Exception { - String vnfc_type = null; + private void createArtifactTrackingRecord(String payload, String requestID, int sdcArtifactId, int sdcReferenceId) + throws Exception { + ObjectMapper objectMapper = new ObjectMapper(); JsonNode payloadObject = objectMapper.readTree(payload); - ArrayList<String> argList = new ArrayList<>(); - argList.add(String.valueOf(sdc_artifact_id)); - argList.add(String.valueOf(sdc_reference_id)); + ArrayList<String> argList = new ArrayList<>(); + argList.add(String.valueOf(sdcArtifactId)); + argList.add(String.valueOf(sdcReferenceId)); argList.add(payloadObject.get(DesignServiceConstants.USER_ID).textValue()); - if (payloadObject.get(DesignServiceConstants.TECHNOLOGY) != null &&! payloadObject.get(DesignServiceConstants.TECHNOLOGY).textValue().isEmpty()) + if (payloadObject.get(DesignServiceConstants.TECHNOLOGY) != null && !payloadObject + .get(DesignServiceConstants.TECHNOLOGY).textValue().isEmpty()) { argList.add(payloadObject.get(DesignServiceConstants.TECHNOLOGY).textValue()); - else + } else { argList.add(""); + } - if (payloadObject.get(DesignServiceConstants.PROTOCOL) != null &&! payloadObject.get(DesignServiceConstants.PROTOCOL).textValue().isEmpty()) + if (payloadObject.get(DesignServiceConstants.PROTOCOL) != null && !payloadObject + .get(DesignServiceConstants.PROTOCOL).textValue().isEmpty()) { argList.add(payloadObject.get(DesignServiceConstants.PROTOCOL).textValue()); - else + } else { argList.add(""); + } + String queryString = "INSERT INTO DT_ARTIFACT_TRACKING (ASDC_ARTIFACTS_ID, ASDC_REFERENCE_ID, USER, TECHNOLOGY, CREATION_DATE, UPDATED_DATE, ARTIFACT_STATUS, PROTOCOL, IN_CART) VALUES (? , ? , ?, ?, sysdate() , sysdate(), 'Created', ? ,'N' )"; - String queryString = "INSERT INTO DT_ARTIFACT_TRACKING (ASDC_ARTIFACTS_ID, ASDC_REFERENCE_ID, USER, TECHNOLOGY, CREATION_DATE, UPDATED_DATE, ARTIFACT_STATUS, PROTOCOL, IN_CART) VALUES (? , ? , ?, ?, sysdate() , sysdate(), 'Created', ? ,'N' )" ; - - log.info("Query String :" + queryString); + log.info(QUERY_STR + queryString); boolean data = dbservice.updateDBData(queryString, argList); - if(!data) - throw new Exception("Error Updating DT_ARTIFACT_TRACKING "); - - + if (!data) { + throw new DBDesignException("Error Updating DT_ARTIFACT_TRACKING "); + } } private int getSDCArtifactIDbyRequestID(String requestID) throws Exception { log.info("Starting getArtifactIDbyRequestID DB Operation"); - int artifact_id = 0; - try{ - ArrayList<String> argList = new ArrayList<>(); - argList.add("TLSUUID" + requestID); - String queryString = " SELECT ASDC_ARTIFACTS_ID FROM ASDC_ARTIFACTS where SERVICE_UUID = ? "; - log.info("Query String :" + queryString); + int artifactId = 0; + try { + ArrayList<String> argList = new ArrayList<>(); + argList.add("TLSUUID" + requestID); + String queryString = " SELECT ASDC_ARTIFACTS_ID FROM ASDC_ARTIFACTS where SERVICE_UUID = ? "; + log.info(QUERY_STR + queryString); ResultSet data = dbservice.getDBData(queryString, argList); - while(data.next()){ - artifact_id = data.getInt("ASDC_ARTIFACTS_ID"); + while (data.next()) { + artifactId = data.getInt("ASDC_ARTIFACTS_ID"); } - } - catch(Exception e){ - e.printStackTrace(); + } catch (Exception e) { + log.error("An error occurred in getSDCArtifactIDbyRequestID", e); throw e; } - log.info("Got SDC_ARTIFACTS_ID As :" + artifact_id); - return artifact_id; + log.info("Got SDC_ARTIFACTS_ID As :" + artifactId); + return artifactId; } private String getArtifact(String payload, String requestID) throws Exception { - String fn = "DBService.getStatus "; log.info("Starting getArtifact DB Operation"); - try{ - String vnfc_type = null; + try { ObjectMapper objectMapper = new ObjectMapper(); JsonNode payloadObject = objectMapper.readTree(payload); ArrayList<String> argList = new ArrayList<>(); @@ -383,244 +391,191 @@ public class DesignDBService { argList.add(payloadObject.get("artifact-type").textValue()); String queryString = "SELECT INTERNAL_VERSION, ARTIFACT_CONTENT FROM ASDC_ARTIFACTS where " + - " ARTIFACT_NAME = ? AND ARTIFACT_TYPE = ? " ; + " ARTIFACT_NAME = ? AND ARTIFACT_TYPE = ? "; - log.info("Query String :" + queryString); + log.info(QUERY_STR + queryString); ResultSet data = dbservice.getDBData(queryString, argList); - String artifact_content = null; - int hightestVerion = -1 ; - while(data.next()) { + String artifactContent = null; + int hightestVerion = -1; + while (data.next()) { int version = data.getInt("INTERNAL_VERSION"); - if(hightestVerion < version) - artifact_content = data.getString("ARTIFACT_CONTENT"); + if (hightestVerion < version) { + artifactContent = data.getString("ARTIFACT_CONTENT"); + } + } + if (artifactContent == null || artifactContent.isEmpty()) { + throw new DBDesignException( + "Sorry !!! I dont have any artifact Named : " + payloadObject.get("artifact-name").textValue()); } - if(artifact_content == null || artifact_content.isEmpty()) - throw new Exception("Sorry !!! I dont have any artifact Named : " + payloadObject.get("artifact-name").textValue()); DesignResponse designResponse = new DesignResponse(); - //designResponse.setUserId(payloadObject.get("userID").textValue()); - List<ArtifactInfo> artifactInfoList = new ArrayList<ArtifactInfo>(); - ArtifactInfo artifactInfo = new ArtifactInfo(); - artifactInfo.setArtifact_content(artifact_content); + List<ArtifactInfo> artifactInfoList = new ArrayList<>(); + ArtifactInfo artifactInfo = new ArtifactInfo(); + artifactInfo.setArtifact_content(artifactContent); artifactInfoList.add(artifactInfo); designResponse.setArtifactInfo(artifactInfoList); ObjectMapper mapper = new ObjectMapper(); String jsonString = mapper.writeValueAsString(designResponse); - log.info("Info : " + jsonString); + log.info(INFO_STR + jsonString); return jsonString; - } - catch(SQLException e) - { - log.error("Error while DB operation : " + e.getMessage()); - e.printStackTrace(); - throw e; - } - catch(Exception e) - { - log.error("Error while DB operation : " + e.getMessage()); - e.printStackTrace(); + } catch (Exception e) { + log.error(DB_OPERATION_ERROR, e); throw e; } - } + private String setStatus(String payload, String requestID) throws Exception { - String fn = "DBService.getStatus "; + log.info("Starting getStatus DB Operation"); - try{ - String vnfc_type = null; + try { ObjectMapper objectMapper = new ObjectMapper(); JsonNode payloadObject = objectMapper.readTree(payload); - ArrayList<String> argList = new ArrayList<>(); argList.add(payloadObject.get("artifact_status").textValue()); argList.add(payloadObject.get("action_status").textValue()); - argList.add(payloadObject.get("userID").textValue()); + argList.add(payloadObject.get(USER_ID).textValue()); argList.add(payloadObject.get("vnf-type").textValue()); - String queryString = " UPDATE DT_ARTIFACT_TRACKING DAT, DT_STATUS_RELATIONSHIP DSR SET DAT.ARTIFACT_STATUS = ? , DAS.DT_ACTION_STATUS = ? " + String queryString = + " UPDATE DT_ARTIFACT_TRACKING DAT, DT_STATUS_RELATIONSHIP DSR SET DAT.ARTIFACT_STATUS = ? , DAS.DT_ACTION_STATUS = ? " + " where DAT.USER = DAS.USER and DSR.DT_ARTIFACT_TRACKING_ID = DAT.DT_ARTIFACT_TRACKING_ID " + " and DSR.DT_ACTION_STATUS_ID = DAS.DT_ACTION_STATUS_ID and DAT.USER = ? " - + " and DAS.VNF_TYPE = ? " ; + + " and DAS.VNF_TYPE = ? "; - if(payloadObject.get("vnfc-type") !=null && !payloadObject.get("vnfc-type").textValue().isEmpty()){ - argList.add(payloadObject.get("vnfc-type").textValue()); - queryString = queryString + " and DAS.VNFC_TYPE = ? "; + if (payloadObject.get(VNFC_TYPE) != null && !payloadObject.get(VNFC_TYPE).textValue().isEmpty()) { + argList.add(payloadObject.get(VNFC_TYPE).textValue()); + queryString = queryString + " and DAS.VNFC_TYPE = ? "; } - log.info("Query String :" + queryString); + log.info(QUERY_STR + queryString); DesignResponse designResponse = new DesignResponse(); - designResponse.setUserId(payloadObject.get("userID").textValue()); - List<StatusInfo> statusInfoList = new ArrayList<StatusInfo>(); + designResponse.setUserId(payloadObject.get(USER_ID).textValue()); boolean update = dbservice.updateDBData(queryString, argList); - if(!update) - throw new Exception("Sorry .....Something went wrong while updating the Status"); + if (!update) { + throw new DBDesignException("Sorry .....Something went wrong while updating the Status"); + } ObjectMapper mapper = new ObjectMapper(); String jsonString = mapper.writeValueAsString(designResponse); - log.info("Info : " + jsonString); + log.info(INFO_STR + jsonString); return jsonString; - } - catch(SQLException e) - { - log.error("Error while DB operation : " + e.getMessage()); - e.printStackTrace(); - throw e; - } - catch(Exception e) - { - log.error("Error while DB operation : " + e.getMessage()); - e.printStackTrace(); + } catch (Exception e) { + log.error(DB_OPERATION_ERROR, e); throw e; } } + private String getStatus(String payload, String requestID) throws Exception { - String fn = "DBService.getStatus "; log.info("Starting getStatus DB Operation"); - try{ - String vnfc_type = null; + try { + String vnfcType = null; ObjectMapper objectMapper = new ObjectMapper(); JsonNode payloadObject = objectMapper.readTree(payload); - String UserID = payloadObject.get("userID").textValue(); - String vnf_type = payloadObject.get("vnf-type").textValue(); - if(payloadObject.get("vnfc-type") != null ) - vnfc_type = payloadObject.get("vnfc-type").textValue(); + String userID = payloadObject.get(USER_ID).textValue(); + String vnfType = payloadObject.get("vnf-type").textValue(); + if (payloadObject.get(VNFC_TYPE) != null) { + vnfcType = payloadObject.get(VNFC_TYPE).textValue(); + } ArrayList<String> argList = new ArrayList<>(); - argList.add(UserID); - argList.add(vnf_type); + argList.add(userID); + argList.add(vnfType); String queryString = "SELECT DAS.VNF_TYPE, DAS.VNFC_TYPE, DAS.STATUS, DAS.ACTION, DAT.ARTIFACT_STATUS " - + "from DT_ACTION_STATUS DAS , DT_ARTIFACT_TRACKING DAT, DT_STATUS_RELATIONSHIP DSR " + - " where DAT.USER = DAS.USER and DSR.DT_ARTIFACT_TRACKING_ID = DAT.DT_ARTIFACT_TRACKING_ID " - + " and DSR.DT_ACTION_STATUS_ID = DAS.DT_ACTION_STATUS_ID and DAT.USER = ? " - + " and DAS.VNF_TYPE = ? " ; - - if(vnfc_type !=null && ! vnfc_type.isEmpty()){ - argList.add(vnfc_type); - queryString = queryString + " and DAS.VNFC_TYPE = ? "; + + "from DT_ACTION_STATUS DAS , DT_ARTIFACT_TRACKING DAT, DT_STATUS_RELATIONSHIP DSR " + + " where DAT.USER = DAS.USER and DSR.DT_ARTIFACT_TRACKING_ID = DAT.DT_ARTIFACT_TRACKING_ID " + + " and DSR.DT_ACTION_STATUS_ID = DAS.DT_ACTION_STATUS_ID and DAT.USER = ? " + + " and DAS.VNF_TYPE = ? "; + + if (vnfcType != null && !vnfcType.isEmpty()) { + argList.add(vnfcType); + queryString = queryString + " and DAS.VNFC_TYPE = ? "; } - log.info("Query String :" + queryString); + log.info(QUERY_STR + queryString); DesignResponse designResponse = new DesignResponse(); - designResponse.setUserId(UserID); - List<StatusInfo> statusInfoList = new ArrayList<StatusInfo>(); + designResponse.setUserId(userID); + List<StatusInfo> statusInfoList = new ArrayList<>(); ResultSet data = dbservice.getDBData(queryString, argList); - while(data.next()) { + while (data.next()) { StatusInfo statusInfo = new StatusInfo(); statusInfo.setAction(data.getString("ACTION")); - statusInfo.setAction_status(data.getString("STATUS")); + statusInfo.setAction_status(data.getString(STATUS)); statusInfo.setArtifact_status(data.getString("ARTIFACT_STATUS")); statusInfo.setVnf_type(data.getString("VNF_TYPE")); - statusInfo.setVnfc_type(data.getString("VNFC_TYPE")); + statusInfo.setVnfc_type(data.getString("VNFC_TYPE")); statusInfoList.add(statusInfo); } - if(statusInfoList.size() < 1) - throw new Exception("OOPS !!!! No VNF information available for VNF-TYPE : " + vnf_type + " for User : " + UserID); + if (statusInfoList.isEmpty()) { + throw new DBDesignException( + "OOPS !!!! No VNF information available for VNF-TYPE : " + vnfType + " for User : " + userID); + } designResponse.setStatusInfoList(statusInfoList); ObjectMapper mapper = new ObjectMapper(); String jsonString = mapper.writeValueAsString(designResponse); - log.info("Info : " + jsonString); + log.info(INFO_STR + jsonString); return jsonString; - } - catch(SQLException e) - { - log.error("Error while DB operation : " + e.getMessage()); - e.printStackTrace(); + } catch (SQLException e) { + log.error(DB_OPERATION_ERROR, e); throw e; - } - catch(Exception e) - { - log.error("Error while DB operation : " + e.getMessage()); - log.error("Exception : ",e); + } catch (Exception e) { + log.error(DB_OPERATION_ERROR + e.getMessage()); + log.error("Exception : ", e); throw e; } } + private String getGuiReference(String payload, String requestID) { // TODO Auto-generated method stub return null; } + private String getArtifactReference(String payload, String requestID) { // TODO Auto-generated method stub return null; } - private String getAddInCart(String payload, String requestID) { - // TODO Auto-generated method stub - return null; - } - - // private String getDesigns(String payload, String requestID) throws SQLException, JsonProcessingException, IOException, SvcLogicException { - // - // String fn = "DBService.getDesigns "; - // QueryStatus status = null; - // ObjectMapper objectMapper = new ObjectMapper(); - // JsonNode jnode = objectMapper.readTree(payload); - // String UserId = jnode.get("userID").textValue(); - // SvcLogicContext localContext = new SvcLogicContext(); - // localContext.setAttribute("requestID", requestID); - // localContext.setAttribute("userID", UserId); - // if (serviceLogic != null && localContext != null) { - // String queryString = "SELECT AR.VNF_TYPE, AR.VNFC_TYPE, DAT.PROTOCOL, DAT.IN_CART from " + - // DesignServiceConstants.DB_DT_ARTIFACT_TRACKING + " DAT , " + DesignServiceConstants.DB_SDC_REFERENCE + - // " AR where DAT.SDC_REFERENCE_ID= AR.SDC_REFERENCE_ID and DAT.USER = $userID" ; - // - // log.info(fn + "Query String : " + queryString); - // try { - // status = serviceLogic.query("SQL", true, null, queryString, null, null, localContext); - // } catch (SvcLogicException e1) { - // // TODO Auto-generated catch block - // e1.printStackTrace(); - // } - // - // if(status.toString().equals("FAILURE")) - // throw new SvcLogicException("Error - while getting FlowReferenceData "); - // - // Properties props = localContext.toProperties(); - // log.info("SvcLogicContext contains the following : " + props.toString()); - // for (Enumeration e = props.propertyNames(); e.hasMoreElements() ; ) { - // String propName = (String) e.nextElement(); - // log.info(propName+" = "+props.getProperty(propName)); - // - // } - // } - // return requestID; - // - // } private String getDesigns(String payload, String requestID) throws Exception { - String fn = "DBService.getDesigns "; String queryString; - log.info("Starting getDesgins DB Operation"); + log.info("Starting getDesigns DB Operation"); - - try{ + try { ObjectMapper objectMapper = new ObjectMapper(); JsonNode payloadObject = objectMapper.readTree(payload); - String UserID = payloadObject.get("userID").textValue(); - String filterKey =null; - if(payloadObject.hasNonNull("filter")) + String userID = payloadObject.get(USER_ID).textValue(); + String filterKey = null; + if (payloadObject.hasNonNull("filter")) { filterKey = payloadObject.get("filter").textValue(); + } ArrayList<String> argList = new ArrayList<>(); - argList.add(UserID); - - if(filterKey!=null){ - queryString = "SELECT AR.VNF_TYPE, AR.VNFC_TYPE, DAT.PROTOCOL, DAT.IN_CART, AR.ACTION, AR.ARTIFACT_NAME, AR.ARTIFACT_TYPE from " + - DesignServiceConstants.DB_DT_ARTIFACT_TRACKING + " DAT , " + DesignServiceConstants.DB_SDC_REFERENCE + - " AR where DAT.ASDC_REFERENCE_ID= AR.ASDC_REFERENCE_ID and DAT.USER = ? and AR.ARTIFACT_NAME like '%"+filterKey+"%' GROUP BY AR.VNF_TYPE,AR.ARTIFACT_NAME"; - }else{ - queryString = "SELECT AR.VNF_TYPE, AR.VNFC_TYPE, DAT.PROTOCOL, DAT.IN_CART, AR.ACTION, AR.ARTIFACT_NAME, AR.ARTIFACT_TYPE from " + - DesignServiceConstants.DB_DT_ARTIFACT_TRACKING + " DAT , " + DesignServiceConstants.DB_SDC_REFERENCE + + argList.add(userID); + + if (filterKey != null) { + queryString = + "SELECT AR.VNF_TYPE, AR.VNFC_TYPE, DAT.PROTOCOL, DAT.IN_CART, AR.ACTION, AR.ARTIFACT_NAME, AR.ARTIFACT_TYPE from " + + + DesignServiceConstants.DB_DT_ARTIFACT_TRACKING + " DAT , " + + DesignServiceConstants.DB_SDC_REFERENCE + + " AR where DAT.ASDC_REFERENCE_ID= AR.ASDC_REFERENCE_ID and DAT.USER = ? and AR.ARTIFACT_NAME like '%" + + filterKey + "%' GROUP BY AR.VNF_TYPE,AR.ARTIFACT_NAME"; + } else { + queryString = + "SELECT AR.VNF_TYPE, AR.VNFC_TYPE, DAT.PROTOCOL, DAT.IN_CART, AR.ACTION, AR.ARTIFACT_NAME, AR.ARTIFACT_TYPE from " + + + DesignServiceConstants.DB_DT_ARTIFACT_TRACKING + " DAT , " + + DesignServiceConstants.DB_SDC_REFERENCE + " AR where DAT.ASDC_REFERENCE_ID= AR.ASDC_REFERENCE_ID and DAT.USER = ? GROUP BY AR.VNF_TYPE,AR.ARTIFACT_NAME"; } DesignResponse designResponse = new DesignResponse(); - designResponse.setUserId(UserID); - List<DesignInfo> designInfoList = new ArrayList<DesignInfo>(); + designResponse.setUserId(userID); + List<DesignInfo> designInfoList = new ArrayList<>(); ResultSet data = dbservice.getDBData(queryString, argList); - while(data.next()) { + while (data.next()) { DesignInfo designInfo = new DesignInfo(); designInfo.setInCart(data.getString("IN_CART")); designInfo.setProtocol(data.getString("PROTOCOL")); @@ -631,21 +586,20 @@ public class DesignDBService { designInfo.setArtifact_name(data.getString("ARTIFACT_NAME")); designInfoList.add(designInfo); } - if(designInfoList.size() < 1) - throw new Exception(" Welcome to CDT, Looks like you dont have Design Yet... Lets create some...."); + if (designInfoList.isEmpty()) { + throw new DBDesignException( + " Welcome to CDT, Looks like you dont have Design Yet... Lets create some...."); + } designResponse.setDesignInfoList(designInfoList); ObjectMapper mapper = new ObjectMapper(); String jsonString = mapper.writeValueAsString(designResponse); - log.info("Info : " + jsonString); + log.info(INFO_STR + jsonString); return jsonString; - } - catch(Exception e) - { - log.error("Error while Starting getDesgins DB operation : ",e); + } catch (Exception e) { + log.error("Error while Starting getDesgins DB operation : ", e); throw e; } } - } |