gpt4 book ai didi

org.finra.herd.dao.helper.XmlHelper.objectToXml()方法的使用及代码示例

转载 作者:知者 更新时间:2024-03-18 23:14:40 29 4
gpt4 key购买 nike

本文整理了Java中org.finra.herd.dao.helper.XmlHelper.objectToXml()方法的一些代码示例,展示了XmlHelper.objectToXml()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。XmlHelper.objectToXml()方法的具体详情如下:
包路径:org.finra.herd.dao.helper.XmlHelper
类名称:XmlHelper
方法名:objectToXml

XmlHelper.objectToXml介绍

[英]Returns XML representation of the object.
[中]返回对象的XML表示形式。

代码示例

代码示例来源:origin: org.finra.herd/herd-dao

/**
 * Returns XML representation of the object.
 *
 * @param obj the Java object to be serialized
 *
 * @return the XML representation of this object
 * @throws javax.xml.bind.JAXBException if a JAXB error occurred.
 */
public String objectToXml(Object obj) throws JAXBException
{
  // By default, we do not ask the marshalled XML data to be formatted with line feeds and indentation.
  return objectToXml(obj, false);
}

代码示例来源:origin: FINRAOS/herd

/**
 * Returns XML representation of the object.
 *
 * @param obj the Java object to be serialized
 *
 * @return the XML representation of this object
 * @throws javax.xml.bind.JAXBException if a JAXB error occurred.
 */
public String objectToXml(Object obj) throws JAXBException
{
  // By default, we do not ask the marshalled XML data to be formatted with line feeds and indentation.
  return objectToXml(obj, false);
}

代码示例来源:origin: FINRAOS/herd

private HttpEntity getHttpEntity(Object content) throws UnsupportedCharsetException, JAXBException
{
  String xml = xmlHelper.objectToXml(content);
  LOGGER.debug("xml = " + xml);
  ContentType contentType = ContentType.APPLICATION_XML.withCharset(StandardCharsets.UTF_8);
  return new StringEntity(xml, contentType);
}

代码示例来源:origin: org.finra.herd/herd-service

@NamespacePermission(fields = "#emrClusterDefinitionKey?.namespace", permissions = NamespacePermissionEnum.WRITE)
@Override
public EmrClusterDefinitionInformation deleteEmrClusterDefinition(EmrClusterDefinitionKey emrClusterDefinitionKey) throws Exception
{
  // Perform validate and trim of the EMR cluster definition key.
  emrClusterDefinitionHelper.validateEmrClusterDefinitionKey(emrClusterDefinitionKey);
  // Retrieve and ensure that a EMR cluster definition already exists with the specified key.
  EmrClusterDefinitionEntity emrClusterDefinitionEntity = emrClusterDefinitionDaoHelper.getEmrClusterDefinitionEntity(emrClusterDefinitionKey);
  // Log the existing EMR cluster definition.
  LOGGER.info("Logging EMR cluster definition being deleted. emrClusterDefinition={}",
    xmlHelper.objectToXml(createEmrClusterDefinitionFromEntity(emrClusterDefinitionEntity), true));
  // Delete the EMR cluster definition.
  emrClusterDefinitionDao.delete(emrClusterDefinitionEntity);
  // Create and return the EMR cluster definition object from the deleted entity.
  return createEmrClusterDefinitionFromEntity(emrClusterDefinitionEntity);
}

代码示例来源:origin: FINRAOS/herd

@NamespacePermission(fields = "#emrClusterDefinitionKey?.namespace", permissions = NamespacePermissionEnum.WRITE)
@Override
public EmrClusterDefinitionInformation deleteEmrClusterDefinition(EmrClusterDefinitionKey emrClusterDefinitionKey) throws Exception
{
  // Perform validate and trim of the EMR cluster definition key.
  emrClusterDefinitionHelper.validateEmrClusterDefinitionKey(emrClusterDefinitionKey);
  // Retrieve and ensure that a EMR cluster definition already exists with the specified key.
  EmrClusterDefinitionEntity emrClusterDefinitionEntity = emrClusterDefinitionDaoHelper.getEmrClusterDefinitionEntity(emrClusterDefinitionKey);
  // Log the existing EMR cluster definition.
  LOGGER.info("Logging EMR cluster definition being deleted. emrClusterDefinition={}",
    xmlHelper.objectToXml(createEmrClusterDefinitionFromEntity(emrClusterDefinitionEntity), true));
  // Delete the EMR cluster definition.
  emrClusterDefinitionDao.delete(emrClusterDefinitionEntity);
  // Create and return the EMR cluster definition object from the deleted entity.
  return createEmrClusterDefinitionFromEntity(emrClusterDefinitionEntity);
}

代码示例来源:origin: FINRAOS/herd

private void populateParameters(JdbcExecutionRequest jdbcExecutionRequest, List<FieldExtension> fieldExtensionList, List<Parameter> parameters)
  {
    try
    {
      String jdbcExecutionRequestString = xmlHelper.objectToXml(jdbcExecutionRequest);

      fieldExtensionList.add(buildFieldExtension("contentType", "${contentType}"));
      fieldExtensionList.add(buildFieldExtension("jdbcExecutionRequest", "${jdbcExecutionRequest}"));

      parameters.add(buildParameter("contentType", "xml"));
      parameters.add(buildParameter("jdbcExecutionRequest", jdbcExecutionRequestString));
    }
    catch (JAXBException e)
    {
      throw new IllegalArgumentException(e);
    }
  }
}

代码示例来源:origin: FINRAOS/herd

@Test
public void testRegisterBusinessObjectDataXml() throws Exception
{
  BusinessObjectDataCreateRequest businessObjectDataCreateRequest = businessObjectDataServiceTestHelper.getNewBusinessObjectDataCreateRequest();
  List<FieldExtension> fieldExtensionList = new ArrayList<>();
  fieldExtensionList.add(buildFieldExtension("contentType", "${contentType}"));
  fieldExtensionList.add(buildFieldExtension("businessObjectDataCreateRequest", "${businessObjectDataCreateRequest}"));
  List<Parameter> parameters = new ArrayList<>();
  parameters.add(buildParameter("contentType", "xml"));
  parameters.add(buildParameter("businessObjectDataCreateRequest", xmlHelper.objectToXml(businessObjectDataCreateRequest)));
  Map<String, Object> variableValuesToValidate = new HashMap<>();
  variableValuesToValidate.put(RegisterBusinessObjectData.VARIABLE_ID, VARIABLE_VALUE_NOT_NULL);
  variableValuesToValidate.put(BaseJavaDelegate.VARIABLE_JSON_RESPONSE, VARIABLE_VALUE_NOT_NULL);
  testActivitiServiceTaskSuccess(RegisterBusinessObjectData.class.getCanonicalName(), fieldExtensionList, parameters, variableValuesToValidate);
}

代码示例来源:origin: FINRAOS/herd

@Test
public void testAddBusinessObjectDataStorageFilesXml() throws Exception
{
  BusinessObjectDataStorageFilesCreateRequest businessObjectDataStorageFilesCreateRequest =
    businessObjectDataServiceTestHelper.getNewBusinessObjectDataStorageFilesCreateRequest();
  List<FieldExtension> fieldExtensionList = new ArrayList<>();
  fieldExtensionList.add(buildFieldExtension("contentType", "${contentType}"));
  fieldExtensionList.add(buildFieldExtension("businessObjectDataStorageFilesCreateRequest", "${businessObjectDataStorageFilesCreateRequest}"));
  List<Parameter> parameters = new ArrayList<>();
  parameters.add(buildParameter("contentType", "xml"));
  parameters.add(buildParameter("businessObjectDataStorageFilesCreateRequest", xmlHelper.objectToXml(businessObjectDataStorageFilesCreateRequest)));
  Map<String, Object> variableValuesToValidate = new HashMap<>();
  variableValuesToValidate.put(BaseJavaDelegate.VARIABLE_JSON_RESPONSE, VARIABLE_VALUE_NOT_NULL);
  testActivitiServiceTaskSuccess(AddBusinessObjectDataStorageFiles.class.getCanonicalName(), fieldExtensionList, parameters, variableValuesToValidate);
}

代码示例来源:origin: FINRAOS/herd

@Test
public void testObjectToXmlFormatted() throws Exception
{
  assertEquals(getTestXml().replaceAll("\\s+",""), xmlHelper.objectToXml(getTestBuildInformation(), true).replaceAll("\\s+",""));
}

代码示例来源:origin: FINRAOS/herd

@Test
  public void testAddBusinessObjectDataStorageUnitUsingXmlRequest() throws Exception
  {
    BusinessObjectDataStorageUnitCreateRequest businessObjectDataStorageUnitCreateRequest =
      businessObjectDataServiceTestHelper.getBusinessObjectDataStorageUnitCreateRequest();

    List<FieldExtension> fieldExtensionList = new ArrayList<>();

    fieldExtensionList.add(buildFieldExtension("contentType", "${contentType}"));
    fieldExtensionList.add(buildFieldExtension("businessObjectDataStorageUnitCreateRequest", "${businessObjectDataStorageUnitCreateRequest}"));

    List<Parameter> parameters = new ArrayList<>();

    parameters.add(buildParameter("contentType", "xml"));
    parameters.add(buildParameter("businessObjectDataStorageUnitCreateRequest", xmlHelper.objectToXml(businessObjectDataStorageUnitCreateRequest)));

    Map<String, Object> variableValuesToValidate = new HashMap<>();
    variableValuesToValidate.put(BaseJavaDelegate.VARIABLE_JSON_RESPONSE, VARIABLE_VALUE_NOT_NULL);

    testActivitiServiceTaskSuccess(AddBusinessObjectDataStorageUnit.class.getCanonicalName(), fieldExtensionList, parameters, variableValuesToValidate);
  }
}

代码示例来源:origin: FINRAOS/herd

@Test
public void testCreateClusterOverrideXml() throws Exception
{
  String clusterName = "testCluster" + Math.random();
  String override = xmlHelper.objectToXml(new EmrClusterDefinition());
  Map<String, Object> variables = createJob(clusterName, "false", "xml", override);
  assertEquals("taskStatus", "SUCCESS", variables.get("createClusterServiceTask_taskStatus"));
  assertNotNull("emrClusterId", variables.get("createClusterServiceTask_emrClusterId"));
  assertNotNull("emrClusterStatus", variables.get("createClusterServiceTask_emrClusterStatus"));
  assertNotNull("emrClusterCreated", variables.get("createClusterServiceTask_emrClusterCreated"));
  assertNotNull("emrClusterDefinition", variables.get("createClusterServiceTask_emrClusterDefinition"));
  terminateCluster(TEST_ACTIVITI_NAMESPACE_CD, EMR_CLUSTER_DEFINITION_NAME, clusterName);
}

代码示例来源:origin: FINRAOS/herd

@Test
public void testObjectToXml() throws Exception
{
  assertEquals(getTestXml(), xmlHelper.objectToXml(getTestBuildInformation()));
}

代码示例来源:origin: FINRAOS/herd

/**
 * This method tests the error cases for AmazonExceptions for Illegal Argument
 */
@Test(expected = IllegalArgumentException.class)
public void testCreateEmrClusterAmazonBadRequest() throws Exception
{
  // Create the namespace entity.
  NamespaceEntity namespaceEntity = namespaceDaoTestHelper.createNamespaceEntity(NAMESPACE);
  String configXml = IOUtils.toString(resourceLoader.getResource(EMR_CLUSTER_DEFINITION_XML_FILE_MINIMAL_CLASSPATH).getInputStream());
  EmrClusterDefinition emrClusterDefinition = xmlHelper.unmarshallXmlToObject(EmrClusterDefinition.class, configXml);
  emrClusterDefinition.setAmiVersion(MockAwsOperationsHelper.AMAZON_BAD_REQUEST);
  configXml = xmlHelper.objectToXml(emrClusterDefinition);
  emrClusterDefinitionDaoTestHelper.createEmrClusterDefinitionEntity(namespaceEntity, EMR_CLUSTER_DEFINITION_NAME, configXml);
  // Create a new EMR cluster create request.
  EmrClusterCreateRequest request = getNewEmrClusterCreateRequest();
  emrService.createCluster(request);
}

代码示例来源:origin: FINRAOS/herd

/**
 * This method tests the error cases for AmazonExceptions for AmazonServiceException
 */
@Test(expected = AmazonServiceException.class)
public void testCreateEmrClusterAmazonOtherException() throws Exception
{
  // Create the namespace entity.
  NamespaceEntity namespaceEntity = namespaceDaoTestHelper.createNamespaceEntity(NAMESPACE);
  String configXml = IOUtils.toString(resourceLoader.getResource(EMR_CLUSTER_DEFINITION_XML_FILE_MINIMAL_CLASSPATH).getInputStream());
  EmrClusterDefinition emrClusterDefinition = xmlHelper.unmarshallXmlToObject(EmrClusterDefinition.class, configXml);
  emrClusterDefinition.setAmiVersion(MockAwsOperationsHelper.AMAZON_SERVICE_EXCEPTION);
  configXml = xmlHelper.objectToXml(emrClusterDefinition);
  emrClusterDefinitionDaoTestHelper.createEmrClusterDefinitionEntity(namespaceEntity, EMR_CLUSTER_DEFINITION_NAME, configXml);
  // Create a new EMR cluster create request.
  EmrClusterCreateRequest request = getNewEmrClusterCreateRequest();
  emrService.createCluster(request);
}

代码示例来源:origin: FINRAOS/herd

/**
 * This method tests the error cases for AmazonExceptions for Illegal Argument
 */
@Test(expected = ObjectNotFoundException.class)
public void testCreateEmrClusterAmazonObjectNotFound() throws Exception
{
  // Create the namespace entity.
  NamespaceEntity namespaceEntity = namespaceDaoTestHelper.createNamespaceEntity(NAMESPACE);
  String configXml = IOUtils.toString(resourceLoader.getResource(EMR_CLUSTER_DEFINITION_XML_FILE_MINIMAL_CLASSPATH).getInputStream());
  EmrClusterDefinition emrClusterDefinition = xmlHelper.unmarshallXmlToObject(EmrClusterDefinition.class, configXml);
  emrClusterDefinition.setAmiVersion(MockAwsOperationsHelper.AMAZON_NOT_FOUND);
  configXml = xmlHelper.objectToXml(emrClusterDefinition);
  emrClusterDefinitionDaoTestHelper.createEmrClusterDefinitionEntity(namespaceEntity, EMR_CLUSTER_DEFINITION_NAME, configXml);
  // Create a new EMR cluster create request.
  EmrClusterCreateRequest request = getNewEmrClusterCreateRequest();
  emrService.createCluster(request);
}

代码示例来源:origin: FINRAOS/herd

/**
 * This method tests supported product
 */
@Test
public void testCreateEmrClusterSupportedProduct() throws Exception
{
  // Create the namespace entity.
  NamespaceEntity namespaceEntity = namespaceDaoTestHelper.createNamespaceEntity(NAMESPACE);
  String configXml = IOUtils.toString(resourceLoader.getResource(EMR_CLUSTER_DEFINITION_XML_FILE_MINIMAL_CLASSPATH).getInputStream());
  EmrClusterDefinition emrClusterDefinition = xmlHelper.unmarshallXmlToObject(EmrClusterDefinition.class, configXml);
  // Set the supported product
  emrClusterDefinition.setSupportedProduct("mapr-m3");
  configXml = xmlHelper.objectToXml(emrClusterDefinition);
  emrClusterDefinitionDaoTestHelper.createEmrClusterDefinitionEntity(namespaceEntity, EMR_CLUSTER_DEFINITION_NAME, configXml);
  // Create a new EMR cluster create request.
  EmrClusterCreateRequest request = getNewEmrClusterCreateRequest();
  emrService.createCluster(request);
}

代码示例来源:origin: FINRAOS/herd

@Test
public void testCreateEmrClusterSecurityConfigurationReleaseLabelWithPrefix() throws Exception
{
  // Create the namespace entity.
  NamespaceEntity namespaceEntity = namespaceDaoTestHelper.createNamespaceEntity(NAMESPACE);
  String configXml = IOUtils.toString(resourceLoader.getResource(EMR_CLUSTER_DEFINITION_XML_FILE_MINIMAL_CLASSPATH).getInputStream());
  EmrClusterDefinition emrClusterDefinition = xmlHelper.unmarshallXmlToObject(EmrClusterDefinition.class, configXml);
  // Set the security configuration along with the EMR release label starting with an "emr-" prefix.
  // This is needed since security configuration is not supported prior to EMR version 4.8.0.
  emrClusterDefinition.setSecurityConfiguration("securityConfiguration");
  emrClusterDefinition.setReleaseLabel("emr-4.8.0");
  configXml = xmlHelper.objectToXml(emrClusterDefinition);
  emrClusterDefinitionDaoTestHelper.createEmrClusterDefinitionEntity(namespaceEntity, EMR_CLUSTER_DEFINITION_NAME, configXml);
  // Create a new EMR cluster create request.
  EmrClusterCreateRequest request = getNewEmrClusterCreateRequest();
  emrService.createCluster(request);
}

代码示例来源:origin: FINRAOS/herd

/**
 * This method tests the service IAM role
 */
@Test
public void testCreateEmrClusterServiceRole() throws Exception
{
  // Create the namespace entity.
  NamespaceEntity namespaceEntity = namespaceDaoTestHelper.createNamespaceEntity(NAMESPACE);
  String configXml = IOUtils.toString(resourceLoader.getResource(EMR_CLUSTER_DEFINITION_XML_FILE_WITH_CLASSPATH).getInputStream());
  EmrClusterDefinition emrClusterDefinition = xmlHelper.unmarshallXmlToObject(EmrClusterDefinition.class, configXml);
  emrClusterDefinition.setServiceIamRole(emrClusterDefinition.getEc2NodeIamProfileName());
  configXml = xmlHelper.objectToXml(emrClusterDefinition);
  emrClusterDefinitionDaoTestHelper.createEmrClusterDefinitionEntity(namespaceEntity, EMR_CLUSTER_DEFINITION_NAME, configXml);
  // Create a new EMR cluster create request.
  EmrClusterCreateRequest request = getNewEmrClusterCreateRequest();
  emrService.createCluster(request);
}

代码示例来源:origin: FINRAOS/herd

@Test
public void testGetBusinessObjectDataStorageFilesCreateResponse200ValidResponse() throws Exception
{
  CloseableHttpResponse httpResponse = new MockCloseableHttpResponse(new BasicStatusLine(HttpVersion.HTTP_1_1, 200, "testReasonPhrase"), false);
  httpResponse.setEntity(new StringEntity(xmlHelper.objectToXml(new BusinessObjectDataStorageFilesCreateResponse())));
  BusinessObjectDataStorageFilesCreateResponse businessObjectDataStorageFilesCreateResponse =
    dataBridgeWebClient.getBusinessObjectDataStorageFilesCreateResponse(httpResponse);
  assertNotNull("businessObjectDataStorageFilesCreateResponse", businessObjectDataStorageFilesCreateResponse);
}

代码示例来源:origin: FINRAOS/herd

@Test
public void testGetBusinessObjectDataStorageFilesCreateResponse200ValidResponseHttpResponseThrowsExceptionOnClose() throws Exception
{
  CloseableHttpResponse httpResponse = new MockCloseableHttpResponse(new BasicStatusLine(HttpVersion.HTTP_1_1, 200, "testReasonPhrase"), true);
  httpResponse.setEntity(new StringEntity(xmlHelper.objectToXml(new BusinessObjectDataStorageFilesCreateResponse())));
  executeWithoutLogging(DataBridgeWebClient.class, () -> {
    BusinessObjectDataStorageFilesCreateResponse businessObjectDataStorageFilesCreateResponse =
      dataBridgeWebClient.getBusinessObjectDataStorageFilesCreateResponse(httpResponse);
    assertNotNull("businessObjectDataStorageFilesCreateResponse", businessObjectDataStorageFilesCreateResponse);
  });
}

29 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com