org.apache.flink.connector.jdbc.utils

Class JdbcTypeUtil

java.lang.Object

org.apache.flink.connector.jdbc.utils.JdbcTypeUtil

@Internal
public class JdbcTypeUtil
extends Object

Utils for jdbc type.

Method Summary

Modifier and Type	Method and Description
static String	getTypeName(int type)
static String	getTypeName(TypeInformation<?> type)
static TableSchema	normalizeTableSchema(TableSchema schema) The original table schema may contain generated columns which shouldn't be produced/consumed by TableSource/TableSink.
static int	typeInformationToSqlType(TypeInformation<?> type)

Methods inherited from class java.lang.Object

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

Method Detail

typeInformationToSqlType

public static int typeInformationToSqlType(TypeInformation<?> type)

getTypeName

public static String getTypeName(int type)

getTypeName

public static String getTypeName(TypeInformation<?> type)

normalizeTableSchema

public static TableSchema normalizeTableSchema(TableSchema schema)

The original table schema may contain generated columns which shouldn't be produced/consumed by TableSource/TableSink. And the original TIMESTAMP/DATE/TIME types uses LocalDateTime/LocalDate/LocalTime as the conversion classes, however, JDBC connector uses Timestamp/Date/Time classes. So that we bridge them to the expected conversion classes.