public static DataType fromJDBCType()

in hologres-connector-flink-base/src/main/java/com/alibaba/ververica/connectors/hologres/utils/PostgresTypeUtil.java [48:120]
71 lines of code
33 McCabe index (conditional complexity)

    public static DataType fromJDBCType(ResultSetMetaData metadata, int colIndex)
            throws SQLException {
        String pgType = metadata.getColumnTypeName(colIndex);

        switch (pgType) {
            case PG_BOOLEAN:
                return DataTypes.BOOLEAN();
            case PG_BOOLEAN_ARRAY:
                return DataTypes.ARRAY(DataTypes.BOOLEAN());
            case PG_BYTEA:
            case PG_BYTEA_ARRAY:
                return DataTypes.BYTES();
            case PG_SMALLINT:
                return DataTypes.SMALLINT();
            case PG_SMALLINT_ARRAY:
                return DataTypes.ARRAY(DataTypes.SMALLINT());
            case PG_INTEGER:
                return DataTypes.INT();
            case PG_INTEGER_ARRAY:
                return DataTypes.ARRAY(DataTypes.INT());
            case PG_BIGINT:
                return DataTypes.BIGINT();
            case PG_BIGINT_ARRAY:
                return DataTypes.ARRAY(DataTypes.BIGINT());
            case PG_REAL:
                return DataTypes.FLOAT();
            case PG_REAL_ARRAY:
                return DataTypes.ARRAY(DataTypes.FLOAT());
            case PG_DOUBLE_PRECISION:
                return DataTypes.DOUBLE();
            case PG_DOUBLE_PRECISION_ARRAY:
                return DataTypes.ARRAY(DataTypes.DOUBLE());
            case PG_NUMERIC:
                return DataTypes.DECIMAL(
                        metadata.getPrecision(colIndex), metadata.getScale(colIndex));
            case PG_NUMERIC_ARRAY:
                return DataTypes.ARRAY(
                        DataTypes.DECIMAL(
                                metadata.getPrecision(colIndex), metadata.getScale(colIndex)));
            case PG_CHAR:
            case PG_CHARACTER:
                return DataTypes.CHAR(1);
            case PG_CHAR_ARRAY:
            case PG_CHARACTER_ARRAY:
                return DataTypes.ARRAY(DataTypes.CHAR(1));
            case PG_TEXT:
            case PG_CHARACTER_VARYING:
                return DataTypes.STRING();
            case PG_TEXT_ARRAY:
            case PG_CHARACTER_VARYING_ARRAY:
                return DataTypes.ARRAY(DataTypes.STRING());
            case PG_TIMESTAMP:
                return DataTypes.TIMESTAMP();
            case PG_TIMESTAMP_ARRAY:
                return DataTypes.ARRAY(DataTypes.TIMESTAMP());
                // TODO: add timestamptz for Holo
            case PG_TIMESTAMPTZ:
                return DataTypes.TIMESTAMP();
            case PG_TIMESTAMPTZ_ARRAY:
                return DataTypes.ARRAY(DataTypes.TIMESTAMP());
            case PG_TIME:
                return DataTypes.TIME();
            case PG_TIME_ARRAY:
                return DataTypes.ARRAY(DataTypes.TIME());
            case PG_DATE:
                return DataTypes.DATE();
            case PG_DATE_ARRAY:
                return DataTypes.ARRAY(DataTypes.DATE());
            default:
                throw new UnsupportedOperationException(
                        String.format("Doesn't support Postgres type '%s' yet", pgType));
        }
    }