in flink-vvp-connector-adbpg/src/main/java/org/apache/flink/connector/jdbc/table/utils/StreamingServerTypeUtil.java [56:92]
static {
HashMap<TypeInformation<?>, Integer> m = new HashMap<>();
m.put(BasicTypeInfo.STRING_TYPE_INFO, java.sql.Types.VARCHAR);
m.put(BasicTypeInfo.BOOLEAN_TYPE_INFO, java.sql.Types.BOOLEAN);
m.put(BasicTypeInfo.BYTE_TYPE_INFO, java.sql.Types.TINYINT);
m.put(BasicTypeInfo.SHORT_TYPE_INFO, java.sql.Types.SMALLINT);
m.put(BasicTypeInfo.INT_TYPE_INFO, java.sql.Types.INTEGER);
m.put(BasicTypeInfo.LONG_TYPE_INFO, java.sql.Types.BIGINT);
m.put(BasicTypeInfo.FLOAT_TYPE_INFO, java.sql.Types.REAL);
m.put(BasicTypeInfo.DOUBLE_TYPE_INFO, java.sql.Types.DOUBLE);
m.put(SqlTimeTypeInfo.DATE, java.sql.Types.DATE);
m.put(SqlTimeTypeInfo.TIME, java.sql.Types.TIME);
m.put(SqlTimeTypeInfo.TIMESTAMP, java.sql.Types.TIMESTAMP);
m.put(LocalTimeTypeInfo.LOCAL_DATE, java.sql.Types.DATE);
m.put(LocalTimeTypeInfo.LOCAL_TIME, java.sql.Types.TIME);
m.put(LocalTimeTypeInfo.LOCAL_DATE_TIME, java.sql.Types.TIMESTAMP);
m.put(BasicTypeInfo.BIG_DEC_TYPE_INFO, java.sql.Types.DECIMAL);
m.put(PrimitiveArrayTypeInfo.BYTE_PRIMITIVE_ARRAY_TYPE_INFO, java.sql.Types.BINARY);
TYPE_MAPPING = Collections.unmodifiableMap(m);
HashMap<Integer, String> names = new HashMap<>();
names.put(java.sql.Types.VARCHAR, "VARCHAR");
names.put(java.sql.Types.BOOLEAN, "BOOLEAN");
names.put(java.sql.Types.TINYINT, "TINYINT");
names.put(java.sql.Types.SMALLINT, "SMALLINT");
names.put(java.sql.Types.INTEGER, "INTEGER");
names.put(java.sql.Types.BIGINT, "BIGINT");
names.put(java.sql.Types.FLOAT, "FLOAT");
names.put(java.sql.Types.DOUBLE, "DOUBLE");
names.put(java.sql.Types.CHAR, "CHAR");
names.put(java.sql.Types.DATE, "DATE");
names.put(java.sql.Types.TIME, "TIME");
names.put(java.sql.Types.TIMESTAMP, "TIMESTAMP");
names.put(java.sql.Types.DECIMAL, "DECIMAL");
names.put(java.sql.Types.BINARY, "BINARY");
SQL_TYPE_NAMES = Collections.unmodifiableMap(names);
}