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/ScpDataMovementResource.java ---------------------------------------------------------------------- diff --git a/modules/app-catalog/app-catalog-data/src/main/java/org/apache/aiaravata/application/catalog/data/resources/ScpDataMovementResource.java b/modules/app-catalog/app-catalog-data/src/main/java/org/apache/aiaravata/application/catalog/data/resources/ScpDataMovementResource.java deleted file mode 100644 index 8c593f3..0000000 --- a/modules/app-catalog/app-catalog-data/src/main/java/org/apache/aiaravata/application/catalog/data/resources/ScpDataMovementResource.java +++ /dev/null @@ -1,308 +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.ScpDataMovement; -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 ScpDataMovementResource extends AbstractResource { - private final static Logger logger = LoggerFactory.getLogger(ScpDataMovementResource.class); - private String queueDescription; - private String dataMovementInterfaceId; - private String securityProtocol; - private String alternativeScpHostname; - private int sshPort; - private Timestamp createdTime; - private Timestamp updatedTime; - - 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; - } - - @Override - public void remove(Object identifier) throws AppCatalogException { - EntityManager em = null; - try { - em = AppCatalogJPAUtils.getEntityManager(); - em.getTransaction().begin(); - AppCatalogQueryGenerator generator = new AppCatalogQueryGenerator(SCP_DATA_MOVEMENT); - generator.setParameter(ScpDataMovementConstants.DATA_MOVEMENT_INTERFACE_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(SCP_DATA_MOVEMENT); - generator.setParameter(ScpDataMovementConstants.DATA_MOVEMENT_INTERFACE_ID, identifier); - Query q = generator.selectQuery(em); - ScpDataMovement scpDataMovement = (ScpDataMovement) q.getSingleResult(); - ScpDataMovementResource scpDataMovementResource = (ScpDataMovementResource) AppCatalogJPAUtils.getResource(AppCatalogResourceType.SCP_DATA_MOVEMENT, scpDataMovement); - em.getTransaction().commit(); - em.close(); - return scpDataMovementResource; - } 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> scpDataMovementResources = new ArrayList<Resource>(); - EntityManager em = null; - try { - em = AppCatalogJPAUtils.getEntityManager(); - em.getTransaction().begin(); - AppCatalogQueryGenerator generator = new AppCatalogQueryGenerator(SCP_DATA_MOVEMENT); - Query q; - if ((fieldName.equals(ScpDataMovementConstants.QUEUE_DESCRIPTION)) || (fieldName.equals(ScpDataMovementConstants.DATA_MOVEMENT_INTERFACE_ID)) || (fieldName.equals(ScpDataMovementConstants.SECURITY_PROTOCOL)) || (fieldName.equals(ScpDataMovementConstants.ALTERNATIVE_SCP_HOSTNAME)) || (fieldName.equals(ScpDataMovementConstants.SSH_PORT))) { - generator.setParameter(fieldName, value); - q = generator.selectQuery(em); - List<?> results = q.getResultList(); - for (Object result : results) { - ScpDataMovement scpDataMovement = (ScpDataMovement) result; - ScpDataMovementResource scpDataMovementResource = (ScpDataMovementResource) AppCatalogJPAUtils.getResource(AppCatalogResourceType.SCP_DATA_MOVEMENT, scpDataMovement); - scpDataMovementResources.add(scpDataMovementResource); - } - } else { - em.getTransaction().commit(); - em.close(); - logger.error("Unsupported field name for Scp Data Movement Resource.", new IllegalArgumentException()); - throw new IllegalArgumentException("Unsupported field name for Scp Data Movement 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 scpDataMovementResources; - } - - @Override - public List<Resource> getAll() throws AppCatalogException { - return null; - } - - @Override - public List<String> getAllIds() throws AppCatalogException { - return null; - } - - @Override - public List<String> getIds(String fieldName, Object value) throws AppCatalogException { - List<String> scpDataMovementResourceIDs = new ArrayList<String>(); - EntityManager em = null; - try { - em = AppCatalogJPAUtils.getEntityManager(); - em.getTransaction().begin(); - AppCatalogQueryGenerator generator = new AppCatalogQueryGenerator(SCP_DATA_MOVEMENT); - Query q; - if ((fieldName.equals(ScpDataMovementConstants.QUEUE_DESCRIPTION)) || (fieldName.equals(ScpDataMovementConstants.DATA_MOVEMENT_INTERFACE_ID)) || (fieldName.equals(ScpDataMovementConstants.SECURITY_PROTOCOL)) || (fieldName.equals(ScpDataMovementConstants.ALTERNATIVE_SCP_HOSTNAME)) || (fieldName.equals(ScpDataMovementConstants.SSH_PORT))) { - generator.setParameter(fieldName, value); - q = generator.selectQuery(em); - List<?> results = q.getResultList(); - for (Object result : results) { - ScpDataMovement scpDataMovement = (ScpDataMovement) result; - ScpDataMovementResource scpDataMovementResource = (ScpDataMovementResource) AppCatalogJPAUtils.getResource(AppCatalogResourceType.SCP_DATA_MOVEMENT, scpDataMovement); - scpDataMovementResourceIDs.add(scpDataMovementResource.getDataMovementInterfaceId()); - } - } else { - em.getTransaction().commit(); - em.close(); - logger.error("Unsupported field name for Scp Data Movement Resource.", new IllegalArgumentException()); - throw new IllegalArgumentException("Unsupported field name for Scp Data Movement 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 scpDataMovementResourceIDs; - } - - @Override - public void save() throws AppCatalogException { - EntityManager em = null; - try { - em = AppCatalogJPAUtils.getEntityManager(); - ScpDataMovement existingScpDataMovement = em.find(ScpDataMovement.class, dataMovementInterfaceId); - em.close(); - ScpDataMovement scpDataMovement; - em = AppCatalogJPAUtils.getEntityManager(); - em.getTransaction().begin(); - if (existingScpDataMovement == null) { - scpDataMovement = new ScpDataMovement(); - scpDataMovement.setCreationTime(AiravataUtils.getCurrentTimestamp()); - } else { - scpDataMovement = existingScpDataMovement; - scpDataMovement.setUpdateTime(AiravataUtils.getCurrentTimestamp()); - } - scpDataMovement.setQueueDescription(getQueueDescription()); - scpDataMovement.setDataMovementInterfaceId(getDataMovementInterfaceId()); - scpDataMovement.setSecurityProtocol(getSecurityProtocol()); - scpDataMovement.setAlternativeScpHostname(getAlternativeScpHostname()); - scpDataMovement.setSshPort(getSshPort()); - if (existingScpDataMovement == null) { - em.persist(scpDataMovement); - } else { - em.merge(scpDataMovement); - } - 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(); - ScpDataMovement scpDataMovement = em.find(ScpDataMovement.class, identifier); - em.close(); - return scpDataMovement != 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 getQueueDescription() { - return queueDescription; - } - - public String getDataMovementInterfaceId() { - return dataMovementInterfaceId; - } - - public String getSecurityProtocol() { - return securityProtocol; - } - - public String getAlternativeScpHostname() { - return alternativeScpHostname; - } - - public int getSshPort() { - return sshPort; - } - - public void setQueueDescription(String queueDescription) { - this.queueDescription=queueDescription; - } - - public void setDataMovementInterfaceId(String dataMovementInterfaceId) { - this.dataMovementInterfaceId=dataMovementInterfaceId; - } - - public void setSecurityProtocol(String securityProtocol) { - this.securityProtocol=securityProtocol; - } - - public void setAlternativeScpHostname(String alternativeScpHostname) { - this.alternativeScpHostname=alternativeScpHostname; - } - - public void setSshPort(int sshPort) { - this.sshPort=sshPort; - } -} \ No newline at end of file
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/SshJobSubmissionResource.java ---------------------------------------------------------------------- diff --git a/modules/app-catalog/app-catalog-data/src/main/java/org/apache/aiaravata/application/catalog/data/resources/SshJobSubmissionResource.java b/modules/app-catalog/app-catalog-data/src/main/java/org/apache/aiaravata/application/catalog/data/resources/SshJobSubmissionResource.java deleted file mode 100644 index ee14d76..0000000 --- a/modules/app-catalog/app-catalog-data/src/main/java/org/apache/aiaravata/application/catalog/data/resources/SshJobSubmissionResource.java +++ /dev/null @@ -1,332 +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 java.sql.Timestamp; -import java.util.ArrayList; -import java.util.List; - -import javax.persistence.EntityManager; -import javax.persistence.Query; - -import org.airavata.appcatalog.cpi.AppCatalogException; -import org.apache.aiaravata.application.catalog.data.model.ResourceJobManager; -import org.apache.aiaravata.application.catalog.data.model.SshJobSubmission; -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; - -public class SshJobSubmissionResource extends AbstractResource { - private final static Logger logger = LoggerFactory.getLogger(SshJobSubmissionResource.class); - private String resourceJobManagerId; - private ResourceJobManagerResource resourceJobManagerResource; - private String jobSubmissionInterfaceId; - private String alternativeSshHostname; - private String securityProtocol; - private int sshPort; - private String monitorMode; - private Timestamp createdTime; - private Timestamp updatedTime; - - 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; - } - - @Override - public void remove(Object identifier) throws AppCatalogException { - EntityManager em = null; - try { - em = AppCatalogJPAUtils.getEntityManager(); - em.getTransaction().begin(); - AppCatalogQueryGenerator generator = new AppCatalogQueryGenerator(SSH_JOB_SUBMISSION); - generator.setParameter(SshJobSubmissionConstants.JOB_SUBMISSION_INTERFACE_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(SSH_JOB_SUBMISSION); - generator.setParameter(SshJobSubmissionConstants.JOB_SUBMISSION_INTERFACE_ID, identifier); - Query q = generator.selectQuery(em); - SshJobSubmission sshJobSubmission = (SshJobSubmission) q.getSingleResult(); - SshJobSubmissionResource sshJobSubmissionResource = (SshJobSubmissionResource) AppCatalogJPAUtils.getResource(AppCatalogResourceType.SSH_JOB_SUBMISSION, sshJobSubmission); - em.getTransaction().commit(); - em.close(); - return sshJobSubmissionResource; - } 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> sshJobSubmissionResources = new ArrayList<Resource>(); - EntityManager em = null; - try { - em = AppCatalogJPAUtils.getEntityManager(); - em.getTransaction().begin(); - AppCatalogQueryGenerator generator = new AppCatalogQueryGenerator(SSH_JOB_SUBMISSION); - Query q; - if ((fieldName.equals(SshJobSubmissionConstants.RESOURCE_JOB_MANAGER_ID)) || (fieldName.equals(SshJobSubmissionConstants.JOB_SUBMISSION_INTERFACE_ID)) || (fieldName.equals(SshJobSubmissionConstants.ALTERNATIVE_SSH_HOSTNAME)) || (fieldName.equals(SshJobSubmissionConstants.SECURITY_PROTOCOL)) || (fieldName.equals(SshJobSubmissionConstants.SSH_PORT))) { - generator.setParameter(fieldName, value); - q = generator.selectQuery(em); - List<?> results = q.getResultList(); - for (Object result : results) { - SshJobSubmission sshJobSubmission = (SshJobSubmission) result; - SshJobSubmissionResource sshJobSubmissionResource = (SshJobSubmissionResource) AppCatalogJPAUtils.getResource(AppCatalogResourceType.SSH_JOB_SUBMISSION, sshJobSubmission); - sshJobSubmissionResources.add(sshJobSubmissionResource); - } - } else { - em.getTransaction().commit(); - em.close(); - logger.error("Unsupported field name for Ssh Job Submission Resource.", new IllegalArgumentException()); - throw new IllegalArgumentException("Unsupported field name for Ssh Job Submission 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 sshJobSubmissionResources; - } - - @Override - public List<Resource> getAll() throws AppCatalogException { - return null; - } - - @Override - public List<String> getAllIds() throws AppCatalogException { - return null; - } - - @Override - public List<String> getIds(String fieldName, Object value) throws AppCatalogException { - List<String> sshJobSubmissionResourceIDs = new ArrayList<String>(); - EntityManager em = null; - try { - em = AppCatalogJPAUtils.getEntityManager(); - em.getTransaction().begin(); - AppCatalogQueryGenerator generator = new AppCatalogQueryGenerator(SSH_JOB_SUBMISSION); - Query q; - if ((fieldName.equals(SshJobSubmissionConstants.RESOURCE_JOB_MANAGER_ID)) || (fieldName.equals(SshJobSubmissionConstants.JOB_SUBMISSION_INTERFACE_ID)) || (fieldName.equals(SshJobSubmissionConstants.ALTERNATIVE_SSH_HOSTNAME)) || (fieldName.equals(SshJobSubmissionConstants.SECURITY_PROTOCOL)) || (fieldName.equals(SshJobSubmissionConstants.SSH_PORT))) { - generator.setParameter(fieldName, value); - q = generator.selectQuery(em); - List<?> results = q.getResultList(); - for (Object result : results) { - SshJobSubmission sshJobSubmission = (SshJobSubmission) result; - SshJobSubmissionResource sshJobSubmissionResource = (SshJobSubmissionResource) AppCatalogJPAUtils.getResource(AppCatalogResourceType.SSH_JOB_SUBMISSION, sshJobSubmission); - sshJobSubmissionResourceIDs.add(sshJobSubmissionResource.getJobSubmissionInterfaceId()); - } - } else { - em.getTransaction().commit(); - em.close(); - logger.error("Unsupported field name for Ssh Job Submission Resource.", new IllegalArgumentException()); - throw new IllegalArgumentException("Unsupported field name for Ssh Job Submission 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 sshJobSubmissionResourceIDs; - } - - @Override - public void save() throws AppCatalogException { - EntityManager em = null; - try { - em = AppCatalogJPAUtils.getEntityManager(); - SshJobSubmission existingSshJobSubmission = em.find(SshJobSubmission.class, jobSubmissionInterfaceId); - em.close(); - SshJobSubmission sshJobSubmission; - em = AppCatalogJPAUtils.getEntityManager(); - em.getTransaction().begin(); - if (existingSshJobSubmission == null) { - sshJobSubmission = new SshJobSubmission(); - sshJobSubmission.setCreationTime(AiravataUtils.getCurrentTimestamp()); - } else { - sshJobSubmission = existingSshJobSubmission; - sshJobSubmission.setUpdateTime(AiravataUtils.getCurrentTimestamp()); - } - sshJobSubmission.setResourceJobManagerId(getResourceJobManagerId()); - ResourceJobManager resourceJobManager = em.find(ResourceJobManager.class, getResourceJobManagerId()); - sshJobSubmission.setResourceJobManager(resourceJobManager); - sshJobSubmission.setJobSubmissionInterfaceId(getJobSubmissionInterfaceId()); - sshJobSubmission.setAlternativeSshHostname(getAlternativeSshHostname()); - sshJobSubmission.setSecurityProtocol(getSecurityProtocol()); - sshJobSubmission.setSshPort(getSshPort()); - sshJobSubmission.setMonitorMode(getMonitorMode()); - if (existingSshJobSubmission == null) { - em.persist(sshJobSubmission); - } else { - em.merge(sshJobSubmission); - } - 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(); - SshJobSubmission sshJobSubmission = em.find(SshJobSubmission.class, identifier); - em.close(); - return sshJobSubmission != 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 getResourceJobManagerId() { - return resourceJobManagerId; - } - - public ResourceJobManagerResource getResourceJobManagerResource() { - return resourceJobManagerResource; - } - - public String getJobSubmissionInterfaceId() { - return jobSubmissionInterfaceId; - } - - public String getAlternativeSshHostname() { - return alternativeSshHostname; - } - - public String getSecurityProtocol() { - return securityProtocol; - } - - public int getSshPort() { - return sshPort; - } - - public void setResourceJobManagerId(String resourceJobManagerId) { - this.resourceJobManagerId=resourceJobManagerId; - } - - public void setResourceJobManagerResource(ResourceJobManagerResource resourceJobManagerResource) { - this.resourceJobManagerResource=resourceJobManagerResource; - } - - public void setJobSubmissionInterfaceId(String jobSubmissionInterfaceId) { - this.jobSubmissionInterfaceId=jobSubmissionInterfaceId; - } - - public void setAlternativeSshHostname(String alternativeSshHostname) { - this.alternativeSshHostname=alternativeSshHostname; - } - - public void setSecurityProtocol(String securityProtocol) { - this.securityProtocol=securityProtocol; - } - - public void setSshPort(int sshPort) { - this.sshPort=sshPort; - } - - public String getMonitorMode() { - return monitorMode; - } - - public void setMonitorMode(String monitorMode) { - this.monitorMode = monitorMode; - } - -} \ No newline at end of file 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/UnicoreDataMovementResource.java ---------------------------------------------------------------------- diff --git a/modules/app-catalog/app-catalog-data/src/main/java/org/apache/aiaravata/application/catalog/data/resources/UnicoreDataMovementResource.java b/modules/app-catalog/app-catalog-data/src/main/java/org/apache/aiaravata/application/catalog/data/resources/UnicoreDataMovementResource.java deleted file mode 100644 index 63f2b70..0000000 --- a/modules/app-catalog/app-catalog-data/src/main/java/org/apache/aiaravata/application/catalog/data/resources/UnicoreDataMovementResource.java +++ /dev/null @@ -1,255 +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.UnicoreDataMovement; -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.slf4j.Logger; -import org.slf4j.LoggerFactory; - -import javax.persistence.EntityManager; -import javax.persistence.Query; -import java.util.ArrayList; -import java.util.List; - -public class UnicoreDataMovementResource extends AbstractResource { - - private final static Logger logger = LoggerFactory.getLogger(UnicoreDataMovementResource.class); - - private String dataMovementId; - private String securityProtocol; - private String unicoreEndpointUrl; - - public void remove(Object identifier) throws AppCatalogException { - EntityManager em = null; - try { - em = AppCatalogJPAUtils.getEntityManager(); - em.getTransaction().begin(); - AppCatalogQueryGenerator generator = new AppCatalogQueryGenerator(UNICORE_DATA_MOVEMENT); - generator.setParameter(UnicoreDataMovementConstants.DATAMOVEMENT_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(); - } - } - } - - public Resource get(Object identifier) throws AppCatalogException { - EntityManager em = null; - try { - em = AppCatalogJPAUtils.getEntityManager(); - em.getTransaction().begin(); - AppCatalogQueryGenerator generator = new AppCatalogQueryGenerator(UNICORE_DATA_MOVEMENT); - generator.setParameter(UnicoreDataMovementConstants.DATAMOVEMENT_ID, identifier); - Query q = generator.selectQuery(em); - UnicoreDataMovement unicoreDataMovement = (UnicoreDataMovement) q.getSingleResult(); - UnicoreDataMovementResource dataMovementResource = - (UnicoreDataMovementResource) AppCatalogJPAUtils - .getResource(AppCatalogResourceType.UNICORE_DATA_MOVEMENT, - unicoreDataMovement); - em.getTransaction().commit(); - em.close(); - return dataMovementResource; - } 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 List<Resource> get(String fieldName, Object value) throws AppCatalogException { - List<Resource> unicoreDMResourceList = new ArrayList<Resource>(); - EntityManager em = null; - try { - em = AppCatalogJPAUtils.getEntityManager(); - em.getTransaction().begin(); - Query q; - AppCatalogQueryGenerator generator = new AppCatalogQueryGenerator(UNICORE_DATA_MOVEMENT); - List results; - if (fieldName.equals(UnicoreDataMovementConstants.UNICORE_ENDPOINT_URL)) { - generator.setParameter(UnicoreDataMovementConstants.UNICORE_ENDPOINT_URL, value); - q = generator.selectQuery(em); - results = q.getResultList(); - if (results.size() != 0) { - for (Object result : results) { - UnicoreDataMovement dataMovement = (UnicoreDataMovement) result; - UnicoreDataMovementResource unicoreJobSubmissionResource = - (UnicoreDataMovementResource) AppCatalogJPAUtils.getResource( - AppCatalogResourceType.UNICORE_DATA_MOVEMENT, dataMovement); - unicoreDMResourceList.add(unicoreJobSubmissionResource); - } - } - } else if (fieldName.equals(UnicoreDataMovementConstants.SECURITY_PROTOCAL)) { - generator.setParameter(UnicoreDataMovementConstants.SECURITY_PROTOCAL, value); - q = generator.selectQuery(em); - results = q.getResultList(); - if (results.size() != 0) { - for (Object result : results) { - UnicoreDataMovement dataMovement = (UnicoreDataMovement) result; - UnicoreDataMovementResource dataMovementResource = - (UnicoreDataMovementResource) AppCatalogJPAUtils.getResource( - AppCatalogResourceType.UNICORE_DATA_MOVEMENT, dataMovement); - unicoreDMResourceList.add(dataMovementResource); - } - } - } else { - em.getTransaction().commit(); - em.close(); - logger.error("Unsupported field name for Unicore data movement resource.", new IllegalArgumentException()); - throw new IllegalArgumentException("Unsupported field name for Unicore data movement resource."); - } - 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 unicoreDMResourceList; - } - - @Override - public List<Resource> getAll() throws AppCatalogException { - // TODO Auto-generated method stub - return null; - } - - @Override - public List<String> getAllIds() throws AppCatalogException { - // TODO Auto-generated method stub - return null; - } - - public List<String> getIds(String fieldName, Object value) throws AppCatalogException { - return null; - } - - public void save() throws AppCatalogException { - EntityManager em = null; - try { - em = AppCatalogJPAUtils.getEntityManager(); - UnicoreDataMovement existingDataMovement = em.find(UnicoreDataMovement.class, dataMovementId); - em.close(); - - em = AppCatalogJPAUtils.getEntityManager(); - em.getTransaction().begin(); - if (existingDataMovement != null) { - existingDataMovement.setDataMovementId(dataMovementId);; - existingDataMovement.setUnicoreEndpointUrl(unicoreEndpointUrl); - existingDataMovement.setSecurityProtocol(securityProtocol); - em.merge(existingDataMovement); - } else { - UnicoreDataMovement unicoreJobSubmission = new UnicoreDataMovement(); - unicoreJobSubmission.setDataMovementId(dataMovementId); - unicoreJobSubmission.setUnicoreEndpointUrl(unicoreEndpointUrl); - unicoreJobSubmission.setSecurityProtocol(securityProtocol); - em.persist(unicoreJobSubmission); - } - 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(); - } - } - } - - public boolean isExists(Object identifier) throws AppCatalogException { - EntityManager em = null; - try { - em = AppCatalogJPAUtils.getEntityManager(); - UnicoreDataMovement dataMovement = em.find(UnicoreDataMovement.class, identifier); - em.close(); - return dataMovement != 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 getDataMovementId() { - return dataMovementId; - } - - public void setDataMovementId(String dataMovementId) { - this.dataMovementId = dataMovementId; - } - - public String getSecurityProtocol() { - return securityProtocol; - } - - public void setSecurityProtocol(String securityProtocol) { - this.securityProtocol = securityProtocol; - } - - public String getUnicoreEndpointUrl() { - return unicoreEndpointUrl; - } - - public void setUnicoreEndpointUrl(String unicoreEndpointUrl) { - this.unicoreEndpointUrl = unicoreEndpointUrl; - } - - -} 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/UnicoreJobSubmissionResource.java ---------------------------------------------------------------------- diff --git a/modules/app-catalog/app-catalog-data/src/main/java/org/apache/aiaravata/application/catalog/data/resources/UnicoreJobSubmissionResource.java b/modules/app-catalog/app-catalog-data/src/main/java/org/apache/aiaravata/application/catalog/data/resources/UnicoreJobSubmissionResource.java deleted file mode 100644 index 4c772e1..0000000 --- a/modules/app-catalog/app-catalog-data/src/main/java/org/apache/aiaravata/application/catalog/data/resources/UnicoreJobSubmissionResource.java +++ /dev/null @@ -1,328 +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 java.util.ArrayList; -import java.util.HashMap; -import java.util.List; - -import javax.persistence.EntityManager; -import javax.persistence.Query; - -import org.airavata.appcatalog.cpi.AppCatalogException; -import org.apache.aiaravata.application.catalog.data.model.GlobusJobSubmission; -import org.apache.aiaravata.application.catalog.data.model.UnicoreJobSubmission; -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.slf4j.Logger; -import org.slf4j.LoggerFactory; - -public class UnicoreJobSubmissionResource extends AbstractResource { - - private final static Logger logger = LoggerFactory.getLogger(UnicoreJobSubmissionResource.class); - - private String jobSubmissionInterfaceId; - private String securityProtocol; - private String unicoreEndpointUrl; - - public void remove(Object identifier) throws AppCatalogException { - EntityManager em = null; - try { - em = AppCatalogJPAUtils.getEntityManager(); - em.getTransaction().begin(); - AppCatalogQueryGenerator generator = new AppCatalogQueryGenerator(UNICORE_JOB_SUBMISSION); - generator.setParameter(UnicoreJobSubmissionConstants.SUBMISSION_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(); - } - } - } - - public Resource get(Object identifier) throws AppCatalogException { - HashMap<String, String> ids; - EntityManager em = null; - try { - em = AppCatalogJPAUtils.getEntityManager(); - em.getTransaction().begin(); - AppCatalogQueryGenerator generator = new AppCatalogQueryGenerator(UNICORE_JOB_SUBMISSION); - generator.setParameter(UnicoreJobSubmissionConstants.SUBMISSION_ID, identifier); - Query q = generator.selectQuery(em); - UnicoreJobSubmission unicoreJobSubmission = (UnicoreJobSubmission) q.getSingleResult(); - UnicoreJobSubmissionResource unicoreSubmissionResource = - (UnicoreJobSubmissionResource) AppCatalogJPAUtils - .getResource(AppCatalogResourceType.UNICORE_JOB_SUBMISSION, - unicoreJobSubmission); - em.getTransaction().commit(); - em.close(); - return unicoreSubmissionResource; - } 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 List<Resource> get(String fieldName, Object value) throws AppCatalogException { - List<Resource> unicoreSubmissionResourceList = new ArrayList<Resource>(); - EntityManager em = null; - try { - em = AppCatalogJPAUtils.getEntityManager(); - em.getTransaction().begin(); - Query q; - AppCatalogQueryGenerator generator = new AppCatalogQueryGenerator(UNICORE_JOB_SUBMISSION); - List results; - if (fieldName.equals(UnicoreJobSubmissionConstants.UNICORE_ENDPOINT_URL)) { - generator.setParameter(UnicoreJobSubmissionConstants.UNICORE_ENDPOINT_URL, value); - q = generator.selectQuery(em); - results = q.getResultList(); - if (results.size() != 0) { - for (Object result : results) { - UnicoreJobSubmission unicoreJobSubmission = (UnicoreJobSubmission) result; - UnicoreJobSubmissionResource unicoreJobSubmissionResource = - (UnicoreJobSubmissionResource) AppCatalogJPAUtils.getResource( - AppCatalogResourceType.UNICORE_JOB_SUBMISSION, unicoreJobSubmission); - unicoreSubmissionResourceList.add(unicoreJobSubmissionResource); - } - } - } else if (fieldName.equals(UnicoreJobSubmissionConstants.SECURITY_PROTOCAL)) { - generator.setParameter(UnicoreJobSubmissionConstants.SECURITY_PROTOCAL, value); - q = generator.selectQuery(em); - results = q.getResultList(); - if (results.size() != 0) { - for (Object result : results) { - UnicoreJobSubmission unicoreJobSubmission = (UnicoreJobSubmission) result; - UnicoreJobSubmissionResource unicoreJobSubmissionResource = - (UnicoreJobSubmissionResource) AppCatalogJPAUtils.getResource( - AppCatalogResourceType.UNICORE_JOB_SUBMISSION, unicoreJobSubmission); - unicoreSubmissionResourceList.add(unicoreJobSubmissionResource); - } - } - } - else { - em.getTransaction().commit(); - em.close(); - logger.error("Unsupported field name for Unicore submission resource.", new IllegalArgumentException()); - throw new IllegalArgumentException("Unsupported field name for Unicore Submission resource."); - } - 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 unicoreSubmissionResourceList; - } - - @Override - public List<Resource> getAll() throws AppCatalogException { - // TODO Auto-generated method stub - return null; - } - - @Override - public List<String> getAllIds() throws AppCatalogException { - // TODO Auto-generated method stub - return null; - } - - public List<String> getIds(String fieldName, Object value) throws AppCatalogException { - List<String> globusSubmissionResourceIDs = new ArrayList<String>(); - EntityManager em = null; - try { - em = AppCatalogJPAUtils.getEntityManager(); - em.getTransaction().begin(); - Query q; - AppCatalogQueryGenerator generator = new AppCatalogQueryGenerator(GLOBUS_SUBMISSION); - List results; - if (fieldName.equals(GlobusJobSubmissionConstants.SUBMISSION_ID)) { - generator.setParameter(GlobusJobSubmissionConstants.SUBMISSION_ID, value); - q = generator.selectQuery(em); - results = q.getResultList(); - if (results.size() != 0) { - for (Object result : results) { - GlobusJobSubmission globusJobSubmission = (GlobusJobSubmission) result; - globusSubmissionResourceIDs.add(globusJobSubmission.getSubmissionID()); - } - } - } else if (fieldName.equals(GlobusJobSubmissionConstants.GLOBUS_GATEKEEPER_EP)) { - generator.setParameter(GlobusJobSubmissionConstants.GLOBUS_GATEKEEPER_EP, value); - q = generator.selectQuery(em); - results = q.getResultList(); - if (results.size() != 0) { - for (Object result : results) { - GlobusJobSubmission globusJobSubmission = (GlobusJobSubmission) result; - globusSubmissionResourceIDs.add(globusJobSubmission.getSubmissionID()); - } - } - } - else if (fieldName.equals(GlobusJobSubmissionConstants.SECURITY_PROTOCAL)) { - generator.setParameter(GlobusJobSubmissionConstants.SECURITY_PROTOCAL, value); - q = generator.selectQuery(em); - results = q.getResultList(); - if (results.size() != 0) { - for (Object result : results) { - GlobusJobSubmission globusJobSubmission = (GlobusJobSubmission) result; - globusSubmissionResourceIDs.add(globusJobSubmission.getSubmissionID()); - } - } - } else if (fieldName.equals(GlobusJobSubmissionConstants.RESOURCE_JOB_MANAGER)) { - generator.setParameter(GlobusJobSubmissionConstants.RESOURCE_JOB_MANAGER, value); - q = generator.selectQuery(em); - results = q.getResultList(); - if (results.size() != 0) { - for (Object result : results) { - GlobusJobSubmission globusJobSubmission = (GlobusJobSubmission) result; - globusSubmissionResourceIDs.add(globusJobSubmission.getSubmissionID()); - } - } - } else { - em.getTransaction().commit(); - em.close(); - logger.error("Unsupported field name for Globus Submission resource.", new IllegalArgumentException()); - throw new IllegalArgumentException("Unsupported field name for Globus Submission resource."); - } - 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 globusSubmissionResourceIDs; - } - - public void save() throws AppCatalogException { - EntityManager em = null; - try { - em = AppCatalogJPAUtils.getEntityManager(); - UnicoreJobSubmission existingUnicoreSubmission = em.find(UnicoreJobSubmission.class, jobSubmissionInterfaceId); - em.close(); - - em = AppCatalogJPAUtils.getEntityManager(); - em.getTransaction().begin(); - if (existingUnicoreSubmission != null) { - existingUnicoreSubmission.setSubmissionID(jobSubmissionInterfaceId);; - existingUnicoreSubmission.setUnicoreEndpointUrl(unicoreEndpointUrl); - existingUnicoreSubmission.setSecurityProtocol(securityProtocol); - - em.merge(existingUnicoreSubmission); - } else { - UnicoreJobSubmission unicoreJobSubmission = new UnicoreJobSubmission(); - unicoreJobSubmission.setSubmissionID(jobSubmissionInterfaceId); - unicoreJobSubmission.setUnicoreEndpointUrl(unicoreEndpointUrl); - unicoreJobSubmission.setSecurityProtocol(securityProtocol); - em.persist(unicoreJobSubmission); - } - 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(); - } - } - } - - public boolean isExists(Object identifier) throws AppCatalogException { - EntityManager em = null; - try { - em = AppCatalogJPAUtils.getEntityManager(); - UnicoreJobSubmission unicoreJobSubmission = em.find(UnicoreJobSubmission.class, identifier); - em.close(); - return unicoreJobSubmission != 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 getjobSubmissionInterfaceId() { - return jobSubmissionInterfaceId; - } - - public void setjobSubmissionInterfaceId(String jobSubmissionInterfaceId) { - this.jobSubmissionInterfaceId = jobSubmissionInterfaceId; - } - - public String getSecurityProtocol() { - return securityProtocol; - } - - public void setSecurityProtocol(String securityProtocol) { - this.securityProtocol = securityProtocol; - } - - public String getUnicoreEndpointUrl() { - return unicoreEndpointUrl; - } - - public void setUnicoreEndpointUrl(String unicoreEndpointUrl) { - this.unicoreEndpointUrl = unicoreEndpointUrl; - } - -} 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/WorkflowInputResource.java ---------------------------------------------------------------------- diff --git a/modules/app-catalog/app-catalog-data/src/main/java/org/apache/aiaravata/application/catalog/data/resources/WorkflowInputResource.java b/modules/app-catalog/app-catalog-data/src/main/java/org/apache/aiaravata/application/catalog/data/resources/WorkflowInputResource.java deleted file mode 100644 index ac22744..0000000 --- a/modules/app-catalog/app-catalog-data/src/main/java/org/apache/aiaravata/application/catalog/data/resources/WorkflowInputResource.java +++ /dev/null @@ -1,451 +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.model.WorkflowInput; -import org.apache.aiaravata.application.catalog.data.model.WorkflowInput_PK; -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.slf4j.Logger; -import org.slf4j.LoggerFactory; - -import javax.persistence.EntityManager; -import javax.persistence.Query; -import java.util.ArrayList; -import java.util.HashMap; -import java.util.List; -import java.util.Map; - -public class WorkflowInputResource extends AbstractResource { - - private final static Logger logger = LoggerFactory.getLogger(WorkflowInputResource.class); - - private String wfTemplateId; - private String inputKey; - private String dataType; - private String inputVal; - private String metadata; - private String appArgument; - private String userFriendlyDesc; - private boolean standardInput; - private int inputOrder; - private boolean isRequired; - private boolean requiredToCMD; - private boolean dataStaged; - - private WorkflowResource workflowResource; - - public void remove(Object identifier) throws AppCatalogException { - HashMap<String, String> ids; - if (identifier instanceof Map) { - ids = (HashMap) identifier; - } else { - logger.error("Identifier should be a map with the field name and it's value"); - throw new AppCatalogException("Identifier should be a map with the field name and it's value"); - } - - EntityManager em = null; - try { - em = AppCatalogJPAUtils.getEntityManager(); - em.getTransaction().begin(); - AppCatalogQueryGenerator generator = new AppCatalogQueryGenerator(WORKFLOW_INPUT); - generator.setParameter(WFInputConstants.WF_TEMPLATE_ID, ids.get(WFInputConstants.WF_TEMPLATE_ID)); - generator.setParameter(WFInputConstants.INPUT_KEY, ids.get(WFInputConstants.INPUT_KEY)); - 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(); - } - } - } - - public Resource get(Object identifier) throws AppCatalogException { - HashMap<String, String> ids; - if (identifier instanceof Map) { - ids = (HashMap<String, String>) identifier; - } else { - logger.error("Identifier should be a map with the field name and it's value"); - throw new AppCatalogException("Identifier should be a map with the field name and it's value"); - } - - EntityManager em = null; - try { - em = AppCatalogJPAUtils.getEntityManager(); - em.getTransaction().begin(); - AppCatalogQueryGenerator generator = new AppCatalogQueryGenerator(WORKFLOW_INPUT); - generator.setParameter(WFInputConstants.WF_TEMPLATE_ID, ids.get(WFInputConstants.WF_TEMPLATE_ID)); - generator.setParameter(WFInputConstants.INPUT_KEY, ids.get(WFInputConstants.INPUT_KEY)); - Query q = generator.selectQuery(em); - WorkflowInput workflowInput = (WorkflowInput) q.getSingleResult(); - WorkflowInputResource workflowInputResource = - (WorkflowInputResource) AppCatalogJPAUtils.getResource(AppCatalogResourceType.WORKFLOW_INPUT - , workflowInput); - em.getTransaction().commit(); - em.close(); - return workflowInputResource; - } 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 List<Resource> get(String fieldName, Object value) throws AppCatalogException { - List<Resource> wfInputResources = new ArrayList<Resource>(); - EntityManager em = null; - try { - em = AppCatalogJPAUtils.getEntityManager(); - em.getTransaction().begin(); - Query q; - AppCatalogQueryGenerator generator = new AppCatalogQueryGenerator(WORKFLOW_INPUT); - List results; - if (fieldName.equals(WFInputConstants.WF_TEMPLATE_ID)) { - generator.setParameter(WFInputConstants.WF_TEMPLATE_ID, value); - q = generator.selectQuery(em); - results = q.getResultList(); - if (results.size() != 0) { - for (Object result : results) { - WorkflowInput workflowInput = (WorkflowInput) result; - WorkflowInputResource workflowInputResource = - (WorkflowInputResource) AppCatalogJPAUtils.getResource( - AppCatalogResourceType.WORKFLOW_INPUT, workflowInput); - wfInputResources.add(workflowInputResource); - } - } - } else if (fieldName.equals(WFInputConstants.INPUT_KEY)) { - generator.setParameter(WFInputConstants.INPUT_KEY, value); - q = generator.selectQuery(em); - results = q.getResultList(); - if (results.size() != 0) { - for (Object result : results) { - WorkflowInput workflowInput = (WorkflowInput) result; - WorkflowInputResource workflowInputResource = - (WorkflowInputResource) AppCatalogJPAUtils.getResource( - AppCatalogResourceType.WORKFLOW_INPUT, workflowInput); - wfInputResources.add(workflowInputResource); - } - } - } else if (fieldName.equals(WFInputConstants.DATA_TYPE)) { - generator.setParameter(WFInputConstants.DATA_TYPE, value); - q = generator.selectQuery(em); - results = q.getResultList(); - if (results.size() != 0) { - for (Object result : results) { - WorkflowInput workflowInput = (WorkflowInput) result; - WorkflowInputResource workflowInputResource = - (WorkflowInputResource) AppCatalogJPAUtils.getResource( - AppCatalogResourceType.WORKFLOW_INPUT, workflowInput); - wfInputResources.add(workflowInputResource); - } - } - } else { - em.getTransaction().commit(); - em.close(); - logger.error("Unsupported field name for WFInput Resource.", new IllegalArgumentException()); - throw new IllegalArgumentException("Unsupported field name for WFInput Resource."); - } - 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 wfInputResources; - } - - public List<Resource> getAll() throws AppCatalogException { - return null; - } - - public List<String> getAllIds() throws AppCatalogException { - return null; - } - - public List<String> getIds(String fieldName, Object value) throws AppCatalogException { - List<String> wfInputResourceIDs = new ArrayList<String>(); - EntityManager em = null; - try { - em = AppCatalogJPAUtils.getEntityManager(); - em.getTransaction().begin(); - Query q; - AppCatalogQueryGenerator generator = new AppCatalogQueryGenerator(WORKFLOW_INPUT); - List results; - if (fieldName.equals(WFInputConstants.WF_TEMPLATE_ID)) { - generator.setParameter(WFInputConstants.WF_TEMPLATE_ID, value); - q = generator.selectQuery(em); - results = q.getResultList(); - if (results.size() != 0) { - for (Object result : results) { - WorkflowInput workflowInput = (WorkflowInput) result; - wfInputResourceIDs.add(workflowInput.getWfTemplateId()); - } - } - } else if (fieldName.equals(WFInputConstants.INPUT_KEY)) { - generator.setParameter(WFInputConstants.INPUT_KEY, value); - q = generator.selectQuery(em); - results = q.getResultList(); - if (results.size() != 0) { - for (Object result : results) { - WorkflowInput workflowInput = (WorkflowInput) result; - wfInputResourceIDs.add(workflowInput.getWfTemplateId()); - } - } - } else if (fieldName.equals(WFInputConstants.DATA_TYPE)) { - generator.setParameter(WFInputConstants.DATA_TYPE, value); - q = generator.selectQuery(em); - results = q.getResultList(); - if (results.size() != 0) { - for (Object result : results) { - WorkflowInput workflowInput = (WorkflowInput) result; - wfInputResourceIDs.add(workflowInput.getWfTemplateId()); - } - } - } else { - em.getTransaction().commit(); - em.close(); - logger.error("Unsupported field name for WFInput resource.", new IllegalArgumentException()); - throw new IllegalArgumentException("Unsupported field name for WFInput Resource."); - } - 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 wfInputResourceIDs; - } - - public void save() throws AppCatalogException { - EntityManager em = null; - try { - em = AppCatalogJPAUtils.getEntityManager(); - WorkflowInput existingWFInput = em.find(WorkflowInput.class, new WorkflowInput_PK(wfTemplateId, inputKey)); - em.close(); - WorkflowInput workflowInput; - em = AppCatalogJPAUtils.getEntityManager(); - em.getTransaction().begin(); - if (existingWFInput == null) { - workflowInput = new WorkflowInput(); - } else { - workflowInput=existingWFInput; - } - workflowInput.setWfTemplateId(wfTemplateId); - Workflow workflow = em.find(Workflow.class, wfTemplateId); - workflowInput.setWorkflow(workflow); - workflowInput.setDataType(dataType); - workflowInput.setInputKey(inputKey); - if (inputVal != null){ - workflowInput.setInputVal(inputVal.toCharArray()); - } - workflowInput.setMetadata(metadata); - workflowInput.setAppArgument(appArgument); - workflowInput.setUserFriendlyDesc(userFriendlyDesc); - workflowInput.setStandardInput(standardInput); - workflowInput.setRequiredToCMD(requiredToCMD); - workflowInput.setRequired(isRequired); - workflowInput.setDataStaged(dataStaged); - if (existingWFInput == null) { - em.persist(workflowInput); - } else { - em.merge(workflowInput); - } - 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(); - } - } - } - - public boolean isExists(Object identifier) throws AppCatalogException { - HashMap<String, String> ids; - if (identifier instanceof Map) { - ids = (HashMap<String, String>) identifier; - } else { - logger.error("Identifier should be a map with the field name and it's value"); - throw new AppCatalogException("Identifier should be a map with the field name and it's value"); - } - - EntityManager em = null; - try { - em = AppCatalogJPAUtils.getEntityManager(); - WorkflowInput workflowInput = em.find(WorkflowInput.class, new WorkflowInput_PK( - ids.get(WFInputConstants.WF_TEMPLATE_ID), - ids.get(WFInputConstants.INPUT_KEY))); - - em.close(); - return workflowInput != 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 getWfTemplateId() { - return wfTemplateId; - } - - public void setWfTemplateId(String wfTemplateId) { - this.wfTemplateId = wfTemplateId; - } - - public String getInputKey() { - return inputKey; - } - - public void setInputKey(String inputKey) { - this.inputKey = inputKey; - } - - public String getDataType() { - return dataType; - } - - public void setDataType(String dataType) { - this.dataType = dataType; - } - - public String getInputVal() { - return inputVal; - } - - public void setInputVal(String inputVal) { - this.inputVal = inputVal; - } - - public String getMetadata() { - return metadata; - } - - public void setMetadata(String metadata) { - this.metadata = metadata; - } - - public String getAppArgument() { - return appArgument; - } - - public void setAppArgument(String appArgument) { - this.appArgument = appArgument; - } - - public String getUserFriendlyDesc() { - return userFriendlyDesc; - } - - public void setUserFriendlyDesc(String userFriendlyDesc) { - this.userFriendlyDesc = userFriendlyDesc; - } - - public WorkflowResource getWorkflowResource() { - return workflowResource; - } - - public void setWorkflowResource(WorkflowResource workflowResource) { - this.workflowResource = workflowResource; - } - - public boolean isStandardInput() { - return standardInput; - } - - public void setStandardInput(boolean standardInput) { - this.standardInput = standardInput; - } - - public int getInputOrder() { - return inputOrder; - } - - public void setInputOrder(int inputOrder) { - this.inputOrder = inputOrder; - } - - public boolean getRequired() { - return isRequired; - } - - public void setRequired(boolean required) { - this.isRequired = required; - } - - public boolean getRequiredToCMD() { - return requiredToCMD; - } - - public void setRequiredToCMD(boolean requiredToCMD) { - this.requiredToCMD = requiredToCMD; - } - - public boolean isDataStaged() { - return dataStaged; - } - - public void setDataStaged(boolean dataStaged) { - this.dataStaged = dataStaged; - } -} 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/WorkflowOutputResource.java ---------------------------------------------------------------------- diff --git a/modules/app-catalog/app-catalog-data/src/main/java/org/apache/aiaravata/application/catalog/data/resources/WorkflowOutputResource.java b/modules/app-catalog/app-catalog-data/src/main/java/org/apache/aiaravata/application/catalog/data/resources/WorkflowOutputResource.java deleted file mode 100644 index 7f180bd..0000000 --- a/modules/app-catalog/app-catalog-data/src/main/java/org/apache/aiaravata/application/catalog/data/resources/WorkflowOutputResource.java +++ /dev/null @@ -1,410 +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.model.WorkflowOutput; -import org.apache.aiaravata.application.catalog.data.model.WorkflowOutput_PK; -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.slf4j.Logger; -import org.slf4j.LoggerFactory; - -import javax.persistence.EntityManager; -import javax.persistence.Query; -import java.util.ArrayList; -import java.util.HashMap; -import java.util.List; -import java.util.Map; - -public class WorkflowOutputResource extends AbstractResource { - private final static Logger logger = LoggerFactory.getLogger(WorkflowOutputResource.class); - - private String wfTemplateId; - private String outputKey; - private String outputVal; - private String dataType; - private String validityType; - private boolean dataMovement; - private String dataNameLocation; - - private WorkflowResource workflowResource; - - public void remove(Object identifier) throws AppCatalogException { - HashMap<String, String> ids; - if (identifier instanceof Map) { - ids = (HashMap) identifier; - } else { - logger.error("Identifier should be a map with the field name and it's value"); - throw new AppCatalogException("Identifier should be a map with the field name and it's value"); - } - - EntityManager em = null; - try { - em = AppCatalogJPAUtils.getEntityManager(); - em.getTransaction().begin(); - AppCatalogQueryGenerator generator = new AppCatalogQueryGenerator(WORKFLOW_OUTPUT); - generator.setParameter(WFOutputConstants.WF_TEMPLATE_ID, ids.get(WFOutputConstants.WF_TEMPLATE_ID)); - generator.setParameter(WFOutputConstants.OUTPUT_KEY, ids.get(WFOutputConstants.OUTPUT_KEY)); - 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(); - } - } - } - - public Resource get(Object identifier) throws AppCatalogException { - HashMap<String, String> ids; - if (identifier instanceof Map) { - ids = (HashMap) identifier; - } else { - logger.error("Identifier should be a map with the field name and it's value"); - throw new AppCatalogException("Identifier should be a map with the field name and it's value"); - } - - EntityManager em = null; - try { - em = AppCatalogJPAUtils.getEntityManager(); - em.getTransaction().begin(); - AppCatalogQueryGenerator generator = new AppCatalogQueryGenerator(WORKFLOW_OUTPUT); - generator.setParameter(WFOutputConstants.WF_TEMPLATE_ID, ids.get(WFOutputConstants.WF_TEMPLATE_ID)); - generator.setParameter(WFOutputConstants.OUTPUT_KEY, ids.get(WFOutputConstants.OUTPUT_KEY)); - Query q = generator.selectQuery(em); - WorkflowOutput wfOutput = (WorkflowOutput) q.getSingleResult(); - WorkflowOutputResource workflowOutputResource = - (WorkflowOutputResource) AppCatalogJPAUtils.getResource(AppCatalogResourceType.WORKFLOW_OUTPUT - , wfOutput); - em.getTransaction().commit(); - em.close(); - return workflowOutputResource; - } 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 List<Resource> get(String fieldName, Object value) throws AppCatalogException { - List<Resource> wfOutputResources = new ArrayList<Resource>(); - EntityManager em = null; - try { - em = AppCatalogJPAUtils.getEntityManager(); - em.getTransaction().begin(); - Query q; - AppCatalogQueryGenerator generator = new AppCatalogQueryGenerator(WORKFLOW_OUTPUT); - List results; - if (fieldName.equals(WFOutputConstants.WF_TEMPLATE_ID)) { - generator.setParameter(WFOutputConstants.WF_TEMPLATE_ID, value); - q = generator.selectQuery(em); - results = q.getResultList(); - if (results.size() != 0) { - for (Object result : results) { - WorkflowOutput wfOutput = (WorkflowOutput) result; - WorkflowOutputResource workflowOutputResource = - (WorkflowOutputResource) AppCatalogJPAUtils.getResource( - AppCatalogResourceType.WORKFLOW_OUTPUT, wfOutput); - wfOutputResources.add(workflowOutputResource); - } - } - } else if (fieldName.equals(WFOutputConstants.OUTPUT_KEY)) { - generator.setParameter(WFOutputConstants.OUTPUT_KEY, value); - q = generator.selectQuery(em); - results = q.getResultList(); - if (results.size() != 0) { - for (Object result : results) { - WorkflowOutput workflowOutput = (WorkflowOutput) result; - WorkflowOutputResource workflowOutputResource = - (WorkflowOutputResource) AppCatalogJPAUtils.getResource( - AppCatalogResourceType.WORKFLOW_OUTPUT, workflowOutput); - wfOutputResources.add(workflowOutputResource); - } - } - } else if (fieldName.equals(WFOutputConstants.DATA_TYPE)) { - generator.setParameter(WFOutputConstants.DATA_TYPE, value); - q = generator.selectQuery(em); - results = q.getResultList(); - if (results.size() != 0) { - for (Object result : results) { - WorkflowOutput workflowOutput = (WorkflowOutput) result; - WorkflowOutputResource workflowOutputResource = - (WorkflowOutputResource) AppCatalogJPAUtils.getResource( - AppCatalogResourceType.WORKFLOW_OUTPUT, workflowOutput); - wfOutputResources.add(workflowOutputResource); - } - } - } else { - em.getTransaction().commit(); - em.close(); - logger.error("Unsupported field name for WF Output Resource.", new IllegalArgumentException()); - throw new IllegalArgumentException("Unsupported field name for WF Output Resource."); - } - 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 wfOutputResources; - } - - public List<Resource> getAll() throws AppCatalogException { - return null; - } - - public List<String> getAllIds() throws AppCatalogException { - return null; - } - - public List<String> getIds(String fieldName, Object value) throws AppCatalogException { - List<String> wfOutputResourceIDs = new ArrayList<String>(); - EntityManager em = null; - try { - em = AppCatalogJPAUtils.getEntityManager(); - em.getTransaction().begin(); - Query q; - AppCatalogQueryGenerator generator = new AppCatalogQueryGenerator(WORKFLOW_OUTPUT); - List results; - if (fieldName.equals(WFOutputConstants.WF_TEMPLATE_ID)) { - generator.setParameter(WFOutputConstants.WF_TEMPLATE_ID, value); - q = generator.selectQuery(em); - results = q.getResultList(); - if (results.size() != 0) { - for (Object result : results) { - WorkflowOutput workflowOutput = (WorkflowOutput) result; - wfOutputResourceIDs.add(workflowOutput.getWfTemplateId()); - } - } - } - if (fieldName.equals(WFOutputConstants.OUTPUT_KEY)) { - generator.setParameter(WFOutputConstants.OUTPUT_KEY, value); - q = generator.selectQuery(em); - results = q.getResultList(); - if (results.size() != 0) { - for (Object result : results) { - WorkflowOutput workflowOutput = (WorkflowOutput) result; - wfOutputResourceIDs.add(workflowOutput.getWfTemplateId()); - } - } - } else if (fieldName.equals(WFOutputConstants.DATA_TYPE)) { - generator.setParameter(WFOutputConstants.DATA_TYPE, value); - q = generator.selectQuery(em); - results = q.getResultList(); - if (results.size() != 0) { - for (Object result : results) { - WorkflowOutput workflowOutput = (WorkflowOutput) result; - wfOutputResourceIDs.add(workflowOutput.getWfTemplateId()); - } - } - } else { - em.getTransaction().commit(); - em.close(); - logger.error("Unsupported field name for WF Output resource.", new IllegalArgumentException()); - throw new IllegalArgumentException("Unsupported field name for WF Output Resource."); - } - 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 wfOutputResourceIDs; - } - - public void save() throws AppCatalogException { - EntityManager em = null; - try { - em = AppCatalogJPAUtils.getEntityManager(); - WorkflowOutput existingWorkflowOutput = em.find(WorkflowOutput.class, - new WorkflowOutput_PK(wfTemplateId, outputKey)); - em.close(); - - em = AppCatalogJPAUtils.getEntityManager(); - em.getTransaction().begin(); - if (existingWorkflowOutput != null) { - existingWorkflowOutput.setWfTemplateId(wfTemplateId); - Workflow workflow = em.find(Workflow.class, wfTemplateId); - existingWorkflowOutput.setWorkflow(workflow); - existingWorkflowOutput.setDataType(dataType); - existingWorkflowOutput.setOutputKey(outputKey); - if (outputVal != null){ - existingWorkflowOutput.setOutputVal(outputVal.toCharArray()); - } - existingWorkflowOutput.setValidityType(validityType); - existingWorkflowOutput.setDataMovement(dataMovement); - existingWorkflowOutput.setDataNameLocation(dataNameLocation); - em.merge(existingWorkflowOutput); - } else { - WorkflowOutput workflowOutput = new WorkflowOutput(); - workflowOutput.setWfTemplateId(wfTemplateId); - Workflow workflow = em.find(Workflow.class, wfTemplateId); - workflowOutput.setWorkflow(workflow); - workflowOutput.setDataType(dataType); - workflowOutput.setOutputKey(outputKey); - if (outputVal != null){ - workflowOutput.setOutputVal(outputVal.toCharArray()); - } - workflowOutput.setValidityType(validityType); - workflowOutput.setDataMovement(dataMovement); - workflowOutput.setDataNameLocation(dataNameLocation); - em.persist(workflowOutput); - } - 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(); - } - } - } - - public boolean isExists(Object identifier) throws AppCatalogException { - HashMap<String, String> ids; - if (identifier instanceof Map) { - ids = (HashMap) identifier; - } else { - logger.error("Identifier should be a map with the field name and it's value"); - throw new AppCatalogException("Identifier should be a map with the field name and it's value"); - } - - EntityManager em = null; - try { - em = AppCatalogJPAUtils.getEntityManager(); - WorkflowOutput workflowOutput = em.find(WorkflowOutput.class, new WorkflowOutput_PK( - ids.get(WFOutputConstants.WF_TEMPLATE_ID), - ids.get(WFOutputConstants.OUTPUT_KEY))); - - em.close(); - return workflowOutput != 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 getWfTemplateId() { - return wfTemplateId; - } - - public void setWfTemplateId(String wfTemplateId) { - this.wfTemplateId = wfTemplateId; - } - - public String getOutputKey() { - return outputKey; - } - - public void setOutputKey(String outputKey) { - this.outputKey = outputKey; - } - - public String getOutputVal() { - return outputVal; - } - - public void setOutputVal(String outputVal) { - this.outputVal = outputVal; - } - - public String getDataType() { - return dataType; - } - - public void setDataType(String dataType) { - this.dataType = dataType; - } - - public WorkflowResource getWorkflowResource() { - return workflowResource; - } - - public void setWorkflowResource(WorkflowResource workflowResource) { - this.workflowResource = workflowResource; - } - - public String getValidityType() { - return validityType; - } - - public void setValidityType(String validityType) { - this.validityType = validityType; - } - - public boolean isDataMovement() { - return dataMovement; - } - - public void setDataMovement(boolean dataMovement) { - this.dataMovement = dataMovement; - } - - public String getDataNameLocation() { - return dataNameLocation; - } - - public void setDataNameLocation(String dataNameLocation) { - this.dataNameLocation = dataNameLocation; - } -}
