如何通过Java DataStax驱动获取Cassandra列TTL并基于现有TTL更新列

首先明确：Cassandra的TTL是列级别的属性，不存在整行统一TTL的概念，只有当你写入整行时给所有列设置了相同TTL，才会出现整行TTL一致的情况；主键列没有TTL属性，永久有效。

查询TTL直接使用Cassandra原生的TTL()函数即可，DataStax Java驱动不需要额外配置，直接在CQL中调用就能拿到结果：

• 查询单/多列TTL时，在SELECT子句中为每个需要获取TTL的列追加TTL(列名) AS 别名，返回值为该列距离过期的剩余秒数，若返回值为null代表该列未设置TTL、永久有效。
• 如果需要获取所谓“整行TTL”，可以把所有非主键列都套上TTL()函数查询，当所有非主键列返回的TTL值完全一致时，就是你写入时设置的整行TTL。

示例代码（基于DataStax Java Driver 4.x版本）：

// 初始化CQL会话
CqlSession session = CqlSession.builder().build();
// 以查询user表主键id=123的username、email列值及对应TTL为例
PreparedStatement queryPs = session.prepare(
    "SELECT username, TTL(username) AS username_ttl, email, TTL(email) AS email_ttl " +
    "FROM user WHERE id = ?"
);
ResultSet rs = session.execute(queryPs.bind(123));
Row result = rs.one();
if (result != null) {
    // 取列值
    String username = result.getString("username");
    String email = result.getString("email");
    // 取对应TTL，单位为秒
    Integer usernameTtl = result.get("username_ttl", Integer.class);
    Integer emailTtl = result.get("email_ttl", Integer.class);
}

Cassandra没有提供直接继承列原有TTL的更新语法，实现复用的核心逻辑是先查询目标列的剩余TTL，再在更新时将该TTL值传入，具体实现步骤如下：

1. 先执行查询语句，拿到待更新列当前的剩余TTL值；
2. 根据TTL查询结果构建更新语句：如果TTL为null说明列是永久有效，更新时不要带TTL参数；如果TTL有值，在更新该列时通过USING TTL传入查到的剩余秒数即可。

示例代码：

int targetUserId = 123;
String newUsernameVal = "new_demo_name";

// 第一步：查询目标列现有TTL
PreparedStatement ttlQueryPs = session.prepare("SELECT TTL(username) AS ttl FROM user WHERE id = ?");
Row ttlResult = session.execute(ttlQueryPs.bind(targetUserId)).one();
Integer existTtl = ttlResult == null ? null : ttlResult.get("ttl", Integer.class);

// 第二步：构建更新语句复用TTL
SimpleStatement updateStmt;
if (existTtl != null) {
    // 有TTL时传入剩余秒数，保持原有过期时间点不变
    updateStmt = SimpleStatement.builder("UPDATE user SET username = ? USING TTL ? WHERE id = ?")
            .addPositionalValue(newUsernameVal)
            .addPositionalValue(existTtl)
            .addPositionalValue(targetUserId)
            .build();
} else {
    // 无TTL时不设置TTL，保持永久有效属性
    updateStmt = SimpleStatement.builder("UPDATE user SET username = ? WHERE id = ?")
            .addPositionalValue(newUsernameVal)
            .addPositionalValue(targetUserId)
            .build();
}
session.execute(updateStmt);

注意事项 #

• 普通“查TTL+更新”的流程不是原子操作，如果查询和更新的间隙有其他请求修改了目标列的TTL，会出现TTL配置不一致的问题。如果对一致性要求极高，可以使用Cassandra轻量事务（LWT）将两个操作合并为原子操作，但会带来明显的性能损耗，按需选择。
• 不要在UPDATE语句最外层直接加USING TTL，否则会把本次更新涉及的所有列都重置为同一个TTL，容易导致其他列的原有TTL配置被覆盖。
• 不要默认整行所有列的TTL一致，除非业务逻辑上明确保证写入时所有列用了相同TTL，否则批量复用TTL会导致部分列意外过期或永久留存。

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