Java插入Cassandra遇InvalidQueryException，如何提前规避驱动错误？

这个错误我之前帮团队排查过好几次，本质就是你插入的数据和Cassandra表定义的字段类型不兼容，或者传了不符合Cassandra int类型规范的值——Cassandra的int是固定4字节的有符号整数，范围在-2147483648到2147483647之间，错误里的(10)应该是指你传的某个数据长度不对，比如把字符串"10"当成int传了，或者数值超出范围，甚至是字段类型定义和你传的类型不匹配。

下面是几个提前处理的方法，能帮你规避这类驱动错误：

1. 先对齐表结构与实体类的字段类型 #

首先得确认Cassandra中flights表的各个字段类型，比如year字段如果定义的是int，那你的flight.getYear()返回的必须是Java的Integer类型，不能是String或者超出int范围的Long。举个例子：如果CSV里的年份是字符串"20240"（超出int最大值2147483647），直接转成Integer插入就会触发这个错误。

2. 给每个插入字段加前置数据校验 #

在循环插入之前，对每个要插入的字段做合法性校验，把问题扼杀在插入之前：

• 对于int类型字段：
  • 检查数值范围：如果数值超出Cassandra int的范围，要么修改表字段为bigint（对应Java的Long），要么抛出业务异常提示数据问题，别硬插。
  • 检查空值：如果表字段不允许null，提前给空值设默认值或者跳过这条数据。
  • 从CSV读取的字符串类型要先做格式校验，用try-catch包裹转换逻辑，避免把非数字字符串传进去。

示例校验代码：

for (Flight flight : flightList) {
    // 校验year字段
    Integer year = flight.getYear();
    if (year == null) {
        System.err.println("跳过航班 " + flight.getId() + ": 年份为空");
        continue;
    }
    if (year < Integer.MIN_VALUE || year > Integer.MAX_VALUE) {
        throw new IllegalArgumentException("航班 " + flight.getId() + " 的年份 " + year + " 超出Cassandra int类型范围");
        // 或者转成Long，同时修改表的year字段为bigint
        // Long yearBig = year.longValue();
    }

    // 其他字段同理做校验...

    Insert query = QueryBuilder.insertInto("flights")
            .value("id", flight.getId())
            .value("year", year)
            // 其他字段赋值...
}

3. 用类型安全的Object Mapper替代手动构建查询 #

Datastax驱动提供了Object Mapper API，能帮你自动处理实体类和表字段的类型映射，还会在插入前提前检查类型匹配，比手动写QueryBuilder更安全。比如先给实体类加注解：

@Table(keyspace = "你的keyspace名称", name = "flights")
public class Flight {
    @PartitionKey
    private UUID id;
    @Column(name = "year")
    private Integer year;
    // 其他字段及对应的getter/setter
}

然后用Mapper插入：

MappingManager manager = new MappingManager(session);
Mapper<Flight> flightMapper = manager.mapper(Flight.class);
flightMapper.save(flight);

这样如果类型不匹配，Mapper会在更早的阶段抛出错误，而不是等到插入时才触发InvalidQueryException。

4. 批量插入前先做抽样测试 #

如果你的CSV数据量很大，不想每条都做校验，可以先取前10-20条数据做测试插入，提前发现数据问题，避免处理了几万条数据才报错的尴尬情况。

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