http://git-wip-us.apache.org/repos/asf/airavata/blob/ec8c6202/modules/app-catalog/app-catalog-data/src/main/java/org/apache/aiaravata/application/catalog/data/resources/WorkflowResource.java ---------------------------------------------------------------------- diff --git a/modules/app-catalog/app-catalog-data/src/main/java/org/apache/aiaravata/application/catalog/data/resources/WorkflowResource.java b/modules/app-catalog/app-catalog-data/src/main/java/org/apache/aiaravata/application/catalog/data/resources/WorkflowResource.java deleted file mode 100644 index 3e52019..0000000 --- a/modules/app-catalog/app-catalog-data/src/main/java/org/apache/aiaravata/application/catalog/data/resources/WorkflowResource.java +++ /dev/null @@ -1,382 +0,0 @@ -/* - * - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, - * software distributed under the License is distributed on an - * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY - * KIND, either express or implied. See the License for the - * specific language governing permissions and limitations - * under the License. - * - */ - -package org.apache.aiaravata.application.catalog.data.resources; - -import org.airavata.appcatalog.cpi.AppCatalogException; -import org.apache.aiaravata.application.catalog.data.model.Workflow; -import org.apache.aiaravata.application.catalog.data.util.AppCatalogJPAUtils; -import org.apache.aiaravata.application.catalog.data.util.AppCatalogQueryGenerator; -import org.apache.aiaravata.application.catalog.data.util.AppCatalogResourceType; -import org.apache.airavata.common.exception.ApplicationSettingsException; -import org.apache.airavata.common.utils.AiravataUtils; -import org.slf4j.Logger; -import org.slf4j.LoggerFactory; - -import javax.persistence.EntityManager; -import javax.persistence.Query; -import java.sql.Timestamp; -import java.util.ArrayList; -import java.util.List; - -public class WorkflowResource extends AbstractResource { - private final static Logger logger = LoggerFactory.getLogger(WorkflowResource.class); - private String wfName; - private String createdUser; - private String graph; - private String wfTemplateId; - private Timestamp createdTime; - private Timestamp updatedTime; - private String image; - private String gatewayId; - - public Timestamp getCreatedTime() { - return createdTime; - } - - public void setCreatedTime(Timestamp createdTime) { - this.createdTime = createdTime; - } - - public Timestamp getUpdatedTime() { - return updatedTime; - } - - public void setUpdatedTime(Timestamp updatedTime) { - this.updatedTime = updatedTime; - } - - public String getImage() { - return image; - } - - public void setImage(String image) { - this.image = image; - } - - public String getGatewayId() { - return gatewayId; - } - - public void setGatewayId(String gatewayId) { - this.gatewayId = gatewayId; - } - - @Override - public void remove(Object identifier) throws AppCatalogException { - EntityManager em = null; - try { - em = AppCatalogJPAUtils.getEntityManager(); - em.getTransaction().begin(); - AppCatalogQueryGenerator generator = new AppCatalogQueryGenerator(WORKFLOW); - generator.setParameter(WorkflowConstants.WF_TEMPLATE_ID, identifier); - Query q = generator.deleteQuery(em); - q.executeUpdate(); - em.getTransaction().commit(); - em.close(); - } catch (ApplicationSettingsException e) { - logger.error(e.getMessage(), e); - throw new AppCatalogException(e); - } finally { - if (em != null && em.isOpen()) { - if (em.getTransaction().isActive()) { - em.getTransaction().rollback(); - } - em.close(); - } - } - } - - @Override - public Resource get(Object identifier) throws AppCatalogException { - EntityManager em = null; - try { - em = AppCatalogJPAUtils.getEntityManager(); - em.getTransaction().begin(); - AppCatalogQueryGenerator generator = new AppCatalogQueryGenerator(WORKFLOW); - generator.setParameter(WorkflowConstants.WF_TEMPLATE_ID, identifier); - Query q = generator.selectQuery(em); - Workflow workflow = (Workflow) q.getSingleResult(); - WorkflowResource workflowResource = (WorkflowResource) AppCatalogJPAUtils.getResource(AppCatalogResourceType.WORKFLOW, workflow); - em.getTransaction().commit(); - em.close(); - return workflowResource; - } catch (ApplicationSettingsException e) { - logger.error(e.getMessage(), e); - throw new AppCatalogException(e); - } finally { - if (em != null && em.isOpen()) { - if (em.getTransaction().isActive()) { - em.getTransaction().rollback(); - } - em.close(); - } - } - } - - @Override - public List<Resource> get(String fieldName, Object value) throws AppCatalogException { - List<Resource> workflowResources = new ArrayList<Resource>(); - EntityManager em = null; - try { - em = AppCatalogJPAUtils.getEntityManager(); - em.getTransaction().begin(); - AppCatalogQueryGenerator generator = new AppCatalogQueryGenerator(WORKFLOW); - Query q; - if ((fieldName.equals(WorkflowConstants.WF_NAME)) || (fieldName.equals(WorkflowConstants.CREATED_USER)) || (fieldName.equals(WorkflowConstants.GRAPH)) || (fieldName.equals(WorkflowConstants.WF_TEMPLATE_ID))) { - generator.setParameter(fieldName, value); - q = generator.selectQuery(em); - List<?> results = q.getResultList(); - for (Object result : results) { - Workflow workflow = (Workflow) result; - WorkflowResource workflowResource = (WorkflowResource) AppCatalogJPAUtils.getResource(AppCatalogResourceType.WORKFLOW, workflow); - workflowResources.add(workflowResource); - } - } else { - em.getTransaction().commit(); - em.close(); - logger.error("Unsupported field name for Workflow Resource.", new IllegalArgumentException()); - throw new IllegalArgumentException("Unsupported field name for Workflow Resource."); - } - em.getTransaction().commit(); - em.close(); - } catch (ApplicationSettingsException e) { - logger.error(e.getMessage(), e); - throw new AppCatalogException(e); - } finally { - if (em != null && em.isOpen()) { - if (em.getTransaction().isActive()) { - em.getTransaction().rollback(); - } - em.close(); - } - } - return workflowResources; - } - - @Override - public List<Resource> getAll() throws AppCatalogException { - List<Resource> workflows = new ArrayList<Resource>(); - EntityManager em = null; - try { - em = AppCatalogJPAUtils.getEntityManager(); - em.getTransaction().begin(); - AppCatalogQueryGenerator generator = new AppCatalogQueryGenerator(WORKFLOW); - generator.setParameter(WorkflowConstants.GATEWAY_ID, gatewayId); - Query q = generator.selectQuery(em); - List results = q.getResultList(); - if (results.size() != 0) { - for (Object result : results) { - Workflow workflow = (Workflow) result; - WorkflowResource wfResource = - (WorkflowResource) AppCatalogJPAUtils.getResource(AppCatalogResourceType.WORKFLOW, workflow); - workflows.add(wfResource); - } - } - em.getTransaction().commit(); - em.close(); - } catch (Exception e) { - logger.error(e.getMessage(), e); - throw new AppCatalogException(e); - } finally { - if (em != null && em.isOpen()) { - if (em.getTransaction().isActive()) { - em.getTransaction().rollback(); - } - em.close(); - } - } - return workflows; - } - - @Override - public List<String> getAllIds() throws AppCatalogException { - List<String> workflowIds = new ArrayList<String>(); - EntityManager em = null; - try { - em = AppCatalogJPAUtils.getEntityManager(); - em.getTransaction().begin(); - AppCatalogQueryGenerator generator = new AppCatalogQueryGenerator(WORKFLOW); - generator.setParameter(WorkflowConstants.GATEWAY_ID, gatewayId); - Query q = generator.selectQuery(em); - List results = q.getResultList(); - if (results.size() != 0) { - for (Object result : results) { - Workflow workflow = (Workflow) result; - workflowIds.add(workflow.getWfTemplateId()); - } - } - em.getTransaction().commit(); - em.close(); - } catch (Exception e) { - logger.error(e.getMessage(), e); - throw new AppCatalogException(e); - } finally { - if (em != null && em.isOpen()) { - if (em.getTransaction().isActive()) { - em.getTransaction().rollback(); - } - em.close(); - } - } - return workflowIds; - } - - @Override - public List<String> getIds(String fieldName, Object value) throws AppCatalogException { - List<String> workflowResourceIDs = new ArrayList<String>(); - EntityManager em = null; - try { - em = AppCatalogJPAUtils.getEntityManager(); - em.getTransaction().begin(); - AppCatalogQueryGenerator generator = new AppCatalogQueryGenerator(WORKFLOW); - Query q; - if ((fieldName.equals(WorkflowConstants.WF_NAME)) || (fieldName.equals(WorkflowConstants.CREATED_USER)) || (fieldName.equals(WorkflowConstants.GRAPH)) || (fieldName.equals(WorkflowConstants.WF_TEMPLATE_ID))) { - generator.setParameter(fieldName, value); - q = generator.selectQuery(em); - List<?> results = q.getResultList(); - for (Object result : results) { - Workflow workflow = (Workflow) result; - WorkflowResource workflowResource = (WorkflowResource) AppCatalogJPAUtils.getResource(AppCatalogResourceType.WORKFLOW, workflow); - workflowResourceIDs.add(workflowResource.getWfTemplateId()); - } - } else { - em.getTransaction().commit(); - em.close(); - logger.error("Unsupported field name for Workflow Resource.", new IllegalArgumentException()); - throw new IllegalArgumentException("Unsupported field name for Workflow Resource."); - } - em.getTransaction().commit(); - em.close(); - } catch (ApplicationSettingsException e) { - logger.error(e.getMessage(), e); - throw new AppCatalogException(e); - } finally { - if (em != null && em.isOpen()) { - if (em.getTransaction().isActive()) { - em.getTransaction().rollback(); - } - em.close(); - } - } - return workflowResourceIDs; - } - - @Override - public void save() throws AppCatalogException { - EntityManager em = null; - try { - em = AppCatalogJPAUtils.getEntityManager(); - Workflow existingWorkflow = em.find(Workflow.class, wfTemplateId); - em.close(); - Workflow workflow; - em = AppCatalogJPAUtils.getEntityManager(); - em.getTransaction().begin(); - if (existingWorkflow == null) { - workflow = new Workflow(); - workflow.setCreationTime(AiravataUtils.getCurrentTimestamp()); - } else { - workflow = existingWorkflow; - workflow.setUpdateTime(AiravataUtils.getCurrentTimestamp()); - } - workflow.setWfName(getWfName()); - workflow.setCreatedUser(getCreatedUser()); - workflow.setGatewayId(gatewayId); - if (getGraph() != null){ - workflow.setGraph(getGraph().toCharArray()); - } - if (image != null){ - workflow.setImage(image.getBytes()); - } - workflow.setWfTemplateId(getWfTemplateId()); - if (existingWorkflow == null) { - em.persist(workflow); - } else { - em.merge(workflow); - } - em.getTransaction().commit(); - em.close(); - } catch (Exception e) { - logger.error(e.getMessage(), e); - throw new AppCatalogException(e); - } finally { - if (em != null && em.isOpen()) { - if (em.getTransaction().isActive()) { - em.getTransaction().rollback(); - } - em.close(); - } - } - } - - @Override - public boolean isExists(Object identifier) throws AppCatalogException { - EntityManager em = null; - try { - em = AppCatalogJPAUtils.getEntityManager(); - Workflow workflow = em.find(Workflow.class, identifier); - em.close(); - return workflow != null; - } catch (ApplicationSettingsException e) { - logger.error(e.getMessage(), e); - throw new AppCatalogException(e); - } finally { - if (em != null && em.isOpen()) { - if (em.getTransaction().isActive()) { - em.getTransaction().rollback(); - } - em.close(); - } - } - } - - public String getWfName() { - return wfName; - } - - public String getCreatedUser() { - return createdUser; - } - - public String getGraph() { - return graph; - } - - public String getWfTemplateId() { - return wfTemplateId; - } - - public void setWfName(String wfName) { - this.wfName=wfName; - } - - public void setCreatedUser(String createdUser) { - this.createdUser=createdUser; - } - - public void setGraph(String graph) { - this.graph=graph; - } - - public void setWfTemplateId(String wfTemplateId) { - this.wfTemplateId=wfTemplateId; - } -}
http://git-wip-us.apache.org/repos/asf/airavata/blob/ec8c6202/modules/app-catalog/app-catalog-data/src/main/java/org/apache/aiaravata/application/catalog/data/util/AppCatalogJPAUtils.java ---------------------------------------------------------------------- diff --git a/modules/app-catalog/app-catalog-data/src/main/java/org/apache/aiaravata/application/catalog/data/util/AppCatalogJPAUtils.java b/modules/app-catalog/app-catalog-data/src/main/java/org/apache/aiaravata/application/catalog/data/util/AppCatalogJPAUtils.java deleted file mode 100644 index 4ee983f..0000000 --- a/modules/app-catalog/app-catalog-data/src/main/java/org/apache/aiaravata/application/catalog/data/util/AppCatalogJPAUtils.java +++ /dev/null @@ -1,911 +0,0 @@ -/* - * - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, - * software distributed under the License is distributed on an - * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY - * KIND, either express or implied. See the License for the - * specific language governing permissions and limitations - * under the License. - * - */ - -package org.apache.aiaravata.application.catalog.data.util; - -import org.apache.aiaravata.application.catalog.data.model.*; -import org.apache.aiaravata.application.catalog.data.resources.*; -import org.apache.airavata.common.exception.ApplicationSettingsException; -import org.apache.airavata.common.utils.ServerSettings; -import org.slf4j.Logger; -import org.slf4j.LoggerFactory; - -import javax.persistence.EntityManager; -import javax.persistence.EntityManagerFactory; -import javax.persistence.Persistence; -import java.util.HashMap; -import java.util.Map; - -public class AppCatalogJPAUtils { - private final static Logger logger = LoggerFactory.getLogger(AppCatalogJPAUtils.class); - private static final String PERSISTENCE_UNIT_NAME = "appcatalog_data"; - private static final String APPCATALOG_JDBC_DRIVER = "appcatalog.jdbc.driver"; - private static final String APPCATALOG_JDBC_URL = "appcatalog.jdbc.url"; - private static final String APPCATALOG_JDBC_USER = "appcatalog.jdbc.user"; - private static final String APPCATALOG_JDBC_PWD = "appcatalog.jdbc.password"; - private static final String APPCATALOG_VALIDATION_QUERY = "appcatalog.validationQuery"; - private static final String JPA_CACHE_SIZE = "jpa.cache.size"; - protected static EntityManagerFactory factory; - - public static EntityManager getEntityManager() throws ApplicationSettingsException { - if (factory == null) { - String connectionProperties = "DriverClassName=" + readServerProperties(APPCATALOG_JDBC_DRIVER) + "," + - "Url=" + readServerProperties(APPCATALOG_JDBC_URL) + "?autoReconnect=true," + - "Username=" + readServerProperties(APPCATALOG_JDBC_USER) + "," + - "Password=" + readServerProperties(APPCATALOG_JDBC_PWD) + - ",validationQuery=" + readServerProperties(APPCATALOG_VALIDATION_QUERY); - System.out.println(connectionProperties); - Map<String, String> properties = new HashMap<String, String>(); - properties.put("openjpa.ConnectionDriverName", "org.apache.commons.dbcp.BasicDataSource"); - properties.put("openjpa.ConnectionProperties", connectionProperties); - properties.put("openjpa.DynamicEnhancementAgent", "true"); - properties.put("openjpa.RuntimeUnenhancedClasses", "unsupported"); - properties.put("openjpa.DataCache","true(CacheSize=" + Integer.valueOf(readServerProperties(JPA_CACHE_SIZE)) + ", SoftReferenceSize=0)"); - properties.put("openjpa.QueryCache","true(CacheSize=" + Integer.valueOf(readServerProperties(JPA_CACHE_SIZE)) + ", SoftReferenceSize=0)"); - properties.put("openjpa.RemoteCommitProvider","sjvm"); - properties.put("openjpa.Log","DefaultLevel=INFO, Runtime=INFO, Tool=INFO, SQL=INFO"); - properties.put("openjpa.jdbc.SynchronizeMappings", "buildSchema(ForeignKeys=true)"); - properties.put("openjpa.jdbc.QuerySQLCache", "false"); - properties.put("openjpa.ConnectionFactoryProperties", "PrettyPrint=true, PrettyPrintLineLength=72, PrintParameters=true, MaxActive=10, MaxIdle=5, MinIdle=2, MaxWait=31536000, autoReconnect=true"); - factory = Persistence.createEntityManagerFactory(PERSISTENCE_UNIT_NAME, properties); - } - return factory.createEntityManager(); - } - - private static String readServerProperties (String propertyName) throws ApplicationSettingsException { - try { - return ServerSettings.getSetting(propertyName); - } catch (ApplicationSettingsException e) { - logger.error("Unable to read airavata-server.properties...", e); - throw new ApplicationSettingsException("Unable to read airavata-server.properties..."); - } - } - - /** - * - * @param type model type - * @param o model type instance - * @return corresponding resource object - */ - public static Resource getResource(AppCatalogResourceType type, Object o) { - switch (type){ - case COMPUTE_RESOURCE: - if (o instanceof ComputeResource){ - return createComputeResource((ComputeResource) o); - }else{ - logger.error("Object should be a Compute Resource.", new IllegalArgumentException()); - throw new IllegalArgumentException("Object should be a Compute Resource."); - } - case HOST_ALIAS: - if (o instanceof HostAlias){ - return createHostAlias((HostAlias) o); - }else { - logger.error("Object should be a Host Alias.", new IllegalArgumentException()); - throw new IllegalArgumentException("Object should be a Host Alias."); - } - case HOST_IPADDRESS: - if (o instanceof HostIPAddress){ - return createHostIPAddress((HostIPAddress) o); - }else { - logger.error("Object should be a Host IPAdress.", new IllegalArgumentException()); - throw new IllegalArgumentException("Object should be a Host IPAdress."); - } - case GSISSH_SUBMISSION: - if (o instanceof GSISSHSubmission){ - return createGSSISSHSubmission((GSISSHSubmission) o); - }else { - logger.error("Object should be a GSISSH Submission", new IllegalArgumentException()); - throw new IllegalArgumentException("Object should be a GSISSH Submission."); - } - case UNICORE_JOB_SUBMISSION: - if (o instanceof UnicoreJobSubmission){ - return createUnicoreJobSubmission((UnicoreJobSubmission) o); - }else { - logger.error("Object should be a GSISSH Submission", new IllegalArgumentException()); - throw new IllegalArgumentException("Object should be a GSISSH Submission."); - } - case UNICORE_DATA_MOVEMENT: - if (o instanceof UnicoreDataMovement){ - return createUnicoreDataMovement((UnicoreDataMovement) o); - }else { - logger.error("Object should be a GSISSH Submission", new IllegalArgumentException()); - throw new IllegalArgumentException("Object should be a GSISSH Submission."); - } - case GSISSH_EXPORT: - if (o instanceof GSISSHExport){ - return createGSISSHExport((GSISSHExport) o); - }else { - logger.error("Object should be a GSISSH Export.", new IllegalArgumentException()); - throw new IllegalArgumentException("Object should be a GSISSH Export."); - } - case PRE_JOBCOMMAND: - if (o instanceof PreJobCommand){ - return createPreJobCommand((PreJobCommand) o); - }else { - logger.error("Object should be a GSISSHPreJobCommand.", new IllegalArgumentException()); - throw new IllegalArgumentException("Object should be a GSISSHPreJobCommand."); - } - case POST_JOBCOMMAND: - if (o instanceof PostJobCommand){ - return createPostJObCommand((PostJobCommand) o); - }else { - logger.error("Object should be a GSISSHPostJobCommand.", new IllegalArgumentException()); - throw new IllegalArgumentException("Object should be a GSISSHPostJobCommand."); - } - case GLOBUS_SUBMISSION: - if (o instanceof GlobusJobSubmission){ - return createGlobusJobSubmission((GlobusJobSubmission) o); - }else { - logger.error("Object should be a GlobusJobSubmission.", new IllegalArgumentException()); - throw new IllegalArgumentException("Object should be a GlobusJobSubmission."); - } - case GLOBUS_GK_ENDPOINT: - if (o instanceof GlobusGKEndpoint){ - return createGlobusEndpoint((GlobusGKEndpoint) o); - }else { - logger.error("Object should be a GlobusJobSubmission.", new IllegalArgumentException()); - throw new IllegalArgumentException("Object should be a GlobusJobSubmission."); - } - case SSH_JOB_SUBMISSION: - if (o instanceof SshJobSubmission){ - return createSshJobSubmission((SshJobSubmission) o); - }else{ - logger.error("Object should be a Ssh Job Submission.", new IllegalArgumentException()); - throw new IllegalArgumentException("Object should be a Ssh Job Submission."); - } - case SCP_DATA_MOVEMENT: - if (o instanceof ScpDataMovement){ - return createScpDataMovement((ScpDataMovement) o); - }else{ - logger.error("Object should be a Scp Data Movement.", new IllegalArgumentException()); - throw new IllegalArgumentException("Object should be a Scp Data Movement."); - } - case GRIDFTP_DATA_MOVEMENT: - if (o instanceof GridftpDataMovement){ - return createGridftpDataMovement((GridftpDataMovement) o); - }else{ - logger.error("Object should be a Gridftp Data Movement.", new IllegalArgumentException()); - throw new IllegalArgumentException("Object should be a Gridftp Data Movement."); - } - case GRIDFTP_ENDPOINT: - if (o instanceof GridftpEndpoint){ - return createGridftpEndpoint((GridftpEndpoint) o); - }else{ - logger.error("Object should be a Gridftp Endpoint.", new IllegalArgumentException()); - throw new IllegalArgumentException("Object should be a Gridftp Endpoint."); - } -// case JOB_SUBMISSION_PROTOCOL: -// if (o instanceof JobSubmissionProtocol){ -// return createJobSubmissionProtocol((JobSubmissionProtocol) o); -// }else { -// logger.error("Object should be a JobSubmissionProtocol.", new IllegalArgumentException()); -// throw new IllegalArgumentException("Object should be a JobSubmissionProtocol."); -// } -// case DATA_MOVEMENT_PROTOCOL: -// if (o instanceof DataMovementProtocol){ -// return createDataMovementProtocol((DataMovementProtocol) o); -// }else { -// logger.error("Object should be a DataMovementProtocol.", new IllegalArgumentException()); -// throw new IllegalArgumentException("Object should be a DataMovementProtocol."); -// } - case APPLICATION_MODULE: - if (o instanceof ApplicationModule){ - return createApplicationModule((ApplicationModule) o); - }else { - logger.error("Object should be a Application Module.", new IllegalArgumentException()); - throw new IllegalArgumentException("Object should be a Application Module."); - } - case APPLICATION_DEPLOYMENT: - if (o instanceof ApplicationDeployment){ - return createApplicationDeployment((ApplicationDeployment) o); - }else { - logger.error("Object should be a Application Deployment.", new IllegalArgumentException()); - throw new IllegalArgumentException("Object should be a Application Deployment."); - } - case LIBRARY_PREPAND_PATH: - if (o instanceof LibraryPrepandPath){ - return createLibraryPrepPathResource((LibraryPrepandPath) o); - }else { - logger.error("Object should be a Library Prepand path.", new IllegalArgumentException()); - throw new IllegalArgumentException("Object should be a Library Prepand path."); - } - case LIBRARY_APEND_PATH: - if (o instanceof LibraryApendPath){ - return createLibraryApendPathResource((LibraryApendPath) o); - }else { - logger.error("Object should be a Library Apend path.", new IllegalArgumentException()); - throw new IllegalArgumentException("Object should be a Library Apend."); - } - case APP_ENVIRONMENT: - if (o instanceof AppEnvironment){ - return createAppEnvironmentResource((AppEnvironment) o); - }else { - logger.error("Object should be a AppEnvironment.", new IllegalArgumentException()); - throw new IllegalArgumentException("Object should be a AppEnvironment."); - } - case APPLICATION_INTERFACE: - if (o instanceof ApplicationInterface){ - return createAppInterfaceResource((ApplicationInterface) o); - }else { - logger.error("Object should be a ApplicationInterface.", new IllegalArgumentException()); - throw new IllegalArgumentException("Object should be a ApplicationInterface."); - } - case APP_MODULE_MAPPING: - if (o instanceof AppModuleMapping){ - return createAppModMappingResource((AppModuleMapping) o); - }else { - logger.error("Object should be a AppModuleMapping.", new IllegalArgumentException()); - throw new IllegalArgumentException("Object should be a AppModuleMapping."); - } - case APPLICATION_OUTPUT: - if (o instanceof ApplicationOutput){ - return createApplicationOutput((ApplicationOutput) o); - }else { - logger.error("Object should be a ApplicationOutput.", new IllegalArgumentException()); - throw new IllegalArgumentException("Object should be a ApplicationOutput."); - } - case GATEWAY_PROFILE: - if (o instanceof GatewayProfile){ - return createGatewayProfile((GatewayProfile) o); - }else { - logger.error("Object should be a GatewayProfile.", new IllegalArgumentException()); - throw new IllegalArgumentException("Object should be a GatewayProfile."); - } - case COMPUTE_RESOURCE_PREFERENCE: - if (o instanceof ComputeResourcePreference){ - return createComputeResourcePref((ComputeResourcePreference) o); - }else { - logger.error("Object should be a Compute Resource Preference.", new IllegalArgumentException()); - throw new IllegalArgumentException("Object should be a Compute Resource Preference."); - } - case APPLICATION_INPUT: - if (o instanceof ApplicationInput){ - return createApplicationInput((ApplicationInput) o); - }else { - logger.error("Object should be a ApplicationInput.", new IllegalArgumentException()); - throw new IllegalArgumentException("Object should be a ApplicationInput."); - } - case BATCH_QUEUE: - if (o instanceof BatchQueue){ - return createBatchQueue((BatchQueue) o); - }else{ - logger.error("Object should be a Batch Queue.", new IllegalArgumentException()); - throw new IllegalArgumentException("Object should be a Batch Queue."); - } - case COMPUTE_RESOURCE_FILE_SYSTEM: - if (o instanceof ComputeResourceFileSystem){ - return createComputeResourceFileSystem((ComputeResourceFileSystem) o); - }else{ - logger.error("Object should be a Compute Resource File System.", new IllegalArgumentException()); - throw new IllegalArgumentException("Object should be a Compute Resource File System."); - } - case JOB_SUBMISSION_INTERFACE: - if (o instanceof JobSubmissionInterface){ - return createJobSubmissionInterface((JobSubmissionInterface) o); - }else{ - logger.error("Object should be a Job Submission Interface.", new IllegalArgumentException()); - throw new IllegalArgumentException("Object should be a Job Submission Interface."); - } - case DATA_MOVEMENT_INTERFACE: - if (o instanceof DataMovementInterface){ - return createDataMovementInterface((DataMovementInterface) o); - }else{ - logger.error("Object should be a Data Movement Interface.", new IllegalArgumentException()); - throw new IllegalArgumentException("Object should be a Data Movement Interface."); - } - case RESOURCE_JOB_MANAGER: - if (o instanceof ResourceJobManager){ - return createResourceJobManager((ResourceJobManager) o); - }else{ - logger.error("Object should be a Resource Job Manager.", new IllegalArgumentException()); - throw new IllegalArgumentException("Object should be a Resource Job Manager."); - } - case JOB_MANAGER_COMMAND: - if (o instanceof JobManagerCommand){ - return createJobManagerCommand((JobManagerCommand) o); - }else{ - logger.error("Object should be a Job Manager Command.", new IllegalArgumentException()); - throw new IllegalArgumentException("Object should be a Job Manager Command."); - } - case LOCAL_SUBMISSION: - if (o instanceof LocalSubmission){ - return createLocalSubmission((LocalSubmission) o); - }else{ - logger.error("Object should be a Local Submission.", new IllegalArgumentException()); - throw new IllegalArgumentException("Object should be a Local Submission."); - } - case LOCAL_DATA_MOVEMENT: - if (o instanceof LocalDataMovement){ - return createLocalDataMovement((LocalDataMovement) o); - }else{ - logger.error("Object should be a Local Data Movement.", new IllegalArgumentException()); - throw new IllegalArgumentException("Object should be a Local Data Movement."); - } - case MODULE_LOAD_CMD: - if (o instanceof ModuleLoadCmd) { - return createModuleLoadCmd((ModuleLoadCmd) o); - } else { - logger.error("Object should be a Module Load Cmd.", new IllegalArgumentException()); - throw new IllegalArgumentException("Object should be a Module Load Cmd."); - } - case WORKFLOW: - if (o instanceof Workflow) { - return createWorkflow((Workflow) o); - } else { - logger.error("Object should be a Workflow.", new IllegalArgumentException()); - throw new IllegalArgumentException("Object should be a Workflow."); - } - case WORKFLOW_INPUT: - if (o instanceof WorkflowInput){ - return createWorflowInput((WorkflowInput) o); - }else { - logger.error("Object should be a Workflow Input.", new IllegalArgumentException()); - throw new IllegalArgumentException("Object should be a Workflow Input."); - } - case WORKFLOW_OUTPUT: - if (o instanceof WorkflowOutput){ - return createWorkflowOutput((WorkflowOutput) o); - }else { - logger.error("Object should be a Workflow Output.", new IllegalArgumentException()); - throw new IllegalArgumentException("Object should be a Workflow Output."); - } - default: - logger.error("Illegal data type..", new IllegalArgumentException()); - throw new IllegalArgumentException("Illegal data type.."); - } - } - - private static Resource createLocalDataMovement(LocalDataMovement o) { - LocalDataMovementResource localDataMovementResource = new LocalDataMovementResource(); - if (o != null){ - localDataMovementResource.setDataMovementInterfaceId(o.getDataMovementInterfaceId()); - } - return localDataMovementResource; - } - - private static Resource createLocalSubmission(LocalSubmission o) { - LocalSubmissionResource localSubmissionResource = new LocalSubmissionResource(); - if (o != null){ - localSubmissionResource.setResourceJobManagerId(o.getResourceJobManagerId()); - localSubmissionResource.setResourceJobManagerResource((ResourceJobManagerResource)createResourceJobManager(o.getResourceJobManager())); - localSubmissionResource.setJobSubmissionInterfaceId(o.getJobSubmissionInterfaceId()); - localSubmissionResource.setCreatedTime(o.getCreationTime()); - if (o.getUpdateTime() != null){ - localSubmissionResource.setUpdatedTime(o.getUpdateTime()); - } - } - return localSubmissionResource; - } - - private static Resource createJobManagerCommand(JobManagerCommand o) { - JobManagerCommandResource jobManagerCommandResource = new JobManagerCommandResource(); - if (o != null){ - jobManagerCommandResource.setResourceJobManagerId(o.getResourceJobManagerId()); - jobManagerCommandResource.setResourceJobManagerResource((ResourceJobManagerResource)createResourceJobManager(o.getResourceJobManager())); - jobManagerCommandResource.setCommandType(o.getCommandType()); - jobManagerCommandResource.setCommand(o.getCommand()); - } - return jobManagerCommandResource; - } - - private static Resource createResourceJobManager(ResourceJobManager o) { - ResourceJobManagerResource resourceJobManagerResource = new ResourceJobManagerResource(); - if (o != null) { - resourceJobManagerResource.setResourceJobManagerId(o.getResourceJobManagerId()); - resourceJobManagerResource.setPushMonitoringEndpoint(o.getPushMonitoringEndpoint()); - resourceJobManagerResource.setJobManagerBinPath(o.getJobManagerBinPath()); - resourceJobManagerResource.setResourceJobManagerType(o.getResourceJobManagerType()); - resourceJobManagerResource.setCreatedTime(o.getCreationTime()); - if (o.getUpdateTime() != null){ - resourceJobManagerResource.setUpdatedTime(o.getUpdateTime()); - } - } - return resourceJobManagerResource; - } - - private static Resource createDataMovementInterface(DataMovementInterface o) { - DataMovementInterfaceResource dataMovementInterfaceResource = new DataMovementInterfaceResource(); - if (o != null) { - dataMovementInterfaceResource.setComputeResourceId(o.getComputeResourceId()); - dataMovementInterfaceResource.setComputeHostResource((ComputeResourceResource)createComputeResource(o.getComputeResource())); - dataMovementInterfaceResource.setDataMovementProtocol(o.getDataMovementProtocol()); - dataMovementInterfaceResource.setDataMovementInterfaceId(o.getDataMovementInterfaceId()); - dataMovementInterfaceResource.setPriorityOrder(o.getPriorityOrder()); - dataMovementInterfaceResource.setCreatedTime(o.getCreationTime()); - if (o.getUpdateTime() != null){ - dataMovementInterfaceResource.setUpdatedTime(o.getUpdateTime()); - } - } - return dataMovementInterfaceResource; - } - - private static Resource createJobSubmissionInterface(JobSubmissionInterface o) { - JobSubmissionInterfaceResource jobSubmissionInterfaceResource = new JobSubmissionInterfaceResource(); - if (o != null) { - jobSubmissionInterfaceResource.setJobSubmissionInterfaceId(o.getJobSubmissionInterfaceId()); - jobSubmissionInterfaceResource.setComputeResourceId(o.getComputeResourceId()); - jobSubmissionInterfaceResource.setComputeHostResource((ComputeResourceResource)createComputeResource(o.getComputeResource())); - jobSubmissionInterfaceResource.setJobSubmissionProtocol(o.getJobSubmissionProtocol()); - jobSubmissionInterfaceResource.setPriorityOrder(o.getPriorityOrder()); - jobSubmissionInterfaceResource.setCreatedTime(o.getCreationTime()); - if (o.getUpdateTime() != null){ - jobSubmissionInterfaceResource.setUpdatedTime(o.getUpdateTime()); - } - } - return jobSubmissionInterfaceResource; - } - - private static Resource createComputeResourceFileSystem(ComputeResourceFileSystem o) { - ComputeResourceFileSystemResource computeResourceFileSystemResource = new ComputeResourceFileSystemResource(); - if (o != null){ - computeResourceFileSystemResource.setComputeResourceId(o.getComputeResourceId()); - computeResourceFileSystemResource.setComputeHostResource((ComputeResourceResource)createComputeResource(o.getComputeResource())); - computeResourceFileSystemResource.setPath(o.getPath()); - computeResourceFileSystemResource.setFileSystem(o.getFileSystem()); - } - return computeResourceFileSystemResource; - } - - private static Resource createBatchQueue(BatchQueue o) { - BatchQueueResource batchQueueResource = new BatchQueueResource(); - if (o != null){ - batchQueueResource.setComputeResourceId(o.getComputeResourceId()); - batchQueueResource.setComputeHostResource((ComputeResourceResource)createComputeResource(o.getComputeResource())); - batchQueueResource.setMaxRuntime(o.getMaxRuntime()); - batchQueueResource.setMaxJobInQueue(o.getMaxJobInQueue()); - batchQueueResource.setQueueDescription(o.getQueueDescription()); - batchQueueResource.setQueueName(o.getQueueName()); - batchQueueResource.setMaxProcessors(o.getMaxProcessors()); - batchQueueResource.setMaxNodes(o.getMaxNodes()); - batchQueueResource.setMaxMemory(o.getMaxMemory()); - } - return batchQueueResource; - } - private static Resource createComputeResource(ComputeResource o) { - ComputeResourceResource computeResourceResource = new ComputeResourceResource(); - if (o != null) { - computeResourceResource.setResourceDescription(o.getResourceDescription()); - computeResourceResource.setResourceId(o.getResourceId()); - computeResourceResource.setHostName(o.getHostName()); - computeResourceResource.setCreatedTime(o.getCreationTime()); - computeResourceResource.setMaxMemoryPerNode(o.getMaxMemoryPerNode()); - if (o.getUpdateTime() != null){ - computeResourceResource.setUpdatedTime(o.getUpdateTime()); - } - } - return computeResourceResource; - } - - private static Resource createHostAlias(HostAlias o) { - HostAliasResource aliasResource = new HostAliasResource(); - if (o != null){ - aliasResource.setResourceID(o.getResourceID()); - aliasResource.setAlias(o.getAlias()); - aliasResource.setComputeHostResource((ComputeResourceResource)createComputeResource(o.getComputeResource())); - } - return aliasResource; - } - - private static Resource createHostIPAddress(HostIPAddress o) { - HostIPAddressResource ipAddressResource = new HostIPAddressResource(); - if (o != null){ - ipAddressResource.setResourceID(o.getResourceID()); - ipAddressResource.setIpaddress(o.getIpaddress()); - ipAddressResource.setComputeHostResource((ComputeResourceResource)createComputeResource(o.getComputeResource())); - } - return ipAddressResource; - } - - private static Resource createGSSISSHSubmission(GSISSHSubmission o) { - GSISSHSubmissionResource submissionResource = new GSISSHSubmissionResource(); - if (o != null) { - submissionResource.setSubmissionID(o.getSubmissionID()); - submissionResource.setResourceJobManager(o.getResourceJobManager()); - submissionResource.setSshPort(o.getSshPort()); - submissionResource.setInstalledPath(o.getInstalledPath()); - submissionResource.setMonitorMode(o.getMonitorMode()); - } - return submissionResource; - } - - - private static Resource createUnicoreJobSubmission(UnicoreJobSubmission o) { - UnicoreJobSubmissionResource submissionResource = new UnicoreJobSubmissionResource(); - if (o != null) { - submissionResource.setjobSubmissionInterfaceId(o.getSubmissionID()); - submissionResource.setUnicoreEndpointUrl(o.getUnicoreEndpointUrl()); - submissionResource.setSecurityProtocol(o.getSecurityProtocol()); - } - return submissionResource; - } - - private static Resource createUnicoreDataMovement(UnicoreDataMovement o) { - UnicoreDataMovementResource dataMovementResource = new UnicoreDataMovementResource(); - if (o != null) { - dataMovementResource.setDataMovementId(o.getDataMovementId()); - dataMovementResource.setUnicoreEndpointUrl(o.getUnicoreEndpointUrl()); - dataMovementResource.setSecurityProtocol(o.getSecurityProtocol()); - } - return dataMovementResource; - } - - private static Resource createGSISSHExport(GSISSHExport o){ - GSISSHExportResource resource = new GSISSHExportResource(); - if (o != null) { - resource.setSubmissionID(o.getSubmissionID()); - resource.setExport(o.getExport()); - resource.setGsisshSubmissionResource((GSISSHSubmissionResource)createGSSISSHSubmission(o.getGsisshJobSubmission())); - } - return resource; - } - - private static Resource createPreJobCommand(PreJobCommand o){ - PreJobCommandResource resource = new PreJobCommandResource(); - if (o != null) { - resource.setAppDeploymentId(o.getDeploymentId()); - resource.setCommand(o.getCommand()); - resource.setAppDeploymentResource((AppDeploymentResource) createApplicationDeployment(o.getApplicationDeployment())); - } - return resource; - } - - private static Resource createPostJObCommand(PostJobCommand o){ - PostJobCommandResource resource = new PostJobCommandResource(); - if (o != null){ - resource.setAppDeploymentId(o.getDeploymentId()); - resource.setCommand(o.getCommand()); - resource.setAppDeploymentResource((AppDeploymentResource) createApplicationDeployment(o.getDeployment())); - } - return resource; - } - - private static Resource createGlobusJobSubmission(GlobusJobSubmission o) { - GlobusJobSubmissionResource resource = new GlobusJobSubmissionResource(); - if (o != null){ - resource.setSubmissionID(o.getSubmissionID()); - resource.setResourceJobManager(o.getResourceJobManager()); - resource.setSecurityProtocol(o.getSecurityProtocol()); - } - return resource; - } - - private static Resource createGlobusEndpoint(GlobusGKEndpoint o) { - GlobusGKEndpointResource resource = new GlobusGKEndpointResource(); - if (o != null){ - resource.setSubmissionID(o.getSubmissionID()); - resource.setEndpoint(o.getEndpoint()); - resource.setGlobusJobSubmissionResource((GlobusJobSubmissionResource)createGlobusJobSubmission(o.getGlobusSubmission())); - } - return resource; - } - - private static Resource createSshJobSubmission(SshJobSubmission o) { - SshJobSubmissionResource sshJobSubmissionResource = new SshJobSubmissionResource(); - if (o != null) { - sshJobSubmissionResource.setResourceJobManagerId(o.getResourceJobManagerId()); - sshJobSubmissionResource.setResourceJobManagerResource((ResourceJobManagerResource) createResourceJobManager(o.getResourceJobManager())); - sshJobSubmissionResource.setJobSubmissionInterfaceId(o.getJobSubmissionInterfaceId()); - sshJobSubmissionResource.setAlternativeSshHostname(o.getAlternativeSshHostname()); - sshJobSubmissionResource.setSecurityProtocol(o.getSecurityProtocol()); - sshJobSubmissionResource.setSshPort(o.getSshPort()); - sshJobSubmissionResource.setMonitorMode(o.getMonitorMode()); - sshJobSubmissionResource.setCreatedTime(o.getCreationTime()); - if (o.getUpdateTime() != null){ - sshJobSubmissionResource.setUpdatedTime(o.getUpdateTime()); - } - } - return sshJobSubmissionResource; - } - - private static Resource createScpDataMovement(ScpDataMovement o) { - ScpDataMovementResource scpDataMovementResource = new ScpDataMovementResource(); - if (o != null){ - scpDataMovementResource.setQueueDescription(o.getQueueDescription()); - scpDataMovementResource.setDataMovementInterfaceId(o.getDataMovementInterfaceId()); - scpDataMovementResource.setSecurityProtocol(o.getSecurityProtocol()); - scpDataMovementResource.setAlternativeScpHostname(o.getAlternativeScpHostname()); - scpDataMovementResource.setSshPort(o.getSshPort()); - scpDataMovementResource.setCreatedTime(o.getCreationTime()); - if (o.getUpdateTime() != null){ - scpDataMovementResource.setUpdatedTime(o.getUpdateTime()); - } - } - return scpDataMovementResource; - } - - private static Resource createGridftpDataMovement(GridftpDataMovement o) { - GridftpDataMovementResource gridftpDataMovementResource = new GridftpDataMovementResource(); - if (o != null){ - gridftpDataMovementResource.setDataMovementInterfaceId(o.getDataMovementInterfaceId()); - gridftpDataMovementResource.setSecurityProtocol(o.getSecurityProtocol()); - gridftpDataMovementResource.setCreatedTime(o.getCreationTime()); - if (o.getUpdateTime() != null){ - gridftpDataMovementResource.setUpdatedTime(o.getUpdateTime()); - } - } - return gridftpDataMovementResource; - } - - private static Resource createGridftpEndpoint(GridftpEndpoint o) { - GridftpEndpointResource gridftpEndpointResource = new GridftpEndpointResource(); - if (o != null){ - gridftpEndpointResource.setEndpoint(o.getEndpoint()); - gridftpEndpointResource.setDataMovementInterfaceId(o.getDataMovementInterfaceId()); - gridftpEndpointResource.setGridftpDataMovementResource((GridftpDataMovementResource)createGridftpDataMovement(o.getGridftpDataMovement())); - gridftpEndpointResource.setCreatedTime(o.getCreationTime()); - if (o.getUpdateTime() != null){ - gridftpEndpointResource.setUpdatedTime(o.getUpdateTime()); - } - } - return gridftpEndpointResource; - } - -// private static Resource createJobSubmissionProtocol(JobSubmissionProtocol o) { -// JobSubmissionProtocolResource resource = new JobSubmissionProtocolResource(); -// if (o != null){ -// resource.setResourceID(o.getResourceID()); -// resource.setSubmissionID(o.getSubmissionID()); -// resource.setJobType(o.getJobType()); -// resource.setComputeHostResource((ComputeResourceResource)createComputeResource(o.getComputeResource())); -// } -// return resource; -// } -// -// private static Resource createDataMovementProtocol(DataMovementProtocol o) { -// DataMovementProtocolResource resource = new DataMovementProtocolResource(); -// if (o != null) { -// resource.setResourceID(o.getResourceID()); -// resource.setDataMoveID(o.getDataMoveID()); -// resource.setDataMoveType(o.getDataMoveType()); -// resource.setComputeHostResource((ComputeResourceResource)createComputeResource(o.getComputeResource())); -// } -// return resource; -// } - - private static Resource createApplicationModule(ApplicationModule o) { - AppModuleResource moduleResource = new AppModuleResource(); - if (o != null){ - moduleResource.setModuleId(o.getModuleID()); - moduleResource.setModuleDesc(o.getModuleDesc()); - moduleResource.setGatewayId(o.getGatewayId()); - moduleResource.setModuleName(o.getModuleName()); - moduleResource.setModuleVersion(o.getModuleVersion()); - moduleResource.setCreatedTime(o.getCreationTime()); - if (o.getUpdateTime() != null){ - moduleResource.setUpdatedTime(o.getUpdateTime()); - } - } - return moduleResource; - } - - private static Resource createApplicationDeployment(ApplicationDeployment o) { - AppDeploymentResource resource = new AppDeploymentResource(); - if (o != null){ - resource.setDeploymentId(o.getDeploymentID()); - resource.setAppDes(o.getApplicationDesc()); - resource.setAppModuleId(o.getAppModuleID()); - resource.setHostId(o.getHostID()); - resource.setExecutablePath(o.getExecutablePath()); - resource.setGatewayId(o.getGatewayId()); - resource.setParallelism(o.getParallelism()); - resource.setModuleResource((AppModuleResource) createApplicationModule(o.getApplicationModule())); - resource.setHostResource((ComputeResourceResource) createComputeResource(o.getComputeResource())); - resource.setCreatedTime(o.getCreationTime()); - if (o.getUpdateTime() != null){ - resource.setUpdatedTime(o.getUpdateTime()); - } - } - return resource; - } - - private static Resource createLibraryPrepPathResource(LibraryPrepandPath o) { - LibraryPrepandPathResource resource = new LibraryPrepandPathResource(); - if (o != null){ - resource.setDeploymentId(o.getDeploymentID()); - resource.setName(o.getName()); - resource.setValue(o.getValue()); - resource.setAppDeploymentResource((AppDeploymentResource) createApplicationDeployment(o.getApplicationDeployment())); - } - return resource; - } - - private static Resource createLibraryApendPathResource(LibraryApendPath o) { - LibraryApendPathResource resource = new LibraryApendPathResource(); - if (o != null){ - resource.setDeploymentId(o.getDeploymentID()); - resource.setName(o.getName()); - resource.setValue(o.getValue()); - resource.setAppDeploymentResource((AppDeploymentResource)createApplicationDeployment(o.getApplicationDeployment())); - } - return resource; - } - - private static Resource createAppEnvironmentResource(AppEnvironment o) { - AppEnvironmentResource resource = new AppEnvironmentResource(); - if (o != null){ - resource.setDeploymentId(o.getDeploymentID()); - resource.setName(o.getName()); - resource.setValue(o.getValue()); - resource.setAppDeploymentResource((AppDeploymentResource)createApplicationDeployment(o.getApplicationDeployment())); - } - return resource; - } - - private static Resource createAppInterfaceResource(ApplicationInterface o) { - AppInterfaceResource resource = new AppInterfaceResource(); - if (o != null){ - resource.setInterfaceId(o.getInterfaceID()); - resource.setAppName(o.getAppName()); - resource.setAppDescription(o.getAppDescription()); - resource.setCreatedTime(o.getCreationTime()); - resource.setGatewayId(o.getGatewayId()); - if (o.getUpdateTime() != null){ - resource.setUpdatedTime(o.getUpdateTime()); - } - } - return resource; - } - - private static Resource createAppModMappingResource(AppModuleMapping o) { - AppModuleMappingResource resource = new AppModuleMappingResource(); - if (o != null){ - resource.setInterfaceId(o.getInterfaceID()); - resource.setModuleId(o.getModuleID()); - } - return resource; - } - - private static Resource createApplicationInput(ApplicationInput o) { - ApplicationInputResource resource = new ApplicationInputResource(); - if (o != null){ - resource.setInterfaceID(o.getInterfaceID()); - resource.setInputKey(o.getInputKey()); - resource.setInputVal(o.getInputVal()); - resource.setDataType(o.getDataType()); - resource.setMetadata(o.getMetadata()); - resource.setAppArgument(o.getAppArgument()); - resource.setUserFriendlyDesc(o.getUserFriendlyDesc()); - resource.setStandardInput(o.isStandardInput()); - resource.setInputOrder(o.getInputOrder()); - resource.setRequired(o.isRequired()); - resource.setRequiredToCMD(o.isRequiredToCMD()); - resource.setDataStaged(o.isDataStaged()); - resource.setAppInterfaceResource((AppInterfaceResource)createAppInterfaceResource(o.getApplicationInterface())); - } - return resource; - } - - private static Resource createWorflowInput(WorkflowInput o) { - WorkflowInputResource resource = new WorkflowInputResource(); - if (o != null){ - resource.setWfTemplateId(o.getWfTemplateId()); - resource.setInputKey(o.getInputKey()); - if (o.getInputVal() != null){ - resource.setInputVal(new String(o.getInputVal())); - } - resource.setDataType(o.getDataType()); - resource.setMetadata(o.getMetadata()); - resource.setAppArgument(o.getAppArgument()); - resource.setInputOrder(o.getInputOrder()); - resource.setUserFriendlyDesc(o.getUserFriendlyDesc()); - resource.setStandardInput(o.isStandardInput()); - resource.setRequired(o.isRequired()); - resource.setRequiredToCMD(o.isRequiredToCMD()); - resource.setDataStaged(o.isDataStaged()); - resource.setWorkflowResource((WorkflowResource)createWorkflow(o.getWorkflow())); - } - return resource; - } - - private static Resource createApplicationOutput(ApplicationOutput o) { - ApplicationOutputResource resource = new ApplicationOutputResource(); - if (o != null){ - resource.setInterfaceID(o.getInterfaceID()); - resource.setOutputKey(o.getOutputKey()); - resource.setOutputVal(o.getOutputVal()); - resource.setDataType(o.getDataType()); - resource.setRequired(o.isRequired()); - resource.setRequiredToCMD(o.isRequiredToCMD()); - resource.setDataMovement(o.isDataMovement()); - resource.setDataNameLocation(o.getDataNameLocation()); - resource.setSearchQuery(o.getSearchQuery()); - resource.setAppArgument(o.getApplicationArgument()); - resource.setAppInterfaceResource((AppInterfaceResource)createAppInterfaceResource(o.getApplicationInterface())); - } - return resource; - } - - private static Resource createWorkflowOutput(WorkflowOutput o) { - WorkflowOutputResource resource = new WorkflowOutputResource(); - if (o != null){ - resource.setWfTemplateId(o.getWfTemplateId()); - resource.setOutputKey(o.getOutputKey()); - if (o.getOutputVal() != null){ - resource.setOutputVal(new String(o.getOutputVal())); - } - resource.setDataType(o.getDataType()); - resource.setValidityType(o.getValidityType()); - resource.setDataMovement(o.isDataMovement()); - resource.setDataNameLocation(o.getDataNameLocation()); - resource.setWorkflowResource((WorkflowResource)createWorkflow(o.getWorkflow())); - } - return resource; - } - - private static Resource createGatewayProfile(GatewayProfile o) { - GatewayProfileResource resource = new GatewayProfileResource(); - if (o != null) { - resource.setGatewayID(o.getGatewayID()); - resource.setCreatedTime(o.getCreationTime()); - if (o.getUpdateTime() != null){ - resource.setUpdatedTime(o.getUpdateTime()); - } - } - return resource; - } - - private static Resource createComputeResourcePref(ComputeResourcePreference o) { - ComputeHostPreferenceResource resource = new ComputeHostPreferenceResource(); - if (o != null) { - resource.setGatewayId(o.getGatewayId()); - resource.setResourceId(o.getResourceId()); - resource.setOverrideByAiravata(o.isOverrideByAiravata()); - resource.setPreferredJobProtocol(o.getPreferedJobSubmissionProtocol()); - resource.setPreferedDMProtocol(o.getPreferedDataMoveProtocol()); - resource.setBatchQueue(o.getBatchQueue()); - resource.setScratchLocation(o.getScratchLocation()); - resource.setProjectNumber(o.getProjectNumber()); - resource.setLoginUserName(o.getLoginUserName()); - resource.setComputeHostResource((ComputeResourceResource) createComputeResource(o.getComputeHostResource())); - resource.setGatewayProfile((GatewayProfileResource) createGatewayProfile(o.getGatewayProfile())); - } - return resource; - } - - private static Resource createModuleLoadCmd(ModuleLoadCmd o) { - ModuleLoadCmdResource moduleLoadCmdResource = new ModuleLoadCmdResource(); - if (o != null){ - moduleLoadCmdResource.setCmd(o.getCmd()); - moduleLoadCmdResource.setAppDeploymentId(o.getAppDeploymentId()); - moduleLoadCmdResource.setAppDeploymentResource((AppDeploymentResource)createApplicationDeployment(o.getApplicationDeployment())); - } - return moduleLoadCmdResource; - } - - private static Resource createWorkflow(Workflow o) { - WorkflowResource workflowResource = new WorkflowResource(); - workflowResource.setWfName(o.getWfName()); - workflowResource.setCreatedUser(o.getCreatedUser()); - if (o.getGraph() != null){ - workflowResource.setGraph(new String(o.getGraph())); - } - if (o.getImage() != null){ - workflowResource.setImage(new String(o.getImage())); - } - workflowResource.setCreatedTime(o.getCreationTime()); - if (o.getUpdateTime() != null){ - workflowResource.setUpdatedTime(o.getUpdateTime()); - } - workflowResource.setWfTemplateId(o.getWfTemplateId()); - workflowResource.setGatewayId(o.getGatewayId()); - return workflowResource; - } -} http://git-wip-us.apache.org/repos/asf/airavata/blob/ec8c6202/modules/app-catalog/app-catalog-data/src/main/java/org/apache/aiaravata/application/catalog/data/util/AppCatalogQueryGenerator.java ---------------------------------------------------------------------- diff --git a/modules/app-catalog/app-catalog-data/src/main/java/org/apache/aiaravata/application/catalog/data/util/AppCatalogQueryGenerator.java b/modules/app-catalog/app-catalog-data/src/main/java/org/apache/aiaravata/application/catalog/data/util/AppCatalogQueryGenerator.java deleted file mode 100644 index 8f41538..0000000 --- a/modules/app-catalog/app-catalog-data/src/main/java/org/apache/aiaravata/application/catalog/data/util/AppCatalogQueryGenerator.java +++ /dev/null @@ -1,90 +0,0 @@ -/* - * - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, - * software distributed under the License is distributed on an - * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY - * KIND, either express or implied. See the License for the - * specific language governing permissions and limitations - * under the License. - * - */ - -package org.apache.aiaravata.application.catalog.data.util; - -import javax.persistence.EntityManager; -import javax.persistence.Query; -import java.util.HashMap; -import java.util.Map; - -public class AppCatalogQueryGenerator { - private String tableName; - private Map<String,Object> matches=new HashMap<String, Object>(); - private static final String SELECT_OBJ="p"; - private static final String DELETE_OBJ="p"; - private static final String TABLE_OBJ="p"; - - public AppCatalogQueryGenerator(String tableName, Object[]...params) { - setTableName(tableName); - for (Object[] param : params) { - addMatch(param[0].toString(), param[1]); - } - } - - public String getTableName() { - return tableName; - } - public void setTableName(String tableName) { - this.tableName = tableName; - } - public void addMatch(String colName, Object matchValue){ - matches.put(colName, matchValue); - } - - public void setParameter(String colName, Object matchValue){ - addMatch(colName, matchValue); - } - - public Query selectQuery(EntityManager entityManager){ - String queryString="SELECT "+ SELECT_OBJ + " FROM " +getTableName()+" "+TABLE_OBJ; - return generateQueryWithParameters(entityManager, queryString); - } - - public Query deleteQuery(EntityManager entityManager){ - String queryString="Delete FROM "+getTableName()+" "+TABLE_OBJ; - return generateQueryWithParameters(entityManager, queryString); - } - - private Query generateQueryWithParameters(EntityManager entityManager, - String queryString) { - Map<String,Object> queryParameters=new HashMap<String, Object>(); - if (matches.size()>0){ - String matchString = ""; - int paramCount=0; - for (String colName : matches.keySet()) { - String paramName="param"+paramCount; - queryParameters.put(paramName, matches.get(colName)); - if (!matchString.equals("")){ - matchString+=" AND "; - } - matchString+=TABLE_OBJ+"."+colName+" =:"+paramName; - paramCount++; - } - queryString+=" WHERE "+matchString; - } - Query query = entityManager.createQuery(queryString); - for (String paramName : queryParameters.keySet()) { - query.setParameter(paramName, queryParameters.get(paramName)); - } - return query; - } -} http://git-wip-us.apache.org/repos/asf/airavata/blob/ec8c6202/modules/app-catalog/app-catalog-data/src/main/java/org/apache/aiaravata/application/catalog/data/util/AppCatalogResourceType.java ---------------------------------------------------------------------- diff --git a/modules/app-catalog/app-catalog-data/src/main/java/org/apache/aiaravata/application/catalog/data/util/AppCatalogResourceType.java b/modules/app-catalog/app-catalog-data/src/main/java/org/apache/aiaravata/application/catalog/data/util/AppCatalogResourceType.java deleted file mode 100644 index 196d3a1..0000000 --- a/modules/app-catalog/app-catalog-data/src/main/java/org/apache/aiaravata/application/catalog/data/util/AppCatalogResourceType.java +++ /dev/null @@ -1,66 +0,0 @@ -/* - * - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, - * software distributed under the License is distributed on an - * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY - * KIND, either express or implied. See the License for the - * specific language governing permissions and limitations - * under the License. - * - */ - -package org.apache.aiaravata.application.catalog.data.util; - -public enum AppCatalogResourceType { - COMPUTE_RESOURCE, - HOST_ALIAS, - HOST_IPADDRESS, - GSISSH_SUBMISSION, - GSISSH_EXPORT, - PRE_JOBCOMMAND, - POST_JOBCOMMAND, - GLOBUS_SUBMISSION, - UNICORE_JOB_SUBMISSION, - UNICORE_DATA_MOVEMENT, - GLOBUS_GK_ENDPOINT, - SSH_JOB_SUBMISSION, - SCP_DATA_MOVEMENT, - GRIDFTP_DATA_MOVEMENT, - GRIDFTP_ENDPOINT, - JOB_SUBMISSION_PROTOCOL, - DATA_MOVEMENT_PROTOCOL, - APPLICATION_MODULE, - APPLICATION_DEPLOYMENT, - LIBRARY_PREPAND_PATH, - LIBRARY_APEND_PATH, - APP_ENVIRONMENT, - APPLICATION_INTERFACE, - APP_MODULE_MAPPING, - APPLICATION_INPUT, - APPLICATION_OUTPUT, - GATEWAY_PROFILE, - COMPUTE_RESOURCE_PREFERENCE, - BATCH_QUEUE, - COMPUTE_RESOURCE_FILE_SYSTEM, - JOB_SUBMISSION_INTERFACE, - DATA_MOVEMENT_INTERFACE, - RESOURCE_JOB_MANAGER, - JOB_MANAGER_COMMAND, - LOCAL_SUBMISSION, - LOCAL_DATA_MOVEMENT, - MODULE_LOAD_CMD, - ClOUD_SUBMISSION, - WORKFLOW, - WORKFLOW_INPUT, - WORKFLOW_OUTPUT -}
