in flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/utils/JdbcTypeUtil.java [68:87]
static {
HashMap<TypeInformation<?>, Integer> m = new HashMap<>();
m.put(STRING_TYPE_INFO, Types.VARCHAR);
m.put(BOOLEAN_TYPE_INFO, Types.BOOLEAN);
m.put(BYTE_TYPE_INFO, Types.TINYINT);
m.put(SHORT_TYPE_INFO, Types.SMALLINT);
m.put(INT_TYPE_INFO, Types.INTEGER);
m.put(LONG_TYPE_INFO, Types.BIGINT);
m.put(FLOAT_TYPE_INFO, Types.REAL);
m.put(DOUBLE_TYPE_INFO, Types.DOUBLE);
m.put(SqlTimeTypeInfo.DATE, Types.DATE);
m.put(SqlTimeTypeInfo.TIME, Types.TIME);
m.put(SqlTimeTypeInfo.TIMESTAMP, Types.TIMESTAMP);
m.put(LocalTimeTypeInfo.LOCAL_DATE, Types.DATE);
m.put(LocalTimeTypeInfo.LOCAL_TIME, Types.TIME);
m.put(LocalTimeTypeInfo.LOCAL_DATE_TIME, Types.TIMESTAMP);
m.put(BIG_DEC_TYPE_INFO, Types.DECIMAL);
m.put(BYTE_PRIMITIVE_ARRAY_TYPE_INFO, Types.BINARY);
TYPE_MAPPING = Collections.unmodifiableMap(m);
}