static

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);
    }