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/AppCatalogThriftConversion.java ---------------------------------------------------------------------- diff --git a/modules/app-catalog/app-catalog-data/src/main/java/org/apache/aiaravata/application/catalog/data/util/AppCatalogThriftConversion.java b/modules/app-catalog/app-catalog-data/src/main/java/org/apache/aiaravata/application/catalog/data/util/AppCatalogThriftConversion.java deleted file mode 100644 index 123ae96..0000000 --- a/modules/app-catalog/app-catalog-data/src/main/java/org/apache/aiaravata/application/catalog/data/util/AppCatalogThriftConversion.java +++ /dev/null @@ -1,800 +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.airavata.appcatalog.cpi.AppCatalogException; -import org.apache.aiaravata.application.catalog.data.resources.*; -import org.apache.airavata.model.Workflow; -import org.apache.airavata.model.appcatalog.appdeployment.ApplicationDeploymentDescription; -import org.apache.airavata.model.appcatalog.appdeployment.ApplicationModule; -import org.apache.airavata.model.appcatalog.appdeployment.ApplicationParallelismType; -import org.apache.airavata.model.appcatalog.appdeployment.SetEnvPaths; -import org.apache.airavata.model.appcatalog.appinterface.*; -import org.apache.airavata.model.appcatalog.computeresource.*; -import org.apache.airavata.model.appcatalog.computeresource.BatchQueue; -import org.apache.airavata.model.appcatalog.computeresource.CloudJobSubmission; -import org.apache.airavata.model.appcatalog.computeresource.DataMovementInterface; -import org.apache.airavata.model.appcatalog.computeresource.JobManagerCommand; -import org.apache.airavata.model.appcatalog.computeresource.JobSubmissionInterface; -import org.apache.airavata.model.appcatalog.computeresource.ResourceJobManager; -import org.apache.airavata.model.appcatalog.computeresource.UnicoreDataMovement; -import org.apache.airavata.model.appcatalog.computeresource.UnicoreJobSubmission; -import org.apache.airavata.model.appcatalog.gatewayprofile.ComputeResourcePreference; -import org.apache.airavata.model.appcatalog.gatewayprofile.GatewayResourceProfile; - -import java.util.*; - -public class AppCatalogThriftConversion { - public static ComputeResourceResource getComputeHostResource (ComputeResourceDescription description){ - ComputeResourceResource resource = new ComputeResourceResource(); - resource.setHostName(description.getHostName()); - resource.setResourceDescription(description.getResourceDescription()); - resource.setResourceId(description.getComputeResourceId()); - resource.setMaxMemoryPerNode(description.getMaxMemoryPerNode()); - return resource; - } - - public static ComputeResourceDescription getComputeHostDescription (ComputeResourceResource resource) throws AppCatalogException { - ComputeResourceDescription description = new ComputeResourceDescription(); - description.setComputeResourceId(resource.getResourceId()); - description.setHostName(resource.getHostName()); - description.setResourceDescription(resource.getResourceDescription()); - description.setMaxMemoryPerNode(resource.getMaxMemoryPerNode()); - HostAliasResource aliasResource = new HostAliasResource(); - List<Resource> resources = aliasResource.get(AbstractResource.HostAliasConstants.RESOURCE_ID, resource.getResourceId()); - if (resources != null && !resources.isEmpty()){ - description.setHostAliases(getHostAliases(resources)); - } - HostIPAddressResource ipAddressResource = new HostIPAddressResource(); - List<Resource> ipAddresses = ipAddressResource.get(AbstractResource.HostIPAddressConstants.RESOURCE_ID, resource.getResourceId()); - if (ipAddresses != null && !ipAddresses.isEmpty()){ - description.setIpAddresses(getIpAddresses(ipAddresses)); - } - - BatchQueueResource bqResource = new BatchQueueResource(); - List<Resource> batchQueues = bqResource.get(AbstractResource.BatchQueueConstants.COMPUTE_RESOURCE_ID, resource.getResourceId()); - if (batchQueues != null && !batchQueues.isEmpty()){ - description.setBatchQueues(getBatchQueues(batchQueues)); - } - - ComputeResourceFileSystemResource fsResource = new ComputeResourceFileSystemResource(); - List<Resource> fsList = fsResource.get(AbstractResource.ComputeResourceFileSystemConstants.COMPUTE_RESOURCE_ID, resource.getResourceId()); - description.setFileSystems(new HashMap<FileSystems,String>()); - if (fsList != null && !fsList.isEmpty()){ - for (Resource r : fsList) { - ComputeResourceFileSystemResource rr=(ComputeResourceFileSystemResource)r; - description.getFileSystems().put(FileSystems.valueOf(rr.getFileSystem()), rr.getPath()); - } - } - - JobSubmissionInterfaceResource jsiResource = new JobSubmissionInterfaceResource(); - List<Resource> hsiList = jsiResource.get(AbstractResource.JobSubmissionInterfaceConstants.COMPUTE_RESOURCE_ID, resource.getResourceId()); - if (hsiList != null && !hsiList.isEmpty()){ - description.setJobSubmissionInterfaces(getJobSubmissionInterfaces(hsiList)); - } - - DataMovementInterfaceResource dmiResource = new DataMovementInterfaceResource(); - List<Resource> dmiList = dmiResource.get(AbstractResource.DataMovementInterfaceConstants.COMPUTE_RESOURCE_ID, resource.getResourceId()); - if (dmiList != null && !dmiList.isEmpty()){ - description.setDataMovementInterfaces(getDataMovementInterfaces(dmiList)); - } - return description; - } - - public static List<ComputeResourceDescription> getComputeDescriptionList (List<Resource> resources) throws AppCatalogException { - List<ComputeResourceDescription> list = new ArrayList<ComputeResourceDescription>(); - for (Resource resource : resources){ - list.add(getComputeHostDescription((ComputeResourceResource)resource)); - } - return list; - } - - public static List<String> getHostAliases (List<Resource> resources){ - List<String> hostAliases = new ArrayList<String>(); - for (Resource alias : resources){ - hostAliases.add(((HostAliasResource)alias).getAlias()); - } - return hostAliases; - } - - public static List<String> getIpAddresses (List<Resource> resources){ - List<String> hostIpAddresses = new ArrayList<String>(); - for (Resource resource : resources){ - hostIpAddresses.add(((HostIPAddressResource)resource).getIpaddress()); - } - return hostIpAddresses; - } - - public static List<BatchQueue> getBatchQueues (List<Resource> resources){ - List<BatchQueue> batchQueues = new ArrayList<BatchQueue>(); - for (Resource resource : resources){ - batchQueues.add(getBatchQueue((BatchQueueResource)resource)); - } - return batchQueues; - } - - public static List<DataMovementInterface> getDataMovementInterfaces(List<Resource> resources){ - List<DataMovementInterface> dataMovementInterfaces = new ArrayList<DataMovementInterface>(); - for (Resource resource : resources){ - dataMovementInterfaces.add(getDataMovementInterface((DataMovementInterfaceResource)resource)); - } - return dataMovementInterfaces; - } - - public static DataMovementInterface getDataMovementInterface(DataMovementInterfaceResource resource){ - DataMovementInterface dmi = new DataMovementInterface(); - dmi.setDataMovementInterfaceId(resource.getDataMovementInterfaceId()); - dmi.setDataMovementProtocol(DataMovementProtocol.valueOf(resource.getDataMovementProtocol())); - dmi.setPriorityOrder(resource.getPriorityOrder()); - return dmi; - } - - public static DataMovementInterfaceResource getDataMovementInterface(DataMovementInterface resource){ - DataMovementInterfaceResource dmi = new DataMovementInterfaceResource(); - dmi.setDataMovementInterfaceId(resource.getDataMovementInterfaceId()); - dmi.setDataMovementProtocol(resource.getDataMovementProtocol().toString()); - dmi.setPriorityOrder(resource.getPriorityOrder()); - return dmi; - } - - public static List<JobSubmissionInterface> getJobSubmissionInterfaces(List<Resource> resources){ - List<JobSubmissionInterface> jobSubmissionInterfaces = new ArrayList<JobSubmissionInterface>(); - for (Resource resource : resources){ - jobSubmissionInterfaces.add(getJobSubmissionInterface((JobSubmissionInterfaceResource)resource)); - } - return jobSubmissionInterfaces; - } - - public static JobSubmissionInterface getJobSubmissionInterface(JobSubmissionInterfaceResource resource){ - JobSubmissionInterface jsi = new JobSubmissionInterface(); - jsi.setJobSubmissionInterfaceId(resource.getJobSubmissionInterfaceId()); - jsi.setJobSubmissionProtocol(JobSubmissionProtocol.valueOf(resource.getJobSubmissionProtocol())); - jsi.setPriorityOrder(resource.getPriorityOrder()); - return jsi; - } - - public static JobSubmissionInterfaceResource getJobSubmissionInterface(JobSubmissionInterface resource){ - JobSubmissionInterfaceResource jsi = new JobSubmissionInterfaceResource(); - jsi.setJobSubmissionInterfaceId(resource.getJobSubmissionInterfaceId()); - jsi.setJobSubmissionProtocol(resource.getJobSubmissionProtocol().toString()); - jsi.setPriorityOrder(resource.getPriorityOrder()); - return jsi; - } - - public static BatchQueue getBatchQueue(BatchQueueResource resource){ - BatchQueue batchQueue = new BatchQueue(); - batchQueue.setMaxJobsInQueue(resource.getMaxJobInQueue()); - batchQueue.setMaxNodes(resource.getMaxNodes()); - batchQueue.setMaxProcessors(resource.getMaxProcessors()); - batchQueue.setMaxRunTime(resource.getMaxRuntime()); - batchQueue.setMaxMemory(resource.getMaxMemory()); - batchQueue.setQueueDescription(resource.getQueueDescription()); - batchQueue.setQueueName(resource.getQueueName()); - return batchQueue; - } - - public static BatchQueueResource getBatchQueue(BatchQueue resource){ - BatchQueueResource batchQueue = new BatchQueueResource(); - batchQueue.setMaxJobInQueue(resource.getMaxJobsInQueue()); - batchQueue.setMaxNodes(resource.getMaxNodes()); - batchQueue.setMaxProcessors(resource.getMaxProcessors()); - batchQueue.setMaxRuntime(resource.getMaxRunTime()); - batchQueue.setQueueDescription(resource.getQueueDescription()); - batchQueue.setQueueName(resource.getQueueName()); - batchQueue.setMaxMemory(resource.getMaxMemory()); - return batchQueue; - } - -// public static Map<String, JobSubmissionProtocol> getJobSubmissionProtocolList(List<Resource> resources){ -// Map<String, JobSubmissionProtocol> protocols = new HashMap<String, JobSubmissionProtocol>(); -// for (Resource resource : resources){ -// JobSubmissionProtocolResource submission = (JobSubmissionProtocolResource) resource; -// protocols.put(submission.getSubmissionID(), JobSubmissionProtocol.valueOf(submission.getJobType())); -// } -// return protocols; -// } - -// public static Map<String, DataMovementProtocol> getDataMoveProtocolList(List<Resource> resources){ -// Map<String, DataMovementProtocol> protocols = new HashMap<String, DataMovementProtocol>(); -// for (Resource resource : resources){ -// DataMovementProtocolResource protocolResource = (DataMovementProtocolResource) resource; -// protocols.put(protocolResource.getDataMoveID(), DataMovementProtocol.valueOf(protocolResource.getDataMoveType())); -// } -// return protocols; -// } - - public static SshJobSubmissionResource getSSHJobSubmission (SSHJobSubmission submission){ - SshJobSubmissionResource resource = new SshJobSubmissionResource(); - resource.setAlternativeSshHostname(submission.getAlternativeSSHHostName()); - resource.setJobSubmissionInterfaceId(submission.getJobSubmissionInterfaceId()); - ResourceJobManagerResource resourceJobManager = getResourceJobManager(submission.getResourceJobManager()); -// resourceJobManager.setResourceJobManagerId(submission.getJobSubmissionInterfaceId()); - resource.setResourceJobManagerId(resourceJobManager.getResourceJobManagerId()); - if (submission.getMonitorMode() != null){ - resource.setMonitorMode(submission.getMonitorMode().toString()); - } - resource.setResourceJobManagerResource(resourceJobManager); - if (submission.getSecurityProtocol() != null){ - resource.setSecurityProtocol(submission.getSecurityProtocol().toString()); - } - resource.setSshPort(submission.getSshPort()); - return resource; - } - - - public static UnicoreJobSubmissionResource getUnicoreJobSubmission (UnicoreJobSubmission submission){ - UnicoreJobSubmissionResource resource = new UnicoreJobSubmissionResource(); - resource.setjobSubmissionInterfaceId(submission.getJobSubmissionInterfaceId()); - if (submission.getSecurityProtocol() != null){ - resource.setSecurityProtocol(submission.getSecurityProtocol().toString()); - } - resource.setUnicoreEndpointUrl(submission.getUnicoreEndPointURL()); - return resource; - } - - public static UnicoreDataMovementResource getUnicoreDMResource (UnicoreDataMovement dataMovement){ - UnicoreDataMovementResource resource = new UnicoreDataMovementResource(); - resource.setDataMovementId(dataMovement.getDataMovementInterfaceId()); - if (dataMovement.getSecurityProtocol() != null){ - resource.setSecurityProtocol(dataMovement.getSecurityProtocol().toString()); - } - resource.setUnicoreEndpointUrl(dataMovement.getUnicoreEndPointURL()); - return resource; - } - - - public static CloudSubmissionResource getCloudJobSubmission (CloudJobSubmission submission){ - CloudSubmissionResource resource = new CloudSubmissionResource(); - resource.setJobSubmissionInterfaceId(submission.getJobSubmissionInterfaceId()); - if (submission.getSecurityProtocol() != null){ - resource.setSecurityProtocol(submission.getSecurityProtocol().toString()); - } - if(submission.getProviderName() != null){ - resource.setProviderName(submission.getProviderName().toString()); - } - resource.setUserAccountName(submission.getUserAccountName()); - resource.setNodeId(submission.getNodeId()); - resource.setExecutableType(submission.getExecutableType()); - return resource; - } - - public static LocalDataMovementResource getLocalDataMovement(LOCALDataMovement localSubmission)throws AppCatalogException { - LocalDataMovementResource submission = new LocalDataMovementResource(); - submission.setDataMovementInterfaceId(localSubmission.getDataMovementInterfaceId()); - return submission; - } - - public static LOCALDataMovement getLocalDataMovement(LocalDataMovementResource localSubmission)throws AppCatalogException { - LOCALDataMovement submission = new LOCALDataMovement(); - submission.setDataMovementInterfaceId(localSubmission.getDataMovementInterfaceId()); - return submission; - } - - - public static LocalSubmissionResource getLocalJobSubmission(LOCALSubmission localSubmission)throws AppCatalogException { - LocalSubmissionResource submission = new LocalSubmissionResource(); - submission.setJobSubmissionInterfaceId(localSubmission.getJobSubmissionInterfaceId()); - ResourceJobManagerResource resourceJobManager = getResourceJobManager(localSubmission.getResourceJobManager()); - submission.setResourceJobManagerId(resourceJobManager.getResourceJobManagerId()); - submission.setResourceJobManagerResource(resourceJobManager); - return submission; - } - - public static LOCALSubmission getLocalJobSubmission(LocalSubmissionResource localSubmission)throws AppCatalogException { - LOCALSubmission submission = new LOCALSubmission(); - submission.setJobSubmissionInterfaceId(localSubmission.getJobSubmissionInterfaceId()); - submission.setResourceJobManager(getResourceJobManager(localSubmission.getResourceJobManagerResource())); - return submission; - } - - public static ResourceJobManagerResource getResourceJobManager(ResourceJobManager manager){ - ResourceJobManagerResource r = new ResourceJobManagerResource(); - r.setResourceJobManagerId(manager.getResourceJobManagerId()); - r.setJobManagerBinPath(manager.getJobManagerBinPath()); - r.setPushMonitoringEndpoint(manager.getPushMonitoringEndpoint()); - r.setResourceJobManagerType(manager.getResourceJobManagerType().toString()); - return r; - } - - public static ResourceJobManager getResourceJobManager(ResourceJobManagerResource manager) throws AppCatalogException { - ResourceJobManager r = new ResourceJobManager(); - r.setResourceJobManagerId(manager.getResourceJobManagerId()); - r.setJobManagerBinPath(manager.getJobManagerBinPath()); - r.setPushMonitoringEndpoint(manager.getPushMonitoringEndpoint()); - r.setResourceJobManagerType(ResourceJobManagerType.valueOf(manager.getResourceJobManagerType())); - r.setJobManagerCommands(new HashMap<JobManagerCommand, String>()); - JobManagerCommandResource jmcr=new JobManagerCommandResource(); - List<Resource> jmcrList = jmcr.get(AbstractResource.JobManagerCommandConstants.RESOURCE_JOB_MANAGER_ID, manager.getResourceJobManagerId()); - if (jmcrList != null && !jmcrList.isEmpty()){ - for (Resource rrr : jmcrList) { - JobManagerCommandResource rr=(JobManagerCommandResource)rrr; - r.getJobManagerCommands().put(JobManagerCommand.valueOf(rr.getCommandType()), rr.getCommand()); - } - } - return r; - } - - - public static SSHJobSubmission getSSHJobSubmissionDescription (SshJobSubmissionResource submission) throws AppCatalogException { - SSHJobSubmission sshJobSubmission = new SSHJobSubmission(); - sshJobSubmission.setAlternativeSSHHostName(submission.getAlternativeSshHostname()); - sshJobSubmission.setJobSubmissionInterfaceId(submission.getJobSubmissionInterfaceId()); - sshJobSubmission.setResourceJobManager(getResourceJobManager(submission.getResourceJobManagerResource())); - sshJobSubmission.setSecurityProtocol(SecurityProtocol.valueOf(submission.getSecurityProtocol())); - sshJobSubmission.setSshPort(submission.getSshPort()); - if (submission.getMonitorMode() != null){ - sshJobSubmission.setMonitorMode(MonitorMode.valueOf(submission.getMonitorMode())); - } - return sshJobSubmission; - } - - public static UnicoreJobSubmission getUnicoreJobSubmissionDescription (UnicoreJobSubmissionResource submission) throws AppCatalogException { - UnicoreJobSubmission unicoreJobSubmission = new UnicoreJobSubmission(); - unicoreJobSubmission.setUnicoreEndPointURL(submission.getUnicoreEndpointUrl()); - unicoreJobSubmission.setJobSubmissionInterfaceId(submission.getjobSubmissionInterfaceId()); - if (submission.getSecurityProtocol() != null){ - unicoreJobSubmission.setSecurityProtocol(SecurityProtocol.valueOf(submission.getSecurityProtocol())); - } - return unicoreJobSubmission; - } - - public static UnicoreDataMovement getUnicoreDMDescription (UnicoreDataMovementResource resource) throws AppCatalogException { - UnicoreDataMovement dataMovement = new UnicoreDataMovement(); - dataMovement.setUnicoreEndPointURL(resource.getUnicoreEndpointUrl()); - dataMovement.setDataMovementInterfaceId(resource.getDataMovementId()); - if (resource.getSecurityProtocol() != null){ - dataMovement.setSecurityProtocol(SecurityProtocol.valueOf(resource.getSecurityProtocol())); - } - return dataMovement; - } - - - public static CloudJobSubmission getCloudJobSubmissionDescription (CloudSubmissionResource submission) throws AppCatalogException { - CloudJobSubmission cloudJobSubmission = new CloudJobSubmission(); - cloudJobSubmission.setJobSubmissionInterfaceId(submission.getJobSubmissionInterfaceId()); - cloudJobSubmission.setExecutableType(submission.getExecutableType()); - cloudJobSubmission.setSecurityProtocol(SecurityProtocol.valueOf(submission.getSecurityProtocol())); - cloudJobSubmission.setNodeId(submission.getNodeId()); - cloudJobSubmission.setUserAccountName(submission.getUserAccountName()); - cloudJobSubmission.setProviderName(ProviderName.valueOf(submission.getProviderName())); - return cloudJobSubmission; - } - -// public static GlobusJobSubmission getGlobusJobSubmissionDescription (GlobusJobSubmissionResource submission) throws AppCatalogException { -// GlobusJobSubmission globusJobSubmission = new GlobusJobSubmission(); -// globusJobSubmission.setJobSubmissionInterfaceId(submission.getSubmissionID()); -// globusJobSubmission.setResourceJobManager(ResourceJobManager.valueOf(submission.getResourceJobManager())); -// globusJobSubmission.setSecurityProtocol(SecurityProtocol.valueOf(submission.getSecurityProtocol())); -// -// GlobusGKEndpointResource endpointResource = new GlobusGKEndpointResource(); -// List<Resource> endpoints = endpointResource.get(AbstractResource.GlobusEPConstants.SUBMISSION_ID, submission.getSubmissionID()); -// if (endpoints != null && !endpoints.isEmpty()){ -// globusJobSubmission.setGlobusGateKeeperEndPoint(getGlobusGateKeeperEndPointList(endpoints)); -// } -// -// return globusJobSubmission; -// } - - public static SCPDataMovement getSCPDataMovementDescription (ScpDataMovementResource dataMovementResource) throws AppCatalogException { - SCPDataMovement dataMovement = new SCPDataMovement(); - dataMovement.setDataMovementInterfaceId(dataMovementResource.getDataMovementInterfaceId()); - dataMovement.setAlternativeSCPHostName(dataMovementResource.getAlternativeScpHostname()); - dataMovement.setSecurityProtocol(SecurityProtocol.valueOf(dataMovementResource.getSecurityProtocol())); - dataMovement.setSshPort(dataMovementResource.getSshPort()); - return dataMovement; - } - - public static ScpDataMovementResource getSCPDataMovementDescription (SCPDataMovement dataMovementResource) throws AppCatalogException { - ScpDataMovementResource dataMovement = new ScpDataMovementResource(); - dataMovement.setDataMovementInterfaceId(dataMovementResource.getDataMovementInterfaceId()); - dataMovement.setAlternativeScpHostname(dataMovementResource.getAlternativeSCPHostName()); - dataMovement.setSecurityProtocol(dataMovementResource.getSecurityProtocol().toString()); - dataMovement.setSshPort(dataMovementResource.getSshPort()); - return dataMovement; - } - - public static GridFTPDataMovement getGridFTPDataMovementDescription (GridftpDataMovementResource dataMovementResource) throws AppCatalogException { - GridFTPDataMovement dataMovement = new GridFTPDataMovement(); - dataMovement.setDataMovementInterfaceId(dataMovementResource.getDataMovementInterfaceId()); - dataMovement.setSecurityProtocol(SecurityProtocol.valueOf(dataMovementResource.getSecurityProtocol())); - GridftpEndpointResource endpointResource = new GridftpEndpointResource(); - List<Resource> endpoints = endpointResource.get(AbstractResource.GridftpEndpointConstants.DATA_MOVEMENT_INTERFACE_ID, dataMovementResource.getDataMovementInterfaceId()); - if (endpoints != null && !endpoints.isEmpty()){ - dataMovement.setGridFTPEndPoints(getGridFTPDMEPList(endpoints)); - } - return dataMovement; - } - - public static GridftpDataMovementResource getGridFTPDataMovementDescription (GridFTPDataMovement dataMovementResource) throws AppCatalogException { - GridftpDataMovementResource dataMovement = new GridftpDataMovementResource(); - dataMovement.setDataMovementInterfaceId(dataMovementResource.getDataMovementInterfaceId()); - dataMovement.setSecurityProtocol(dataMovementResource.getSecurityProtocol().toString()); - return dataMovement; - } - - public static List<String> getGridFTPDMEPList (List<Resource> endpoints){ - List<String> list = new ArrayList<String>(); - for (Resource resource : endpoints){ - list.add(((GridftpEndpointResource) resource).getEndpoint()); - } - return list; - } - - public static List<String> getGlobusGateKeeperEndPointList (List<Resource> resources) throws AppCatalogException { - List<String> list = new ArrayList<String>(); - for (Resource resource : resources){ - list.add(((GlobusGKEndpointResource) resource).getEndpoint()); - } - return list; - } -// -// public static List<GSISSHJobSubmission> getGSISSHSubmissionList (List<Resource> resources) throws AppCatalogException { -// List<GSISSHJobSubmission> list = new ArrayList<GSISSHJobSubmission>(); -// for (Resource resource : resources){ -// list.add(getGSISSHSubmissionDescription((GSISSHSubmissionResource) resource)); -// } -// return list; -// } -// -// public static List<GlobusJobSubmission> getGlobusSubmissionList (List<Resource> resources) throws AppCatalogException { -// List<GlobusJobSubmission> list = new ArrayList<GlobusJobSubmission>(); -// for (Resource resource : resources){ -// list.add(getGlobusJobSubmissionDescription((GlobusJobSubmissionResource) resource)); -// } -// return list; -// } -// -// public static List<SSHJobSubmission> getSSHSubmissionList (List<Resource> resources) throws AppCatalogException { -// List<SSHJobSubmission> list = new ArrayList<SSHJobSubmission>(); -// for (Resource resource : resources){ -// list.add(getSSHJobSubmissionDescription((SshJobSubmissionResource) resource)); -// } -// return list; -// } -// -// public static List<GridFTPDataMovement> getGridFTPDataMovementList (List<Resource> resources) throws AppCatalogException { -// List<GridFTPDataMovement> list = new ArrayList<GridFTPDataMovement>(); -// for (Resource resource : resources){ -// list.add(getGridFTPDataMovementDescription((GridftpDataMovementResource) resource)); -// } -// return list; -// } -// -// public static List<SCPDataMovement> getSCPDataMovementList (List<Resource> resources) throws AppCatalogException { -// List<SCPDataMovement> list = new ArrayList<SCPDataMovement>(); -// for (Resource resource : resources){ -// list.add(getSCPDataMovementDescription((ScpDataMovementResource) resource)); -// } -// return list; -// } -// -// public static Set<String> getGSISSHExports (List<Resource> gsisshExportResources){ -// Set<String> exports = new HashSet<String>(); -// for (Resource resource : gsisshExportResources){ -// exports.add(((GSISSHExportResource) resource).getExport()); -// } -// return exports; -// } -// -// public static List<String> getGSISSHPreJobCommands (List<Resource> gsisshPreJobCommandResources){ -// List<String> list = new ArrayList<String>(); -// for (Resource resource : gsisshPreJobCommandResources){ -// list.add(((GSISSHPreJobCommandResource) resource).getCommand()); -// } -// return list; -// } -// -// public static List<String> getGSISSHPostJobCommands (List<Resource> gsisshPostJobCommandResources){ -// List<String> list = new ArrayList<String>(); -// for (Resource resource : gsisshPostJobCommandResources){ -// list.add(((GSISSHPostJobCommandResource) resource).getCommand()); -// } -// return list; -// } -// -// public static GlobusJobSubmissionResource getGlobusJobSubmission (GlobusJobSubmission submission){ -// GlobusJobSubmissionResource resource = new GlobusJobSubmissionResource(); -// resource.setSubmissionID(submission.getJobSubmissionDataID()); -// resource.setSecurityProtocol(submission.getSecurityProtocol().toString()); -// resource.setResourceJobManager(submission.getResourceJobManager().toString()); -// return resource; -// } - - public static ApplicationModule getApplicationModuleDesc (AppModuleResource resource){ - ApplicationModule module = new ApplicationModule(); - module.setAppModuleId(resource.getModuleId()); - module.setAppModuleDescription(resource.getModuleDesc()); - module.setAppModuleName(resource.getModuleName()); - module.setAppModuleVersion(resource.getModuleVersion()); - return module; - } - - public static ApplicationInterfaceDescription getApplicationInterfaceDescription (AppInterfaceResource resource) throws AppCatalogException { - ApplicationInterfaceDescription description = new ApplicationInterfaceDescription(); - description.setApplicationInterfaceId(resource.getInterfaceId()); - description.setApplicationName(resource.getAppName()); - description.setApplicationDescription(resource.getAppDescription()); - - AppModuleMappingResource appModuleMappingResource = new AppModuleMappingResource(); - List<Resource> appModules = appModuleMappingResource.get(AbstractResource.AppModuleMappingConstants.INTERFACE_ID, resource.getInterfaceId()); - if (appModules != null && !appModules.isEmpty()){ - description.setApplicationModules(getAppModuleIds(appModules)); - } - - ApplicationInputResource inputResource = new ApplicationInputResource(); - List<Resource> appInputs = inputResource.get(AbstractResource.AppInputConstants.INTERFACE_ID, resource.getInterfaceId()); - if (appInputs != null && !appInputs.isEmpty()){ - description.setApplicationInputs(getAppInputs(appInputs)); - } - - ApplicationOutputResource outputResource = new ApplicationOutputResource(); - List<Resource> appOutputs = outputResource.get(AbstractResource.AppOutputConstants.INTERFACE_ID, resource.getInterfaceId()); - if (appOutputs != null && !appOutputs.isEmpty()){ - description.setApplicationOutputs(getAppOutputs(appOutputs)); - } - return description; - } - - public static List<String> getAppModuleIds (List<Resource> appModuleMappings){ - List<String> modules = new ArrayList<String>(); - for (Resource resource : appModuleMappings){ - modules.add(((AppModuleMappingResource)resource).getModuleId()); - } - return modules; - } - - public static List<ApplicationModule> getAppModules (List<Resource> appModules){ - List<ApplicationModule> modules = new ArrayList<ApplicationModule>(); - for (Resource resource : appModules){ - modules.add(getApplicationModuleDesc((AppModuleResource) resource)); - } - return modules; - } - - public static List<ApplicationInterfaceDescription> getAppInterfaceDescList (List<Resource> appInterfaces) throws AppCatalogException { - List<ApplicationInterfaceDescription> interfaceDescriptions = new ArrayList<ApplicationInterfaceDescription>(); - for (Resource resource : appInterfaces){ - interfaceDescriptions.add(getApplicationInterfaceDescription((AppInterfaceResource) resource)); - } - return interfaceDescriptions; - } - - public static List<InputDataObjectType> getAppInputs (List<Resource> resources){ - List<InputDataObjectType> inputs = new ArrayList<InputDataObjectType>(); - for (Resource resource : resources){ - inputs.add(getInputDataObjType((ApplicationInputResource) resource)); - } - return inputs; - } - - public static InputDataObjectType getInputDataObjType (ApplicationInputResource input){ - InputDataObjectType inputDataObjectType = new InputDataObjectType(); - inputDataObjectType.setName(input.getInputKey()); - inputDataObjectType.setValue(input.getInputVal()); - inputDataObjectType.setApplicationArgument(input.getAppArgument()); - inputDataObjectType.setInputOrder(input.getInputOrder()); - inputDataObjectType.setMetaData(input.getMetadata()); - inputDataObjectType.setType(DataType.valueOf(input.getDataType())); - inputDataObjectType.setStandardInput(input.isStandardInput()); - inputDataObjectType.setUserFriendlyDescription(input.getUserFriendlyDesc()); - inputDataObjectType.setIsRequired(input.getRequired()); - inputDataObjectType.setRequiredToAddedToCommandLine(input.getRequiredToCMD()); - inputDataObjectType.setDataStaged(input.isDataStaged()); - return inputDataObjectType; - } - - public static List<OutputDataObjectType> getAppOutputs (List<Resource> resources){ - List<OutputDataObjectType> outputs = new ArrayList<OutputDataObjectType>(); - for (Resource resource : resources){ - outputs.add(getOutputDataObjType((ApplicationOutputResource) resource)); - } - return outputs; - } - public static OutputDataObjectType getOutputDataObjType (ApplicationOutputResource output){ - OutputDataObjectType outputDataObjectType = new OutputDataObjectType(); - outputDataObjectType.setName(output.getOutputKey()); - outputDataObjectType.setValue(output.getOutputVal()); - outputDataObjectType.setType(DataType.valueOf(output.getDataType())); - outputDataObjectType.setIsRequired(output.getRequired()); - outputDataObjectType.setRequiredToAddedToCommandLine(output.getRequiredToCMD()); - outputDataObjectType.setDataMovement(output.isDataMovement()); - outputDataObjectType.setLocation(output.getDataNameLocation()); - outputDataObjectType.setSearchQuery(output.getSearchQuery()); - outputDataObjectType.setApplicationArgument(output.getAppArgument()); - return outputDataObjectType; - } - - public static ApplicationDeploymentDescription getApplicationDeploymentDescription (AppDeploymentResource resource) throws AppCatalogException { - ApplicationDeploymentDescription description = new ApplicationDeploymentDescription(); - description.setAppDeploymentId(resource.getDeploymentId()); - description.setAppModuleId(resource.getAppModuleId()); - description.setComputeHostId(resource.getHostId()); - description.setExecutablePath(resource.getExecutablePath()); - if (resource.getParallelism() != null){ - description.setParallelism(ApplicationParallelismType.valueOf(resource.getParallelism())); - } - description.setAppDeploymentDescription(resource.getAppDes()); - ModuleLoadCmdResource cmdResource = new ModuleLoadCmdResource(); - List<Resource> moduleLoadCmds = cmdResource.get(AbstractResource.ModuleLoadCmdConstants.APP_DEPLOYMENT_ID, resource.getDeploymentId()); - if (moduleLoadCmds != null && !moduleLoadCmds.isEmpty()){ - for (Resource moduleLoadCmd : moduleLoadCmds){ - description.addToModuleLoadCmds(((ModuleLoadCmdResource) moduleLoadCmd).getCmd()); - } - } - LibraryPrepandPathResource prepandPathResource = new LibraryPrepandPathResource(); - List<Resource> libPrepandPaths = prepandPathResource.get(AbstractResource.LibraryPrepandPathConstants.DEPLOYMENT_ID, resource.getDeploymentId()); - if (libPrepandPaths != null && !libPrepandPaths.isEmpty()){ - description.setLibPrependPaths(getLibPrepandPaths(libPrepandPaths)); - } - - LibraryApendPathResource apendPathResource = new LibraryApendPathResource(); - List<Resource> libApendPaths = apendPathResource.get(AbstractResource.LibraryPrepandPathConstants.DEPLOYMENT_ID, resource.getDeploymentId()); - if (libApendPaths != null && !libApendPaths.isEmpty()){ - description.setLibAppendPaths(getLibApendPaths(libApendPaths)); - } - - AppEnvironmentResource appEnvironmentResource = new AppEnvironmentResource(); - List<Resource> appEnvList = appEnvironmentResource.get(AbstractResource.LibraryPrepandPathConstants.DEPLOYMENT_ID, resource.getDeploymentId()); - if (appEnvList != null && !appEnvList.isEmpty()){ - description.setSetEnvironment(getAppEnvPaths(appEnvList)); - } - PreJobCommandResource preJobCommandResource = new PreJobCommandResource(); - List<Resource> preJobCommands = preJobCommandResource.get(AbstractResource.PreJobCommandConstants.DEPLOYMENT_ID, resource.getDeploymentId()); - if (preJobCommands != null && !preJobCommands.isEmpty()){ - for (Resource prejobCommand : preJobCommands){ - description.addToPreJobCommands(((PreJobCommandResource) prejobCommand).getCommand()); - } - } - PostJobCommandResource postJobCommandResource = new PostJobCommandResource(); - List<Resource> postJobCommands = postJobCommandResource.get(AbstractResource.PostJobCommandConstants.DEPLOYMENT_ID, resource.getDeploymentId()); - if (postJobCommands != null && !postJobCommands.isEmpty()){ - for (Resource postjobCommand : postJobCommands){ - description.addToPostJobCommands(((PostJobCommandResource) postjobCommand).getCommand()); - } - } - return description; - } - - public static List<ApplicationDeploymentDescription> getAppDepDescList (List<Resource> resources) throws AppCatalogException { - List<ApplicationDeploymentDescription> appList = new ArrayList<ApplicationDeploymentDescription>(); - for (Resource resource : resources){ - appList.add(getApplicationDeploymentDescription((AppDeploymentResource)resource)); - } - return appList; - } - - public static SetEnvPaths getSetEnvPath(Resource resource){ - SetEnvPaths envPaths = new SetEnvPaths(); - if (resource instanceof LibraryPrepandPathResource){ - envPaths.setName(((LibraryPrepandPathResource) resource).getName()); - envPaths.setValue(((LibraryPrepandPathResource) resource).getValue()); - return envPaths; - }else if (resource instanceof LibraryApendPathResource){ - envPaths.setName(((LibraryApendPathResource) resource).getName()); - envPaths.setValue(((LibraryApendPathResource) resource).getValue()); - return envPaths; - }else if (resource instanceof AppEnvironmentResource){ - envPaths.setName(((AppEnvironmentResource) resource).getName()); - envPaths.setValue(((AppEnvironmentResource) resource).getValue()); - return envPaths; - }else { - return null; - } - } - - public static List<SetEnvPaths> getLibPrepandPaths (List<Resource> prepandPaths){ - List<SetEnvPaths> pathList = new ArrayList<SetEnvPaths>(); - for (Resource resource : prepandPaths){ - pathList.add(getSetEnvPath(resource)); - } - return pathList; - } - - public static List<SetEnvPaths> getLibApendPaths (List<Resource> appendPaths){ - List<SetEnvPaths> pathList = new ArrayList<SetEnvPaths>(); - for (Resource resource : appendPaths){ - pathList.add(getSetEnvPath(resource)); - } - return pathList; - } - - public static List<SetEnvPaths> getAppEnvPaths (List<Resource> appEnvPaths){ - List<SetEnvPaths> pathList = new ArrayList<SetEnvPaths>(); - for (Resource resource : appEnvPaths){ - pathList.add(getSetEnvPath(resource)); - } - return pathList; - } - - public static ComputeResourcePreference getComputeResourcePreference (ComputeHostPreferenceResource resource){ - ComputeResourcePreference preference = new ComputeResourcePreference(); - preference.setComputeResourceId(resource.getResourceId()); - preference.setOverridebyAiravata(resource.getOverrideByAiravata()); - if (resource.getPreferredJobProtocol() != null){ - preference.setPreferredJobSubmissionProtocol(JobSubmissionProtocol.valueOf(resource.getPreferredJobProtocol())); - } - if (resource.getPreferedDMProtocol() != null){ - preference.setPreferredDataMovementProtocol(DataMovementProtocol.valueOf(resource.getPreferedDMProtocol())); - } - preference.setPreferredBatchQueue(resource.getBatchQueue()); - preference.setScratchLocation(resource.getScratchLocation()); - preference.setAllocationProjectNumber(resource.getProjectNumber()); - preference.setLoginUserName(resource.getLoginUserName()); - return preference; - } - - public static List<ComputeResourcePreference> getComputeResourcePreferences (List<Resource> resources){ - List<ComputeResourcePreference> preferences = new ArrayList<ComputeResourcePreference>(); - if (resources != null && !resources.isEmpty()){ - for (Resource resource : resources){ - preferences.add(getComputeResourcePreference((ComputeHostPreferenceResource)resource)); - } - } - return preferences; - } - - public static InputDataObjectType getWorkflowInput (WorkflowInputResource resource){ - InputDataObjectType input = new InputDataObjectType(); - input.setName(resource.getInputKey()); - input.setApplicationArgument(resource.getAppArgument()); - input.setInputOrder(resource.getInputOrder()); - input.setType(DataType.valueOf(resource.getDataType())); - input.setMetaData(resource.getMetadata()); - input.setUserFriendlyDescription(resource.getUserFriendlyDesc()); - input.setIsRequired(resource.getRequired()); - input.setRequiredToAddedToCommandLine(resource.getRequiredToCMD()); - input.setDataStaged(resource.isDataStaged()); - return input; - } - - public static List<InputDataObjectType> getWFInputs(List<Resource> resources){ - List<InputDataObjectType> inputResources = new ArrayList<InputDataObjectType>(); - if (resources != null && !resources.isEmpty()){ - for (Resource resource : resources){ - inputResources.add(getWorkflowInput((WorkflowInputResource) resource)); - } - } - return inputResources; - } - - public static GatewayResourceProfile getGatewayResourceProfile(GatewayProfileResource gw, List<ComputeResourcePreference> preferences){ - GatewayResourceProfile gatewayProfile = new GatewayResourceProfile(); - gatewayProfile.setGatewayID(gw.getGatewayID()); - gatewayProfile.setComputeResourcePreferences(preferences); - return gatewayProfile; - } - - public static Workflow getWorkflow (WorkflowResource resource) throws AppCatalogException { - Workflow workflow = new Workflow(); - workflow.setTemplateId(resource.getWfTemplateId()); - workflow.setGraph(resource.getGraph()); - workflow.setName(resource.getWfName()); - if (resource.getImage() != null){ - workflow.setImage(resource.getImage().getBytes()); - } - WorkflowInputResource inputResource = new WorkflowInputResource(); - List<Resource> resources = inputResource.get(AbstractResource.WFInputConstants.WF_TEMPLATE_ID, resource.getWfTemplateId()); - workflow.setWorkflowInputs(getWFInputs(resources)); - - return workflow; - } -}
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/AppCatalogUtils.java ---------------------------------------------------------------------- diff --git a/modules/app-catalog/app-catalog-data/src/main/java/org/apache/aiaravata/application/catalog/data/util/AppCatalogUtils.java b/modules/app-catalog/app-catalog-data/src/main/java/org/apache/aiaravata/application/catalog/data/util/AppCatalogUtils.java deleted file mode 100644 index 4b173be..0000000 --- a/modules/app-catalog/app-catalog-data/src/main/java/org/apache/aiaravata/application/catalog/data/util/AppCatalogUtils.java +++ /dev/null @@ -1,31 +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 java.util.UUID; - -public class AppCatalogUtils { - public static String getID (String name){ - String pro = name.replaceAll("\\s", ""); - return pro + "_" + UUID.randomUUID(); - } -} http://git-wip-us.apache.org/repos/asf/airavata/blob/ec8c6202/modules/app-catalog/app-catalog-data/src/main/resources/META-INF/persistence.xml ---------------------------------------------------------------------- diff --git a/modules/app-catalog/app-catalog-data/src/main/resources/META-INF/persistence.xml b/modules/app-catalog/app-catalog-data/src/main/resources/META-INF/persistence.xml deleted file mode 100644 index 5fa184d..0000000 --- a/modules/app-catalog/app-catalog-data/src/main/resources/META-INF/persistence.xml +++ /dev/null @@ -1,67 +0,0 @@ -<?xml version="1.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. - * -* --> -<persistence xmlns="http://java.sun.com/xml/ns/persistence"; - xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"; version="1.0"> - <persistence-unit name="appcatalog_data"> - <provider>org.apache.openjpa.persistence.PersistenceProviderImpl</provider> - <class>org.apache.aiaravata.application.catalog.data.model.ComputeResource</class> - <class>org.apache.aiaravata.application.catalog.data.model.GlobusJobSubmission</class> - <class>org.apache.aiaravata.application.catalog.data.model.GlobusGKEndpoint</class> - <class>org.apache.aiaravata.application.catalog.data.model.GSISSHSubmission</class> - <class>org.apache.aiaravata.application.catalog.data.model.GSISSHExport</class> - <class>org.apache.aiaravata.application.catalog.data.model.PreJobCommand</class> - <class>org.apache.aiaravata.application.catalog.data.model.PostJobCommand</class> - <class>org.apache.aiaravata.application.catalog.data.model.UnicoreJobSubmission</class> - <class>org.apache.aiaravata.application.catalog.data.model.UnicoreDataMovement</class> - <class>org.apache.aiaravata.application.catalog.data.model.HostAlias</class> - <class>org.apache.aiaravata.application.catalog.data.model.HostIPAddress</class> - <class>org.apache.aiaravata.application.catalog.data.model.ScpDataMovement</class> - <class>org.apache.aiaravata.application.catalog.data.model.GridftpDataMovement</class> - <class>org.apache.aiaravata.application.catalog.data.model.GridftpEndpoint</class> - <class>org.apache.aiaravata.application.catalog.data.model.SshJobSubmission</class> - <class>org.apache.aiaravata.application.catalog.data.model.ApplicationModule</class> - <class>org.apache.aiaravata.application.catalog.data.model.ApplicationDeployment</class> - <class>org.apache.aiaravata.application.catalog.data.model.ModuleLoadCmd</class> - <class>org.apache.aiaravata.application.catalog.data.model.LibraryPrepandPath</class> - <class>org.apache.aiaravata.application.catalog.data.model.LibraryApendPath</class> - <class>org.apache.aiaravata.application.catalog.data.model.AppEnvironment</class> - <class>org.apache.aiaravata.application.catalog.data.model.ApplicationInterface</class> - <class>org.apache.aiaravata.application.catalog.data.model.AppModuleMapping</class> - <class>org.apache.aiaravata.application.catalog.data.model.ApplicationInput</class> - <class>org.apache.aiaravata.application.catalog.data.model.ApplicationOutput</class> - <class>org.apache.aiaravata.application.catalog.data.model.GatewayProfile</class> - <class>org.apache.aiaravata.application.catalog.data.model.ComputeResourcePreference</class> - <class>org.apache.aiaravata.application.catalog.data.model.BatchQueue</class> - <class>org.apache.aiaravata.application.catalog.data.model.ComputeResourceFileSystem</class> - <class>org.apache.aiaravata.application.catalog.data.model.JobSubmissionInterface</class> - <class>org.apache.aiaravata.application.catalog.data.model.DataMovementInterface</class> - <class>org.apache.aiaravata.application.catalog.data.model.ResourceJobManager</class> - <class>org.apache.aiaravata.application.catalog.data.model.JobManagerCommand</class> - <class>org.apache.aiaravata.application.catalog.data.model.LocalSubmission</class> - <class>org.apache.aiaravata.application.catalog.data.model.LocalDataMovement</class> - <class>org.apache.aiaravata.application.catalog.data.model.Workflow</class> - <class>org.apache.aiaravata.application.catalog.data.model.WorkflowInput</class> - <class>org.apache.aiaravata.application.catalog.data.model.WorkflowOutput</class> - <class>org.apache.aiaravata.application.catalog.data.model.Configuration</class> - <exclude-unlisted-classes>true</exclude-unlisted-classes> - </persistence-unit> -</persistence> http://git-wip-us.apache.org/repos/asf/airavata/blob/ec8c6202/modules/app-catalog/app-catalog-data/src/main/resources/appcatalog-derby.sql ---------------------------------------------------------------------- diff --git a/modules/app-catalog/app-catalog-data/src/main/resources/appcatalog-derby.sql b/modules/app-catalog/app-catalog-data/src/main/resources/appcatalog-derby.sql deleted file mode 100644 index fc24d83..0000000 --- a/modules/app-catalog/app-catalog-data/src/main/resources/appcatalog-derby.sql +++ /dev/null @@ -1,460 +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. - * - */ - -CREATE TABLE COMPUTE_RESOURCE -( - RESOURCE_ID VARCHAR (255) NOT NULL, - HOST_NAME VARCHAR (255) NOT NULL, - RESOURCE_DESCRIPTION VARCHAR (255), - CREATION_TIME TIMESTAMP DEFAULT CURRENT_TIMESTAMP, - UPDATE_TIME TIMESTAMP DEFAULT '0000-00-00 00:00:00', - MAX_MEMORY_NODE INTEGER, - PRIMARY KEY (RESOURCE_ID) -); - -CREATE TABLE HOST_ALIAS -( - RESOURCE_ID VARCHAR(255), - ALIAS VARCHAR(255), - PRIMARY KEY(RESOURCE_ID,ALIAS), - FOREIGN KEY (RESOURCE_ID) REFERENCES COMPUTE_RESOURCE(RESOURCE_ID) ON DELETE CASCADE -); - -CREATE TABLE HOST_IPADDRESS -( - RESOURCE_ID VARCHAR(255), - IP_ADDRESS VARCHAR(255), - PRIMARY KEY(RESOURCE_ID,IP_ADDRESS), - FOREIGN KEY (RESOURCE_ID) REFERENCES COMPUTE_RESOURCE(RESOURCE_ID) ON DELETE CASCADE -); - -CREATE TABLE GSISSH_SUBMISSION -( - SUBMISSION_ID VARCHAR(255), - RESOURCE_JOB_MANAGER VARCHAR(255), - SSH_PORT INTEGER, - INSTALLED_PATH VARCHAR(255), - MONITOR_MODE VARCHAR(255), - PRIMARY KEY(SUBMISSION_ID) -); - -CREATE TABLE GSISSH_EXPORT -( - SUBMISSION_ID VARCHAR(255), - EXPORT VARCHAR(255), - PRIMARY KEY(SUBMISSION_ID, EXPORT), - FOREIGN KEY (SUBMISSION_ID) REFERENCES GSISSH_SUBMISSION(SUBMISSION_ID) ON DELETE CASCADE -); - - - -CREATE TABLE GLOBUS_SUBMISSION -( - SUBMISSION_ID VARCHAR(255), - RESOURCE_JOB_MANAGER VARCHAR(255), - SECURITY_PROTOCAL VARCHAR(255), - PRIMARY KEY(SUBMISSION_ID) -); - -CREATE TABLE UNICORE_SUBMISSION -( - SUBMISSION_ID VARCHAR(255), - SECURITY_PROTOCAL VARCHAR(255), - UNICORE_ENDPOINT_URL VARCHAR(255), - PRIMARY KEY(SUBMISSION_ID) -); - -CREATE TABLE UNICORE_DATAMOVEMENT -( - DATAMOVEMENT_ID VARCHAR(255), - SECURITY_PROTOCAL VARCHAR(255), - UNICORE_ENDPOINT_URL VARCHAR(255), - PRIMARY KEY(DATAMOVEMENT_ID) -); - - -CREATE TABLE GLOBUS_GK_ENDPOINT -( - SUBMISSION_ID VARCHAR(255), - ENDPOINT VARCHAR(255), - PRIMARY KEY(SUBMISSION_ID, ENDPOINT), - FOREIGN KEY (SUBMISSION_ID) REFERENCES GLOBUS_SUBMISSION(SUBMISSION_ID) ON DELETE CASCADE -); - -CREATE TABLE RESOURCE_JOB_MANAGER -( - RESOURCE_JOB_MANAGER_ID VARCHAR (255) NOT NULL, - PUSH_MONITORING_ENDPOINT VARCHAR (255), - JOB_MANAGER_BIN_PATH VARCHAR (255), - RESOURCE_JOB_MANAGER_TYPE VARCHAR (255) NOT NULL, - CREATION_TIME TIMESTAMP DEFAULT CURRENT_TIMESTAMP, - UPDATE_TIME TIMESTAMP DEFAULT '0000-00-00 00:00:00', - PRIMARY KEY (RESOURCE_JOB_MANAGER_ID) -); - - - -CREATE TABLE SSH_JOB_SUBMISSION -( - RESOURCE_JOB_MANAGER_ID VARCHAR (255) NOT NULL, - JOB_SUBMISSION_INTERFACE_ID VARCHAR (255) NOT NULL, - ALTERNATIVE_SSH_HOSTNAME VARCHAR (255), - SECURITY_PROTOCOL VARCHAR (255) NOT NULL, - SSH_PORT INTEGER, - MONITOR_MODE VARCHAR (255), - CREATION_TIME TIMESTAMP DEFAULT CURRENT_TIMESTAMP, - UPDATE_TIME TIMESTAMP DEFAULT '0000-00-00 00:00:00', - PRIMARY KEY (JOB_SUBMISSION_INTERFACE_ID), - FOREIGN KEY (RESOURCE_JOB_MANAGER_ID) REFERENCES RESOURCE_JOB_MANAGER(RESOURCE_JOB_MANAGER_ID) -); - -CREATE TABLE SCP_DATA_MOVEMENT -( - QUEUE_DESCRIPTION VARCHAR (255), - DATA_MOVEMENT_INTERFACE_ID VARCHAR (255) NOT NULL, - SECURITY_PROTOCOL VARCHAR (255) NOT NULL, - ALTERNATIVE_SCP_HOSTNAME VARCHAR (255), - SSH_PORT INTEGER, - CREATION_TIME TIMESTAMP DEFAULT CURRENT_TIMESTAMP, - UPDATE_TIME TIMESTAMP DEFAULT '0000-00-00 00:00:00', - PRIMARY KEY (DATA_MOVEMENT_INTERFACE_ID) -); - -CREATE TABLE GRIDFTP_DATA_MOVEMENT -( - DATA_MOVEMENT_INTERFACE_ID VARCHAR (255) NOT NULL, - SECURITY_PROTOCOL VARCHAR (255) NOT NULL, - CREATION_TIME TIMESTAMP DEFAULT CURRENT_TIMESTAMP, - UPDATE_TIME TIMESTAMP DEFAULT '0000-00-00 00:00:00', - PRIMARY KEY (DATA_MOVEMENT_INTERFACE_ID) -); - -CREATE TABLE GRIDFTP_ENDPOINT -( - ENDPOINT VARCHAR (255) NOT NULL, - DATA_MOVEMENT_INTERFACE_ID VARCHAR (255) NOT NULL, - PRIMARY KEY (DATA_MOVEMENT_INTERFACE_ID,ENDPOINT), - CREATION_TIME TIMESTAMP DEFAULT CURRENT_TIMESTAMP, - UPDATE_TIME TIMESTAMP DEFAULT '0000-00-00 00:00:00', - FOREIGN KEY (DATA_MOVEMENT_INTERFACE_ID) REFERENCES GRIDFTP_DATA_MOVEMENT(DATA_MOVEMENT_INTERFACE_ID) ON DELETE CASCADE -); - ---CREATE TABLE JOB_SUBMISSION_PROTOCOL ---( --- RESOURCE_ID VARCHAR(255), --- SUBMISSION_ID VARCHAR(255), --- JOB_TYPE VARCHAR(255), --- CREATION_TIME TIMESTAMP DEFAULT CURRENT_TIMESTAMP, --- UPDATE_TIME TIMESTAMP DEFAULT '0000-00-00 00:00:00', --- PRIMARY KEY(RESOURCE_ID,SUBMISSION_ID,JOB_TYPE), --- FOREIGN KEY (RESOURCE_ID) REFERENCES COMPUTE_RESOURCE(RESOURCE_ID) ON DELETE CASCADE ---); --- ---CREATE TABLE DATA_MOVEMENT_PROTOCOL ---( --- RESOURCE_ID VARCHAR(255), --- DATA_MOVE_ID VARCHAR(255), --- DATA_MOVE_TYPE VARCHAR(255), --- CREATION_TIME TIMESTAMP DEFAULT CURRENT_TIMESTAMP, --- UPDATE_TIME TIMESTAMP DEFAULT '0000-00-00 00:00:00', --- PRIMARY KEY(RESOURCE_ID,DATA_MOVE_ID,DATA_MOVE_TYPE), --- FOREIGN KEY (RESOURCE_ID) REFERENCES COMPUTE_RESOURCE(RESOURCE_ID) ON DELETE CASCADE ---); - -CREATE TABLE APPLICATION_MODULE -( - MODULE_ID VARCHAR(255), - MODULE_NAME VARCHAR(255), - MODULE_VERSION VARCHAR(255), - MODULE_DESC VARCHAR(255), - GATEWAY_ID VARCHAR (255), - CREATION_TIME TIMESTAMP DEFAULT CURRENT_TIMESTAMP, - UPDATE_TIME TIMESTAMP DEFAULT '0000-00-00 00:00:00', - PRIMARY KEY(MODULE_ID) -); - -CREATE TABLE APPLICATION_DEPLOYMENT -( - DEPLOYMENT_ID VARCHAR(255), - APP_MODULE_ID VARCHAR(255), - COMPUTE_HOSTID VARCHAR(255), - EXECUTABLE_PATH VARCHAR(255), - PARALLELISM VARCHAR(255), - APPLICATION_DESC VARCHAR(255), - CREATION_TIME TIMESTAMP DEFAULT CURRENT_TIMESTAMP, - UPDATE_TIME TIMESTAMP DEFAULT '0000-00-00 00:00:00', - GATEWAY_ID VARCHAR(255), - PRIMARY KEY(DEPLOYMENT_ID), - FOREIGN KEY (COMPUTE_HOSTID) REFERENCES COMPUTE_RESOURCE(RESOURCE_ID) ON DELETE CASCADE, - FOREIGN KEY (APP_MODULE_ID) REFERENCES APPLICATION_MODULE(MODULE_ID) ON DELETE CASCADE -); - -CREATE TABLE MODULE_LOAD_CMD -( - CMD VARCHAR (255) NOT NULL, - APP_DEPLOYMENT_ID VARCHAR (255) NOT NULL, - PRIMARY KEY (APP_DEPLOYMENT_ID,CMD), - FOREIGN KEY (APP_DEPLOYMENT_ID) REFERENCES APPLICATION_DEPLOYMENT(DEPLOYMENT_ID) ON DELETE CASCADE -); - -CREATE TABLE PREJOB_COMMAND -( - APPDEPLOYMENT_ID VARCHAR(255), - COMMAND VARCHAR(255), - PRIMARY KEY(APPDEPLOYMENT_ID, COMMAND), - FOREIGN KEY (APPDEPLOYMENT_ID) REFERENCES APPLICATION_DEPLOYMENT(DEPLOYMENT_ID) ON DELETE CASCADE -); - -CREATE TABLE POSTJOB_COMMAND -( - APPDEPLOYMENT_ID VARCHAR(255), - COMMAND VARCHAR(255), - PRIMARY KEY(APPDEPLOYMENT_ID, COMMAND), - FOREIGN KEY (APPDEPLOYMENT_ID) REFERENCES APPLICATION_DEPLOYMENT(DEPLOYMENT_ID) ON DELETE CASCADE -); - -CREATE TABLE LIBRARY_PREPAND_PATH -( - DEPLOYMENT_ID VARCHAR(255), - NAME VARCHAR(255), - VALUE VARCHAR(255), - PRIMARY KEY(DEPLOYMENT_ID, NAME), - FOREIGN KEY (DEPLOYMENT_ID) REFERENCES APPLICATION_DEPLOYMENT(DEPLOYMENT_ID) ON DELETE CASCADE -); - -CREATE TABLE LIBRARY_APEND_PATH -( - DEPLOYMENT_ID VARCHAR(255), - NAME VARCHAR(255), - VALUE VARCHAR(255), - PRIMARY KEY(DEPLOYMENT_ID, NAME), - FOREIGN KEY (DEPLOYMENT_ID) REFERENCES APPLICATION_DEPLOYMENT(DEPLOYMENT_ID) ON DELETE CASCADE -); - -CREATE TABLE APP_ENVIRONMENT -( - DEPLOYMENT_ID VARCHAR(255), - NAME VARCHAR(255), - VALUE VARCHAR(255), - PRIMARY KEY(DEPLOYMENT_ID, NAME), - FOREIGN KEY (DEPLOYMENT_ID) REFERENCES APPLICATION_DEPLOYMENT(DEPLOYMENT_ID) ON DELETE CASCADE -); - -CREATE TABLE APPLICATION_INTERFACE -( - INTERFACE_ID VARCHAR(255), - APPLICATION_NAME VARCHAR(255), - APPLICATION_DESCRIPTION VARCHAR(255), - GATEWAY_ID VARCHAR(255), - CREATION_TIME TIMESTAMP DEFAULT CURRENT_TIMESTAMP, - UPDATE_TIME TIMESTAMP DEFAULT '0000-00-00 00:00:00', - PRIMARY KEY(INTERFACE_ID) -); - -CREATE TABLE APP_MODULE_MAPPING -( - INTERFACE_ID VARCHAR(255), - MODULE_ID VARCHAR(255), - PRIMARY KEY(INTERFACE_ID, MODULE_ID), - FOREIGN KEY (INTERFACE_ID) REFERENCES APPLICATION_INTERFACE(INTERFACE_ID) ON DELETE CASCADE, - FOREIGN KEY (MODULE_ID) REFERENCES APPLICATION_MODULE(MODULE_ID) ON DELETE CASCADE -); - -CREATE TABLE APPLICATION_INPUT -( - INTERFACE_ID VARCHAR(255), - INPUT_KEY VARCHAR(255), - INPUT_VALUE VARCHAR(255), - DATA_TYPE VARCHAR(255), - METADATA VARCHAR(255), - APP_ARGUMENT VARCHAR(255), - STANDARD_INPUT SMALLINT, - INPUT_ORDER INTEGER, - IS_REQUIRED SMALLINT, - REQUIRED_TO_COMMANDLINE SMALLINT, - DATA_STAGED SMALLINT, - USER_FRIENDLY_DESC VARCHAR(255), - PRIMARY KEY(INTERFACE_ID,INPUT_KEY), - FOREIGN KEY (INTERFACE_ID) REFERENCES APPLICATION_INTERFACE(INTERFACE_ID) ON DELETE CASCADE -); - -CREATE TABLE APPLICATION_OUTPUT -( - INTERFACE_ID VARCHAR(255), - OUTPUT_KEY VARCHAR(255), - OUTPUT_VALUE VARCHAR(255), - DATA_TYPE VARCHAR(255), - IS_REQUIRED SMALLINT, - REQUIRED_TO_COMMANDLINE SMALLINT, - DATA_MOVEMENT SMALLINT, - DATA_NAME_LOCATION VARCHAR(255), - SEARCH_QUERY VARCHAR(255), - APP_ARGUMENT VARCHAR(255), - PRIMARY KEY(INTERFACE_ID,OUTPUT_KEY), - FOREIGN KEY (INTERFACE_ID) REFERENCES APPLICATION_INTERFACE(INTERFACE_ID) ON DELETE CASCADE -); - -CREATE TABLE GATEWAY_PROFILE -( - GATEWAY_ID VARCHAR(255), - CREATION_TIME TIMESTAMP DEFAULT CURRENT_TIMESTAMP, - UPDATE_TIME TIMESTAMP DEFAULT '0000-00-00 00:00:00', - PRIMARY KEY(GATEWAY_ID) -); - -CREATE TABLE COMPUTE_RESOURCE_PREFERENCE -( - GATEWAY_ID VARCHAR(255), - RESOURCE_ID VARCHAR(255), - OVERRIDE_BY_AIRAVATA SMALLINT, - PREFERED_JOB_SUB_PROTOCOL VARCHAR(255), - PREFERED_DATA_MOVE_PROTOCOL VARCHAR(255), - PREFERED_BATCH_QUEUE VARCHAR(255), - SCRATCH_LOCATION VARCHAR(255), - ALLOCATION_PROJECT_NUMBER VARCHAR(255), - LOGIN_USERNAME VARCHAR(255), - PRIMARY KEY(GATEWAY_ID,RESOURCE_ID), - FOREIGN KEY (RESOURCE_ID) REFERENCES COMPUTE_RESOURCE(RESOURCE_ID) ON DELETE CASCADE, - FOREIGN KEY (GATEWAY_ID) REFERENCES GATEWAY_PROFILE(GATEWAY_ID) ON DELETE CASCADE -); - -CREATE TABLE BATCH_QUEUE -( - COMPUTE_RESOURCE_ID VARCHAR(255) NOT NULL, - MAX_RUNTIME INTEGER, - MAX_JOB_IN_QUEUE INTEGER, - QUEUE_DESCRIPTION VARCHAR(255), - QUEUE_NAME VARCHAR(255) NOT NULL, - MAX_PROCESSORS INTEGER, - MAX_NODES INTEGER, - MAX_MEMORY INTEGER, - PRIMARY KEY (COMPUTE_RESOURCE_ID,QUEUE_NAME), - FOREIGN KEY (COMPUTE_RESOURCE_ID) REFERENCES COMPUTE_RESOURCE(RESOURCE_ID) ON DELETE CASCADE -); - -CREATE TABLE COMPUTE_RESOURCE_FILE_SYSTEM -( - COMPUTE_RESOURCE_ID VARCHAR (255) NOT NULL, - PATH VARCHAR (255), - FILE_SYSTEM VARCHAR (255) NOT NULL, - PRIMARY KEY (COMPUTE_RESOURCE_ID,FILE_SYSTEM), - FOREIGN KEY (COMPUTE_RESOURCE_ID) REFERENCES COMPUTE_RESOURCE(RESOURCE_ID) ON DELETE CASCADE - ); - -CREATE TABLE JOB_SUBMISSION_INTERFACE -( - JOB_SUBMISSION_INTERFACE_ID VARCHAR (255) NOT NULL, - COMPUTE_RESOURCE_ID VARCHAR (255) NOT NULL, - JOB_SUBMISSION_PROTOCOL VARCHAR (255) NOT NULL, - PRIORITY_ORDER INTEGER, - CREATION_TIME TIMESTAMP DEFAULT CURRENT_TIMESTAMP, - UPDATE_TIME TIMESTAMP DEFAULT '0000-00-00 00:00:00', - PRIMARY KEY (COMPUTE_RESOURCE_ID,JOB_SUBMISSION_INTERFACE_ID), - FOREIGN KEY (COMPUTE_RESOURCE_ID) REFERENCES COMPUTE_RESOURCE(RESOURCE_ID) ON DELETE CASCADE -); - -CREATE TABLE DATA_MOVEMENT_INTERFACE -( - COMPUTE_RESOURCE_ID VARCHAR (255) NOT NULL, - DATA_MOVEMENT_PROTOCOL VARCHAR (255) NOT NULL, - DATA_MOVEMENT_INTERFACE_ID VARCHAR (255) NOT NULL, - PRIORITY_ORDER INTEGER, - CREATION_TIME TIMESTAMP DEFAULT CURRENT_TIMESTAMP, - UPDATE_TIME TIMESTAMP DEFAULT '0000-00-00 00:00:00', - PRIMARY KEY (COMPUTE_RESOURCE_ID,DATA_MOVEMENT_INTERFACE_ID), - FOREIGN KEY (COMPUTE_RESOURCE_ID) REFERENCES COMPUTE_RESOURCE(RESOURCE_ID) ON DELETE CASCADE -); - -CREATE TABLE JOB_MANAGER_COMMAND -( - RESOURCE_JOB_MANAGER_ID VARCHAR (255) NOT NULL, - COMMAND_TYPE VARCHAR (255) NOT NULL, - COMMAND VARCHAR (255), - PRIMARY KEY (RESOURCE_JOB_MANAGER_ID,COMMAND_TYPE), - FOREIGN KEY (RESOURCE_JOB_MANAGER_ID) REFERENCES RESOURCE_JOB_MANAGER(RESOURCE_JOB_MANAGER_ID) ON DELETE CASCADE -); - -CREATE TABLE LOCAL_SUBMISSION -( - RESOURCE_JOB_MANAGER_ID VARCHAR (255) NOT NULL, - JOB_SUBMISSION_INTERFACE_ID VARCHAR (255) NOT NULL, - CREATION_TIME TIMESTAMP DEFAULT CURRENT_TIMESTAMP, - UPDATE_TIME TIMESTAMP DEFAULT '0000-00-00 00:00:00', - PRIMARY KEY (JOB_SUBMISSION_INTERFACE_ID), - FOREIGN KEY (RESOURCE_JOB_MANAGER_ID) REFERENCES RESOURCE_JOB_MANAGER(RESOURCE_JOB_MANAGER_ID) - ); - -CREATE TABLE LOCAL_DATA_MOVEMENT -( - DATA_MOVEMENT_INTERFACE_ID VARCHAR (255) NOT NULL, - PRIMARY KEY (DATA_MOVEMENT_INTERFACE_ID) -); - -CREATE TABLE WORKFLOW -( - WF_TEMPLATE_ID VARCHAR (255) NOT NULL, - WF_NAME VARCHAR (255) NOT NULL, - GRAPH CLOB, - OWNER VARCHAR(255), - GATEWAY_ID VARCHAR(255), - CREATION_TIME TIMESTAMP DEFAULT CURRENT_TIMESTAMP, - UPDATE_TIME TIMESTAMP DEFAULT '0000-00-00 00:00:00', - IMAGE BLOB, - PRIMARY KEY (WF_TEMPLATE_ID) -); - -CREATE TABLE WORKFLOW_INPUT -( - WF_TEMPLATE_ID VARCHAR(255), - INPUT_KEY VARCHAR(255), - INPUT_VALUE CLOB, - DATA_TYPE VARCHAR(255), - METADATA VARCHAR(255), - APP_ARGUMENT VARCHAR(255), - STANDARD_INPUT SMALLINT, - USER_FRIENDLY_DESC VARCHAR(255), - PRIMARY KEY(WF_TEMPLATE_ID,INPUT_KEY), - FOREIGN KEY (WF_TEMPLATE_ID) REFERENCES WORKFLOW(WF_TEMPLATE_ID) ON DELETE CASCADE -); - -CREATE TABLE WORKFLOW_OUTPUT -( - WF_TEMPLATE_ID VARCHAR(255), - OUTPUT_KEY VARCHAR(255), - OUTPUT_VALUE CLOB, - DATA_TYPE VARCHAR(255), - PRIMARY KEY(WF_TEMPLATE_ID,OUTPUT_KEY), - FOREIGN KEY (WF_TEMPLATE_ID) REFERENCES WORKFLOW(WF_TEMPLATE_ID) ON DELETE CASCADE -); - - - -CREATE TABLE CONFIGURATION -( - CONFIG_KEY VARCHAR(255), - CONFIG_VAL VARCHAR(255), - PRIMARY KEY(CONFIG_KEY, CONFIG_VAL) -); - -INSERT INTO CONFIGURATION (CONFIG_KEY, CONFIG_VAL) VALUES('app_catalog_version', '0.15'); - - - http://git-wip-us.apache.org/repos/asf/airavata/blob/ec8c6202/modules/app-catalog/app-catalog-data/src/main/resources/appcatalog-mysql.sql ---------------------------------------------------------------------- diff --git a/modules/app-catalog/app-catalog-data/src/main/resources/appcatalog-mysql.sql b/modules/app-catalog/app-catalog-data/src/main/resources/appcatalog-mysql.sql deleted file mode 100644 index 234a26a..0000000 --- a/modules/app-catalog/app-catalog-data/src/main/resources/appcatalog-mysql.sql +++ /dev/null @@ -1,453 +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. - * - */ -CREATE TABLE COMPUTE_RESOURCE -( - RESOURCE_ID VARCHAR (255) NOT NULL, - HOST_NAME VARCHAR (255) NOT NULL, - RESOURCE_DESCRIPTION VARCHAR (255), - CREATION_TIME TIMESTAMP DEFAULT NOW(), - UPDATE_TIME TIMESTAMP DEFAULT '0000-00-00 00:00:00', - MAX_MEMORY_NODE INTEGER, - PRIMARY KEY (RESOURCE_ID) -); - -CREATE TABLE HOST_ALIAS -( - RESOURCE_ID VARCHAR(255), - ALIAS VARCHAR(255), - PRIMARY KEY(RESOURCE_ID,ALIAS), - FOREIGN KEY (RESOURCE_ID) REFERENCES COMPUTE_RESOURCE(RESOURCE_ID) ON DELETE CASCADE -); - -CREATE TABLE HOST_IPADDRESS -( - RESOURCE_ID VARCHAR(255), - IP_ADDRESS VARCHAR(255), - PRIMARY KEY(RESOURCE_ID,IP_ADDRESS), - FOREIGN KEY (RESOURCE_ID) REFERENCES COMPUTE_RESOURCE(RESOURCE_ID) ON DELETE CASCADE -); - -CREATE TABLE GSISSH_SUBMISSION -( - SUBMISSION_ID VARCHAR(255), - RESOURCE_JOB_MANAGER VARCHAR(255), - SSH_PORT INTEGER, - INSTALLED_PATH VARCHAR(255), - MONITOR_MODE VARCHAR(255), - PRIMARY KEY(SUBMISSION_ID) -); - -CREATE TABLE GSISSH_EXPORT -( - SUBMISSION_ID VARCHAR(255), - EXPORT VARCHAR(255), - PRIMARY KEY(SUBMISSION_ID, EXPORT), - FOREIGN KEY (SUBMISSION_ID) REFERENCES GSISSH_SUBMISSION(SUBMISSION_ID) ON DELETE CASCADE -); - -CREATE TABLE GSISSH_PREJOBCOMMAND -( - SUBMISSION_ID VARCHAR(255), - COMMAND VARCHAR(255), - PRIMARY KEY(SUBMISSION_ID, COMMAND), - FOREIGN KEY (SUBMISSION_ID) REFERENCES GSISSH_SUBMISSION(SUBMISSION_ID) ON DELETE CASCADE -); - -CREATE TABLE GSISSH_POSTJOBCOMMAND -( - SUBMISSION_ID VARCHAR(255), - COMMAND VARCHAR(255), - PRIMARY KEY(SUBMISSION_ID, COMMAND), - FOREIGN KEY (SUBMISSION_ID) REFERENCES GSISSH_SUBMISSION(SUBMISSION_ID) ON DELETE CASCADE -); - -CREATE TABLE GLOBUS_SUBMISSION -( - SUBMISSION_ID VARCHAR(255), - RESOURCE_JOB_MANAGER VARCHAR(255), - SECURITY_PROTOCAL VARCHAR(255), - PRIMARY KEY(SUBMISSION_ID) -); -CREATE TABLE UNICORE_SUBMISSION -( - SUBMISSION_ID VARCHAR(255), - SECURITY_PROTOCAL VARCHAR(255), - UNICORE_ENDPOINT_URL VARCHAR(255), - PRIMARY KEY(SUBMISSION_ID) -); - -CREATE TABLE UNICORE_DATAMOVEMENT -( - DATAMOVEMENT_ID VARCHAR(255), - SECURITY_PROTOCAL VARCHAR(255), - UNICORE_ENDPOINT_URL VARCHAR(255), - PRIMARY KEY(DATAMOVEMENT_ID) -); - -CREATE TABLE GLOBUS_GK_ENDPOINT -( - SUBMISSION_ID VARCHAR(255), - ENDPOINT VARCHAR(255), - PRIMARY KEY(SUBMISSION_ID, ENDPOINT), - FOREIGN KEY (SUBMISSION_ID) REFERENCES GLOBUS_SUBMISSION(SUBMISSION_ID) ON DELETE CASCADE -); - -CREATE TABLE RESOURCE_JOB_MANAGER -( - RESOURCE_JOB_MANAGER_ID VARCHAR (255) NOT NULL, - PUSH_MONITORING_ENDPOINT VARCHAR (255), - JOB_MANAGER_BIN_PATH VARCHAR (255), - RESOURCE_JOB_MANAGER_TYPE VARCHAR (255) NOT NULL, - CREATION_TIME TIMESTAMP DEFAULT NOW(), - UPDATE_TIME TIMESTAMP DEFAULT '0000-00-00 00:00:00', - PRIMARY KEY (RESOURCE_JOB_MANAGER_ID) -); - -CREATE TABLE SSH_JOB_SUBMISSION -( - RESOURCE_JOB_MANAGER_ID VARCHAR (255) NOT NULL, - JOB_SUBMISSION_INTERFACE_ID VARCHAR (255) NOT NULL, - ALTERNATIVE_SSH_HOSTNAME VARCHAR (255), - SECURITY_PROTOCOL VARCHAR (255) NOT NULL, - SSH_PORT INTEGER, - MONITOR_MODE VARCHAR (255), - CREATION_TIME TIMESTAMP DEFAULT NOW(), - UPDATE_TIME TIMESTAMP DEFAULT '0000-00-00 00:00:00' , - PRIMARY KEY (JOB_SUBMISSION_INTERFACE_ID), - FOREIGN KEY (RESOURCE_JOB_MANAGER_ID) REFERENCES RESOURCE_JOB_MANAGER(RESOURCE_JOB_MANAGER_ID) -); - - -CREATE TABLE SCP_DATA_MOVEMENT -( - QUEUE_DESCRIPTION VARCHAR (255), - DATA_MOVEMENT_INTERFACE_ID VARCHAR (255) NOT NULL, - SECURITY_PROTOCOL VARCHAR (255) NOT NULL, - ALTERNATIVE_SCP_HOSTNAME VARCHAR (255), - SSH_PORT INTEGER, - CREATION_TIME TIMESTAMP DEFAULT NOW(), - UPDATE_TIME TIMESTAMP DEFAULT '0000-00-00 00:00:00' , - PRIMARY KEY (DATA_MOVEMENT_INTERFACE_ID) -); - -CREATE TABLE GRIDFTP_DATA_MOVEMENT -( - DATA_MOVEMENT_INTERFACE_ID VARCHAR (255) NOT NULL, - SECURITY_PROTOCOL VARCHAR (255) NOT NULL, - CREATION_TIME TIMESTAMP DEFAULT NOW(), - UPDATE_TIME TIMESTAMP DEFAULT '0000-00-00 00:00:00' , - PRIMARY KEY (DATA_MOVEMENT_INTERFACE_ID) -); - -CREATE TABLE GRIDFTP_ENDPOINT -( - ENDPOINT VARCHAR (255) NOT NULL, - DATA_MOVEMENT_INTERFACE_ID VARCHAR (255) NOT NULL, - PRIMARY KEY (DATA_MOVEMENT_INTERFACE_ID,ENDPOINT), - CREATION_TIME TIMESTAMP DEFAULT NOW(), - UPDATE_TIME TIMESTAMP DEFAULT '0000-00-00 00:00:00' , - FOREIGN KEY (DATA_MOVEMENT_INTERFACE_ID) REFERENCES GRIDFTP_DATA_MOVEMENT(DATA_MOVEMENT_INTERFACE_ID) ON DELETE CASCADE -); - ---CREATE TABLE JOB_SUBMISSION_PROTOCOL ---( --- RESOURCE_ID VARCHAR(255), --- SUBMISSION_ID VARCHAR(255), --- JOB_TYPE VARCHAR(255), --- PRIMARY KEY(RESOURCE_ID,SUBMISSION_ID,JOB_TYPE), --- FOREIGN KEY (RESOURCE_ID) REFERENCES COMPUTE_RESOURCE(RESOURCE_ID) ON DELETE CASCADE ---); --- ---CREATE TABLE DATA_MOVEMENT_PROTOCOL ---( --- RESOURCE_ID VARCHAR(255), --- DATA_MOVE_ID VARCHAR(255), --- DATA_MOVE_TYPE VARCHAR(255), --- PRIMARY KEY(RESOURCE_ID,DATA_MOVE_ID,DATA_MOVE_TYPE), --- FOREIGN KEY (RESOURCE_ID) REFERENCES COMPUTE_RESOURCE(RESOURCE_ID) ON DELETE CASCADE ---); - -CREATE TABLE APPLICATION_MODULE -( - MODULE_ID VARCHAR(255), - MODULE_NAME VARCHAR(255), - MODULE_VERSION VARCHAR(255), - MODULE_DESC VARCHAR(255), - GATEWAY_ID VARCHAR (255), - CREATION_TIME TIMESTAMP DEFAULT NOW(), - UPDATE_TIME TIMESTAMP DEFAULT '0000-00-00 00:00:00' , - PRIMARY KEY(MODULE_ID) -); - -CREATE TABLE APPLICATION_DEPLOYMENT -( - DEPLOYMENT_ID VARCHAR(255), - APP_MODULE_ID VARCHAR(255), - COMPUTE_HOSTID VARCHAR(255), - EXECUTABLE_PATH VARCHAR(255), - PARALLELISM VARCHAR(255), - APPLICATION_DESC VARCHAR(255), - ENV_MODULE_LOAD_CMD VARCHAR(255), - CREATION_TIME TIMESTAMP DEFAULT NOW(), - UPDATE_TIME TIMESTAMP DEFAULT '0000-00-00 00:00:00' , - GATEWAY_ID VARCHAR(255), - PRIMARY KEY(DEPLOYMENT_ID), - FOREIGN KEY (COMPUTE_HOSTID) REFERENCES COMPUTE_RESOURCE(RESOURCE_ID) ON DELETE CASCADE, - FOREIGN KEY (APP_MODULE_ID) REFERENCES APPLICATION_MODULE(MODULE_ID) ON DELETE CASCADE -); - -CREATE TABLE LIBRARY_PREPAND_PATH -( - DEPLOYMENT_ID VARCHAR(255), - NAME VARCHAR(255), - VALUE VARCHAR(255), - PRIMARY KEY(DEPLOYMENT_ID, NAME), - FOREIGN KEY (DEPLOYMENT_ID) REFERENCES APPLICATION_DEPLOYMENT(DEPLOYMENT_ID) ON DELETE CASCADE -); - -CREATE TABLE LIBRARY_APEND_PATH -( - DEPLOYMENT_ID VARCHAR(255), - NAME VARCHAR(255), - VALUE VARCHAR(255), - PRIMARY KEY(DEPLOYMENT_ID, NAME), - FOREIGN KEY (DEPLOYMENT_ID) REFERENCES APPLICATION_DEPLOYMENT(DEPLOYMENT_ID) ON DELETE CASCADE -); - -CREATE TABLE APP_ENVIRONMENT -( - DEPLOYMENT_ID VARCHAR(255), - NAME VARCHAR(255), - VALUE VARCHAR(255), - PRIMARY KEY(DEPLOYMENT_ID, NAME), - FOREIGN KEY (DEPLOYMENT_ID) REFERENCES APPLICATION_DEPLOYMENT(DEPLOYMENT_ID) ON DELETE CASCADE -); - -CREATE TABLE PREJOB_COMMAND -( - APPDEPLOYMENT_ID VARCHAR(255), - COMMAND VARCHAR(255), - PRIMARY KEY(APPDEPLOYMENT_ID, COMMAND), - FOREIGN KEY (APPDEPLOYMENT_ID) REFERENCES APPLICATION_DEPLOYMENT(DEPLOYMENT_ID) ON DELETE CASCADE -); - -CREATE TABLE POSTJOB_COMMAND -( - APPLICATION_DEPLOYMENT VARCHAR(255), - COMMAND VARCHAR(255), - PRIMARY KEY(APPLICATION_DEPLOYMENT, COMMAND), - FOREIGN KEY (APPLICATION_DEPLOYMENT) REFERENCES APPLICATION_DEPLOYMENT(DEPLOYMENT_ID) ON DELETE CASCADE -); - -CREATE TABLE APPLICATION_INTERFACE -( - INTERFACE_ID VARCHAR(255), - APPLICATION_NAME VARCHAR(255), - APPLICATION_DESCRIPTION VARCHAR(255), - CREATION_TIME TIMESTAMP DEFAULT NOW(), - UPDATE_TIME TIMESTAMP DEFAULT '0000-00-00 00:00:00' , - PRIMARY KEY(INTERFACE_ID) -); - -CREATE TABLE APP_MODULE_MAPPING -( - INTERFACE_ID VARCHAR(255), - MODULE_ID VARCHAR(255), - PRIMARY KEY(INTERFACE_ID, MODULE_ID), - FOREIGN KEY (INTERFACE_ID) REFERENCES APPLICATION_INTERFACE(INTERFACE_ID) ON DELETE CASCADE, - FOREIGN KEY (MODULE_ID) REFERENCES APPLICATION_MODULE(MODULE_ID) ON DELETE CASCADE -); - -CREATE TABLE APPLICATION_INPUT -( - INTERFACE_ID VARCHAR(255), - INPUT_KEY VARCHAR(255), - INPUT_VALUE VARCHAR(255), - DATA_TYPE VARCHAR(255), - METADATA VARCHAR(255), - APP_ARGUMENT VARCHAR(255), - STANDARD_INPUT SMALLINT, - USER_FRIENDLY_DESC VARCHAR(255), - INPUT_ORDER INTEGER, - IS_REQUIRED SMALLINT, - REQUIRED_TO_COMMANDLINE SMALLINT, - DATA_STAGED SMALLINT, - PRIMARY KEY(INTERFACE_ID,INPUT_KEY), - FOREIGN KEY (INTERFACE_ID) REFERENCES APPLICATION_INTERFACE(INTERFACE_ID) ON DELETE CASCADE -); - -CREATE TABLE APPLICATION_OUTPUT -( - INTERFACE_ID VARCHAR(255), - OUTPUT_KEY VARCHAR(255), - OUTPUT_VALUE VARCHAR(255), - DATA_TYPE VARCHAR(255), - IS_REQUIRED SMALLINT, - REQUIRED_TO_COMMANDLINE SMALLINT, - DATA_MOVEMENT SMALLINT, - DATA_NAME_LOCATION VARCHAR(255), - SEARCH_QUERY VARCHAR(255), - APP_ARGUMENT VARCHAR(255), - PRIMARY KEY(INTERFACE_ID,OUTPUT_KEY), - FOREIGN KEY (INTERFACE_ID) REFERENCES APPLICATION_INTERFACE(INTERFACE_ID) ON DELETE CASCADE -); - -CREATE TABLE GATEWAY_PROFILE -( - GATEWAY_ID VARCHAR(255), - CREATION_TIME TIMESTAMP DEFAULT NOW(), - UPDATE_TIME TIMESTAMP DEFAULT '0000-00-00 00:00:00' , - PRIMARY KEY(GATEWAY_ID) -); - -CREATE TABLE COMPUTE_RESOURCE_PREFERENCE -( - GATEWAY_ID VARCHAR(255), - RESOURCE_ID VARCHAR(255), - OVERRIDE_BY_AIRAVATA SMALLINT, - PREFERED_JOB_SUB_PROTOCOL VARCHAR(255), - PREFERED_DATA_MOVE_PROTOCOL VARCHAR(255), - PREFERED_BATCH_QUEUE VARCHAR(255), - SCRATCH_LOCATION VARCHAR(255), - ALLOCATION_PROJECT_NUMBER VARCHAR(255), - LOGIN_USERNAME VARCHAR(255), - PRIMARY KEY(GATEWAY_ID,RESOURCE_ID), - FOREIGN KEY (RESOURCE_ID) REFERENCES COMPUTE_RESOURCE(RESOURCE_ID) ON DELETE CASCADE, - FOREIGN KEY (GATEWAY_ID) REFERENCES GATEWAY_PROFILE(GATEWAY_ID) ON DELETE CASCADE -); - -CREATE TABLE BATCH_QUEUE -( - COMPUTE_RESOURCE_ID VARCHAR(255) NOT NULL, - MAX_RUNTIME INTEGER, - MAX_JOB_IN_QUEUE INTEGER, - QUEUE_DESCRIPTION VARCHAR(255), - QUEUE_NAME VARCHAR(255) NOT NULL, - MAX_PROCESSORS INTEGER, - MAX_NODES INTEGER, - MAX_MEMORY INTEGER, - PRIMARY KEY (COMPUTE_RESOURCE_ID,QUEUE_NAME), - FOREIGN KEY (COMPUTE_RESOURCE_ID) REFERENCES COMPUTE_RESOURCE(RESOURCE_ID) ON DELETE CASCADE -); - -CREATE TABLE COMPUTE_RESOURCE_FILE_SYSTEM -( - COMPUTE_RESOURCE_ID VARCHAR (255) NOT NULL, - PATH VARCHAR (255), - FILE_SYSTEM VARCHAR (255) NOT NULL, - PRIMARY KEY (COMPUTE_RESOURCE_ID,FILE_SYSTEM), - FOREIGN KEY (COMPUTE_RESOURCE_ID) REFERENCES COMPUTE_RESOURCE(RESOURCE_ID) ON DELETE CASCADE -); - -CREATE TABLE JOB_SUBMISSION_INTERFACE -( - JOB_SUBMISSION_INTERFACE_ID VARCHAR (255) NOT NULL, - COMPUTE_RESOURCE_ID VARCHAR (255) NOT NULL, - JOB_SUBMISSION_PROTOCOL VARCHAR (255) NOT NULL, - PRIORITY_ORDER INTEGER, - CREATION_TIME TIMESTAMP DEFAULT NOW(), - UPDATE_TIME TIMESTAMP DEFAULT '0000-00-00 00:00:00', - PRIMARY KEY (COMPUTE_RESOURCE_ID,JOB_SUBMISSION_INTERFACE_ID), - FOREIGN KEY (COMPUTE_RESOURCE_ID) REFERENCES COMPUTE_RESOURCE(RESOURCE_ID) ON DELETE CASCADE -); - -CREATE TABLE DATA_MOVEMENT_INTERFACE -( - COMPUTE_RESOURCE_ID VARCHAR (255) NOT NULL, - DATA_MOVEMENT_PROTOCOL VARCHAR (255) NOT NULL, - DATA_MOVEMENT_INTERFACE_ID VARCHAR (255) NOT NULL, - PRIORITY_ORDER INTEGER, - CREATION_TIME TIMESTAMP DEFAULT NOW(), - UPDATE_TIME TIMESTAMP DEFAULT '0000-00-00 00:00:00', - PRIMARY KEY (COMPUTE_RESOURCE_ID,DATA_MOVEMENT_INTERFACE_ID), - FOREIGN KEY (COMPUTE_RESOURCE_ID) REFERENCES COMPUTE_RESOURCE(RESOURCE_ID) ON DELETE CASCADE -); - -CREATE TABLE JOB_MANAGER_COMMAND -( - RESOURCE_JOB_MANAGER_ID VARCHAR (255) NOT NULL, - COMMAND_TYPE VARCHAR (255) NOT NULL, - COMMAND VARCHAR (255), - PRIMARY KEY (RESOURCE_JOB_MANAGER_ID,COMMAND_TYPE), - FOREIGN KEY (RESOURCE_JOB_MANAGER_ID) REFERENCES RESOURCE_JOB_MANAGER(RESOURCE_JOB_MANAGER_ID) ON DELETE CASCADE -); - -CREATE TABLE LOCAL_SUBMISSION -( - RESOURCE_JOB_MANAGER_ID VARCHAR (255) NOT NULL, - JOB_SUBMISSION_INTERFACE_ID VARCHAR (255) NOT NULL, - CREATION_TIME TIMESTAMP DEFAULT NOW(), - UPDATE_TIME TIMESTAMP DEFAULT '0000-00-00 00:00:00', - PRIMARY KEY (JOB_SUBMISSION_INTERFACE_ID), - FOREIGN KEY (RESOURCE_JOB_MANAGER_ID) REFERENCES RESOURCE_JOB_MANAGER(RESOURCE_JOB_MANAGER_ID) -); - -CREATE TABLE LOCAL_DATA_MOVEMENT -( - DATA_MOVEMENT_INTERFACE_ID VARCHAR (255) NOT NULL, - PRIMARY KEY (DATA_MOVEMENT_INTERFACE_ID) -); - -CREATE TABLE WORKFLOW -( - WF_TEMPLATE_ID VARCHAR (255) NOT NULL, - WF_NAME VARCHAR (255) NOT NULL, - GRAPH LONGTEXT, - OWNER VARCHAR(255), - CREATION_TIME TIMESTAMP DEFAULT NOW(), - UPDATE_TIME TIMESTAMP DEFAULT '0000-00-00 00:00:00', - IMAGE BLOB, - PRIMARY KEY (WF_TEMPLATE_ID) -); - -CREATE TABLE WORKFLOW_INPUT -( - WF_TEMPLATE_ID VARCHAR(255), - INPUT_KEY VARCHAR(255), - INPUT_VALUE LONGTEXT, - DATA_TYPE VARCHAR(255), - METADATA VARCHAR(255), - APP_ARGUMENT VARCHAR(255), - STANDARD_INPUT SMALLINT, - USER_FRIENDLY_DESC VARCHAR(255), - PRIMARY KEY(WF_TEMPLATE_ID,INPUT_KEY), - FOREIGN KEY (WF_TEMPLATE_ID) REFERENCES WORKFLOW(WF_TEMPLATE_ID) ON DELETE CASCADE -); - -CREATE TABLE WORKFLOW_OUTPUT -( - WF_TEMPLATE_ID VARCHAR(255), - OUTPUT_KEY VARCHAR(255), - OUTPUT_VALUE LONGTEXT, - DATA_TYPE VARCHAR(255), - PRIMARY KEY(WF_TEMPLATE_ID,OUTPUT_KEY), - FOREIGN KEY (WF_TEMPLATE_ID) REFERENCES WORKFLOW(WF_TEMPLATE_ID) ON DELETE CASCADE -); - -CREATE TABLE CONFIGURATION -( - CONFIG_KEY VARCHAR(255), - CONFIG_VAL VARCHAR(255), - PRIMARY KEY(CONFIG_KEY, CONFIG_VAL) -); - -INSERT INTO CONFIGURATION (CONFIG_KEY, CONFIG_VAL) VALUES('app_catalog_version', '0.15'); -
