如何在Cassandra中实现列类型切换？getColumnType调用失效

你遇到的问题是误用了JDBC风格的API逻辑，Cassandra的DataStax Java驱动并不支持getColumnType(i)这类方法，得用驱动自身的类型体系实现列类型判断。

修正后的实现思路 #

通过ResultSet.getColumnDefinitions()获取列定义集合，遍历每个ColumnDefinition实例，从中提取对应的DataType枚举，再基于这个枚举做类型分支处理。

完整代码示例 #

ResultSet rs = session.execute(query);
ColumnDefinitions columnDefs = rs.getColumnDefinitions();

for (ColumnDefinition colDef : columnDefs) {
    DataType dataType = colDef.getType();
    String columnName = colDef.getName().toString(); // 获取列名，方便后续取值操作

    switch (dataType) {
        case SMALLINT:
            // 处理SMALLINT类型，示例：rs.getSmallInt(columnName)
            break;
        case INT:
            // 处理Cassandra的INT类型，对应Java的Integer：rs.getInt(columnName)
            break;
        case BIGINT:
            // 处理BIGINT类型，对应Java的Long：rs.getLong(columnName)
            break;
        case DECIMAL:
            // 处理DECIMAL类型：rs.getDecimal(columnName)
            break;
        case FLOAT:
            // 处理FLOAT类型：rs.getFloat(columnName)
            break;
        case DOUBLE:
            // 处理DOUBLE类型：rs.getDouble(columnName)
            break;
        // 可按需添加其他Cassandra类型分支，比如TEXT、BOOLEAN、UUID等
        default:
            // 处理未匹配的类型
            break;
    }
}

关键说明 #

• Cassandra的DataType枚举和JDBC的Types枚举不直接对应，比如Cassandra里的INT对应JDBC的Types.INTEGER，必须用驱动提供的DataType枚举值做判断。
• 取值时优先用列名而非索引，既提升代码可读性，也能避免列顺序变化引发的问题。
• 若需要兼容更多Cassandra数据类型，直接在switch分支中添加对应的DataType枚举项即可。

内容的提问来源于stack exchange，提问作者elads11