java - 创建表时 Cassandra 'timestamp' InvalidQueryException

Question

我有一个 Cassandra 3 的小表定义，如下所示。

create table if not exists mytable(id uuid primary key, data text, timestamp lastupdated);

我希望能够将名为“lastupdated”的时间戳列映射到 java.time.Instant 类型。这可以根据 Cassandra 文档通过注册新的即时编解码器来处理，如此处所述 https://datastax.github.io/java-driver/manual/custom_codecs/extras/

按照说明进行操作，包括导入 com.datastax.cassandra:cassandra-driver-extras:3.1.0，我使用以下代码添加即时编解码器。

    // Extra setup to allow Cassandra Timestamp to map to Java 8 Instant
    CodecRegistry myCodecRegistry;
    myCodecRegistry = CodecRegistry.DEFAULT_INSTANCE;
    myCodecRegistry.register(InstantCodec.instance);

    Cluster cluster = Cluster.builder().
            addContactPoints(extractAddresses(config())).
            withCodecRegistry(myCodecRegistry).build();

当我调试此代码时，我可以看到我的 Cluster 对象在初始化后在 cluster.getConfiguration().codecRegistry 中包含新的即时编解码器。

但是，当我执行创建表的 cql(如顶部所定义)时，我通过 session.execute 得到以下异常:

unknown type xxx.lastupdated : 
com.datastax.driver.core.exceptions.InvalidQueryException: Unknown type xxx.lastupdated

我觉得我错过了一些明显的事情，因为即使没有即时编解码器，时间戳也应该被识别，任何帮助将不胜感激。

Answer 1

答案很简单，只需将列名与类型反转即可!

create table if not exists mytable (
    id uuid primary key, 
    data text, 
    lastupdated timestamp
);