in src/main/java/com/aliyun/odps/jdbc/utils/JdbcColumn.java [205:236]
public static int columnScale(OdpsType type, TypeInfo typeInfo) throws SQLException {
int columnType = odpsTypeToSqlType(type);
// according to odpsTypeToSqlType possible options are:
switch (columnType) {
case Types.NULL:
case Types.BOOLEAN:
case Types.CHAR:
case Types.VARCHAR:
case Types.TINYINT:
case Types.SMALLINT:
case Types.INTEGER:
case Types.BIGINT:
case Types.DATE:
case Types.BINARY:
return 0;
case Types.FLOAT:
return 7;
case Types.DOUBLE:
return 15;
case Types.TIMESTAMP:
return 9;
case Types.DECIMAL:
return ((DecimalTypeInfo) typeInfo).getScale();
case Types.OTHER:
case Types.JAVA_OBJECT:
case Types.ARRAY:
case Types.STRUCT:
return 0;
default:
throw new SQLException("Invalid odps type: " + columnType);
}
}