com.google.api.client.json.JsonParser.parseAndClose()方法的使用及代码示例

x33g5p2x  于2022-01-22 转载在 其他  
字(9.4k)|赞(0)|评价(0)|浏览(159)

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

JsonParser.parseAndClose介绍

暂无

代码示例

代码示例来源:origin: googleapis/google-cloud-java

  1. new JacksonFactory()
  2. .createJsonParser(new FileInputStream(args[0]))
  3. .parseAndClose(String[].class);

代码示例来源:origin: firebase/firebase-admin-java

  1. private Map<String, Object> parseCustomClaims(String customClaims, JsonFactory jsonFactory) {
  2. if (Strings.isNullOrEmpty(customClaims)) {
  3. return ImmutableMap.of();
  4. }
  5. try {
  6. Map<String, Object> parsed = new HashMap<>();
  7. jsonFactory.createJsonParser(customClaims).parseAndClose(parsed);
  8. return ImmutableMap.copyOf(parsed);
  9. } catch (IOException e) {
  10. throw new IllegalArgumentException("Failed to parse custom claims json", e);
  11. }
  12. }

代码示例来源:origin: com.google.api.client/google-api-client-googleapis

  1. @Override
  2. public <T> T parse(HttpResponse response, Class<T> dataClass) throws IOException {
  3. return parserForResponse(jsonFactory, response).parseAndClose(dataClass, null);
  4. }

代码示例来源:origin: com.google.cloud.bigdataoss/bigquery-connector

  1. /**
  2. * Parses table schema JSON into {@link TableSchema}.
  3. *
  4. * @param tableSchemaJson JSON table schema to convert to {@link TableSchema}
  5. * @return {@link TableSchema}
  6. * @throws IOException if the JSON is invalid.
  7. */
  8. static TableSchema parseTableSchema(String tableSchemaJson) throws IOException {
  9. JsonParser parser = JacksonFactory.getDefaultInstance().createJsonParser(tableSchemaJson);
  10. return parser.parseAndClose(TableSchema.class);
  11. }

代码示例来源:origin: com.google.http-client/google-http-client-test

  1. public void testParseFeed() throws Exception {
  2. JsonParser parser = newFactory().createJsonParser(JSON_FEED);
  3. parser.nextToken();
  4. Feed feed = parser.parseAndClose(Feed.class);
  5. Iterator<Entry> iterator = feed.entries.iterator();
  6. assertEquals("foo", iterator.next().title);
  7. assertEquals("bar", iterator.next().title);
  8. assertFalse(iterator.hasNext());
  9. }

代码示例来源:origin: com.google.http-client/google-http-client-test

  1. public void testParse_emptyMap() throws Exception {
  2. JsonParser parser = newFactory().createJsonParser(EMPTY_OBJECT);
  3. parser.nextToken();
  4. @SuppressWarnings("unchecked")
  5. HashMap<String, Object> map = parser.parseAndClose(HashMap.class);
  6. assertTrue(map.isEmpty());
  7. }

代码示例来源:origin: com.google.http-client/google-http-client-test

  1. @SuppressWarnings("unchecked")
  2. public void testParseEntryAsMap() throws Exception {
  3. JsonParser parser = newFactory().createJsonParser(JSON_ENTRY);
  4. parser.nextToken();
  5. HashMap<String, Object> map = parser.parseAndClose(HashMap.class);
  6. assertEquals("foo", map.remove("title"));
  7. assertTrue(map.isEmpty());
  8. }

代码示例来源:origin: com.google.http-client/google-http-client-test

  1. public void testParseEntry() throws Exception {
  2. Entry entry = newFactory().createJsonParser(JSON_ENTRY).parseAndClose(Entry.class);
  3. assertEquals("foo", entry.title);
  4. }

代码示例来源:origin: com.google.http-client/google-http-client-test

  1. public void testParse_empty() throws Exception {
  2. JsonParser parser = newFactory().createJsonParser(EMPTY);
  3. parser.nextToken();
  4. try {
  5. parser.parseAndClose(HashMap.class);
  6. fail("expected " + IllegalArgumentException.class);
  7. } catch (IllegalArgumentException e) {
  8. // expected
  9. }
  10. }

代码示例来源:origin: firebase/firebase-admin-java

  1. private void handleTopicManagementHttpError(
  2. HttpResponseException e) throws FirebaseMessagingException {
  3. InstanceIdServiceErrorResponse response = new InstanceIdServiceErrorResponse();
  4. try {
  5. JsonParser parser = jsonFactory.createJsonParser(e.getContent());
  6. parser.parseAndClose(response);
  7. } catch (IOException ignored) {
  8. // ignored
  9. }
  10. // Infer error code from HTTP status
  11. String code = IID_ERROR_CODES.get(e.getStatusCode());
  12. if (code == null) {
  13. code = UNKNOWN_ERROR;
  14. }
  15. String msg = response.error;
  16. if (Strings.isNullOrEmpty(msg)) {
  17. msg = String.format("Unexpected HTTP response with status: %d; body: %s",
  18. e.getStatusCode(), e.getContent());
  19. }
  20. throw new FirebaseMessagingException(code, msg, e);
  21. }

代码示例来源:origin: com.google.http-client/google-http-client-test

  1. public void testParse_emptyGenericJson() throws Exception {
  2. JsonParser parser = newFactory().createJsonParser(EMPTY_OBJECT);
  3. parser.nextToken();
  4. GenericJson json = parser.parseAndClose(GenericJson.class);
  5. assertTrue(json.isEmpty());
  6. }

代码示例来源:origin: com.google.http-client/google-http-client-test

  1. public void testParser_partialEmpty() throws Exception {
  2. JsonFactory factory = newFactory();
  3. JsonParser parser;
  4. parser = factory.createJsonParser(EMPTY_OBJECT);
  5. parser.nextToken();
  6. parser.nextToken();
  7. // current token is now end_object
  8. @SuppressWarnings("unchecked")
  9. HashMap<String, Object> result = parser.parseAndClose(HashMap.class);
  10. assertEquals(EMPTY_OBJECT, factory.toString(result));
  11. // check types and values
  12. assertTrue(result.isEmpty());
  13. }

代码示例来源:origin: firebase/firebase-admin-java

  1. private void handleSendHttpError(HttpResponseException e) throws FirebaseMessagingException {
  2. MessagingServiceErrorResponse response = new MessagingServiceErrorResponse();
  3. if (e.getContent() != null) {
  4. try {
  5. JsonParser parser = jsonFactory.createJsonParser(e.getContent());
  6. parser.parseAndClose(response);
  7. } catch (IOException ignored) {
  8. // ignored
  9. }
  10. }
  11. String code = FCM_ERROR_CODES.get(response.getErrorCode());
  12. if (code == null) {
  13. code = UNKNOWN_ERROR;
  14. }
  15. String msg = response.getErrorMessage();
  16. if (Strings.isNullOrEmpty(msg)) {
  17. msg = String.format("Unexpected HTTP response with status: %d; body: %s",
  18. e.getStatusCode(), e.getContent());
  19. }
  20. throw new FirebaseMessagingException(code, msg, e);
  21. }

代码示例来源:origin: firebase/firebase-admin-java

  1. private static FirebaseOptions getOptionsFromEnvironment() throws IOException {
  2. String defaultConfig = System.getenv(FIREBASE_CONFIG_ENV_VAR);
  3. if (Strings.isNullOrEmpty(defaultConfig)) {
  4. return new FirebaseOptions.Builder()
  5. .setCredentials(GoogleCredentials.getApplicationDefault())
  6. .build();
  7. }
  8. JsonFactory jsonFactory = Utils.getDefaultJsonFactory();
  9. FirebaseOptions.Builder builder = new FirebaseOptions.Builder();
  10. JsonParser parser;
  11. if (defaultConfig.startsWith("{")) {
  12. parser = jsonFactory.createJsonParser(defaultConfig);
  13. } else {
  14. FileReader reader;
  15. reader = new FileReader(defaultConfig);
  16. parser = jsonFactory.createJsonParser(reader);
  17. }
  18. parser.parseAndClose(builder);
  19. builder.setCredentials(GoogleCredentials.getApplicationDefault());
  20. return builder.build();
  21. }
  22. }

代码示例来源:origin: com.google.cloud/google-cloud-bigquery

  1. new JacksonFactory()
  2. .createJsonParser(new FileInputStream(args[0]))
  3. .parseAndClose(String[].class);

代码示例来源:origin: com.google.http-client/google-http-client-test

  1. public void testParser_partialEntry() throws Exception {
  2. JsonFactory factory = newFactory();
  3. JsonParser parser;
  4. parser = factory.createJsonParser(JSON_ENTRY);
  5. parser.nextToken();
  6. parser.nextToken();
  7. // current token is now field_name
  8. Entry result = parser.parseAndClose(Entry.class);
  9. assertEquals(JSON_ENTRY, factory.toString(result));
  10. // check types and values
  11. assertEquals("foo", result.title);
  12. }

代码示例来源:origin: com.google.api.client/google-api-client-googleapis

  1. /**
  2. * Forces the discovery document to be loaded, even if the service definition has already been
  3. * loaded.
  4. */
  5. public void load() throws IOException {
  6. GoogleUrl url = discoveryUrl.clone();
  7. url.put("api", name);
  8. HttpRequest request = discoveryTransport.createRequestFactory().buildGetRequest(url);
  9. JsonParser parser = JsonCParser.parserForResponse(jsonFactory, request.execute());
  10. parser.skipToKey(name);
  11. DiscoveryDocument doc = new DiscoveryDocument();
  12. APIDefinition apiDefinition = doc.apiDefinition;
  13. parser.parseAndClose(apiDefinition, null);
  14. serviceDefinition = doc.apiDefinition.get(version);
  15. Preconditions.checkNotNull(serviceDefinition, "version not found: %s", version);
  16. }

代码示例来源:origin: firebase/firebase-admin-java

  1. @Override
  2. protected String execute() throws FirebaseMessagingException {
  3. ImmutableMap.Builder<String, Object> payload = ImmutableMap.<String, Object>builder()
  4. .put("message", message);
  5. if (dryRun) {
  6. payload.put("validate_only", true);
  7. }
  8. HttpResponse response = null;
  9. try {
  10. HttpRequest request = requestFactory.buildPostRequest(
  11. new GenericUrl(url), new JsonHttpContent(jsonFactory, payload.build()));
  12. request.getHeaders().set("X-GOOG-API-FORMAT-VERSION", "2");
  13. request.setParser(new JsonObjectParser(jsonFactory));
  14. request.setResponseInterceptor(interceptor);
  15. response = request.execute();
  16. MessagingServiceResponse parsed = new MessagingServiceResponse();
  17. jsonFactory.createJsonParser(response.getContent()).parseAndClose(parsed);
  18. return parsed.name;
  19. } catch (HttpResponseException e) {
  20. handleSendHttpError(e);
  21. return null;
  22. } catch (IOException e) {
  23. throw new FirebaseMessagingException(
  24. INTERNAL_ERROR, "Error while calling FCM backend service", e);
  25. } finally {
  26. disconnectQuietly(response);
  27. }
  28. }
  29. };

代码示例来源:origin: firebase/firebase-admin-java

  1. response = request.execute();
  2. InstanceIdServiceResponse parsed = new InstanceIdServiceResponse();
  3. jsonFactory.createJsonParser(response.getContent()).parseAndClose(parsed);
  4. checkState(parsed.results != null && !parsed.results.isEmpty(),
  5. "unexpected response from topic management service");

代码示例来源:origin: firebase/firebase-admin-java

  1. <T> void makeRequest(
  2. HttpRequest baseRequest,
  3. T parsedResponseInstance,
  4. String requestIdentifier,
  5. String requestIdentifierDescription) throws FirebaseProjectManagementException {
  6. HttpResponse response = null;
  7. try {
  8. baseRequest.getHeaders().set(CLIENT_VERSION_HEADER, clientVersion);
  9. baseRequest.setParser(new JsonObjectParser(jsonFactory));
  10. baseRequest.setResponseInterceptor(interceptor);
  11. response = baseRequest.execute();
  12. jsonFactory.createJsonParser(response.getContent(), Charsets.UTF_8)
  13. .parseAndClose(parsedResponseInstance);
  14. } catch (Exception e) {
  15. handleError(requestIdentifier, requestIdentifierDescription, e);
  16. } finally {
  17. disconnectQuietly(response);
  18. }
  19. }

相关文章