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 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	serializerGeometry(OutputStream out, ClickHouseColumn column, Object value)
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 byte[]	stringValueToByteArray(Object value)	Used from the bytecode generated by compilePOJOSetter(Method, ClickHouseColumn).
static String	stringValueToString(Object value)	Used from the bytecode generated by compilePOJOSetter(Method, ClickHouseColumn).
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	writeFixedStringBytes(OutputStream stream, byte[] value, int length)	Writes raw bytes as a ClickHouse FixedString(length) value.
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

serializerGeometry

public static void serializerGeometry(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)

convertToString

public static String convertToString(Object value)

stringValueToString

public static String stringValueToString(Object value)

Used from the bytecode generated by compilePOJOSetter(Method, ClickHouseColumn). Does all needed conversions so have to accept Object instead of specific value type.

Parameters:

value - value returned by BinaryStreamReader.readValue

Returns:

the decoded string, or null

stringValueToByteArray

public static byte[] stringValueToByteArray(Object value)

Used from the bytecode generated by compilePOJOSetter(Method, ClickHouseColumn). Does all needed conversions so have to accept Object instead of specific value type.

Parameters:

value - value returned by BinaryStreamReader.readValue

Returns:

the raw bytes, or null

writeFixedStringBytes

public static void writeFixedStringBytes(OutputStream stream,
 byte[] value,
 int length)
                                  throws IOException

Writes raw bytes as a ClickHouse FixedString(length) value. The bytes are written as-is and right-padded with zero bytes when shorter than length.

Parameters:

stream - output stream

value - raw bytes

length - fixed string length

Throws:

IOException - when failed to write to the stream

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)

Parameters:

setterMethod -

column -

Returns:

See Also:

• ClickHouseDataType.toPrimitiveType(Class)
• BinaryStreamReader.isReadToPrimitive(ClickHouseDataType)
• stringValueToString(Object)
• stringValueToByteArray(Object)
• binaryReaderMethodForType(MethodVisitor, Class, ClickHouseDataType)
• intToOpcode(Class)
• longToOpcode(Class)
• floatToOpcode(Class)
• doubleToOpcode(Class)
• BinaryStreamReader.readValue(ClickHouseColumn, Class)
• BinaryStreamReader.readByte()
• BinaryStreamReader.readUnsignedByte()
• BinaryStreamReader.readShortLE()
• BinaryStreamReader.readUnsignedShortLE()
• BinaryStreamReader.readIntLE()
• BinaryStreamReader.readUnsignedIntLE()
• BinaryStreamReader.readLongLE()
• BinaryStreamReader.readFloatLE()
• BinaryStreamReader.readDoubleLE()
• Arrays.asList(Object[])

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