Cassandra中能否用CQL解析JSON属性，实现带指定Timestamp的插入？

结论 #

Cassandra原生CQL不支持在INSERT/UPDATE语句中直接解析输入的JSON字符串，提取其中的属性值作为USING TIMESTAMP的参数。

原因 #

CQL的JSON相关语法（如INSERT ... JSON）仅用于将JSON字段与表列做映射插入，无法直接对原始JSON字符串执行字段提取操作，也没有内置的JSON解析函数支持在语句执行阶段处理这类需求。

可行解决办法 #

1. 客户端提前解析处理

在发送CQL请求前，在客户端代码中先解析JSON字符串，提取mytimestamp字段的值，将其转换为Cassandra要求的毫秒级UNIX时间戳（比如把"2019-09-02T22:02:24.355Z"转换为1567456944355），再构造完整的INSERT语句：

INSERT INTO myspace.mytable (id, data)
VALUES ('123', textAsBlob('{"id":123,"some_string":"hello there","mytimestamp":"2019-09-02T22:02:24.355Z"}'))
USING timestamp 1567456944355;

这种方式是最直接且性能最优的方案，避免了数据库端的额外计算开销。

2. 使用用户自定义函数（UDF）在数据库端处理

如果必须在数据库侧完成解析，可以通过编写UDF实现JSON字段提取。注意需要先在cassandra.yaml中开启enable_user_defined_functions: true，允许创建自定义函数。

首先创建解析JSON提取时间戳的UDF：

CREATE OR REPLACE FUNCTION myspace.extract_timestamp(json_str text, field_name text)
RETURNS NULL ON NULL INPUT
RETURNS bigint
LANGUAGE java
AS '
import com.fasterxml.jackson.databind.JsonNode;
import com.fasterxml.jackson.databind.ObjectMapper;
import java.io.IOException;
import java.time.Instant;
public class TimestampExtractor {
    public static long extract(String jsonStr, String fieldName) throws IOException {
        ObjectMapper mapper = new ObjectMapper();
        JsonNode node = mapper.readTree(jsonStr);
        String tsStr = node.get(fieldName).asText();
        return Instant.parse(tsStr).toEpochMilli();
    }
}
';

之后在INSERT语句中调用该UDF：

INSERT INTO myspace.mytable (id, data)
VALUES ('123', textAsBlob('{"id":123,"some_string":"hello there","mytimestamp":"2019-09-02T22:02:24.355Z"}'))
USING timestamp myspace.extract_timestamp(textFromBlob(data), 'mytimestamp');

注意：这种方式会带来额外的性能开销，且需要处理JSON解析失败的异常场景，仅在客户端无法处理时考虑使用。

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