Package com.clickhouse.client.api.data_formats.internal

Class SerializerUtils

java.lang.Object

com.clickhouse.client.api.data_formats.internal.SerializerUtils

public class SerializerUtils
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	SerializerUtils.DynamicClassLoader

Constructor Summary

Constructors

Constructor	Description
SerializerUtils()

Method Summary

Modifier and Type	Method	Description
static POJOFieldDeserializer	compilePOJOSetter(Method setterMethod, ClickHouseColumn column)
static List<?>	convertArrayValueToList(Object value)
static BigDecimal	convertToBigDecimal(Object value)
static BigInteger	convertToBigInteger(Object value)
static boolean	convertToBoolean(Object value)
static Integer	convertToInteger(Object value)
static Long	convertToLong(Object value)
static String	convertToString(Object value)
static boolean	numberToBoolean(Number value)
static <T extends Enum<T>> Set<T>	parseEnumList(String value, Class<T> enumType)
static void	serializeAggregateFunction(OutputStream stream, Object value, ClickHouseColumn column)
static void	serializeArrayData(OutputStream stream, Object value, ClickHouseColumn column)	DO NOT USE - part of internal API that will be changed
static void	serializeData(OutputStream stream, Object value, ClickHouseColumn column)
static void	serializeEnumData(OutputStream stream, ClickHouseColumn column, Object value)
static void	serializeInterval(OutputStream stream, ClickHouseColumn column, Object value)
static void	serializeJSON(OutputStream stream, Object value)
static void	serializeMapData(OutputStream stream, Object value, ClickHouseColumn column)	DO NOT USE - part of internal API that will be changed
static void	serializerVariant(OutputStream out, ClickHouseColumn column, Object value)
static void	serializeTupleData(OutputStream stream, Object value, ClickHouseColumn column)	DO NOT USE - part of internal API that will be changed
static ClickHouseColumn	valueToColumnForDynamicType(Object value)
static void	writeBoolean(OutputStream output, boolean value)
static void	writeDate(OutputStream output, Object value, ZoneId targetTz)
static void	writeDate32(OutputStream output, Object value, ZoneId targetTz)
static void	writeDateTime(OutputStream output, Object value, ZoneId targetTz)
static void	writeDateTime32(OutputStream output, Object value, ZoneId targetTz)
static void	writeDateTime64(OutputStream output, Object value, int scale, ZoneId targetTz)
static void	writeDynamicTypeTag(OutputStream stream, ClickHouseColumn typeColumn)
static void	writeNonNull(OutputStream output)
static void	writeNull(OutputStream output)
static void	writeVarInt(OutputStream output, long value)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

SerializerUtils

public SerializerUtils()

Method Details

serializeData

public static void serializeData(OutputStream stream,
 Object value,
 ClickHouseColumn column)
                          throws IOException

Throws:

IOException

valueToColumnForDynamicType

public static ClickHouseColumn valueToColumnForDynamicType(Object value)

writeDynamicTypeTag

public static void writeDynamicTypeTag(OutputStream stream,
 ClickHouseColumn typeColumn)
                                throws IOException

Throws:

IOException

serializeArrayData

public static void serializeArrayData(OutputStream stream,
 Object value,
 ClickHouseColumn column)
                               throws IOException

DO NOT USE - part of internal API that will be changed

Throws:

IOException

serializeTupleData

public static void serializeTupleData(OutputStream stream,
 Object value,
 ClickHouseColumn column)
                               throws IOException

DO NOT USE - part of internal API that will be changed

Throws:

IOException

serializeMapData

public static void serializeMapData(OutputStream stream,
 Object value,
 ClickHouseColumn column)
                             throws IOException

DO NOT USE - part of internal API that will be changed

Throws:

IOException

serializeInterval

public static void serializeInterval(OutputStream stream,
 ClickHouseColumn column,
 Object value)
                              throws IOException

Throws:

IOException

serializeEnumData

public static void serializeEnumData(OutputStream stream,
 ClickHouseColumn column,
 Object value)
                              throws IOException

Throws:

IOException

serializeJSON

public static void serializeJSON(OutputStream stream,
 Object value)
                          throws IOException

Throws:

IOException

serializerVariant

public static void serializerVariant(OutputStream out,
 ClickHouseColumn column,
 Object value)
                              throws IOException

Throws:

IOException

serializeAggregateFunction

public static void serializeAggregateFunction(OutputStream stream,
 Object value,
 ClickHouseColumn column)
                                       throws IOException

Throws:

IOException

convertToInteger

public static Integer convertToInteger(Object value)

convertToLong

public static Long convertToLong(Object value)

convertToBigInteger

public static BigInteger convertToBigInteger(Object value)

convertToBigDecimal

public static BigDecimal convertToBigDecimal(Object value)

convertToString

public static String convertToString(Object value)

parseEnumList

public static <T extends Enum<T>> Set<T> parseEnumList(String value,
 Class<T> enumType)

numberToBoolean

public static boolean numberToBoolean(Number value)

convertToBoolean

public static boolean convertToBoolean(Object value)

convertArrayValueToList

public static List<?> convertArrayValueToList(Object value)

compilePOJOSetter

public static POJOFieldDeserializer compilePOJOSetter(Method setterMethod,
 ClickHouseColumn column)

writeVarInt

public static void writeVarInt(OutputStream output,
 long value)
                        throws IOException

Throws:

IOException

writeNull

public static void writeNull(OutputStream output)
                      throws IOException

Throws:

IOException

writeNonNull

public static void writeNonNull(OutputStream output)
                         throws IOException

Throws:

IOException

writeBoolean

public static void writeBoolean(OutputStream output,
 boolean value)
                         throws IOException

Throws:

IOException

writeDate

public static void writeDate(OutputStream output,
 Object value,
 ZoneId targetTz)
                      throws IOException

Throws:

IOException

writeDate32

public static void writeDate32(OutputStream output,
 Object value,
 ZoneId targetTz)
                        throws IOException

Throws:

IOException

writeDateTime32

public static void writeDateTime32(OutputStream output,
 Object value,
 ZoneId targetTz)
                            throws IOException

Throws:

IOException

writeDateTime

public static void writeDateTime(OutputStream output,
 Object value,
 ZoneId targetTz)
                          throws IOException

Throws:

IOException

writeDateTime64

public static void writeDateTime64(OutputStream output,
 Object value,
 int scale,
 ZoneId targetTz)
                            throws IOException

Throws:

IOException