Cassandra如何在表INSERT/UPDATE行时创建触发器自动更新update_date字段

结论先行 #

Cassandra原生没有提供类似Oracle的内置行级触发器功能，但有两种方式可以实现你需要的自动更新记录修改时间的需求，优先推荐使用原生内置函数方案。

方案1：使用内置WRITETIME函数（推荐） #

Cassandra默认会自动为所有非主键字段记录写入/更新的微秒级时间戳，无需额外维护字段，查询时直接调用函数即可获取修改时间：

• 若要转换为标准时间格式，配合toTimestamp()函数使用即可
• 如果需要统一记录整行的更新时间，可选择一个每次修改都会更新的业务字段，或是单独新增一个无业务含义的标记字段，取该字段的WRITETIME作为行更新时间

示例代码 #

-- 示例表结构（无需提前定义update_date字段）
CREATE TABLE product (
    product_id UUID PRIMARY KEY,
    product_name TEXT,
    price INT
);

-- 查询时自动获取更新时间
SELECT 
    product_id,
    product_name,
    price,
    toTimestamp(WRITETIME(product_name)) AS update_date
FROM product 
WHERE product_id = 123e4567-e89b-12d3-a456-426614174000;

方案2：自定义触发器（不推荐） #

如果必须要单独存储update_date字段，可以通过自定义Java触发器实现，但生产环境不建议使用，存在性能损耗、版本适配、集群稳定性风险：

1. 编写Java类实现org.apache.cassandra.triggers.ITrigger接口的augment方法，逻辑为自动给每行写入/更新的记录注入当前时间戳到update_date字段
2. 将编译后的Jar包放到所有Cassandra节点的triggers目录下
3. 执行CQL绑定触发器到对应表：

CREATE TRIGGER auto_update_date ON your_table_name USING 'com.yourorg.trigger.UpdateDateTrigger';

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