com.fasterxml.jackson.core.JsonGenerator#writeFieldName ( )源码实例Demo

下面列出了com.fasterxml.jackson.core.JsonGenerator#writeFieldName ( ) 实例代码，或者点击链接到github查看源代码，也可以在右侧发表评论。

源代码1 项目： FROST-Server 文件： DataArrayResultSerializer.java

@Override
public void serialize(DataArrayResult value, JsonGenerator gen, SerializerProvider serializers) throws IOException {
    gen.writeStartObject();
    long count = value.getCount();
    if (count >= 0) {
        gen.writeNumberField(AT_IOT_COUNT, count);
    }
    String nextLink = value.getNextLink();
    if (nextLink != null) {
        gen.writeStringField(AT_IOT_NEXT_LINK, nextLink);
    }

    gen.writeFieldName("value");
    gen.writeObject(value.getValue());
    gen.writeEndObject();
}

源代码2 项目： beakerx 文件： BasicObjectSerializer.java

@Override
public boolean writeObject(Object obj, JsonGenerator jgen, boolean expand) throws JsonProcessingException, IOException {
  logger.debug("generic map");
  // convert this 'on the fly' to a map of objects
  Map<?, ?> m = (Map<?, ?>) obj;

  Set<?> kset = m.keySet();
  if (kset.size() == 0 || !(kset.iterator().next() instanceof String))
    jgen.writeObject(obj.toString());
  else {
    jgen.writeStartObject();
    for (Object k : kset) {
      jgen.writeFieldName((null == k) ? "null" : k.toString());
      if (!parent.writeObject(m.get(k), jgen, false))
        jgen.writeObject(m.get(k) != null ? (m.get(k).toString()) : "null");
    }
    jgen.writeEndObject();
  }
  return true;
}

源代码3 项目： aws-athena-query-federation 文件： BlockSerDe.java

@Override
protected void doSerialize(Block block, JsonGenerator jgen, SerializerProvider provider)
        throws IOException
{
    jgen.writeStringField(ALLOCATOR_ID_FIELD_NAME, block.getAllocatorId());

    jgen.writeFieldName(SCHEMA_FIELD_NAME);
    schemaSerializer.serialize(block.getSchema(), jgen, provider);

    jgen.writeFieldName(BATCH_FIELD_NAME);
    if (block.getRowCount() > 0) {
        jgen.writeBinary(serializeRecordBatch(block.getRecordBatch()));
    }
    else {
        jgen.writeString("");
    }
}

源代码4 项目： glowroot 文件： TraceCommonService.java

private static @Nullable String toJson(@Nullable Queries queries) throws IOException {
    if (queries == null) {
        return null;
    }
    StringBuilder sb = new StringBuilder();
    JsonGenerator jg = jsonFactory.createGenerator(CharStreams.asWriter(sb));
    try {
        jg.writeStartObject();
        jg.writeFieldName("queries");
        writeQueries(jg, queries.queries());
        jg.writeFieldName("sharedQueryTexts");
        writeSharedQueryTexts(jg, queries.sharedQueryTexts());
        jg.writeEndObject();
    } finally {
        jg.close();
    }
    return sb.toString();
}

源代码5 项目： apiman 文件： HeaderMapSerializer.java

/**
 * @see com.fasterxml.jackson.databind.JsonSerializer#serialize(java.lang.Object, com.fasterxml.jackson.core.JsonGenerator, com.fasterxml.jackson.databind.SerializerProvider)
 */
@Override
public void serialize(HeaderMap map, JsonGenerator gen, SerializerProvider serializers)
        throws IOException, JsonProcessingException {
    gen.writeStartObject(); // {

    for (String key : map.keySet()) {
        List<String> values = map.getAll(key);

        if (values.size() <= 1) {
            gen.writeStringField(key, values.get(0)); // "key": "value"
        } else {
            gen.writeFieldName(key); // "key":
            gen.writeStartArray(values.size()); // [
            for (String val : values) {
                gen.writeString(val); // "value", ...
            }
            gen.writeEndArray();// ]
        }
    }

    gen.writeEndObject(); // }
}

源代码6 项目： vespa 文件： ClusterConnection.java

public String getStatsAsJSon() throws IOException {
    StringWriter stringWriter = new StringWriter();
    JsonGenerator jsonGenerator = jsonFactory.createGenerator(stringWriter);
    jsonGenerator.writeStartObject();
    jsonGenerator.writeArrayFieldStart("session");
    for (IOThread ioThread : ioThreads) {
        jsonGenerator.writeStartObject();
        jsonGenerator.writeObjectFieldStart("endpoint");
        jsonGenerator.writeStringField("host", ioThread.getEndpoint().getHostname());
        jsonGenerator.writeNumberField("port", ioThread.getEndpoint().getPort());
        jsonGenerator.writeEndObject();
        jsonGenerator.writeFieldName("stats");
        IOThread.ConnectionStats connectionStats = ioThread.getConnectionStats();
        objectMapper.writeValue(jsonGenerator, connectionStats);
        jsonGenerator.writeEndObject();
    }
    jsonGenerator.writeEndArray();
    jsonGenerator.writeEndObject();
    jsonGenerator.close();
    return stringWriter.toString();
}

源代码7 项目： kripton 文件： LongBeanTable.java

/**
 * for attribute value2 serialization
 */
public static byte[] serializeValue2(LinkedList<Long> value) {
  if (value==null) {
    return null;
  }
  KriptonJsonContext context=KriptonBinder.jsonBind();
  try (KriptonByteArrayOutputStream stream=new KriptonByteArrayOutputStream(); JacksonWrapperSerializer wrapper=context.createSerializer(stream)) {
    JsonGenerator jacksonSerializer=wrapper.jacksonGenerator;
    jacksonSerializer.writeStartObject();
    int fieldCount=0;
    if (value!=null)  {
      fieldCount++;
      int n=value.size();
      Long item;
      // write wrapper tag
      jacksonSerializer.writeFieldName("element");
      jacksonSerializer.writeStartArray();
      for (int i=0; i<n; i++) {
        item=value.get(i);
        if (item==null) {
          jacksonSerializer.writeNull();
        } else {
          jacksonSerializer.writeNumber(item);
        }
      }
      jacksonSerializer.writeEndArray();
    }
    jacksonSerializer.writeEndObject();
    jacksonSerializer.flush();
    return stream.toByteArray();
  } catch(Exception e) {
    e.printStackTrace();
    throw(new KriptonRuntimeException(e.getMessage()));
  }
}

源代码8 项目： openrtb-doubleclick 文件： ImpExtWriter.java

private void writeBuyerGeneratedRequestDataFields(
    BuyerGeneratedRequestData req, JsonGenerator gen) throws IOException {
  switch (req.getSourceCase()) {
    case SOURCE_APP:
      gen.writeFieldName("source_app");
      writeSourceApp(req.getSourceApp(), gen);
      break;
    default:
  }
  if (req.hasData()) {
    gen.writeStringField("data", req.getData());
  }
}

源代码9 项目： kripton 文件： BindBean2SharedPreferences.java

/**
 * for attribute valueCharArray serialization
 */
protected String serializeValueCharArray(Character[] value) {
  if (value==null) {
    return null;
  }
  KriptonJsonContext context=KriptonBinder.jsonBind();
  try (KriptonByteArrayOutputStream stream=new KriptonByteArrayOutputStream(); JacksonWrapperSerializer wrapper=context.createSerializer(stream)) {
    JsonGenerator jacksonSerializer=wrapper.jacksonGenerator;
    jacksonSerializer.writeStartObject();
    int fieldCount=0;
    if (value!=null)  {
      fieldCount++;
      int n=value.length;
      Character item;
      // write wrapper tag
      jacksonSerializer.writeFieldName("valueCharArray");
      jacksonSerializer.writeStartArray();
      for (int i=0; i<n; i++) {
        item=value[i];
        if (item==null) {
          jacksonSerializer.writeNull();
        } else {
          jacksonSerializer.writeNumber(item);
        }
      }
      jacksonSerializer.writeEndArray();
    }
    jacksonSerializer.writeEndObject();
    jacksonSerializer.flush();
    return stream.toString();
  } catch(Exception e) {
    e.printStackTrace();
    throw(new KriptonRuntimeException(e.getMessage()));
  }
}

源代码10 项目： buck 文件： CoercedTestRunnerSpec.java

private void writeMap(
    JsonGenerator jsonGenerator,
    Map<Arg, CoercedTestRunnerSpec> data,
    SourcePathResolverAdapter sourcePathResolverAdapter)
    throws IOException {
  jsonGenerator.writeStartObject();
  for (Map.Entry<Arg, CoercedTestRunnerSpec> entry : data.entrySet()) {
    jsonGenerator.writeFieldName(Arg.stringify(entry.getKey(), sourcePathResolverAdapter));
    entry.getValue().serialize(jsonGenerator, sourcePathResolverAdapter);
  }
  jsonGenerator.writeEndObject();
}

源代码11 项目： java-json-benchmark 文件： UsersStreamSerializer.java

@Override
public void jackson(JsonGenerator j, Users obj) throws IOException {
    j.writeStartObject();
    if (obj.users != null) {
        j.writeFieldName("users");
        j.writeStartArray();
        for (User u : obj.users) {
            jackson(j, u);
        }
        j.writeEndArray();
    }
    j.writeEndObject();
}

源代码12 项目： olingo-odata4 文件： JsonDeltaSerializerWithNavigations.java

protected void writeProperty(final ServiceMetadata metadata,
    final EdmProperty edmProperty, final Property property,
    final Set<List<String>> selectedPaths, final JsonGenerator json)
    throws IOException, SerializerException {
  boolean isStreamProperty = isStreamProperty(edmProperty);
  if (property != null) {
    if (!isStreamProperty) {
      json.writeFieldName(edmProperty.getName());
    }
    writePropertyValue(metadata, edmProperty, property, selectedPaths, json);
  }
}

源代码13 项目： kripton 文件： LongBeanTable.java

/**
 * for attribute value2 serialization
 */
public static byte[] serializeValue2(Long[] value) {
  if (value==null) {
    return null;
  }
  KriptonJsonContext context=KriptonBinder.jsonBind();
  try (KriptonByteArrayOutputStream stream=new KriptonByteArrayOutputStream(); JacksonWrapperSerializer wrapper=context.createSerializer(stream)) {
    JsonGenerator jacksonSerializer=wrapper.jacksonGenerator;
    jacksonSerializer.writeStartObject();
    int fieldCount=0;
    if (value!=null)  {
      fieldCount++;
      int n=value.length;
      Long item;
      // write wrapper tag
      jacksonSerializer.writeFieldName("element");
      jacksonSerializer.writeStartArray();
      for (int i=0; i<n; i++) {
        item=value[i];
        if (item==null) {
          jacksonSerializer.writeNull();
        } else {
          jacksonSerializer.writeNumber(item);
        }
      }
      jacksonSerializer.writeEndArray();
    }
    jacksonSerializer.writeEndObject();
    jacksonSerializer.flush();
    return stream.toByteArray();
  } catch(Exception e) {
    e.printStackTrace();
    throw(new KriptonRuntimeException(e.getMessage()));
  }
}

源代码14 项目： kripton 文件： Bean2Table.java

/**
 * for attribute valueDoubleSet serialization
 */
public static byte[] serializeValueDoubleSet(HashSet<Double> value) {
  if (value==null) {
    return null;
  }
  KriptonJsonContext context=KriptonBinder.jsonBind();
  try (KriptonByteArrayOutputStream stream=new KriptonByteArrayOutputStream(); JacksonWrapperSerializer wrapper=context.createSerializer(stream)) {
    JsonGenerator jacksonSerializer=wrapper.jacksonGenerator;
    jacksonSerializer.writeStartObject();
    int fieldCount=0;
    if (value!=null)  {
      fieldCount++;
      // write wrapper tag
      jacksonSerializer.writeFieldName("element");
      jacksonSerializer.writeStartArray();
      for (Double item: value) {
        if (item==null) {
          jacksonSerializer.writeNull();
        } else {
          jacksonSerializer.writeNumber(item);
        }
      }
      jacksonSerializer.writeEndArray();
    }
    jacksonSerializer.writeEndObject();
    jacksonSerializer.flush();
    return stream.toByteArray();
  } catch(Exception e) {
    e.printStackTrace();
    throw(new KriptonRuntimeException(e.getMessage()));
  }
}

源代码15 项目： kripton 文件： BindBeanSharedPreferences.java

/**
 * for attribute valueByteSet serialization
 */
protected String serializeValueByteSet(Set<Byte> value) {
  if (value==null) {
    return null;
  }
  KriptonJsonContext context=KriptonBinder.jsonBind();
  try (KriptonByteArrayOutputStream stream=new KriptonByteArrayOutputStream(); JacksonWrapperSerializer wrapper=context.createSerializer(stream)) {
    JsonGenerator jacksonSerializer=wrapper.jacksonGenerator;
    jacksonSerializer.writeStartObject();
    int fieldCount=0;
    if (value!=null)  {
      fieldCount++;
      // write wrapper tag
      jacksonSerializer.writeFieldName("valueByteSet");
      jacksonSerializer.writeStartArray();
      for (Byte item: value) {
        if (item==null) {
          jacksonSerializer.writeNull();
        } else {
          jacksonSerializer.writeNumber(item);
        }
      }
      jacksonSerializer.writeEndArray();
    }
    jacksonSerializer.writeEndObject();
    jacksonSerializer.flush();
    return stream.toString();
  } catch(Exception e) {
    e.printStackTrace();
    throw(new KriptonRuntimeException(e.getMessage()));
  }
}

源代码16 项目： kripton 文件： DoubleBeanTable.java

/**
 * for attribute value2 serialization
 */
public static byte[] serializeValue2(LinkedList<Double> value) {
  if (value==null) {
    return null;
  }
  KriptonJsonContext context=KriptonBinder.jsonBind();
  try (KriptonByteArrayOutputStream stream=new KriptonByteArrayOutputStream(); JacksonWrapperSerializer wrapper=context.createSerializer(stream)) {
    JsonGenerator jacksonSerializer=wrapper.jacksonGenerator;
    jacksonSerializer.writeStartObject();
    int fieldCount=0;
    if (value!=null)  {
      fieldCount++;
      int n=value.size();
      Double item;
      // write wrapper tag
      jacksonSerializer.writeFieldName("element");
      jacksonSerializer.writeStartArray();
      for (int i=0; i<n; i++) {
        item=value.get(i);
        if (item==null) {
          jacksonSerializer.writeNull();
        } else {
          jacksonSerializer.writeNumber(item);
        }
      }
      jacksonSerializer.writeEndArray();
    }
    jacksonSerializer.writeEndObject();
    jacksonSerializer.flush();
    return stream.toByteArray();
  } catch(Exception e) {
    e.printStackTrace();
    throw(new KriptonRuntimeException(e.getMessage()));
  }
}

源代码17 项目： kripton 文件： BeanDaoImpl.java

/**
 * for param serializer1 serialization
 */
private byte[] serializer1(List<BeanBean> value) {
  if (value==null) {
    return null;
  }
  KriptonJsonContext context=KriptonBinder.jsonBind();
  try (KriptonByteArrayOutputStream stream=new KriptonByteArrayOutputStream(); JacksonWrapperSerializer wrapper=context.createSerializer(stream)) {
    JsonGenerator jacksonSerializer=wrapper.jacksonGenerator;
    int fieldCount=0;
    jacksonSerializer.writeStartObject();
    if (value!=null)  {
      int n=value.size();
      BeanBean item;
      // write wrapper tag
      jacksonSerializer.writeFieldName("element");
      jacksonSerializer.writeStartArray();
      for (int i=0; i<n; i++) {
        item=value.get(i);
        if (item==null) {
          jacksonSerializer.writeNull();
        } else {
          beanBeanBindMap.serializeOnJackson(item, jacksonSerializer);
        }
      }
      jacksonSerializer.writeEndArray();
    }
    jacksonSerializer.writeEndObject();
    jacksonSerializer.flush();
    return stream.toByteArray();
  } catch(Exception e) {
    e.printStackTrace();
    throw(new KriptonRuntimeException(e.getMessage()));
  }
}

源代码18 项目： armeria 文件： ThriftJacksonSerializers.java

@Override
public void serialize(ThriftReply value, JsonGenerator gen, SerializerProvider provider)
        throws IOException {
    if (value == null) {
        // Oneway function doesn't provide reply
        gen.writeNull();
        return;
    }

    gen.writeStartObject();
    gen.writeFieldName("header");
    serializeTMessage(value.header(), gen);

    final TBase<?, ?> result;
    final TApplicationException exception;
    if (value.isException()) {
        result = null;
        exception = value.exception();
    } else {
        result = value.result();
        exception = null;
    }

    gen.writeFieldName("result");
    serializeTBase(result, gen, useNamedEnums);
    gen.writeFieldName("exception");
    serializeTApplicationException(exception, gen, useNamedEnums);
    gen.writeEndObject();
}

源代码19 项目： odata 文件： JsonPropertyWriter.java

@Override
protected ChunkedActionRenderResult getComplexPropertyChunked(
        Object data, StructuredType type, ChunkedStreamAction action, ChunkedActionRenderResult previousResult)
        throws ODataException {
    try {
        JsonGenerator generator = previousResult.getWriter() == null ?
                JSON_FACTORY.createGenerator(previousResult.getOutputStream(),
                        JsonEncoding.UTF8).setCodec(new JsonCodecMapper()) :
                (JsonGenerator) previousResult.getWriter();
        switch (action) {
            case START_DOCUMENT:
                generator.writeStringField(CONTEXT, getContextURL(getODataUri(), getEntityDataModel()));
                generator.writeFieldName("value");
                if (isCollection(data)) {
                    generator.writeStartArray();
                }

                return new ChunkedActionRenderResult(previousResult.getOutputStream(), generator);
            case BODY_DOCUMENT:
                if (isCollection(data)) {
                    for (Object obj : (List) data) {
                        writeAllProperties(obj, type);
                    }
                } else {
                    writeAllProperties(data, type);
                }

                return new ChunkedActionRenderResult(previousResult.getOutputStream(), generator);
            case END_DOCUMENT:
                if (isCollection(data)) {
                    generator.writeEndArray();
                }
                generator.writeEndObject();

                return new ChunkedActionRenderResult(previousResult.getOutputStream(), generator);
            default:
                throw new ODataRenderException(format(
                        "Unable to render complex type value because of wrong ChunkedStreamAction: {0}",
                        action));
        }
    } catch (ODataException | IOException e) {
        throw new ODataRenderException("Unable to marshall complex");
    }
}

源代码20 项目： usergrid 文件： ExportAdmins.java

private void saveOrganizations( JsonGenerator jg, AdminUserWriteTask task ) throws Exception {

            final BiMap<UUID, String> orgs = task.orgNamesByUuid;

            jg.writeFieldName( "organizations" );

            jg.writeStartArray();

            for (UUID uuid : orgs.keySet()) {

                jg.writeStartObject();

                jg.writeFieldName( "uuid" );
                jg.writeObject( uuid );

                jg.writeFieldName( "name" );
                jg.writeObject( orgs.get( uuid ) );

                jg.writeEndObject();

                synchronized (orgsWritten) {
                    orgsWritten.add( uuid );
                }
            }

            jg.writeEndArray();
        }