Examples of GridftpEndpoint

Examples of org.apache.aiaravata.application.catalog.data.model.GridftpEndpoint

92
93
94
95
96
97
98
99
100
101
102
      em.getTransaction().begin();
      AppCatalogQueryGenerator generator = new AppCatalogQueryGenerator(GRIDFTP_ENDPOINT);
      generator.setParameter(GridftpEndpointConstants.ENDPOINT, ids.get(GridftpEndpointConstants.ENDPOINT));
      generator.setParameter(GridftpEndpointConstants.DATA_MOVEMENT_INTERFACE_ID, ids.get(GridftpEndpointConstants.DATA_MOVEMENT_INTERFACE_ID));
      Query q = generator.selectQuery(em);
      GridftpEndpoint gridftpEndpoint = (GridftpEndpoint) q.getSingleResult();
      GridftpEndpointResource gridftpEndpointResource = (GridftpEndpointResource) AppCatalogJPAUtils.getResource(AppCatalogResourceType.GRIDFTP_ENDPOINT, gridftpEndpoint);
      em.getTransaction().commit();
      em.close();
      return gridftpEndpointResource;
    } catch (ApplicationSettingsException e) {
View Full Code Here

Examples of org.apache.aiaravata.application.catalog.data.model.GridftpEndpoint

124
125
126
127
128
129
130
131
132
133
134
      if ((fieldName.equals(GridftpEndpointConstants.ENDPOINT)) || (fieldName.equals(GridftpEndpointConstants.DATA_MOVEMENT_INTERFACE_ID))) {
        generator.setParameter(fieldName, value);
        q = generator.selectQuery(em);
        List<?> results = q.getResultList();
        for (Object result : results) {
          GridftpEndpoint gridftpEndpoint = (GridftpEndpoint) result;
          GridftpEndpointResource gridftpEndpointResource = (GridftpEndpointResource) AppCatalogJPAUtils.getResource(AppCatalogResourceType.GRIDFTP_ENDPOINT, gridftpEndpoint);
          gridftpEndpointResources.add(gridftpEndpointResource);
        }
      } else {
        em.getTransaction().commit();
View Full Code Here

Examples of org.apache.aiaravata.application.catalog.data.model.GridftpEndpoint

174
175
176
177
178
179
180
181
182
183
184
      if ((fieldName.equals(GridftpEndpointConstants.ENDPOINT)) || (fieldName.equals(GridftpEndpointConstants.DATA_MOVEMENT_INTERFACE_ID))) {
        generator.setParameter(fieldName, value);
        q = generator.selectQuery(em);
        List<?> results = q.getResultList();
        for (Object result : results) {
          GridftpEndpoint gridftpEndpoint = (GridftpEndpoint) result;
          GridftpEndpointResource gridftpEndpointResource = (GridftpEndpointResource) AppCatalogJPAUtils.getResource(AppCatalogResourceType.GRIDFTP_ENDPOINT, gridftpEndpoint);
          gridftpEndpointResourceIDs.add(gridftpEndpointResource.getDataMovementInterfaceId());
        }
      } else {
        em.getTransaction().commit();
View Full Code Here

Examples of org.apache.aiaravata.application.catalog.data.model.GridftpEndpoint

205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
  @Override
  public void save() throws AppCatalogException {
    EntityManager em = null;
    try {
      em = AppCatalogJPAUtils.getEntityManager();
      GridftpEndpoint existingGridftpEndpoint = em.find(GridftpEndpoint.class, new GridftpEndpoint_PK(endpoint, dataMovementInterfaceId));
      em.close();
      GridftpEndpoint gridftpEndpoint;
      em = AppCatalogJPAUtils.getEntityManager();
      em.getTransaction().begin();
      if (existingGridftpEndpoint == null) {
        gridftpEndpoint = new GridftpEndpoint();
      } else {
        gridftpEndpoint = existingGridftpEndpoint;
      }
      gridftpEndpoint.setEndpoint(getEndpoint());
      gridftpEndpoint.setDataMovementInterfaceId(getDataMovementInterfaceId());
      GridftpDataMovement gridftpDataMovement = em.find(GridftpDataMovement.class, getDataMovementInterfaceId());
      gridftpEndpoint.setGridftpDataMovement(gridftpDataMovement);
      if (existingGridftpEndpoint == null) {
        em.persist(gridftpEndpoint);
      } else {
        em.merge(gridftpEndpoint);
      }
View Full Code Here

Examples of org.apache.aiaravata.application.catalog.data.model.GridftpEndpoint

251
252
253
254
255
256
257
258
259
260
261
      throw new AppCatalogException("Identifier should be a map with the field name and it's value");
    }
    EntityManager em = null;
    try {
      em = AppCatalogJPAUtils.getEntityManager();
      GridftpEndpoint gridftpEndpoint = em.find(GridftpEndpoint.class, new GridftpEndpoint_PK(ids.get(GridftpEndpointConstants.ENDPOINT), ids.get(GridftpEndpointConstants.DATA_MOVEMENT_INTERFACE_ID)));
      em.close();
      return gridftpEndpoint != null;
    } catch (ApplicationSettingsException e) {
      logger.error(e.getMessage(), e);
      throw new AppCatalogException(e);
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.