org.apache.commons.lang3.StringUtils#stripToNull ( )源码实例Demo

下面列出了org.apache.commons.lang3.StringUtils#stripToNull ( ) 实例代码,或者点击链接到github查看源代码,也可以在右侧发表评论。

源代码1 项目: synopsys-detect   文件: PackageJsonExtractor.java
public Extraction extract(final PackageJson packageJson, final boolean includeDevDependencies) {
    final List<Dependency> dependencies = packageJson.dependencies.entrySet().stream()
                                              .map(this::entryToDependency)
                                              .collect(Collectors.toList());

    if (includeDevDependencies) {
        final List<Dependency> devDependencies = packageJson.devDependencies.entrySet().stream()
                                                     .map(this::entryToDependency)
                                                     .collect(Collectors.toList());
        dependencies.addAll(devDependencies);
    }

    final MutableMapDependencyGraph dependencyGraph = new MutableMapDependencyGraph();
    dependencyGraph.addChildrenToRoot(dependencies);

    final CodeLocation codeLocation = new CodeLocation(dependencyGraph);

    final String projectName = StringUtils.stripToNull(packageJson.name);
    final String projectVersion = StringUtils.stripToNull(packageJson.version);

    return new Extraction.Builder()
               .success(codeLocation)
               .projectName(projectName)
               .projectVersion(projectVersion)
               .build();
}
 
/**
 * Parses publisher.ext and returns parentAccount value from it. Returns null if any parsing error occurs.
 */
private String parentAccountIdFromExtPublisher(ObjectNode extPublisherNode) {
    if (extPublisherNode == null) {
        return null;
    }

    final ExtPublisher extPublisher;
    try {
        extPublisher = mapper.mapper().convertValue(extPublisherNode, ExtPublisher.class);
    } catch (IllegalArgumentException e) {
        return null; // not critical
    }

    final ExtPublisherPrebid extPublisherPrebid = extPublisher != null ? extPublisher.getPrebid() : null;
    return extPublisherPrebid != null ? StringUtils.stripToNull(extPublisherPrebid.getParentAccount()) : null;
}
 
源代码3 项目: prebid-server-java   文件: EventUtil.java
public static EventRequest from(RoutingContext context) {
    final MultiMap queryParams = context.request().params();

    final String typeAsString = queryParams.get(TYPE_PARAMETER);
    final EventRequest.Type type = typeAsString.equals(WIN_TYPE) ? EventRequest.Type.win : EventRequest.Type.imp;

    final EventRequest.Format format = Objects.equals(queryParams.get(FORMAT_PARAMETER), IMAGE_FORMAT)
            ? EventRequest.Format.image : EventRequest.Format.blank;

    final EventRequest.Analytics analytics = Objects.equals(DISABLED_ANALYTICS,
            queryParams.get(ANALYTICS_PARAMETER))
            ? EventRequest.Analytics.disabled : EventRequest.Analytics.enabled;

    final String timestampAsString = StringUtils.stripToNull(queryParams.get(TIMESTAMP_PARAMETER));
    final Long timestamp = timestampAsString != null ? Long.valueOf(timestampAsString) : null;

    return EventRequest.builder()
            .type(type)
            .bidId(queryParams.get(BID_ID_PARAMETER))
            .accountId(queryParams.get(ACCOUNT_ID_PARAMETER))
            .bidder(queryParams.get(BIDDER_PARAMETER))
            .timestamp(timestamp)
            .format(format)
            .analytics(analytics)
            .build();
}
 
源代码4 项目: livingdoc-core   文件: XmlRpcDataMarshaller.java
/**
 * Transforms the Vector of the Reference parameters into a Reference
 * Object.<br>
 *
 * @param xmlRpcParameters
 * @return the Reference.
 */
@SuppressWarnings(SUPPRESS_UNCHECKED)
public static Reference toReference(List<Object> xmlRpcParameters) {
    Reference reference = null;
    if (!xmlRpcParameters.isEmpty()) {
        Requirement requirement = toRequirement((List<Object>)xmlRpcParameters.get(REFERENCE_REQUIREMENT_IDX));
        Specification specification = toSpecification((List<Object>)xmlRpcParameters.get(
                REFERENCE_SPECIFICATION_IDX));
        SystemUnderTest sut = toSystemUnderTest((List<Object>)xmlRpcParameters.get(REFERENCE_SUT_IDX));
        String sections = StringUtils.stripToNull((String) xmlRpcParameters.get(REFERENCE_SECTIONS_IDX));
        reference = Reference.newInstance(requirement, specification, sut, sections);
        Execution exe = toExecution((List<Object>) xmlRpcParameters.get(REFERENCE_LAST_EXECUTION_IDX));
        reference.setLastExecution(exe);
    }

    return reference;
}
 
源代码5 项目: synopsys-detect   文件: GemspecLineParser.java
private String extractName(final String line) {
    final int openQuoteIndex = line.indexOf(QUOTE_TOKEN);
    if (openQuoteIndex < 0) {
        return "";
    }
    final int closeQuoteIndex = line.indexOf(QUOTE_TOKEN, openQuoteIndex + 1);
    if (closeQuoteIndex < 0) {
        return "";
    }
    final String name = line.substring(openQuoteIndex + 1, closeQuoteIndex);

    return StringUtils.stripToNull(name);
}
 
源代码6 项目: prebid-server-java   文件: EventUtil.java
public static void validateTimestamp(RoutingContext context) {
    final String timestamp = StringUtils.stripToNull(context.request().params().get(TIMESTAMP_PARAMETER));
    if (timestamp != null) {
        try {
            Long.parseLong(timestamp);
        } catch (NumberFormatException e) {
            throw new IllegalArgumentException(String.format(
                    "Timestamp '%s' query parameter is not valid number: %s", TIMESTAMP_PARAMETER, timestamp));
        }
    }
}
 
源代码7 项目: sailfish-core   文件: EnvironmentBean.java
public void setCurrentVariableSet(String currentVariableSet) {
    logger.info("setCurrentVariableSet invoked {} currentVariableSet[{}]", getUser(), currentVariableSet);
    this.currentVariableSet = StringUtils.stripToNull(currentVariableSet);

    if(this.currentVariableSet == null) {
        this.variables = emptyList();
    } else {
        this.variables = copyOf(BeanUtil.getSfContext().getConnectionManager().getVariableSet(currentVariableSet).keySet());
    }
}
 
源代码8 项目: samza   文件: EventHubsInputDescriptor.java
/**
 * Constructs an {@link InputDescriptor} instance.
 *
 * @param streamId id of the stream
 * @param namespace namespace for the Event Hubs entity to consume from, not null
 * @param entityPath entity path for the Event Hubs entity to consume from, not null
 * @param valueSerde serde the values in the messages in the stream
 * @param systemDescriptor system descriptor this stream descriptor was obtained from
 */
EventHubsInputDescriptor(String streamId, String namespace, String entityPath, Serde valueSerde,
    SystemDescriptor systemDescriptor) {
  super(streamId, KVSerde.of(new NoOpSerde<>(), valueSerde), systemDescriptor, null);
  this.namespace = StringUtils.stripToNull(namespace);
  this.entityPath = StringUtils.stripToNull(entityPath);
  if (this.namespace == null || this.entityPath == null) {
    throw new ConfigException(String.format("Missing namespace and entity path Event Hubs input descriptor in " //
        + "system: {%s}, stream: {%s}", getSystemName(), streamId));
  }
}
 
源代码9 项目: samza   文件: EventHubsOutputDescriptor.java
/**
 * Constructs an {@link OutputDescriptor} instance.
 *
 * @param streamId id of the stream
 * @param namespace namespace for the Event Hubs entity to produce to, not null
 * @param entityPath entity path for the Event Hubs entity to produce to, not null
 * @param valueSerde serde the values in the messages in the stream
 * @param systemDescriptor system descriptor this stream descriptor was obtained from
 */
EventHubsOutputDescriptor(String streamId, String namespace, String entityPath, Serde valueSerde,
    SystemDescriptor systemDescriptor) {
  super(streamId, KVSerde.of(new NoOpSerde<>(), valueSerde), systemDescriptor);
  this.namespace = StringUtils.stripToNull(namespace);
  this.entityPath = StringUtils.stripToNull(entityPath);
  if (this.namespace == null || this.entityPath == null) {
    throw new ConfigException(String.format("Missing namespace and entity path Event Hubs output descriptor in "
        + "system: {%s}, stream: {%s}", getSystemName(), streamId));
  }
}
 
源代码10 项目: gocd   文件: BackupService.java
private String postBackupScriptFile() {
    BackupConfig backupConfig = backupConfig();
    if (backupConfig != null) {
        String postBackupScript = backupConfig.getPostBackupScript();
        return StringUtils.stripToNull(postBackupScript);
    }
    return null;
}
 
源代码11 项目: gocd   文件: MailHost.java
@Override
@PostConstruct
public void ensureEncrypted() {
    this.username = StringUtils.stripToNull(username);

    setPasswordIfNotBlank(password);
}
 
源代码12 项目: geoportal-server-harvester   文件: Client.java
/**
 * Lists all available ids.
 *
 * @param resumptionToken resumption token or <code>null</code>
 * @param since since date or <code>null</code>
 * @return list of the ids with the resumption token to continue
 * @throws IOException if error reading response
 * @throws URISyntaxException if invalid URI
 * @throws ParserConfigurationException if error parsing response
 * @throws SAXException if error parsing response
 * @throws XPathExpressionException if error parsing response
 */
public ListIdsResponse listIds(String resumptionToken, Date since) throws IOException, URISyntaxException, ParserConfigurationException, SAXException, XPathExpressionException {
  HttpGet request = new HttpGet(listIdsUri(resumptionToken, since));
  try (CloseableHttpResponse httpResponse = httpClient.execute(request); InputStream contentStream = httpResponse.getEntity().getContent();) {
    String reasonMessage = httpResponse.getStatusLine().getReasonPhrase();
    String responseContent = IOUtils.toString(contentStream, "UTF-8");
    LOG.trace(String.format("RESPONSE: %s, %s", responseContent, reasonMessage));
    
    if (httpResponse.getStatusLine().getStatusCode()==429 || httpResponse.getStatusLine().getStatusCode()==503) {
      Date retryAfter = getRetryAfter(httpResponse);
      if (retryAfter!=null) {
        long delay = retryAfter.getTime()-System.currentTimeMillis();
        if (delay>0) {
          LOG.debug(String.format("Harvestiong suspended for %d milliseconds.", delay));
          try {
            Thread.sleep(delay);
          } catch (InterruptedException ex) {
            // ignore
          }
        }
        return listIds(resumptionToken, since);
      }
    }

    if (httpResponse.getStatusLine().getStatusCode() >= 400) {
      throw new HttpResponseException(httpResponse.getStatusLine().getStatusCode(), httpResponse.getStatusLine().getReasonPhrase());
    }

    Document responseDoc = parseDocument(responseContent);

    XPath xPath = XPathFactory.newInstance().newXPath();

    String errorCode = StringUtils.stripToNull((String) xPath.evaluate("/OAI-PMH/error/@code", responseDoc, XPathConstants.STRING));
    if (errorCode != null) {
      throw new HttpResponseException(HttpStatus.SC_BAD_REQUEST, String.format("Invalid OAI-PMH response with code: %s", errorCode));
    }

    Node listIdentifiersNode = (Node) xPath.evaluate("/OAI-PMH/ListIdentifiers", responseDoc, XPathConstants.NODE);

    ListIdsResponse response = new ListIdsResponse();
    if (listIdentifiersNode != null) {
      NodeList headerNodes = (NodeList) xPath.evaluate("header[not(@status=\"deleted\")]", listIdentifiersNode, XPathConstants.NODESET);
      if (headerNodes != null) {
        ArrayList<Header> headers = new ArrayList<>();
        for (int i = 0; i < headerNodes.getLength(); i++) {
          Header header = new Header();
          header.identifier = (String) xPath.evaluate("identifier", headerNodes.item(i), XPathConstants.STRING);
          header.datestamp = (String) xPath.evaluate("datestamp", headerNodes.item(i), XPathConstants.STRING);
          headers.add(header);
        }
        response.headers = headers.toArray(new Header[headers.size()]);
      }
      response.resumptionToken = StringUtils.trimToNull((String) xPath.evaluate("resumptionToken", listIdentifiersNode, XPathConstants.STRING));
    } else {
      response.resumptionToken = null;
    }
    return response;

  }
}
 
源代码13 项目: geoportal-server-harvester   文件: Client.java
/**
 * Reads record.
 *
 * @param id records id
 * @return record
 * @throws IOException if error reading record
 * @throws URISyntaxException if invalid URI
 * @throws ParserConfigurationException if error parsing response
 * @throws SAXException if error parsing response
 * @throws XPathExpressionException if error parsing response
 * @throws TransformerException if error parsing response
 */
public String readRecord(String id) throws IOException, URISyntaxException, ParserConfigurationException, SAXException, XPathExpressionException, TransformerException {
  HttpGet request = new HttpGet(recordUri(id));
  try (CloseableHttpResponse httpResponse = httpClient.execute(request); InputStream contentStream = httpResponse.getEntity().getContent();) {
    String reasonMessage = httpResponse.getStatusLine().getReasonPhrase();
    String responseContent = IOUtils.toString(contentStream, "UTF-8");
    LOG.trace(String.format("RESPONSE: %s, %s", responseContent, reasonMessage));
    
    if (httpResponse.getStatusLine().getStatusCode()==429 || httpResponse.getStatusLine().getStatusCode()==503) {
      Date retryAfter = getRetryAfter(httpResponse);
      if (retryAfter!=null) {
        long delay = retryAfter.getTime()-System.currentTimeMillis();
        if (delay>0) {
          LOG.debug(String.format("Harvestiong suspended for %d milliseconds.", delay));
          try {
            Thread.sleep(delay);
          } catch (InterruptedException ex) {
            // ignore
          }
        }
        return readRecord(id);
      }
    }

    if (httpResponse.getStatusLine().getStatusCode() >= 400) {
      throw new HttpResponseException(httpResponse.getStatusLine().getStatusCode(), httpResponse.getStatusLine().getReasonPhrase());
    }

    Document responseDoc = parseDocument(responseContent);
    XPath xPath = XPathFactory.newInstance().newXPath();

    String errorCode = StringUtils.stripToNull((String) xPath.evaluate("/OAI-PMH/error/@code", responseDoc, XPathConstants.STRING));
    if (errorCode != null) {
      throw new HttpResponseException(HttpStatus.SC_BAD_REQUEST, String.format("Invalid OAI-PMH response with code: %s", errorCode));
    }

    Node metadataNode = (Node) xPath.evaluate("/OAI-PMH/GetRecord/record/metadata/*[1]", responseDoc, XPathConstants.NODE);

    if (metadataNode == null) {
      throw new IOException("Error reading metadata");
    }

    Document metadataDocument = emptyDocument();
    metadataDocument.appendChild(metadataDocument.importNode(metadataNode, true));

    return XmlUtils.toString(metadataDocument);
  }
}
 
源代码14 项目: livingdoc-core   文件: RepositoryType.java
public void setDocumentUrlFormat(String documentUrlFormat) {
    this.documentUrlFormat = StringUtils.stripToNull(documentUrlFormat);
}
 
源代码15 项目: livingdoc-core   文件: RepositoryType.java
public void setTestUrlFormat(String testUrlFormat) {
    this.testUrlFormat = StringUtils.stripToNull(testUrlFormat);
}
 
源代码16 项目: livingdoc-core   文件: Reference.java
public void setSections(String sections) {
    this.sections = StringUtils.stripToNull(sections);
}
 
源代码17 项目: basiclti-util-java   文件: BasicLTIUtil.java
/**
 * @deprecated See: {@link #parseDescriptor(Map, Map, String)}
 * @param launch_info Variable is mutated by this method.
 * @param postProp Variable is mutated by this method.
 * @param descriptor
 * @return
 */
public static boolean parseDescriptor(Properties launch_info,
        Properties postProp, String descriptor) {
    // this is an ugly copy/paste of the [email protected] method
    // could not convert data types as they variables get mutated (ugh)
    Map<String, Object> tm = null;
    try {
        tm = XMLMap.getFullMap(descriptor.trim());
    } catch (Exception e) {
        M_log.warning("BasicLTIUtil exception parsing BasicLTI descriptor: "
                + e.getMessage());
        return false;
    }
    if (tm == null) {
        M_log.warning("Unable to parse XML in parseDescriptor");
        return false;
    }

    String launch_url = StringUtils.stripToNull(XMLMap.getString(tm, "/basic_lti_link/launch_url"));
    String secure_launch_url = StringUtils.stripToNull(XMLMap.getString(tm, "/basic_lti_link/secure_launch_url"));
    if (launch_url == null && secure_launch_url == null) {
        return false;
    }

    setProperty(launch_info, "launch_url", launch_url);
    setProperty(launch_info, "secure_launch_url", secure_launch_url);

    // Extensions for hand-authored placements - The export process should scrub these
    setProperty(launch_info, "key", StringUtils.stripToNull(XMLMap.getString(tm, "/basic_lti_link/x-secure/launch_key")));
    setProperty(launch_info, "secret", StringUtils.stripToNull(XMLMap.getString(tm, "/basic_lti_link/x-secure/launch_secret")));

    List<Map<String, Object>> theList = XMLMap.getList(tm, "/basic_lti_link/custom/parameter");
    for (Map<String, Object> setting : theList) {
        dPrint("Setting=" + setting);
        String key = XMLMap.getString(setting, "/!key"); // Get the key attribute
        String value = XMLMap.getString(setting, "/"); // Get the value
        if (key == null || value == null) {
            continue;
        }
        key = "custom_" + mapKeyName(key);
        dPrint("key=" + key + " val=" + value);
        postProp.setProperty(key, value);
    }
    return true;
}
 
源代码18 项目: basiclti-util-java   文件: BasicLTIUtil.java
/**
 *
 * @param launch_info Variable is mutated by this method.
 * @param postProp Variable is mutated by this method.
 * @param descriptor
 * @return
 */
public static boolean parseDescriptor(Map<String, String> launch_info,
        Map<String, String> postProp, String descriptor) {
    Map<String, Object> tm = null;
    try {
        tm = XMLMap.getFullMap(descriptor.trim());
    } catch (Exception e) {
        M_log.warning("BasicLTIUtil exception parsing BasicLTI descriptor: "
                + e.getMessage());
        return false;
    }
    if (tm == null) {
        M_log.warning("Unable to parse XML in parseDescriptor");
        return false;
    }

    String launch_url = StringUtils.stripToNull(XMLMap.getString(tm,
            "/basic_lti_link/launch_url"));
    String secure_launch_url = StringUtils.stripToNull(XMLMap.getString(tm,
            "/basic_lti_link/secure_launch_url"));
    if (launch_url == null && secure_launch_url == null) {
        return false;
    }

    setProperty(launch_info, "launch_url", launch_url);
    setProperty(launch_info, "secure_launch_url", secure_launch_url);

    // Extensions for hand-authored placements - The export process should scrub
    // these
    setProperty(launch_info, "key", StringUtils.stripToNull(XMLMap.getString(tm, "/basic_lti_link/x-secure/launch_key")));
    setProperty(launch_info, "secret", StringUtils.stripToNull(XMLMap.getString(tm, "/basic_lti_link/x-secure/launch_secret")));

    List<Map<String, Object>> theList = XMLMap.getList(tm, "/basic_lti_link/custom/parameter");
    for (Map<String, Object> setting : theList) {
        dPrint("Setting=" + setting);
        String key = XMLMap.getString(setting, "/!key"); // Get the key attribute
        String value = XMLMap.getString(setting, "/"); // Get the value
        if (key == null || value == null) {
            continue;
        }
        key = "custom_" + mapKeyName(key);
        dPrint("key=" + key + " val=" + value);
        postProp.put(key, value);
    }
    return true;
}
 
源代码19 项目: gocd   文件: ScmMaterial.java
@PostConstruct
public void ensureEncrypted() {
    this.userName = StringUtils.stripToNull(this.userName);
    setPasswordIfNotBlank(password);
}
 
源代码20 项目: sailfish-core   文件: CsvLibraryBuilder.java
private ScriptList parseScriptList(Map<String, String> row, long currentRecordNumber) throws InvalidRowException {

		String name = row.get(CsvHeader.Name.getFieldKey());

		if(name == null) {
			throw new InvalidRowException(CsvHeader.Name.getFieldKey()
					+ " is required for Script List");
		}

        Set<String> serviceNames = parseServiceListReferences(row.get(CsvHeader.Services.getFieldKey()));

		String priorityString = row.get(CsvHeader.Priority.getFieldKey());

		long priority = 0;
        boolean priorityParsed = true;

		if(StringUtils.isNotEmpty(priorityString)) {

			try {

				priority = Long.parseLong(priorityString);

			} catch(NumberFormatException e) {
                priorityParsed = false;
			}

		}

		String executor = StringUtils.defaultIfBlank(row.get(CsvHeader.Executor.getFieldKey()), null);
        String variableSet = StringUtils.stripToNull(row.get(CsvHeader.VariableSet.getFieldKey()));

        ScriptList result = new ScriptList(name, executor, serviceNames, parseApiOptions(row), priority, currentRecordNumber, variableSet);

        if (!priorityParsed) {
            result.addRejectCause(new ImportError(currentRecordNumber, "'Priority' value is not parsable to number (long)"));
        }

		return result;

	}
 
 同类方法