diff --git a/presto-base-jdbc/src/main/java/com/facebook/presto/plugin/jdbc/BaseJdbcClient.java b/presto-base-jdbc/src/main/java/com/facebook/presto/plugin/jdbc/BaseJdbcClient.java index de285d44c193e..2c18fc93a47a6 100644 --- a/presto-base-jdbc/src/main/java/com/facebook/presto/plugin/jdbc/BaseJdbcClient.java +++ b/presto-base-jdbc/src/main/java/com/facebook/presto/plugin/jdbc/BaseJdbcClient.java @@ -487,14 +487,6 @@ protected Type toPrestoType(int jdbcType, int columnSize) case Types.CHAR: case Types.NCHAR: return createCharType(min(columnSize, CharType.MAX_LENGTH)); - case Types.VARCHAR: - case Types.NVARCHAR: - case Types.LONGVARCHAR: - case Types.LONGNVARCHAR: - if (columnSize > VarcharType.MAX_LENGTH) { - return createUnboundedVarcharType(); - } - return createVarcharType(columnSize); case Types.BINARY: case Types.VARBINARY: case Types.LONGVARBINARY: @@ -505,8 +497,16 @@ protected Type toPrestoType(int jdbcType, int columnSize) return TIME; case Types.TIMESTAMP: return TIMESTAMP; + case Types.VARCHAR: + case Types.NVARCHAR: + case Types.LONGVARCHAR: + case Types.LONGNVARCHAR: + default: + if (columnSize > VarcharType.MAX_LENGTH) { + return createUnboundedVarcharType(); + } + return createVarcharType(columnSize); } - return null; } protected String toSqlType(Type type)