package com.fasterxml.jackson.dataformat.avro.ser;
import java.io.IOException;
import java.math.BigDecimal;
import java.math.BigInteger;
import java.util.ArrayList;
import org.apache.avro.Schema;
import org.apache.avro.Schema.Type;
import org.apache.avro.generic.GenericData;
import org.apache.avro.generic.GenericDatumWriter;
import org.apache.avro.io.Encoder;
public class NonBSGenericDatumWriter<D>
extends GenericDatumWriter<D>
{
private static final GenericData GENERIC_DATA = GenericData.get();
private final static Class<?> CLS_STRING = String.class;
private final static Class<?> CLS_BIG_DECIMAL = BigDecimal.class;
private final static Class<?> CLS_BIG_INTEGER = BigInteger.class;
public NonBSGenericDatumWriter(Schema root) {
super(root);
}
@Override
public int resolveUnion(Schema union, Object datum) {
return AvroWriteContext.resolveUnionIndex(union, datum);
}
@Override
protected void write(Schema schema, Object datum, Encoder out) throws IOException
{
if (datum == null) {
super.writeWithoutConversion(schema, datum, out);
return;
}
switch (schema.getType()) {
case STRING:
Class<?> raw = datum.getClass();
if (raw == CLS_STRING) {
writeString(datum, out);
return;
}
if ((raw == CLS_BIG_DECIMAL) || (raw == CLS_BIG_INTEGER)) {
writeString(datum.toString(), out);
return;
}
break;
case ENUM:
super.writeWithoutConversion(schema, GENERIC_DATA.createEnum(datum.toString(), schema), out);
return;
case INT:
if (datum.getClass() == CLS_STRING) {
String str = (String) datum;
final int len = str.length();
if (len == 1) {
super.writeWithoutConversion(schema, (int) str.charAt(0), out);
return;
}
}
break;
case LONG:
if (datum.getClass() == CLS_BIG_INTEGER) {
datum = ((BigInteger) datum).longValue();
}
break;
case DOUBLE:
if (datum.getClass() == CLS_BIG_DECIMAL) {
datum = ((BigDecimal) datum).doubleValue();
}
break;
case ARRAY:
if (datum.getClass() == CLS_STRING) {
if (schema.getElementType().getType() == Type.INT) {
String str = (String) datum;
final int len = str.length();
ArrayList<Integer> chars = new ArrayList<>(len);
for (int i = 0; i < len; ++i) {
chars.add((int) str.charAt(i));
}
super.writeWithoutConversion(schema, chars, out);
return;
}
}
break;
default:
}
if (datum instanceof EncodedDatum) {
((EncodedDatum) datum).write(out);
return;
}
super.writeWithoutConversion(schema, datum, out);
}
}