Java插入Cassandra报错：timeuuid类型适配问题及代码修改建议

首先看你的报错信息：

Exception in thread "main" com.datastax.driver.core.exceptions.InvalidQueryException: Invalid STRING constant (2012/11/11) for "fl_date" of type timeuuid

很明显，当前表的fl_date字段是timeuuid类型，但你插入的是普通日期字符串2012/11/11，二者完全不兼容。TimeUUID是带时间戳的UUID格式（比如1b053500-80a5-11ee-b9d1-0242ac120002），根本无法直接接受yyyy/MM/dd格式的字符串。

你提到尝试把字段类型改成timestamp但问题仍存在，大概率是两个原因之一：

• 表结构修改没生效（比如执行ALTER TABLE后没刷新，或者操作的是错误的keyspace/表）；
• Java代码里还是在按旧的timeuuid逻辑处理数据，或者没有正确转换日期格式适配timestamp类型。

1. 先确认表结构确实更新为timestamp #

先通过CQL命令验证表结构：

DESCRIBE TABLE your_flight_table;

如果fl_date还是timeuuid，重新执行修改命令（注意替换成你的表名）：

ALTER TABLE your_flight_table ALTER fl_date TYPE timestamp;

Cassandra的timestamp类型支持ISO 8601格式的字符串（比如2012-11-11、2012-11-11T00:00:00Z），或者直接接受Java的java.util.Date、java.time.Instant对象。

2. 修改Java代码适配日期转换 #

你的CSV里的日期格式是yyyy/MM/dd，需要先转换成Cassandratimestamp能识别的格式或对象，再插入。

示例代码修改（Java 8+ 推荐用新的日期API） #

在ProcessFlightsCSV.processFlights方法中，解析fl_date字段时加入格式转换：

import java.time.LocalDate;
import java.time.format.DateTimeFormatter;
import java.sql.Timestamp;

// 定义日期格式匹配CSV的格式
DateTimeFormatter csvDateFormatter = DateTimeFormatter.ofPattern("yyyy/MM/dd");

// 解析CSV中的fl_date字符串（这里假设你用CSV读取工具获取字段值）
String flDateStr = csvRecord.get("fl_date");
LocalDate localDate = LocalDate.parse(flDateStr, csvDateFormatter);
// 转换为Cassandra能接受的Timestamp
Timestamp timestamp = Timestamp.valueOf(localDate.atStartOfDay());

然后在插入Cassandra的代码中，绑定这个timestamp对象：

import com.datastax.driver.core.Session;
import com.datastax.driver.core.PreparedStatement;
import com.datastax.driver.core.BoundStatement;

// 准备插入语句
PreparedStatement insertStmt = session.prepare(
    "INSERT INTO your_flight_table (fl_date, [其他字段]) VALUES (?, [其他占位符])"
);
// 绑定参数时传入转换后的timestamp
BoundStatement boundStmt = insertStmt.bind(timestamp, [其他参数]);
session.execute(boundStmt);

注意事项 #

• 如果你之前的代码里有尝试把日期字符串转换成UUID或TimeUUID的逻辑（比如UUID.fromString(flDateStr)），一定要完全删除，这是错误的根源；
• 如果你用的是旧版Java（Java 7及以下），可以用SimpleDateFormat来转换，但要注意线程安全问题：

  SimpleDateFormat sdf = new SimpleDateFormat("yyyy/MM/dd");
  Date date = sdf.parse(flDateStr);
  Timestamp timestamp = new Timestamp(date.getTime());
  

这个问题最初是数据类型选择完全不匹配（用timeuuid存普通日期），改timestamp是正确方向，但需要确保表结构真正更新，同时代码里完成日期格式的正确转换，才能解决报错。

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