使用gocql操作Cassandra：INSERT后DELETE无延迟不生效问题求助

问题场景 #

使用github.com/gocql/gocql操作Cassandra时，执行INSERT语句后立刻执行DELETE语句，数据无法被删除；但在两者之间添加time.Sleep(time.Second)延迟后，数据可正常删除。

原问题代码：

s.Query(
        "INSERT INTO smth (id, name) VALUES (?,?)",
        data.ID,
        data.Name
    ).ScanCAS(nil, nil, nil)

s.Query(
    "DELETE FROM smth WHERE id = ? AND name = ?",
    data.ID,
    data.Name
).Exec()

原因分析 #

1. CAS方法误用：ScanCAS是用于执行Cassandra的Compare-and-Swap（条件更新/插入）操作的API，普通INSERT操作不需要使用该方法，它无法保证写操作完全完成后再返回执行后续逻辑。
2. 一致性级别问题：Cassandra默认的写一致性级别是ONE，仅需要一个副本确认写成功就返回，但其他副本可能还未同步完成数据。此时执行DELETE操作，可能访问到未同步数据的副本，导致删除失败。

解决方案 #

1. 替换ScanCAS为正确的Exec()方法 #

普通INSERT操作应使用Exec()方法，该方法会等待写操作完成（至少在响应的副本上）后再返回，确保后续DELETE操作能看到最新数据。

修改后的INSERT代码：

err := s.Query(
    "INSERT INTO smth (id, name) VALUES (?,?)",
    data.ID,
    data.Name,
).Exec()
if err != nil {
    // 处理插入错误
}

2. 设置合适的一致性级别 #

将INSERT和DELETE操作的一致性级别设置为QUORUM，要求多数副本确认写/删操作完成，确保集群内数据同步后再执行后续逻辑。

示例代码：

// 插入操作设置QUORUM一致性级别
err := s.Query(
    "INSERT INTO smth (id, name) VALUES (?,?)",
    data.ID,
    data.Name,
).SetConsistency(gocql.Quorum).Exec()
if err != nil {
    // 处理错误
}

// 删除操作同样设置QUORUM一致性级别
err = s.Query(
    "DELETE FROM smth WHERE id = ? AND name = ?",
    data.ID,
    data.Name,
).SetConsistency(gocql.Quorum).Exec()
if err != nil {
    // 处理错误
}

3. 确保操作的顺序性（可选） #

如果需要严格保证INSERT和DELETE的执行顺序，可结合Cassandra的轻量级事务（LWT）特性，但对于这种先插后删的场景，前两种方案通常已足够解决问题。

内容的提问来源于stack exchange，提问作者Haryo Bagas Assyafah