private DataType getNumericType()

in flink-connector-jdbc-oceanbase/src/main/java/org/apache/flink/connector/jdbc/oceanbase/database/catalog/OceanBaseTypeMapper.java [120:137]

• 18 lines of code
• 7 McCabe index (conditional complexity)

    private DataType getNumericType(int precision, int scale) {
        if (precision == 0) {
            return DataTypes.STRING();
        }
        if (scale <= 0) {
            int width = precision - scale;
            if (width < 3) {
                return DataTypes.TINYINT();
            } else if (width < 5) {
                return DataTypes.SMALLINT();
            } else if (width < 10) {
                return DataTypes.INT();
            } else if (width < 19) {
                return DataTypes.BIGINT();
            }
        }
        return getDecimalType(precision, scale);
    }