package org.openecomp.mso.db.catalog;
import java.io.Closeable;
+import java.util.ArrayList;
import java.util.Collections;
import java.util.HashMap;
import java.util.List;
import org.hibernate.service.ServiceRegistry;
import org.hibernate.service.ServiceRegistryBuilder;
+import org.openecomp.mso.db.HibernateUtils;
import org.openecomp.mso.db.catalog.utils.MavenLikeVersioningComparator;
+import org.openecomp.mso.db.catalog.utils.RecordNotFoundException;
import org.openecomp.mso.logger.MessageEnum;
import org.openecomp.mso.logger.MsoLogger;
*/
public class CatalogDatabase implements Closeable {
- protected static final String NETWORK_TYPE = "networkType";
- protected static final String ACTION = "action";
- protected static final String VNF_TYPE = "vnfType";
- protected static final String SERVICE_TYPE = "serviceType";
- protected static final String VNF_COMPONENT_TYPE = "vnfComponentType";
- protected static final String MODEL_NAME = "modelName";
- protected static final String TYPE = "type";
- protected static final String VF_MODULE_ID = "vfModuleId";
- protected static boolean initialized = false;
- protected static SessionFactory sessionFactory;
- protected static ServiceRegistry serviceRegistry;
- protected static final String SERVICE_NAME_VERSION_ID= "serviceNameVersionId";
+ protected static HibernateUtils hibernateUtils = new HibernateUtilsCatalogDb ();
+
+ private static final String NETWORK_TYPE = "networkType";
+ private static final String ACTION = "action";
+ private static final String VNF_TYPE = "vnfType";
+ private static final String SERVICE_TYPE = "serviceType";
+ private static final String VNF_COMPONENT_TYPE = "vnfComponentType";
+ private static final String MODEL_ID = "modelId";
+ private static final String MODEL_NAME = "modelName";
+ private static final String TYPE = "type";
+ private static final String MODEL_TYPE = "modelType";
+ private static final String MODEL_VERSION_ID = "modelVersionId";
+ private static final String MODEL_CUSTOMIZATION_UUID = "modelCustomizationUuid";
+ private static final String VF_MODULE_ID = "vfModuleId";
+ private static final String SERVICE_NAME_VERSION_ID= "serviceNameVersionId";
protected static final MsoLogger LOGGER = MsoLogger.getMsoLogger (MsoLogger.Catalog.GENERAL);
private Session getSession () {
- if (!initialized) {
- LOGGER.debug ("Initializing Catalog Database in Hibernate");
- Configuration configuration = null;
- try {
- if ("MYSQL".equals (System.getProperty ("mso.db"))
- || "MARIADB".equals (System.getProperty ("mso.db"))) {
- configuration = new Configuration ().configure ("hibernate-catalog-mysql.cfg.xml");
-
- serviceRegistry = new ServiceRegistryBuilder ().applySettings (configuration.getProperties ()).buildServiceRegistry ();
-
- sessionFactory = configuration.buildSessionFactory (serviceRegistry);
- } else {
- LOGGER.error (MessageEnum.APIH_DB_ACCESS_EXC_REASON, "DB Connection not specified to the JVM,choose either:-Dmso.db=MARIADB, -Dmso.db=MYSQL or -Dmso.container=AJSC", "", "", MsoLogger.ErrorCode.DataError, "DB Connection not specified to the JVM,choose either:-Dmso.db=MARIADB, -Dmso.db=MYSQL or -Dmso.container=AJSC");
- }
- } catch (Exception e) {
- LOGGER.error (MessageEnum.GENERAL_EXCEPTION_ARG,
- "Catalog DB initialization issue: " + e.getMessage (), "", "", MsoLogger.ErrorCode.DataError, "Catalog DB initialization issue: " + e.getMessage (), e);
- throw e;
- }
- initialized = true;
-
- LOGGER.debug ("Catalog Database initialization complete");
- }
-
- if (session == null) {
+
+ if (session == null) {
try {
- session = sessionFactory.openSession ();
+ session = hibernateUtils.getSessionFactory ().openSession ();
session.beginTransaction ();
} catch (HibernateException he) {
LOGGER.error (MessageEnum.GENERAL_EXCEPTION_ARG, "Error creating Hibernate Session: " + he, "", "", MsoLogger.ErrorCode.DataError, "Error creating Hibernate Session: " + he);
return resultList.get (0);
}
+ /**
+ * Fetch a Service definition by InvariantUUID
+ */
+ public Service getServiceByInvariantUUID (String modelInvariantUUID) {
+
+ long startTime = System.currentTimeMillis ();
+ LOGGER.debug ("Catalog database - get service with Invariant UUID " + modelInvariantUUID);
+
+ String hql = "FROM Service WHERE modelInvariantUUID = :model_invariant_uuid";
+ Query query = getSession ().createQuery (hql);
+ query.setParameter ("model_invariant_uuid", modelInvariantUUID);
+
+ @SuppressWarnings("unchecked")
+ List <Service> resultList = query.list ();
+
+ // See if something came back.
+ if (resultList.isEmpty ()) {
+ LOGGER.recordMetricEvent (startTime, MsoLogger.StatusCode.COMPLETE, MsoLogger.ResponseCode.Suc, "Successfully. Service not found", "CatalogDB", "getServiceByName", null);
+ return null;
+ }
+ Collections.sort (resultList, new MavenLikeVersioningComparator ());
+ Collections.reverse (resultList);
+
+ LOGGER.recordMetricEvent (startTime, MsoLogger.StatusCode.COMPLETE, MsoLogger.ResponseCode.Suc, "Successfully", "CatalogDB", "getServiceByName", null);
+ return resultList.get (0);
+ }
+
/**
* Fetch a Service definition
*/
return resultList.get (0);
}
+ public Service getServiceByVersionAndInvariantId(String modelInvariantId, String modelVersion) throws Exception {
+ long startTime = System.currentTimeMillis ();
+ LOGGER.debug ("Catalog database - get service with modelInvariantId: " + modelInvariantId + " and modelVersion: " + modelVersion);
+
+ String hql = "FROM Service WHERE modelInvariantUUID = :MODEL_INVARIANT_UUID AND version = :VERSION_STR";
+ Query query = getSession ().createQuery (hql);
+ query.setParameter ("MODEL_INVARIANT_UUID", modelInvariantId);
+ query.setParameter("VERSION_STR", modelVersion);
+
+ Service result = null;
+ try {
+ result = (Service) query.uniqueResult();
+ } catch (org.hibernate.NonUniqueResultException nure) {
+ LOGGER.debug("Non Unique Result Exception - the Catalog Database does not match a unique row - data integrity error: modelInvariantId='" + modelInvariantId + "', modelVersion='" + modelVersion + "'");
+ LOGGER.error(MessageEnum.GENERAL_EXCEPTION, " non unique result for modelInvariantId=" + modelInvariantId + " and modelVersion=" + modelVersion, "", "", MsoLogger.ErrorCode.DataError, "Non unique result for modelInvariantId=" + modelInvariantId);
+ throw new Exception("Non Unique Result Exception - the Catalog Database does not match a unique row - data integrity error: modelInvariantId='" + modelInvariantId + "', modelVersion='" + modelVersion + "'");
+ }
+ // See if something came back.
+ if (result==null) {
+ LOGGER.recordMetricEvent (startTime, MsoLogger.StatusCode.COMPLETE, MsoLogger.ResponseCode.Suc, "Successfully. Service not found", "CatalogDB", "getServiceByVersionAndInvariantId", null);
+ return null;
+ }
+
+ LOGGER.recordMetricEvent (startTime, MsoLogger.StatusCode.COMPLETE, MsoLogger.ResponseCode.Suc, "Successfully", "CatalogDB", "getServiceByVersionAndInvariantId", null);
+ return result;
+ }
+
/**
* Return a Service recipe that matches a given SERVICE_NAME_VERSION_ID
* (MODEL_VERSION_ID) and ACTION
* @return ServiceRecipe object or null if none found
*/
public ServiceRecipe getServiceRecipe (int serviceId, String action) {
-
- StringBuilder hql = new StringBuilder ("FROM ServiceRecipe WHERE serviceId = :serviceId AND action = :action ");
-
-
+
+ StringBuilder hql = null;
+
+ if(action == null){
+ hql = new StringBuilder ("FROM ServiceRecipe WHERE serviceId = :serviceId");
+ }else {
+ hql = new StringBuilder ("FROM ServiceRecipe WHERE serviceId = :serviceId AND action = :action ");
+ }
+
long startTime = System.currentTimeMillis ();
LOGGER.debug ("Catalog database - get Service recipe with serviceId " + Integer.toString(serviceId)
+ " and action "
Query query = getSession ().createQuery (hql.toString ());
query.setParameter ("serviceId", serviceId);
query.setParameter (ACTION, action);
-
+ if(action != null){
+ query.setParameter (ACTION, action);
+ }
+
@SuppressWarnings("unchecked")
List <ServiceRecipe> resultList = query.list ();
return resultList.get (0);
}
-
+ public List<ServiceRecipe> getServiceRecipes (int serviceId) {
+
+ StringBuilder hql = null;
+
+ hql = new StringBuilder ("FROM ServiceRecipe WHERE serviceId = :serviceId");
+
+ long startTime = System.currentTimeMillis ();
+ LOGGER.debug ("Catalog database - get Service recipe with serviceId " + Integer.toString(serviceId));
+
+ Query query = getSession ().createQuery (hql.toString ());
+ query.setParameter ("serviceId", serviceId);
+
+ @SuppressWarnings("unchecked")
+ List <ServiceRecipe> resultList = query.list ();
+
+ if (resultList.isEmpty ()) {
+ LOGGER.recordMetricEvent (startTime, MsoLogger.StatusCode.COMPLETE, MsoLogger.ResponseCode.Suc, "Successfully. Service recipe not found", "CatalogDB", "getServiceRecipes", null);
+ return null;
+ }
+
+ Collections.sort (resultList, new MavenLikeVersioningComparator ());
+ Collections.reverse (resultList);
+
+ LOGGER.recordMetricEvent (startTime, MsoLogger.StatusCode.COMPLETE, MsoLogger.ResponseCode.Suc, "Successfully", "CatalogDB", "getServiceRecipes", null);
+ return resultList;
+ }
+
/**
* Return the VNF component data - queried by the VNFs ID and the component type.
*
* @return VnfComponent object or null if none found
*/
public VnfComponent getVnfComponent (int vnfId, String type) {
-
+
long startTime = System.currentTimeMillis();
LOGGER.debug ("Catalog database - get VnfComponent where vnfId="+ vnfId+ " AND componentType="+ type);
-
+
String hql = "FROM VnfComponent WHERE vnfId = :vnf_id AND componentType = :type";
Query query = getSession ().createQuery (hql);
query.setParameter ("vnf_id", vnfId);
VnfComponent result = null;
try {
- result = (VnfComponent) query.uniqueResult();
+ result = (VnfComponent) query.uniqueResult();
} catch (org.hibernate.NonUniqueResultException nure) {
LOGGER.debug("Non Unique Result Exception - the Catalog Database does not match a unique row - data integrity error: vnf_id='" + vnfId + "', componentType='" + type + "'");
LOGGER.error(MessageEnum.GENERAL_EXCEPTION, " non unique result for vnf_id=" + vnfId + " and componentType=" + type, "", "", MsoLogger.ErrorCode.DataError, "Non unique result for vnf_id=" + vnfId);
return resource;
}
+ /**
+ * Return the newest version of a specific VNF resource (queried by modelCustomizationId).
+ *
+ * @param vnfType
+ * @param version
+ * @return VnfResource object or null if none found
+ */
+ public VnfResource getVnfResourceByModelCustomizationId (String modelCustomizationId, String serviceVersion) {
+
+ long startTime = System.currentTimeMillis ();
+ LOGGER.debug ("Catalog database - get VNF resource with modelCustomizationId " + modelCustomizationId);
+
+ String hql = "FROM VnfResource WHERE modelCustomizationUuid = :modelCustomizationId and version = :serviceVersion";
+ Query query = getSession ().createQuery (hql);
+ query.setParameter ("modelCustomizationId", modelCustomizationId);
+ query.setParameter ("serviceVersion", serviceVersion);
+
+ VnfResource resource = null;
+ try {
+ resource = (VnfResource) query.uniqueResult ();
+ } catch (org.hibernate.NonUniqueResultException nure) {
+ LOGGER.debug("Non Unique Result Exception - the Catalog Database does not match a unique row - data integrity error: modelCustomizationUuid='" + modelCustomizationId + "', serviceVersion='" + serviceVersion + "'");
+ LOGGER.error(MessageEnum.GENERAL_EXCEPTION, " non unique result for modelCustomizationUuid=" + modelCustomizationId + " and serviceVersion=" + serviceVersion, "", "", MsoLogger.ErrorCode.DataError, "Non unique result for modelCustomizationId=" + modelCustomizationId);
+ resource = null;
+ } catch (org.hibernate.HibernateException he) {
+ LOGGER.debug("Hibernate Exception - while searching for: modelCustomizationId='" + modelCustomizationId + "', asdc_service_model_version='" + serviceVersion + "'");
+ LOGGER.error(MessageEnum.GENERAL_EXCEPTION, " Hibernate exception searching for modelCustomizationId=" + modelCustomizationId + " and serviceVersion=" + serviceVersion, "", "", MsoLogger.ErrorCode.DataError, "Hibernate exception searching for modelCustomizationId=" + modelCustomizationId);
+ resource = null;
+ } catch (Exception e) {
+ LOGGER.debug("Generic Exception - while searching for: modelCustomizationId='" + modelCustomizationId + "', serviceVersion='" + serviceVersion + "'");
+ LOGGER.error(MessageEnum.GENERAL_EXCEPTION, " Generic exception searching for modelCustomizationId=" + modelCustomizationId + " and serviceVersion=" + serviceVersion, "", "", MsoLogger.ErrorCode.DataError, "Generic exception searching for modelCustomizationId=" + modelCustomizationId);
+ resource = null;
+ }
+ if (resource == null) {
+ LOGGER.recordMetricEvent (startTime, MsoLogger.StatusCode.COMPLETE, MsoLogger.ResponseCode.Suc, "NotFound", "CatalogDB", "getVnfResource", null);
+ } else {
+ LOGGER.recordMetricEvent (startTime, MsoLogger.StatusCode.COMPLETE, MsoLogger.ResponseCode.Suc, "Successfully", "CatalogDB", "getVnfResource", null);
+ }
+ return resource;
+ }
+
/**
* Return the newest version of a specific VNF resource (queried by ID).
*
* Return a VNF recipe that matches a given VF_MODULE_ID and ACTION
*
* @param vfModuleId
- * @param action
+ * @param action
* @return VnfRecipe object or null if none found
*/
public VnfRecipe getVnfRecipeByVfModuleId (String vnfType, String vfModuleId, String action) {
LOGGER.recordMetricEvent (startTime, MsoLogger.StatusCode.COMPLETE, MsoLogger.ResponseCode.Suc, "Successfully. VNF Recipe Entry found", "CatalogDB", "getVnfRecipeByVfModuleId", null);
return resultList.get (0);
}
-
+
+ public VfModule getVfModuleTypeByUuid(String modelCustomizationUuid) {
+ long startTime = System.currentTimeMillis();
+ LOGGER.debug("Catalog database - get vfModuleTypeByUuid with uuid=" + modelCustomizationUuid);
+
+ String hql = "FROM VfModule WHERE modelCustomizationUuid = :modelCustomizationUuid";
+ Query query = getSession().createQuery(hql);
+ query.setParameter("modelCustomizationUuid", modelCustomizationUuid);
+
+ VfModule module = null;
+ try {
+ module = (VfModule) query.uniqueResult();
+ } catch (org.hibernate.NonUniqueResultException nure) {
+ LOGGER.debug("Non Unique Result Exception - the Catalog Database does not match a unique row - data integrity error: modelCustomizationUuid='" + modelCustomizationUuid + "'");
+ LOGGER.error(MessageEnum.GENERAL_EXCEPTION, " non unique result for modelCustomizationUuid=" + modelCustomizationUuid, "", "", MsoLogger.ErrorCode.DataError, "Non unique result for modelCustomizationUuid==" + modelCustomizationUuid);
+ module = null;
+ } catch (org.hibernate.HibernateException he) {
+ LOGGER.debug("Hibernate Exception - while searching for: modelCustomizationUuid='" + modelCustomizationUuid + "'");
+ LOGGER.error(MessageEnum.GENERAL_EXCEPTION, " Hibernate exception searching for modelCustomizationUuid=" + modelCustomizationUuid, "", "", MsoLogger.ErrorCode.DataError, "Hibernate exception searching for modelCustomizationUuid=" + modelCustomizationUuid);
+ module = null;
+ } catch (Exception e) {
+ LOGGER.debug("Generic Exception - while searching for: modelCustomizationUuid='" + modelCustomizationUuid + "'");
+ LOGGER.error(MessageEnum.GENERAL_EXCEPTION, " Generic exception searching for modelCustomizationUuid=" + modelCustomizationUuid, "", "", MsoLogger.ErrorCode.DataError, "Generic exception searching for modelCustomizationUuid=" + modelCustomizationUuid);
+ module = null;
+ }
+ if (module == null) {
+ LOGGER.recordMetricEvent (startTime, MsoLogger.StatusCode.COMPLETE, MsoLogger.ResponseCode.Suc, "NotFound", "CatalogDB", "getVfModuleTypeByUuid", null);
+ } else {
+ LOGGER.recordMetricEvent (startTime, MsoLogger.StatusCode.COMPLETE, MsoLogger.ResponseCode.Suc, "Successfully", "CatalogDB", "getVfModuleTypeByUuid", null);
+ }
+ return module;
+ }
+
public VfModule getVfModuleType(String type) {
long startTime = System.currentTimeMillis();
LOGGER.debug("Catalog database - get vfModuleType with type " + type);
LOGGER.error(MessageEnum.GENERAL_EXCEPTION, " Generic exception searching for type=" + type + " and version=" + version, "", "", MsoLogger.ErrorCode.DataError, "Generic exception searching for type=" + type);
module = null;
}
- if (module == null) {
- LOGGER.recordMetricEvent (startTime, MsoLogger.StatusCode.COMPLETE, MsoLogger.ResponseCode.Suc, "NotFound", "CatalogDB", "getVfModuleType", null);
- } else {
- LOGGER.recordMetricEvent (startTime, MsoLogger.StatusCode.COMPLETE, MsoLogger.ResponseCode.Suc, "Successfully", "CatalogDB", "getVfModuleType", null);
+ if (module == null) {
+ LOGGER.recordMetricEvent (startTime, MsoLogger.StatusCode.COMPLETE, MsoLogger.ResponseCode.Suc, "NotFound", "CatalogDB", "getVfModuleType", null);
+ } else {
+ LOGGER.recordMetricEvent (startTime, MsoLogger.StatusCode.COMPLETE, MsoLogger.ResponseCode.Suc, "Successfully", "CatalogDB", "getVfModuleType", null);
+ }
+ return module;
+ }
+
+ public VnfResource getVnfResourceByServiceUuid(String serviceModelInvariantUuid) {
+ long startTime = System.currentTimeMillis();
+ LOGGER.debug ("Catalog database - get vfModuleType with serviceModelInvariantUuid " + serviceModelInvariantUuid);
+
+ String hql = "FROM VnfResource WHERE serviceModelInvariantUuid = :serviceModelInvariantUuid";
+ Query query = getSession().createQuery(hql);
+ query.setParameter ("serviceModelInvariantUuid", serviceModelInvariantUuid);
+ VnfResource vnfResource = null;
+ try {
+ vnfResource = (VnfResource) query.uniqueResult ();
+ } catch (org.hibernate.NonUniqueResultException nure) {
+ LOGGER.debug("Non Unique Result Exception - the Catalog Database does not match a unique row - data integrity error: serviceModelInvariantUuid='" + serviceModelInvariantUuid);
+ LOGGER.error(MessageEnum.GENERAL_EXCEPTION, " non unique result for serviceModelInvariantUuid=" + serviceModelInvariantUuid, "", "", MsoLogger.ErrorCode.DataError, "Non unique result for serviceModelInvariantUuid==" + serviceModelInvariantUuid);
+ vnfResource = null;
+ } catch (org.hibernate.HibernateException he) {
+ LOGGER.debug("Hibernate Exception - while searching for: serviceModelInvariantUuid='" + serviceModelInvariantUuid + "'");
+ LOGGER.error(MessageEnum.GENERAL_EXCEPTION, " Hibernate exception searching for serviceModelInvariantUuid=" + serviceModelInvariantUuid, "", "", MsoLogger.ErrorCode.DataError, "Hibernate exception searching for serviceModelInvariantUuid=" + serviceModelInvariantUuid);
+ vnfResource = null;
+ } catch (Exception e) {
+ LOGGER.debug("Generic Exception - while searching for: serviceModelInvariantUuid='" + serviceModelInvariantUuid + "'");
+ LOGGER.error(MessageEnum.GENERAL_EXCEPTION, " Generic exception searching for serviceModelInvariantUuid=" + serviceModelInvariantUuid, "", "", MsoLogger.ErrorCode.DataError, "Generic exception searching for serviceModelInvariantUuid=" + serviceModelInvariantUuid);
+ vnfResource = null;
+ }
+ if (vnfResource == null) {
+ LOGGER.recordMetricEvent (startTime, MsoLogger.StatusCode.COMPLETE, MsoLogger.ResponseCode.Suc, "NotFound", "CatalogDB", "getVfModuleType", null);
+ } else {
+ LOGGER.recordMetricEvent (startTime, MsoLogger.StatusCode.COMPLETE, MsoLogger.ResponseCode.Suc, "Successfully", "CatalogDB", "getVfModuleType", null);
+ }
+ return vnfResource;
+ }
+
+ public VnfResource getVnfResourceByVnfUuid(String vnfResourceModelInvariantUuid) {
+ long startTime = System.currentTimeMillis();
+ LOGGER.debug ("Catalog database - get vfModuleType with vnfResourceModelInvariantUuid " + vnfResourceModelInvariantUuid);
+
+ String hql = "FROM VnfResource WHERE vnfResourceModelInvariantUuid = :vnfResourceModelInvariantUuid";
+ Query query = getSession().createQuery(hql);
+ query.setParameter ("vnfResourceModelInvariantUuid", vnfResourceModelInvariantUuid);
+ VnfResource vnfResource = null;
+ try {
+ vnfResource = (VnfResource) query.uniqueResult ();
+ } catch (org.hibernate.NonUniqueResultException nure) {
+ LOGGER.debug("Non Unique Result Exception - the Catalog Database does not match a unique row - data integrity error: vnfResourceModelInvariantUuid='" + vnfResourceModelInvariantUuid);
+ LOGGER.error(MessageEnum.GENERAL_EXCEPTION, " non unique result for vnfResourceModelInvariantUuid=" + vnfResourceModelInvariantUuid, "", "", MsoLogger.ErrorCode.DataError, "Non unique result for vnfResourceModelInvariantUuid==" + vnfResourceModelInvariantUuid);
+ vnfResource = null;
+ } catch (org.hibernate.HibernateException he) {
+ LOGGER.debug("Hibernate Exception - while searching for: vnfResourceModelInvariantUuid='" + vnfResourceModelInvariantUuid + "'");
+ LOGGER.error(MessageEnum.GENERAL_EXCEPTION, " Hibernate exception searching for vnfResourceModelInvariantUuid=" + vnfResourceModelInvariantUuid, "", "", MsoLogger.ErrorCode.DataError, "Hibernate exception searching for vnfResourceModelInvariantUuid=" + vnfResourceModelInvariantUuid);
+ vnfResource = null;
+ } catch (Exception e) {
+ LOGGER.debug("Generic Exception - while searching for: vnfResourceModelInvariantUuid='" + vnfResourceModelInvariantUuid + "'");
+ LOGGER.error(MessageEnum.GENERAL_EXCEPTION, " Generic exception searching for vnfResourceModelInvariantUuid=" + vnfResourceModelInvariantUuid, "", "", MsoLogger.ErrorCode.DataError, "Generic exception searching for vnfResourceModelInvariantUuid=" + vnfResourceModelInvariantUuid);
+ vnfResource = null;
+ }
+ if (vnfResource == null) {
+ LOGGER.recordMetricEvent (startTime, MsoLogger.StatusCode.COMPLETE, MsoLogger.ResponseCode.Suc, "NotFound", "CatalogDB", "getVfModuleType", null);
+ } else {
+ LOGGER.recordMetricEvent (startTime, MsoLogger.StatusCode.COMPLETE, MsoLogger.ResponseCode.Suc, "Successfully", "CatalogDB", "getVfModuleType", null);
+ }
+ return vnfResource;
+ }
+
+ public VnfResource getVnfResourceByType(String vnfType) {
+ return this.getVnfResource(vnfType);
+ }
+
+ public VfModule getVfModuleByModelInvariantUuid(String vfModuleModelInvariantUuid) {
+ long startTime = System.currentTimeMillis();
+ LOGGER.debug ("Catalog database - get vfModuleTypeByUuid with uuid " + vfModuleModelInvariantUuid);
+
+ String hql = "FROM VfModule WHERE vfModuleModelInvariantUuid = :vfModuleModelInvariantUuid ";
+ Query query = getSession().createQuery(hql);
+ query.setParameter ("vfModuleModelInvariantUuid", vfModuleModelInvariantUuid);
+ VfModule module = null;
+ try {
+ module = (VfModule) query.uniqueResult ();
+ } catch (org.hibernate.NonUniqueResultException nure) {
+ LOGGER.debug("Non Unique Result Exception - the Catalog Database does not match a unique row - data integrity error: vfModuleModelInvariantUuid='" + vfModuleModelInvariantUuid + "'");
+ LOGGER.error(MessageEnum.GENERAL_EXCEPTION, " non unique result for vfModuleModelInvariantUuid=" + vfModuleModelInvariantUuid , "", "", MsoLogger.ErrorCode.DataError, "Non unique result for vfModuleModelInvariantUuid==" + vfModuleModelInvariantUuid);
+ module = null;
+ } catch (org.hibernate.HibernateException he) {
+ LOGGER.debug("Hibernate Exception - while searching for: vfModuleModelInvariantUuid='" + vfModuleModelInvariantUuid + "'");
+ LOGGER.error(MessageEnum.GENERAL_EXCEPTION, " Hibernate exception searching for vfModuleModelInvariantUuid=" + vfModuleModelInvariantUuid, "", "", MsoLogger.ErrorCode.DataError, "Hibernate exception searching for vfModuleModelInvariantUuid=" + vfModuleModelInvariantUuid);
+ module = null;
+ } catch (Exception e) {
+ LOGGER.debug("Generic Exception - while searching for: vfModuleModelInvariantUuid='" + vfModuleModelInvariantUuid + "'");
+ LOGGER.error(MessageEnum.GENERAL_EXCEPTION, " Generic exception searching for vfModuleModelInvariantUuid=" + vfModuleModelInvariantUuid, "", "", MsoLogger.ErrorCode.DataError, "Generic exception searching for vfModuleModelInvariantUuid=" + vfModuleModelInvariantUuid);
+ module = null;
+ }
+ if (module == null) {
+ LOGGER.recordMetricEvent (startTime, MsoLogger.StatusCode.COMPLETE, MsoLogger.ResponseCode.Suc, "NotFound", "CatalogDB", "getVfModuleByModelInvariantUuid", null);
+ } else {
+ LOGGER.recordMetricEvent (startTime, MsoLogger.StatusCode.COMPLETE, MsoLogger.ResponseCode.Suc, "Successfully", "CatalogDB", "getVfModuleByModelInvariantUuid", null);
+ }
+ return module;
+ }
+
+ public VfModule getVfModuleByModelCustomizationUuid(String modelCustomizationUuid) {
+ long startTime = System.currentTimeMillis();
+ LOGGER.debug ("Catalog database - get vfModuleTypeByModelCustomizationUuid with uuid " + modelCustomizationUuid);
+
+ String hql = "FROM VfModule WHERE modelCustomizationUuid = :modelCustomizationUuid ";
+ Query query = getSession().createQuery(hql);
+ query.setParameter ("modelCustomizationUuid", modelCustomizationUuid);
+ VfModule module = null;
+ try {
+ module = (VfModule) query.uniqueResult ();
+ } catch (org.hibernate.NonUniqueResultException nure) {
+ LOGGER.debug("Non Unique Result Exception - the Catalog Database does not match a unique row - data integrity error: modelCustomizationUuid='" + modelCustomizationUuid + "'");
+ LOGGER.error(MessageEnum.GENERAL_EXCEPTION, " non unique result for vfModuleModelInvariantUuid=" + modelCustomizationUuid , "", "", MsoLogger.ErrorCode.DataError, "Non unique result for modelCustomizationUuid==" + modelCustomizationUuid);
+ module = null;
+ } catch (org.hibernate.HibernateException he) {
+ LOGGER.debug("Hibernate Exception - while searching for: modelCustomizationUuid='" + modelCustomizationUuid + "'");
+ LOGGER.error(MessageEnum.GENERAL_EXCEPTION, " Hibernate exception searching for modelCustomizationUuid=" + modelCustomizationUuid, "", "", MsoLogger.ErrorCode.DataError, "Hibernate exception searching for modelCustomizationUuid=" + modelCustomizationUuid);
+ module = null;
+ } catch (Exception e) {
+ LOGGER.debug("Generic Exception - while searching for: modelCustomizationUuid='" + modelCustomizationUuid + "'");
+ LOGGER.error(MessageEnum.GENERAL_EXCEPTION, " Generic exception searching for modelCustomizationUuid=" + modelCustomizationUuid, "", "", MsoLogger.ErrorCode.DataError, "Generic exception searching for modelCustomizationUuid=" + modelCustomizationUuid);
+ module = null;
+ }
+ if (module == null) {
+ LOGGER.recordMetricEvent (startTime, MsoLogger.StatusCode.COMPLETE, MsoLogger.ResponseCode.Suc, "NotFound", "CatalogDB", "getVfModuleByModelCustomizationUuid", null);
+ } else {
+ LOGGER.recordMetricEvent (startTime, MsoLogger.StatusCode.COMPLETE, MsoLogger.ResponseCode.Suc, "Successfully", "CatalogDB", "getVfModuleByModelCustomizationUuid", null);
+ }
+ return module;
+ }
+
+ public VfModule getVfModuleByType(String vfModuleType) {
+ return this.getVfModuleType(vfModuleType);
+ }
+
+ public List<VfModule> getVfModulesForVnfResource(VnfResource vnfResource) {
+ if (vnfResource == null)
+ return null;
+ int vnfResourceId = vnfResource.getId();
+
+ long startTime = System.currentTimeMillis();
+ LOGGER.debug("Catalog database - getVfModulesForVnfResource - vnfResource: " + vnfResource.toString());
+
+ return this.getVfModulesForVnfResource(vnfResourceId);
+
+ }
+
+ public List<VfModule> getVfModulesForVnfResource(int vnfResourceId) {
+ long startTime = System.currentTimeMillis();
+ LOGGER.debug("Catalog database - getVfModulesForVnfResource - vnfResourceId: " + vnfResourceId);
+ StringBuilder hql = new StringBuilder("FROM VfModule where vnfResourceId = :vnfResourceId");
+ Query query = getSession().createQuery(hql.toString());
+ query.setParameter("vnfResourceId", vnfResourceId);
+ List<VfModule> resultList = null;
+ try {
+ resultList = query.list();
+ if (resultList != null)
+ LOGGER.debug("\tQuery found " + resultList.size() + " records.");
+ else
+ LOGGER.debug("\tQuery found no records.");
+ } catch (org.hibernate.HibernateException he) {
+ LOGGER.debug("Hibernate Exception - getVfModulesForVnfResource - while searching for: vnfResourceId='" + vnfResourceId + " " + he.getMessage());
+ LOGGER.error(MessageEnum.GENERAL_EXCEPTION, " Hibernate exception - getVfModulesForVnfResource - searching for vnfResourceId=" + vnfResourceId, "", "", MsoLogger.ErrorCode.DataError, "Hibernate exception searching for vnfResourceId=" + vnfResourceId);
+ } catch (Exception e) {
+ LOGGER.debug("Exception - getVfModulesForVnfResource - while searching for: vnfResourceId='" + vnfResourceId + " " + e.getMessage());
+ LOGGER.error(MessageEnum.GENERAL_EXCEPTION, " Hibernate exception - getVfModulesForVnfResource - searching for vnfResourceId=" + vnfResourceId, "", "", MsoLogger.ErrorCode.DataError, "Hibernate exception searching for vnfResourceId=" + vnfResourceId);
+ }
+ if (resultList == null) {
+ resultList = new ArrayList<VfModule>();
+ }
+ LOGGER.recordMetricEvent (startTime, MsoLogger.StatusCode.COMPLETE, MsoLogger.ResponseCode.Suc, "Successfully", "CatalogDB", "getVfModulesForVnfResource", null);
+ return resultList;
+ }
+
+ public Service getServiceByUuid (String serviceModelInvariantUuid) {
+
+ long startTime = System.currentTimeMillis ();
+ LOGGER.debug ("Catalog database - get service with ModelInvariantUuid " + serviceModelInvariantUuid);
+
+ String hql = "FROM Service WHERE modelInvariantUUID = :serviceModelInvariantUuid";
+ Query query = getSession ().createQuery (hql);
+ query.setParameter ("serviceModelInvariantUuid", serviceModelInvariantUuid);
+
+ Service service = null;
+ try {
+ service = (Service) query.uniqueResult ();
+ } catch (org.hibernate.NonUniqueResultException nure) {
+ LOGGER.debug("Non Unique Result Exception - the Catalog Database does not match a unique row - data integrity error: serviceModelInvariantUuid='" + serviceModelInvariantUuid + "'");
+ LOGGER.error(MessageEnum.GENERAL_EXCEPTION, " non unique result for serviceModelInvariantUuid=" + serviceModelInvariantUuid, "", "", MsoLogger.ErrorCode.DataError, "Non unique result for serviceModelInvariantUuid=" + serviceModelInvariantUuid);
+ return null;
+ } catch (org.hibernate.HibernateException he) {
+ LOGGER.debug("Hibernate Exception - while searching for: serviceName='" + serviceModelInvariantUuid + "'");
+ LOGGER.error(MessageEnum.GENERAL_EXCEPTION, " Hibernate exception searching for serviceModelInvariantUuid=" + serviceModelInvariantUuid, "", "", MsoLogger.ErrorCode.DataError, "Hibernate exception searching for serviceModelInvariantUuid=" + serviceModelInvariantUuid);
+ return null;
+ } catch (Exception e) {
+ LOGGER.debug("Generic Exception - while searching for: serviceModelInvariantUuid='" + serviceModelInvariantUuid);
+ LOGGER.error(MessageEnum.GENERAL_EXCEPTION, " Generic exception searching for serviceModelInvariantUuid=" + serviceModelInvariantUuid, "", "", MsoLogger.ErrorCode.DataError, "Generic exception searching for serviceModelInvariantUuid=" + serviceModelInvariantUuid);
+ return null;
+ }
+ if (service == null) {
+ LOGGER.recordMetricEvent (startTime, MsoLogger.StatusCode.COMPLETE, MsoLogger.ResponseCode.Suc, "NotFound", "CatalogDB", "getService", null);
+ } else {
+ LOGGER.recordMetricEvent (startTime, MsoLogger.StatusCode.COMPLETE, MsoLogger.ResponseCode.Suc, "Successfully", "CatalogDB", "getService", null);
+ }
+
+ return service;
+ }
+
+ public NetworkResource getNetworkResourceById(Integer id) {
+ long startTime = System.currentTimeMillis ();
+ LOGGER.debug ("Catalog database - getNetworkResource with id " + id);
+
+ String hql = "FROM NetworkResource WHERE id = :id";
+ Query query = getSession ().createQuery (hql);
+ query.setParameter ("id", id);
+
+ NetworkResource networkResource = null;
+ try {
+ networkResource = (NetworkResource) query.uniqueResult ();
+ } catch (org.hibernate.NonUniqueResultException nure) {
+ LOGGER.debug("Non Unique Result Exception - the Catalog Database does not match a unique row - data integrity error: NETWORK_RESOURCE.id='" + id + "'");
+ LOGGER.error(MessageEnum.GENERAL_EXCEPTION, " non unique result for NETWORK_RESOURCE.id=" + id, "", "", MsoLogger.ErrorCode.DataError, "Non unique result for NETWORK_RESOURCE.id=" + id);
+ return null;
+ } catch (org.hibernate.HibernateException he) {
+ LOGGER.debug("Hibernate Exception - while searching for: NETWORK_RESOURCE.id='" + id + "'");
+ LOGGER.error(MessageEnum.GENERAL_EXCEPTION, " Hibernate exception searching for NETWORK_RESOURCE.id=" + id, "", "", MsoLogger.ErrorCode.DataError, "Hibernate exception searching for NETWORK_RESOURCE.id=" + id);
+ return null;
+ } catch (Exception e) {
+ LOGGER.debug("Generic Exception - while searching for: NETWORK_RESOURCE.id='" + id);
+ LOGGER.error(MessageEnum.GENERAL_EXCEPTION, " Generic exception searching for NETWORK_RESOURCE.id=" + id, "", "", MsoLogger.ErrorCode.DataError, "Generic exception searching for NETWORK_RESOURCE.id=" + id);
+ return null;
+ }
+
+ LOGGER.recordMetricEvent (startTime, MsoLogger.StatusCode.COMPLETE, MsoLogger.ResponseCode.Suc, "Successfully", "CatalogDB", "getNetworkResourceById", null);
+ return networkResource;
+
+ }
+
+ // 1702 API Spec - Query for all networks in a Service:
+ public List<NetworkResourceCustomization> getAllNetworksByServiceModelUuid(String serviceModelUuid) {
+ long startTime = System.currentTimeMillis();
+ LOGGER.debug("Catalog database: getServiceNetworksByServiceModelUuid - " + serviceModelUuid);
+
+ // This is a 2-step process (3 really) - 1) query ServiceToNetworks, 2) query NetworkResourceCustomization, 3) populate the networkType
+
+ StringBuilder hql1 = new StringBuilder("FROM ServiceToNetworks WHERE serviceModelUuid = :serviceModelUuid");
+ Query query = getSession().createQuery(hql1.toString());
+ query.setParameter("serviceModelUuid", serviceModelUuid);
+ @SuppressWarnings("unchecked")
+ List<ServiceToNetworks> resultList1 = query.list();
+ if (resultList1 == null || resultList1.size() < 1) {
+ LOGGER.debug("Found no matches to the query - FROM ServiceToNetworks WHERE serviceModelUuid = " + serviceModelUuid);
+ return null;
+ }
+ LOGGER.debug("Found " + resultList1.size() + " entries in ServiceToNetworks with smu=" + serviceModelUuid);
+
+ ArrayList<NetworkResourceCustomization> masterList = new ArrayList<NetworkResourceCustomization>();
+ for (ServiceToNetworks stn : resultList1) {
+ String networkModelCustomizationUuid = stn.getNetworkModelCustomizationUuid();
+ LOGGER.debug("Now searching for NetworkResourceCustomization for " + networkModelCustomizationUuid);
+ List<NetworkResourceCustomization> resultSet = this.getAllNetworksByNetworkModelCustomizationUuid(networkModelCustomizationUuid);
+ for (NetworkResourceCustomization nrc : resultSet) {
+ masterList.add(nrc);
+ }
+ }
+ LOGGER.debug("Returning " + masterList.size() + " NRC records");
+ LOGGER.recordMetricEvent (startTime, MsoLogger.StatusCode.COMPLETE, MsoLogger.ResponseCode.Suc, "Successfully", "CatalogDB", "getAllNetworksByServiceModelUuid", null);
+ return masterList;
+
+ }
+ public List<NetworkResourceCustomization> getAllNetworksByServiceModelInvariantUuid(String serviceModelInvariantUuid) {
+ long startTime = System.currentTimeMillis();
+ LOGGER.debug("Catalog database: getServiceNetworksByServiceModelInvariantUuid - " + serviceModelInvariantUuid);
+
+ StringBuilder hql = new StringBuilder("FROM Service WHERE modelInvariantUUID = :serviceModelInvariantUuid");
+ Query query = getSession().createQuery(hql.toString());
+ query.setParameter("serviceModelInvariantUuid", serviceModelInvariantUuid);
+ @SuppressWarnings("unchecked")
+ List<Service> serviceList = query.list();
+
+ if (serviceList.isEmpty()) {
+ LOGGER.debug("Could not find Service for " + serviceModelInvariantUuid);
+ return null;
+ }
+
+ Collections.sort (serviceList, new MavenLikeVersioningComparator ());
+ Collections.reverse (serviceList);
+ Service service = serviceList.get(0);
+
+ String serviceNameVersionId = service.getServiceNameVersionId();
+ LOGGER.debug("The highest version for the Service " + serviceModelInvariantUuid + " is " + serviceNameVersionId);
+
+ // Service.serviceNameVersionId == ServiceToNetworks.serviceModelUuid
+ return this.getAllNetworksByServiceModelUuid(serviceNameVersionId);
+ }
+ public List<NetworkResourceCustomization> getAllNetworksByServiceModelInvariantUuid(String serviceModelInvariantUuid, String serviceModelVersion) {
+ long startTime = System.currentTimeMillis();
+ LOGGER.debug("Catalog database: getServiceNetworksByServiceModelInvariantUuid - " + serviceModelInvariantUuid + ", version=" + serviceModelVersion);
+
+ StringBuilder hql = new StringBuilder("FROM Service WHERE modelInvariantUUID = :serviceModelInvariantUuid and version = :serviceModelVersion");
+ Query query = getSession().createQuery(hql.toString());
+ query.setParameter("serviceModelInvariantUuid", serviceModelInvariantUuid);
+ query.setParameter("serviceModelVersion", serviceModelVersion);
+
+ //TODO
+ //can fix this later - no time - could do a unique query here - but this should work
+ @SuppressWarnings("unchecked")
+ List<Service> serviceList = query.list();
+
+ if (serviceList.isEmpty()) {
+ LOGGER.debug("No Service found with smu=" + serviceModelInvariantUuid + " and smv=" + serviceModelVersion);
+ return null;
+ }
+
+ Collections.sort (serviceList, new MavenLikeVersioningComparator ());
+ Collections.reverse (serviceList);
+ Service service = serviceList.get(0);
+
+ String serviceNameVersionId = service.getServiceNameVersionId();
+
+ // Service.serviceNameVersionId == ServiceToNetworks.serviceModelUuid
+ return this.getAllNetworksByServiceModelUuid(serviceNameVersionId);
+
+ }
+ public List<NetworkResourceCustomization> getAllNetworksByNetworkModelCustomizationUuid(String networkModelCustomizationUuid) {
+ long startTime = System.currentTimeMillis();
+ LOGGER.debug("Catalog database: getAllNetworksByNetworkModelCustomizationUuid - " + networkModelCustomizationUuid);
+
+ StringBuilder hql = new StringBuilder("FROM NetworkResourceCustomization WHERE modelCustomizationUuid = :networkModelCustomizationUuid");
+ Query query = getSession().createQuery(hql.toString());
+ query.setParameter("networkModelCustomizationUuid", networkModelCustomizationUuid);
+
+ @SuppressWarnings("unchecked")
+ List<NetworkResourceCustomization> resultList = query.list();
+
+ this.populateNetworkResourceType(resultList);
+
+ LOGGER.recordMetricEvent (startTime, MsoLogger.StatusCode.COMPLETE, MsoLogger.ResponseCode.Suc, "Successfully", "CatalogDB", "getAllNetworksByNetworkModelCustomizationUuid", null);
+ return resultList;
+ }
+ public List<NetworkResourceCustomization> getAllNetworksByNetworkType(String networkType) {
+ long startTime = System.currentTimeMillis();
+ LOGGER.debug("Catalog database: getServiceNetworksByNetworkType - " + networkType);
+
+ NetworkResource nr = this.getNetworkResource(networkType);
+ if (nr == null) {
+ return new ArrayList<NetworkResourceCustomization>();
+ }
+ Integer networkResourceId = nr.getId();
+
+ LOGGER.debug("Now searching for NRC's with networkResourceId = " + networkResourceId);
+ StringBuilder hql = new StringBuilder("FROM NetworkResourceCustomization WHERE networkResourceId = :networkResourceId");
+
+ Query query = getSession().createQuery(hql.toString());
+ query.setParameter("networkResourceId", networkResourceId);
+
+ @SuppressWarnings("unchecked")
+ List<NetworkResourceCustomization> resultList = query.list();
+
+ if (resultList != null && resultList.size() > 0) {
+ LOGGER.debug("Found " + resultList.size() + " results");
+ for (NetworkResourceCustomization nrc : resultList) {
+ nrc.setNetworkType(networkType);
+ nrc.setNetworkResource(nr);
+ }
+ }
+ LOGGER.recordMetricEvent (startTime, MsoLogger.StatusCode.COMPLETE, MsoLogger.ResponseCode.Suc, "Successfully", "CatalogDB", "getAllNetworksByNetworkType", null);
+
+ return resultList;
+ }
+
+ //1702 API Spec cont'd - Query for all VnfResources in a Service:
+ public List<VnfResource> getAllVnfsByServiceModelUuid(String serviceModelUuid) {
+ long startTime = System.currentTimeMillis();
+ LOGGER.debug("Catalog database: getAllVnfsByServiceModelUuid - " + serviceModelUuid);
+
+ StringBuilder hql = new StringBuilder("FROM Service WHERE serviceNameVersionId = :serviceModelUuid");
+ Query query = getSession().createQuery(hql.toString());
+ query.setParameter("serviceModelUuid", serviceModelUuid);
+ @SuppressWarnings("unchecked")
+ List<Service> serviceList = query.list();
+
+ if (serviceList.isEmpty()) {
+ return null;
+ }
+
+ Collections.sort (serviceList, new MavenLikeVersioningComparator ());
+ Collections.reverse (serviceList);
+ Service service = serviceList.get(0);
+
+ String serviceModelInvariantUuid = service.getModelInvariantUUID();
+ String serviceModelVersion = service.getVersion();
+
+ return this.getAllVnfsByServiceModelInvariantUuid(serviceModelInvariantUuid, serviceModelVersion);
+
+ }
+ public List<VnfResource> getAllVnfsByServiceModelInvariantUuid(String serviceModelInvariantUuid) {
+ long startTime = System.currentTimeMillis();
+ LOGGER.debug("Catalog database: getAllVnfsByServiceModelInvariantUuid - " + serviceModelInvariantUuid);
+
+ StringBuilder hqlService = new StringBuilder("FROM Service WHERE modelInvariantUUID = :serviceModelInvariantUuid");
+ Query query = getSession().createQuery(hqlService.toString());
+ query.setParameter("serviceModelInvariantUuid", serviceModelInvariantUuid);
+ @SuppressWarnings("unchecked")
+ List<Service> resultList = query.list();
+
+ if (resultList.isEmpty()) {
+ return null;
+ }
+ Collections.sort (resultList, new MavenLikeVersioningComparator ());
+ Collections.reverse (resultList);
+ Service service = resultList.get(0);
+ //now just call the method that takes the version - the service object will have the highest version
+ return this.getAllVnfsByServiceModelInvariantUuid(serviceModelInvariantUuid, service.getVersion());
+ }
+ public List<VnfResource> getAllVnfsByServiceModelInvariantUuid(String serviceModelInvariantUuid, String serviceModelVersion) {
+ long startTime = System.currentTimeMillis();
+ LOGGER.debug("Catalog database: getAllVnfsByServiceModelInvariantUuid - " + serviceModelInvariantUuid + ", version=" + serviceModelVersion);
+
+ StringBuilder hql = new StringBuilder("FROM VnfResource WHERE serviceModelInvariantUUID = :serviceModelInvariantUuid and version = :serviceModelVersion");
+ Query query = getSession().createQuery(hql.toString());
+ query.setParameter("serviceModelInvariantUuid", serviceModelInvariantUuid);
+ query.setParameter("serviceModelVersion", serviceModelVersion);
+
+ @SuppressWarnings("unchecked")
+ List<VnfResource> resultList = query.list();
+
+ if (resultList.isEmpty()) {
+ return null;
+ }
+ // so we have a list of VnfResource objects - but we need to add each one's VfModule objects
+ for (VnfResource vnfResource : resultList) {
+ List<VfModule> vfModules = this.getVfModulesForVnfResource(vnfResource);
+ if (vfModules != null && !vfModules.isEmpty()) {
+ for (VfModule vfm : vfModules) {
+ vnfResource.addVfModule(vfm);
+ }
+ }
+ }
+ LOGGER.recordMetricEvent (startTime, MsoLogger.StatusCode.COMPLETE, MsoLogger.ResponseCode.Suc, "Successfully", "CatalogDB", "getAllVnfsByServiceModelInvariantUuid", null);
+ return resultList;
+
+ }
+ public List<VnfResource> getAllVnfsByServiceName(String serviceName, String serviceVersion) {
+ long startTime = System.currentTimeMillis();
+ LOGGER.debug("Catalog database: getAllVnfsByServiceName - " + serviceName + ", version=" + serviceVersion);
+ if (serviceVersion == null || serviceVersion.equals("")) {
+ return this.getAllVnfsByServiceName(serviceName);
+ }
+
+ StringBuilder hql = new StringBuilder("FROM Service WHERE serviceName = :serviceName and version = :serviceVersion");
+ Query query = getSession().createQuery(hql.toString());
+ query.setParameter("serviceName", serviceName);
+ query.setParameter("serviceVersion", serviceVersion);
+
+ @SuppressWarnings("unchecked")
+ List<Service> resultList = query.list();
+
+ if (resultList.isEmpty()) {
+ return null;
+ }
+
+ Service service = resultList.get(0);
+
+ return this.getAllVnfsByServiceModelInvariantUuid(service.getModelInvariantUUID(), service.getVersion());
+ }
+ public List<VnfResource> getAllVnfsByServiceName(String serviceName) {
+ long startTime = System.currentTimeMillis();
+ LOGGER.debug("Catalog database: getAllVnfsByServiceName - " + serviceName);
+
+ StringBuilder hql = new StringBuilder("FROM Service WHERE serviceName = :serviceName");
+ Query query = getSession().createQuery(hql.toString());
+ query.setParameter("serviceName", serviceName);
+
+ @SuppressWarnings("unchecked")
+ List<Service> resultList = query.list();
+
+ if (resultList.isEmpty()) {
+ return null;
+ }
+ Collections.sort (resultList, new MavenLikeVersioningComparator ());
+ Collections.reverse (resultList);
+ Service service = resultList.get(0);
+
+ return this.getAllVnfsByServiceModelInvariantUuid(service.getModelInvariantUUID(), service.getVersion());
+ }
+ public List<VnfResource> getAllVnfsByVnfModelCustomizationUuid(String vnfModelCustomizationUuid) {
+ long startTime = System.currentTimeMillis();
+ LOGGER.debug("Catalog database: getAllVnfsByVnfModelCustomizationUuid - " + vnfModelCustomizationUuid);
+
+ StringBuilder hql = new StringBuilder("FROM VnfResource WHERE modelCustomizationUuid = :vnfModelCustomizationUuid");
+ Query query = getSession().createQuery(hql.toString());
+ query.setParameter("vnfModelCustomizationUuid", vnfModelCustomizationUuid);
+
+ @SuppressWarnings("unchecked")
+ List<VnfResource> resultList = query.list();
+
+ if (resultList.isEmpty()) {
+ LOGGER.debug("Found no records matching " + vnfModelCustomizationUuid);
+ return null;
+ }
+ // so we have a list of VnfResource objects - but we need to add each one's VfModule objects
+ for (VnfResource vnfResource : resultList) {
+ LOGGER.debug("Finding vfModules for vnfResource.id=" + vnfResource.getId());
+ List<VfModule> vfModules = this.getVfModulesForVnfResource(vnfResource);
+ if (vfModules != null && !vfModules.isEmpty()) {
+ LOGGER.debug("\tFound " + vfModules.size() + " vf modules");
+ for (VfModule vfm : vfModules) {
+ vnfResource.addVfModule(vfm);
+ }
+ }
+ }
+ LOGGER.debug("Returning " + resultList + " vnf modules");
+ LOGGER.recordMetricEvent (startTime, MsoLogger.StatusCode.COMPLETE, MsoLogger.ResponseCode.Suc, "Successfully", "CatalogDB", "getAllVnfsByVnfModelCustomizationUuid", null);
+ return resultList;
+ }
+
+ //1702 API Spec cont'd - Query for all allotted resources in a Service
+
+ public List<AllottedResourceCustomization> getAllAllottedResourcesByServiceModelUuid(String serviceModelUuid) {
+ long startTime = System.currentTimeMillis();
+ LOGGER.debug("Catalog database: getAllAllottedResourcesByServiceModelUuid - " + serviceModelUuid);
+
+ // This is a 2-step process (3 really) - 1) query ServiceToAllottedResources, 2) query AllottedResourceCustomization
+
+ StringBuilder hql1 = new StringBuilder("FROM ServiceToAllottedResources WHERE serviceModelUuid = :serviceModelUuid");
+ Query query = getSession().createQuery(hql1.toString());
+ query.setParameter("serviceModelUuid", serviceModelUuid);
+ @SuppressWarnings("unchecked")
+ List<ServiceToAllottedResources> resultList1 = query.list();
+ if (resultList1 == null || resultList1.size() < 1) {
+ LOGGER.debug("Found no matches to the query " + hql1.toString());
+ return null;
+ }
+ LOGGER.debug("Found " + resultList1.size() + " entries in ServiceToAllottedResources with smu=" + serviceModelUuid);
+
+ ArrayList<AllottedResourceCustomization> masterList = new ArrayList<AllottedResourceCustomization>();
+ for (ServiceToAllottedResources star : resultList1) {
+ String arModelCustomizationUuid = star.getArModelCustomizationUuid();
+ LOGGER.debug("Now searching for AllottedResourceCustomization for " + arModelCustomizationUuid);
+ List<AllottedResourceCustomization> resultSet = this.getAllAllottedResourcesByArModelCustomizationUuid(arModelCustomizationUuid);
+ for (AllottedResourceCustomization arc : resultSet) {
+ masterList.add(arc);
+ }
+ }
+ LOGGER.debug("Returning " + masterList.size() + " ARC records");
+ LOGGER.recordMetricEvent (startTime, MsoLogger.StatusCode.COMPLETE, MsoLogger.ResponseCode.Suc, "Successfully", "CatalogDB", "getAllAllottedResourcesByServiceModelUuid", null);
+ return masterList;
+ }
+
+ public List<AllottedResourceCustomization> getAllAllottedResourcesByServiceModelInvariantUuid(String serviceModelInvariantUuid) {
+ long startTime = System.currentTimeMillis();
+ LOGGER.debug("Catalog database: getAllAllottedResourcesByServiceModelInvariantUuid - " + serviceModelInvariantUuid);
+
+ StringBuilder hql = new StringBuilder("FROM Service WHERE modelInvariantUUID = :serviceModelInvariantUuid");
+ Query query = getSession().createQuery(hql.toString());
+ query.setParameter("serviceModelInvariantUuid", serviceModelInvariantUuid);
+ @SuppressWarnings("unchecked")
+ List<Service> serviceList = query.list();
+
+ if (serviceList.isEmpty()) {
+ LOGGER.debug("Could not find Service for " + serviceModelInvariantUuid);
+ return null;
+ }
+
+ Collections.sort (serviceList, new MavenLikeVersioningComparator ());
+ Collections.reverse (serviceList);
+ Service service = serviceList.get(0);
+
+ String serviceNameVersionId = service.getServiceNameVersionId();
+ LOGGER.debug("The highest version for the Service " + serviceModelInvariantUuid + " is " + serviceNameVersionId);
+
+ // Service.serviceNameVersionId == ServiceToAllottedResources.serviceModelUuid
+ return this.getAllAllottedResourcesByServiceModelUuid(serviceNameVersionId);
+ }
+
+ public List<AllottedResourceCustomization> getAllAllottedResourcesByServiceModelInvariantUuid(String serviceModelInvariantUuid, String serviceModelVersion) {
+ long startTime = System.currentTimeMillis();
+ LOGGER.debug("Catalog database: getAllAllottedResourcesByServiceModelInvariantUuid - " + serviceModelInvariantUuid + ", version=" + serviceModelVersion);
+
+ StringBuilder hql = new StringBuilder("FROM Service WHERE modelInvariantUUID = :serviceModelInvariantUuid and version = :serviceModelVersion");
+ Query query = getSession().createQuery(hql.toString());
+ query.setParameter("serviceModelInvariantUuid", serviceModelInvariantUuid);
+ query.setParameter("serviceModelVersion", serviceModelVersion);
+
+ //TODO
+ //can fix this later - no time - could do a unique query here - but this should work
+ @SuppressWarnings("unchecked")
+ List<Service> serviceList = query.list();
+
+ if (serviceList.isEmpty()) {
+ LOGGER.debug("No Service found with smu=" + serviceModelInvariantUuid + " and smv=" + serviceModelVersion);
+ return null;
+ }
+
+ Collections.sort (serviceList, new MavenLikeVersioningComparator ());
+ Collections.reverse (serviceList);
+ Service service = serviceList.get(0);
+
+ String serviceNameVersionId = service.getServiceNameVersionId();
+
+ // Service.serviceNameVersionId == ServiceToNetworks.serviceModelUuid
+ return this.getAllAllottedResourcesByServiceModelUuid(serviceNameVersionId);
+ }
+
+ public List<AllottedResourceCustomization> getAllAllottedResourcesByArModelCustomizationUuid(String arModelCustomizationUuid) {
+ long startTime = System.currentTimeMillis();
+ LOGGER.debug("Catalog database: getAllAllottedResourcesByArModelCustomizationUuid - " + arModelCustomizationUuid);
+
+ StringBuilder hql = new StringBuilder("FROM AllottedResourceCustomization WHERE modelCustomizationUuid = :arModelCustomizationUuid");
+ Query query = getSession().createQuery(hql.toString());
+ query.setParameter("arModelCustomizationUuid", arModelCustomizationUuid);
+
+ @SuppressWarnings("unchecked")
+ List<AllottedResourceCustomization> resultList = query.list();
+
+ LOGGER.recordMetricEvent (startTime, MsoLogger.StatusCode.COMPLETE, MsoLogger.ResponseCode.Suc, "Successfully", "CatalogDB", "getAllAllottedResourcesByArModelCustomizationUuid", null);
+ return resultList;
+ }
+
+ //1702 API Spec cont'd - Query for all resources in a Service:
+ public ServiceMacroHolder getAllResourcesByServiceModelUuid(String serviceModelUuid) {
+ long startTime = System.currentTimeMillis();
+ LOGGER.debug("Catalog database: getAllResourcesByServiceModelUuid - " + serviceModelUuid);
+
+ StringBuilder hql = new StringBuilder("FROM Service WHERE serviceNameVersionId = :serviceModelUuid");
+ Query query = getSession().createQuery(hql.toString());
+ query.setParameter("serviceModelUuid", serviceModelUuid);
+ @SuppressWarnings("unchecked")
+ List<Service> serviceList = query.list();
+
+ if (serviceList.isEmpty()) {
+ LOGGER.debug("Unable to find a Service with serviceModelUuid=" + serviceModelUuid);
+ return null;
+ }
+
+ Collections.sort (serviceList, new MavenLikeVersioningComparator ());
+ Collections.reverse (serviceList);
+ Service service = serviceList.get(0);
+
+ ServiceMacroHolder smh = new ServiceMacroHolder(service);
+ ArrayList<NetworkResourceCustomization> nrcList = (ArrayList<NetworkResourceCustomization>) this.getAllNetworksByServiceModelUuid(serviceModelUuid);
+ smh.setNetworkResourceCustomization(nrcList);
+ ArrayList<AllottedResourceCustomization> arcList = (ArrayList<AllottedResourceCustomization>) this.getAllAllottedResourcesByServiceModelUuid(serviceModelUuid);
+ smh.setAllottedResourceCustomization(arcList);
+ ArrayList<VnfResource> vnfList = (ArrayList<VnfResource>) this.getAllVnfsByServiceModelInvariantUuid(service.getModelInvariantUUID(), service.getVersion());
+ smh.setVnfResources(vnfList);
+
+ LOGGER.recordMetricEvent (startTime, MsoLogger.StatusCode.COMPLETE, MsoLogger.ResponseCode.Suc, "Successfully", "CatalogDB", "getAllResourcesByServiceModelUuid", null);
+ return smh;
+ }
+ public ServiceMacroHolder getAllResourcesByServiceModelInvariantUuid(String serviceModelInvariantUuid) {
+ long startTime = System.currentTimeMillis();
+ LOGGER.debug("Catalog database: getAllResourcesByServiceModelInvariantUuid - " + serviceModelInvariantUuid);
+
+ StringBuilder hql = new StringBuilder("FROM Service WHERE modelInvariantUUID = :serviceModelInvariantUuid");
+ Query query = getSession().createQuery(hql.toString());
+ query.setParameter("serviceModelInvariantUuid", serviceModelInvariantUuid);
+ @SuppressWarnings("unchecked")
+ List<Service> serviceList = query.list();
+
+ if (serviceList.isEmpty()) {
+ LOGGER.debug("Unable to find a Service with serviceModelInvariantUuid=" + serviceModelInvariantUuid);
+ return null;
+ }
+
+ Collections.sort (serviceList, new MavenLikeVersioningComparator ());
+ Collections.reverse (serviceList);
+ Service service = serviceList.get(0);
+
+ ServiceMacroHolder smh = new ServiceMacroHolder(service);
+ ArrayList<NetworkResourceCustomization> nrcList = (ArrayList<NetworkResourceCustomization>) this.getAllNetworksByServiceModelUuid(service.getServiceNameVersionId());
+ smh.setNetworkResourceCustomization(nrcList);
+ ArrayList<AllottedResourceCustomization> arcList = (ArrayList<AllottedResourceCustomization>) this.getAllAllottedResourcesByServiceModelUuid(service.getServiceNameVersionId());
+ smh.setAllottedResourceCustomization(arcList);
+ ArrayList<VnfResource> vnfList = (ArrayList<VnfResource>) this.getAllVnfsByServiceModelInvariantUuid(service.getModelInvariantUUID(), service.getVersion());
+ smh.setVnfResources(vnfList);
+
+ LOGGER.recordMetricEvent (startTime, MsoLogger.StatusCode.COMPLETE, MsoLogger.ResponseCode.Suc, "Successfully", "CatalogDB", "getAllResourcesByServiceModelInvariantUuid", null);
+ return smh;
+
+ }
+ public ServiceMacroHolder getAllResourcesByServiceModelInvariantUuid(String serviceModelInvariantUuid, String serviceModelVersion) {
+ long startTime = System.currentTimeMillis();
+ LOGGER.debug("Catalog database: getAllResourcesByServiceModelInvariantUuid - " + serviceModelInvariantUuid + ", version=" + serviceModelVersion);
+
+ StringBuilder hql = new StringBuilder("FROM Service WHERE modelInvariantUUID = :serviceModelInvariantUuid and version = :serviceModelVersion");
+ Query query = getSession().createQuery(hql.toString());
+ query.setParameter("serviceModelInvariantUuid", serviceModelInvariantUuid);
+ query.setParameter("serviceModelVersion", serviceModelVersion);
+ //TODO make this a unique query
+ @SuppressWarnings("unchecked")
+ List<Service> serviceList = query.list();
+
+ if (serviceList.isEmpty()) {
+ LOGGER.debug("Unable to find a Service with serviceModelInvariantUuid=" + serviceModelInvariantUuid + " and serviceModelVersion=" + serviceModelVersion);
+ return null;
}
- return module;
+
+ Collections.sort (serviceList, new MavenLikeVersioningComparator ());
+ Collections.reverse (serviceList);
+ Service service = serviceList.get(0);
+
+ ServiceMacroHolder smh = new ServiceMacroHolder(service);
+ ArrayList<NetworkResourceCustomization> nrcList = (ArrayList<NetworkResourceCustomization>) this.getAllNetworksByServiceModelUuid(service.getServiceNameVersionId());
+ smh.setNetworkResourceCustomization(nrcList);
+ ArrayList<AllottedResourceCustomization> arcList = (ArrayList<AllottedResourceCustomization>) this.getAllAllottedResourcesByServiceModelUuid(service.getServiceNameVersionId());
+ smh.setAllottedResourceCustomization(arcList);
+ ArrayList<VnfResource> vnfList = (ArrayList<VnfResource>) this.getAllVnfsByServiceModelInvariantUuid(service.getModelInvariantUUID(), service.getVersion());
+ smh.setVnfResources(vnfList);
+
+ LOGGER.recordMetricEvent (startTime, MsoLogger.StatusCode.COMPLETE, MsoLogger.ResponseCode.Suc, "Successfully", "CatalogDB", "getAllResourcesByServiceModelUuid with version", null);
+ return smh;
}
-
-
+
+ private void populateNetworkResourceType(List<NetworkResourceCustomization> resultList) {
+ HashMap<Integer, NetworkResource> networkResources = new HashMap<Integer, NetworkResource>();
+
+ for (NetworkResourceCustomization nrc : resultList) {
+ Integer network_id = nrc.getNetworkResourceId();
+ if (network_id == null) {
+ nrc.setNetworkResource(null);
+ nrc.setNetworkType("UNKNOWN_NETWORK_ID_NULL");
+ continue;
+ }
+ if (networkResources.containsKey(network_id)) {
+ nrc.setNetworkResource(networkResources.get(network_id));
+ nrc.setNetworkType(networkResources.get(network_id).getNetworkType());
+ } else {
+ NetworkResource nr = this.getNetworkResourceById(network_id);
+ if (nr == null) {
+ nrc.setNetworkType("INVALID_NETWORK_TYPE_ID_NOT_FOUND");
+ } else {
+ nrc.setNetworkType(nr.getNetworkType());
+ nrc.setNetworkResource(nr);
+ networkResources.put(network_id, nr);
+ }
+ }
+ }
+ }
+
/**
* Return a VNF recipe that matches a given VNF_TYPE, VF_MODULE_MODEL_NAME, and ACTION
* first query VF_MODULE table by type, and then use the ID to query
LOGGER.recordMetricEvent (startTime, MsoLogger.StatusCode.COMPLETE, MsoLogger.ResponseCode.Suc, "Successfully. VNF recipe found", "CatalogDB", "getVfModuleRecipe", null);
return resultList1.get (0);
}
-
+
/**
- * Return a VNF COMPONENTSrecipe that matches a given VNF_TYPE, VF_MODULE_MODEL_NAME,
+ * Return a VNF Module List that matches a given VNF_TYPE, VF_MODULE_MODEL_NAME,
* ASDC_SERVICE_MODEL_VERSION, MODEL_VERSION, and ACTION
- * first query VF_MODULE table by type, and then use the ID to query
- * VNF_COMPONENTS_RECIPE by VF_MODULE_ID and ACTION
+ *
+ * @param vnfModuleType
+ * @parm modelCustomizationUuid
+ * @param asdcServiceModelVersion
+ * @param modelVersion
+ * @param action
+ * @return VfModule list
+ */
+ public List<VfModule> getVfModule (String vfModuleType, String modelCustomizationUuid, String asdcServiceModelVersion, String modelVersion, String action) {
+ StringBuilder hql;
+ Query query;
+ if(modelCustomizationUuid != null){
+ hql = new StringBuilder ("FROM VfModule WHERE modelCustomizationUuid = :modelCustomizationUuid AND version = :version");
+
+ LOGGER.debug ("Catalog database - get VF MODULE with type " + vfModuleType + ", asdcServiceModelVersion " + asdcServiceModelVersion + ", modelVersion " + modelVersion);
+
+ query = getSession ().createQuery (hql.toString ());
+ query.setParameter ("modelCustomizationUuid", modelCustomizationUuid);
+ query.setParameter ("version", asdcServiceModelVersion);
+ }else{
+ hql = new StringBuilder ("FROM VfModule WHERE type = :type AND version = :version AND modelVersion = :modelVersion");
+
+ LOGGER.debug ("Catalog database - get VF MODULE with type " + vfModuleType + ", asdcServiceModelVersion " + asdcServiceModelVersion + ", modelVersion " + modelVersion);
+
+ query = getSession ().createQuery (hql.toString ());
+ query.setParameter (TYPE, vfModuleType);
+ query.setParameter ("version", asdcServiceModelVersion);
+ query.setParameter ("modelVersion", modelVersion);
+ }
+
+ @SuppressWarnings("unchecked")
+ List <VfModule> resultList = query.list ();
+ return resultList;
+ }
+
+ /**
+ * Return a VNF COMPONENTSrecipe that matches a given VNF_TYPE, VF_MODULE_MODEL_NAME,
+ * ASDC_SERVICE_MODEL_VERSION, MODEL_VERSION, and ACTION
+ * first query VF_MODULE table by type, and then use the ID to query
+ * VNF_COMPONENTS_RECIPE by VF_MODULE_ID and ACTION
*
* @param vnfType
* @parm vfModuleModelName
- * @param action
+ * @param action
* @return VnfRecipe object or null if none found
*/
- public VnfComponentsRecipe getVnfComponentsRecipe (String vnfType, String vfModuleModelName, String asdcServiceModelVersion, String modelVersion, String action) {
- String vfModuleType = vnfType + "::" + vfModuleModelName;
-
- StringBuilder hql = new StringBuilder ("FROM VfModule WHERE type = :type AND version = :version AND modelVersion = :modelVersion");
-
+ public VnfComponentsRecipe getVnfComponentsRecipe (String vnfType, String vfModuleModelName, String modelCustomizationUuid, String asdcServiceModelVersion, String modelVersion, String action) {
+ String vfModuleType = vnfType + "::" + vfModuleModelName;
long startTime = System.currentTimeMillis ();
- LOGGER.debug ("Catalog database - get VF MODULE with type " + vfModuleType + ", asdcServiceModelVersion " + asdcServiceModelVersion + ", modelVersion " + modelVersion);
-
- Query query = getSession ().createQuery (hql.toString ());
- query.setParameter (TYPE, vfModuleType);
- query.setParameter ("version", asdcServiceModelVersion);
- query.setParameter ("modelVersion", modelVersion);
-
+ List <VfModule> resultList = getVfModule(vfModuleType, modelCustomizationUuid, asdcServiceModelVersion, modelVersion, action);
+
+ if (resultList.isEmpty ()) {
+ LOGGER.recordMetricEvent (startTime, MsoLogger.StatusCode.COMPLETE, MsoLogger.ResponseCode.Suc, "Successfully. VF Module Entry not found", "CatalogDB", "getVnfComponentsRecipe", null);
+ return null;
+ }
+
+ Collections.sort (resultList, new MavenLikeVersioningComparator ());
+ Collections.reverse (resultList);
+
+ VfModule vfMod = resultList.get(0);
+
+ int id = vfMod.getId();
+ String vfModuleId = Integer.toString(id);
+
+ StringBuilder hql1 = new StringBuilder ("FROM VnfComponentsRecipe WHERE vfModuleId = :vfModuleId AND action = :action ");
+
+ LOGGER.debug ("Catalog database - get Vnf Components recipe with vf module id " + vfModuleId
+ + " and action "
+ + action);
+
+ Query query1 = getSession ().createQuery (hql1.toString ());
+ query1.setParameter (VF_MODULE_ID, vfModuleId);
+ query1.setParameter (ACTION, action);
+
@SuppressWarnings("unchecked")
- List <VfModule> resultList = query.list ();
+ List <VnfComponentsRecipe> resultList1 = query1.list ();
+
+ if (resultList1.isEmpty ()) {
+ LOGGER.recordMetricEvent (startTime, MsoLogger.StatusCode.COMPLETE, MsoLogger.ResponseCode.Suc, "Successfully. VNF recipe not found", "CatalogDB", "getVnfComponentsRecipe", null);
+ return null;
+ }
+
+ Collections.sort (resultList1, new MavenLikeVersioningComparator ());
+ Collections.reverse (resultList1);
+
+ LOGGER.recordMetricEvent (startTime, MsoLogger.StatusCode.COMPLETE, MsoLogger.ResponseCode.Suc, "Successfully. VNF recipe found", "CatalogDB", "getVnfComponentsRecipe", null);
+ if (resultList1.size() > 1 && (!resultList1. get (0).getOrchestrationUri().equals(resultList1.get (1).getOrchestrationUri ()))) {
+ LOGGER.recordMetricEvent (startTime, MsoLogger.StatusCode.COMPLETE, MsoLogger.ResponseCode.Suc, "Successfully. Different ORCHESTRATION URIs found for same VERSION and ID. No result returned.", "CatalogDB", "getVnfComponentsRecipe", null);
+ return null;
+ }
+ return resultList1.get (0);
+ }
+
+ /**
+ * Return a VNF COMPONENTSrecipe that matches a given VNF_TYPE, VF_MODULE_MODEL_NAME,
+ * ASDC_SERVICE_MODEL_VERSION, MODEL_VERSION, and ACTION
+ * first query VF_MODULE table by type, and then use the ID to query
+ * VNF_COMPONENTS_RECIPE by VF_MODULE_ID and ACTION
+ *
+ * @param vnfType
+ * @parm vfModuleModelName
+ * @param action
+ * @return VnfRecipe object or null if none found
+ */
+ public VnfComponentsRecipe getVnfComponentsRecipeByVfModule(List <VfModule> resultList, String action) {
+ long startTime = System.currentTimeMillis ();
if (resultList.isEmpty ()) {
LOGGER.recordMetricEvent (startTime, MsoLogger.StatusCode.COMPLETE, MsoLogger.ResponseCode.Suc, "Successfully. VF Module Entry not found", "CatalogDB", "getVnfComponentsRecipe", null);
LOGGER.recordMetricEvent (startTime, MsoLogger.StatusCode.COMPLETE, MsoLogger.ResponseCode.Suc, "Successfully. VNF recipe found", "CatalogDB", "getVnfComponentsRecipe", null);
if (resultList1.size() > 1 && (!resultList1. get (0).getOrchestrationUri().equals(resultList1.get (1).getOrchestrationUri ()))) {
- LOGGER.recordMetricEvent (startTime, MsoLogger.StatusCode.COMPLETE, MsoLogger.ResponseCode.Suc, "Successfully. Different ORCHESTRATION URIs found for same VERSION and ID. No result returned.", "CatalogDB", "getVnfComponentsRecipe", null);
- return null;
+ LOGGER.recordMetricEvent (startTime, MsoLogger.StatusCode.COMPLETE, MsoLogger.ResponseCode.Suc, "Successfully. Different ORCHESTRATION URIs found for same VERSION and ID. No result returned.", "CatalogDB", "getVnfComponentsRecipe", null);
+ return null;
}
return resultList1.get (0);
}
LOGGER.recordMetricEvent (startTime, MsoLogger.StatusCode.COMPLETE, MsoLogger.ResponseCode.Suc, "Successfully", "CatalogDB", "saveOrUpdateVnfResource", null);
}
}
-
+
+ public void saveAllottedResourceCustomization (AllottedResourceCustomization resourceCustomization) {
+ long startTime = System.currentTimeMillis ();
+ LOGGER.debug ("Catalog database - save Allotted Resource with Name " + resourceCustomization.getModelName());
+ try {
+ List<AllottedResourceCustomization> allottedResourcesList = getAllAllottedResourcesByArModelCustomizationUuid(resourceCustomization.getModelCustomizationUuid());
+
+ if(allottedResourcesList.size() == 0){
+ this.getSession ().save(resourceCustomization);
+ }
+
+ } finally {
+ LOGGER.recordMetricEvent (startTime, MsoLogger.StatusCode.COMPLETE, MsoLogger.ResponseCode.Suc, "Successfully", "CatalogDB", "saveOrUpdateAllottedResourceCustomization", null);
+ }
+ }
+
+ public void saveNetworkResourceCustomization (NetworkResourceCustomization networkResourceCustomization) throws RecordNotFoundException {
+ long startTime = System.currentTimeMillis ();
+ LOGGER.debug ("Catalog database - save Network Resource Customization with Network Name " + networkResourceCustomization.getModelName());
+ try {
+ // Check if NetworkResourceCustomzation record already exists. If so, skip saving it.
+ List<NetworkResourceCustomization> networkResourceCustomizationList = getAllNetworksByNetworkModelCustomizationUuid(networkResourceCustomization.getModelCustomizationUuid());
+ // Do any matching customization records exist?
+ if(networkResourceCustomizationList.size() == 0){
+
+ // Retreive the record from the Network_Resource table associated to the Customization record based on ModelName
+ NetworkResource networkResource = getNetworkResource(networkResourceCustomization.getModelName());
+
+ if(networkResource == null){
+ throw new RecordNotFoundException("No record found in NETWORK_RESOURCE table for model name " + networkResourceCustomization.getModelName());
+ }
+
+ networkResourceCustomization.setNetworkResourceId(networkResource.getId());
+
+ this.getSession ().save(networkResourceCustomization);
+ }
+
+
+ } finally {
+ LOGGER.recordMetricEvent (startTime, MsoLogger.StatusCode.COMPLETE, MsoLogger.ResponseCode.Suc, "Successfully", "CatalogDB", "saveNetworkResourceCustomization", null);
+ }
+ }
+
+ public void saveServiceToNetworks (ServiceToNetworks serviceToNetworks) {
+ long startTime = System.currentTimeMillis ();
+ LOGGER.debug ("Catalog database - save to ServiceToNetworks table with NetworkModelCustomizationUUID of " + serviceToNetworks.getNetworkModelCustomizationUuid() + " and ServiceModelUUID of " + serviceToNetworks.getServiceModelUuid());
+ try {
+ this.getSession ().save(serviceToNetworks);
+
+ } finally {
+ LOGGER.recordMetricEvent (startTime, MsoLogger.StatusCode.COMPLETE, MsoLogger.ResponseCode.Suc, "Successfully", "CatalogDB", "saveNetworkResourceCustomization", null);
+ }
+ }
+
+ public void saveServiceToAllottedResources (ServiceToAllottedResources serviceToAllottedResources) {
+ long startTime = System.currentTimeMillis ();
+ LOGGER.debug ("Catalog database - save to serviceToAllottedResources table with ARModelCustomizationUUID of " + serviceToAllottedResources.getArModelCustomizationUuid() + " and ServiceModelUUID of " + serviceToAllottedResources.getServiceModelUuid());
+ try {
+ this.getSession ().save(serviceToAllottedResources);
+
+ } finally {
+ LOGGER.recordMetricEvent (startTime, MsoLogger.StatusCode.COMPLETE, MsoLogger.ResponseCode.Suc, "Successfully", "CatalogDB", "saveServiceToAllottedResources", null);
+ }
+ }
+
public void saveService (Service service) {
long startTime = System.currentTimeMillis ();
- LOGGER.debug ("Catalog database - save Service with ServiceName/Version/serviceUUID(SERVICE_NAME_VERSION_ID)" + service.getServiceName()+"/"+service.getServiceVersion()+"/"+service.getServiceNameVersionId());
+ LOGGER.debug ("Catalog database - save Service with ServiceName/Version/serviceUUID(SERVICE_NAME_VERSION_ID)" + service.getServiceName()+"/"+service.getVersion()+"/"+service.getServiceNameVersionId());
try {
- Service serviceDB = this.getServiceByUUID(service.getServiceNameVersionId());
+ Service serviceInvariantDB = null;
+ // Retrieve existing service record by nameVersionId
+ Service serviceDB = this.getServiceByUUID(service.getServiceNameVersionId());
if (serviceDB == null) {
- this.getSession ().save (service);
+ // Check to see if a record with the same modelInvariantId already exists. This tells us that a previous version exists and we can copy its recipe Record for the new service record.
+ serviceInvariantDB = this.getServiceByInvariantUUID(service.getModelInvariantUUID());
+ // Save the new Service record
+ this.getSession ().save (service);
}
-
+
+ if(serviceInvariantDB != null){ // existing modelInvariantId was found.
+ // copy the recipe record with the matching invariant id. We will duplicate this for the new service record
+ List<ServiceRecipe> serviceRecipes = getServiceRecipes(serviceInvariantDB.getId());
+
+ if(serviceRecipes != null && serviceRecipes.size() > 0){
+ for(ServiceRecipe serviceRecipe : serviceRecipes){
+ if(serviceRecipe != null){
+ // Fetch the service record that we just added. We do this so we can extract its Id column value, this will be the foreign key we use in the service recipe table.
+ Service newService = this.getServiceByUUID(service.getServiceNameVersionId());
+ // Create a new ServiceRecipe record based on the existing one we just copied from the DB.
+ ServiceRecipe newServiceRecipe = new ServiceRecipe();
+ newServiceRecipe.setAction(serviceRecipe.getAction());
+ newServiceRecipe.setDescription(serviceRecipe.getDescription());
+ newServiceRecipe.setOrchestrationUri(serviceRecipe.getOrchestrationUri());
+ newServiceRecipe.setRecipeTimeout(serviceRecipe.getRecipeTimeout());
+ newServiceRecipe.setServiceParamXSD(serviceRecipe.getServiceParamXSD());
+ newServiceRecipe.setServiceId(newService.getId());
+ newServiceRecipe.setVersion(serviceRecipe.getVersion());
+ // Save the new recipe record in the service_recipe table and associate it to the new service record that we just added.
+ this.getSession ().save (newServiceRecipe);
+ }
+ }
+ }
+
+ }
+
} finally {
LOGGER.recordMetricEvent (startTime, MsoLogger.StatusCode.COMPLETE, MsoLogger.ResponseCode.Suc, "Successfully", "CatalogDB", "saveOrUpdateService", null);
}
}
-
+
public void saveOrUpdateVfModule (VfModule vfModule) {
long startTime = System.currentTimeMillis ();
LOGGER.debug ("Catalog database - save VNF Module with VF Model Name " + vfModule.getModelName());
} else {
this.getSession ().save (vfModule);
}
-
+
} finally {
- LOGGER.recordMetricEvent (startTime, MsoLogger.StatusCode.COMPLETE, MsoLogger.ResponseCode.Suc, "Successfully", "CatalogDB", "saveOrUpdateVfModule", null);
+ LOGGER.recordMetricEvent (startTime, MsoLogger.StatusCode.COMPLETE, MsoLogger.ResponseCode.Suc, "Successfully", "CatalogDB", "saveOrUpdateVfModule", null);
}
}
HeatNestedTemplate nestedTemplate = new HeatNestedTemplate ();
nestedTemplate.setParentTemplateId (parentTemplateId);
nestedTemplate.setChildTemplateId (childTemplateId);
-
+
return (HeatNestedTemplate)session.get (HeatNestedTemplate.class,nestedTemplate);
} finally {
LOGGER.recordMetricEvent (startTime, MsoLogger.StatusCode.COMPLETE, MsoLogger.ResponseCode.Suc, "Successfully", "CatalogDB", "getNestedHeatTemplate", null);
}
}
-
+
public void saveNestedHeatTemplate (int parentTemplateId, HeatTemplate childTemplate, String yamlFile) {
long startTime = System.currentTimeMillis ();
LOGGER.debug ("Catalog database - save nested Heat template with name "
+ childTemplate.getTemplateName ());
try {
-
+
saveHeatTemplate(childTemplate, childTemplate.getParameters());
- if (getNestedHeatTemplate(parentTemplateId,childTemplate.getId()) == null) {
+ if (getNestedHeatTemplate(parentTemplateId,childTemplate.getId()) == null) {
HeatNestedTemplate nestedTemplate = new HeatNestedTemplate ();
nestedTemplate.setParentTemplateId (parentTemplateId);
nestedTemplate.setChildTemplateId (childTemplate.getId ());
LOGGER.recordMetricEvent (startTime, MsoLogger.StatusCode.COMPLETE, MsoLogger.ResponseCode.Suc, "Successfully", "CatalogDB", "saveNestedHeatTemplate", null);
}
}
-
+
public HeatFiles getHeatFiles(int vnfResourceId,String fileName,String asdcResourceName, String version) {
long startTime = System.currentTimeMillis ();
LOGGER.debug ("Catalog database - getHeatFiles with name " + fileName
LOGGER.debug("Generic Exception - while searching for: fileName='" + fileName + "', vnfResourceId='" + vnfResourceId + "' and asdcResourceName=" + asdcResourceName + " and version=" + version);
LOGGER.error(MessageEnum.GENERAL_EXCEPTION, " Generic exception searching for fileName=" + fileName + " and vnfResourceId=" + vnfResourceId + " and asdcResourceName=" + asdcResourceName + " and version=" + version, "", "", MsoLogger.ErrorCode.DataError, "Generic exception searching for fileName=" + fileName);
heatFilesResult = null;
- }
-
+ }
+
// See if something came back.
if (heatFilesResult == null) {
LOGGER.recordMetricEvent (startTime, MsoLogger.StatusCode.COMPLETE, MsoLogger.ResponseCode.Suc, "Successfully. HeatFiles not found", "CatalogDB", "getHeatFiles", null);
LOGGER.recordMetricEvent (startTime, MsoLogger.StatusCode.COMPLETE, MsoLogger.ResponseCode.Suc, "Successfully", "CatalogDB", "getHeatFiles", null);
return heatFilesResult;
}
-
+
public void saveHeatFiles (HeatFiles childFile) {
long startTime = System.currentTimeMillis ();
LOGGER.debug ("Catalog database - save Heat File with name "
// asdc_heat_files_save
this.getSession ().save (childFile);
-
+
} else {
/* replaced 'heatFiles' by 'childFile'
Based on following comment:
LOGGER.recordMetricEvent (startTime, MsoLogger.StatusCode.COMPLETE, MsoLogger.ResponseCode.Suc, "Successfully", "CatalogDB", "saveHeatFiles", null);
}
}
-
+
public void saveVfModuleToHeatFiles (int parentVfModuleId, HeatFiles childFile) {
long startTime = System.currentTimeMillis ();
LOGGER.debug ("Catalog database - save Heat File to VFmodule link "
VfModuleToHeatFiles vfModuleToHeatFile = new VfModuleToHeatFiles ();
vfModuleToHeatFile.setVfModuleId(parentVfModuleId);
vfModuleToHeatFile.setHeatFilesId(childFile.getId());
-
+
session.save (vfModuleToHeatFile);
-
+
} finally {
LOGGER.recordMetricEvent (startTime, MsoLogger.StatusCode.COMPLETE, MsoLogger.ResponseCode.Suc, "Successfully", "CatalogDB", "saveVfModuleToHeatFiles", null);
}
}
-
+
/**
* Return a Network recipe that matches a given NETWORK_TYPE, ACTION, and, if specified, SERVICE_TYPE
if (resultList.isEmpty ()) {
return null;
}
-
+
Collections.sort (resultList, new MavenLikeVersioningComparator ());
Collections.reverse (resultList);
-
+
return resultList.get (0);
} finally {
LOGGER.recordMetricEvent (startTime, MsoLogger.StatusCode.COMPLETE, MsoLogger.ResponseCode.Suc, "Successfully", "CatalogDB", "getNetworkRecipe", null);
}
}
-
+
/**
* Return a Network recipe that matches a given NETWORK_TYPE and ACTION
*
* @param networkType
- * @param action
+ * @param action
* @return NetworkRecipe object or null if none found
*/
public NetworkRecipe getNetworkRecipe (String networkType, String action) {
try {
String hql = "FROM NetworkRecipe WHERE networkType = :networkType AND action = :action";
-
+
Query query = getSession ().createQuery (hql);
query.setParameter (NETWORK_TYPE, networkType);
query.setParameter (ACTION, action);
-
+
@SuppressWarnings("unchecked")
List <NetworkRecipe> resultList = query.list ();
if (resultList.isEmpty ()) {
return null;
}
-
+
Collections.sort (resultList, new MavenLikeVersioningComparator ());
Collections.reverse (resultList);
-
+
return resultList.get (0);
} finally {
LOGGER.recordMetricEvent (startTime, MsoLogger.StatusCode.COMPLETE, MsoLogger.ResponseCode.Suc, "Successfully", "CatalogDB", "getNetworkRecipe", null);
}
}
+ /**
+ * Return a Network Resource that matches the Network Customization defined by given MODEL_CUSTOMIZATION_UUID
+ *
+ * @param networkType
+ * @param action
+ * @param serviceType
+ * @return NetworkRecipe object or null if none found
+ */
+ public NetworkResource getNetworkResourceByModelCustUuid(String modelCustomizationUuid) {
+
+ long startTime = System.currentTimeMillis ();
+ LOGGER.debug ("Catalog database - get network resource with modelCustomizationUuid " + modelCustomizationUuid);
+
+ try {
+ String hql = "select n FROM NetworkResource n, NetworkResourceCustomization c WHERE n.id=c.networkResourceId and c.modelCustomizationUuid = :modelCustomizationUuid";
+ Query query = getSession ().createQuery (hql);
+ query.setParameter (MODEL_CUSTOMIZATION_UUID, modelCustomizationUuid);
+
+ @SuppressWarnings("unchecked")
+ List <NetworkResource> resultList = query.list ();
+
+ if (resultList.isEmpty ()) {
+ return null;
+ }
+
+ Collections.sort (resultList, new MavenLikeVersioningComparator ());
+ Collections.reverse (resultList);
+
+ return resultList.get (0);
+ } finally {
+ LOGGER.recordMetricEvent (startTime, MsoLogger.StatusCode.COMPLETE, MsoLogger.ResponseCode.Suc, "Successfully", "CatalogDB", "getNetworkResourceBySvcNtwkRsrc", null);
+ }
+ }
+
/**
* Return a VnfComponents recipe that matches a given VNF_TYPE, VNF_COMPONENT_TYPE, ACTION, and, if specified,
* SERVICE_TYPE
}
Collections.sort (resultList, new MavenLikeVersioningComparator ());
Collections.reverse (resultList);
-
+
return resultList.get (0);
} finally {
LOGGER.recordMetricEvent (startTime, MsoLogger.StatusCode.COMPLETE, MsoLogger.ResponseCode.Suc, "Successfully", "CatalogDB", "getVnfComponentsRecipe", null);
}
}
-
+
/**
* Return a VnfComponents recipe that matches a given VF_MODULE_ID, VNF_COMPONENT_TYPE, ACTION
*
* @param vfModuleId
* @param vnfComponentType
- * @param action
+ * @param action
* @return VnfComponentsRecipe object or null if none found
*/
public VnfComponentsRecipe getVnfComponentsRecipeByVfModuleId (String vfModuleId,
String vnfComponentType,
- String action) {
+ String action) {
long startTime = System.currentTimeMillis ();
LOGGER.debug ("Catalog database - get Vnf Component recipe with vfModuleId " + vfModuleId
try {
String hql;
hql = "FROM VnfComponentsRecipe WHERE vfModuleId = :vfModuleId AND vnfComponentType = :vnfComponentType AND action = :action ";
-
+
Query query = getSession ().createQuery (hql);
query.setParameter (VF_MODULE_ID, vfModuleId);
query.setParameter (VNF_COMPONENT_TYPE, vnfComponentType);
query.setParameter (ACTION, action);
-
+
@SuppressWarnings("unchecked")
List <VnfComponentsRecipe> resultList = query.list ();
}
Collections.sort (resultList, new MavenLikeVersioningComparator ());
Collections.reverse (resultList);
-
+
return resultList.get (0);
} finally {
LOGGER.recordMetricEvent (startTime, MsoLogger.StatusCode.COMPLETE, MsoLogger.ResponseCode.Suc, "Successfully", "CatalogDB", "getVnfComponentsRecipeByVfModuleId", null);
}
}
+ /**
+ * Return a Model recipe that matches a given MODEL_TYPE, MODEL_VERSION_ID, ACTION
+ * Note: This method is not currently used but was retained in the event the
+ * architecture moves back to a MODEL/MODEL_RECIPE structure.
+ *
+ * @param modelType
+ * @param modelVersionId
+ * @param action
+ * @return ModelRecipe object or null if none found
+ */
+ public ModelRecipe getModelRecipe(String modelType,
+ String modelVersionId,
+ String action) {
+
+ long startTime = System.currentTimeMillis();
+ LOGGER.debug("Catalog database - get Model recipe with modelType=" + modelType
+ + " and modeVersionId=" + modelVersionId
+ + " and action=" + action);
+
+ try {
+ String hql;
+ // TBD - at some point it would be desirable to figure out how to do a HQL JOIN across
+ // the MODEL and MODEL_RECIPE tables in HQL instead of 2 separate queries.
+ // There seems to be 2 issues: formatting a hql query that executes successfully
+ // and then being able to generate a result that will fit into the ModelRecipe class.
+
+ // 1st query to get the Model record for the given MODEL_TYPE and MODEL_VERSION_ID
+ hql = "FROM Model WHERE modelType = :modelType AND modelVersionId = :modelVersionId";
+ Query query = getSession().createQuery(hql);
+ query.setParameter(MODEL_TYPE, modelType);
+ query.setParameter(MODEL_VERSION_ID, modelVersionId);
+
+ @SuppressWarnings("unchecked")
+ List<Model> modelResultList = query.list();
+ if (modelResultList.isEmpty()) {
+ LOGGER.debug("Catalog database - modelResultList is null");
+ return null;
+ }
+ Collections.sort(modelResultList, new MavenLikeVersioningComparator());
+ Collections.reverse(modelResultList);
+ LOGGER.debug("Catalog database - modelResultList contains " + modelResultList.get(0).toString());
+
+ // 2nd query to get the ModelRecipe record corresponding to the Model from the 1st query
+ hql = "FROM ModelRecipe WHERE modelId = :modelId AND action = :action";
+ query = getSession().createQuery(hql);
+ // The MODEL table 'id' field maps to the MODEL_RECIPE table 'MODEL_ID' field
+ query.setParameter(MODEL_ID, modelResultList.get(0).getId());
+ query.setParameter(ACTION, action);
+
+ @SuppressWarnings("unchecked")
+ List<ModelRecipe> recipeResultList = query.list();
+ if (recipeResultList.isEmpty()) {
+ LOGGER.debug("Catalog database - recipeResultList is null");
+ return null;
+ }
+ Collections.sort(recipeResultList, new MavenLikeVersioningComparator());
+ Collections.reverse(recipeResultList);
+ LOGGER.debug("Catalog database - recipeResultList contains " + recipeResultList.get(0).toString());
+
+ return recipeResultList.get(0);
+ } finally {
+ LOGGER.recordMetricEvent(startTime, MsoLogger.StatusCode.COMPLETE, MsoLogger.ResponseCode.Suc, "Successfully", "CatalogDB", "getModelRecipe", null);
+ }
+ }
+
/**
* Verify the health of the DB.
Code Review / so.git / blobdiff