如何通过gocql判断Cassandra的CQL查询是否执行生效？

当然可以实现！gocql专门提供了处理这类带条件的原子操作的方法，完全能满足你既要原子性又要知晓操作是否生效的需求，不用依赖Exec()只返回错误的方式。

核心方法：Query.ScanCAS() #

Cassandra的IF NOT EXISTS插入属于Compare-and-Swap（CAS）操作，gocql的ScanCAS()方法就是为这类场景设计的——它会直接返回操作是否生效的applied状态，还能获取到已存在的重复数据（如果插入失败的话）。

代码示例 #

下面是一个完整的实现示例，对应你给出的tests.demo表结构：

package main

import (
    "fmt"
    "log"
    "github.com/gocql/gocql"
)

func main() {
    // 初始化Cassandra会话
    cluster := gocql.NewCluster("127.0.0.1") // 替换成你的Cassandra节点地址
    cluster.Keyspace = "tests"
    session, err := cluster.CreateSession()
    if err != nil {
        log.Fatalf("Failed to create session: %v", err)
    }
    defer session.Close()

    // 准备带IF NOT EXISTS的插入语句
    uuid := "test"
    data := "data"
    query := session.Query(`INSERT INTO tests.demo (uuid, data) VALUES (?, ?) IF NOT EXISTS`, uuid, data)

    // 定义变量接收结果：第一个变量对应applied状态，后面的对应返回的现有行数据
    var applied bool
    var existingUUID, existingData string

    // 执行CAS查询并绑定结果
    err = query.ScanCAS(&applied, &existingUUID, &existingData)
    if err != nil {
        log.Printf("Query execution failed: %v", err)
        return
    }

    // 根据applied状态处理结果
    if applied {
        fmt.Println("插入成功：没有重复的主键条目")
    } else {
        fmt.Printf("插入失败：已存在重复条目 -> UUID: %s, Data: %s\n", existingUUID, existingData)
    }
}

关键细节说明 #

• 参数顺序对应：ScanCAS()的变量顺序必须和Cassandra返回的列顺序完全一致。当插入失败（applied=false）时，Cassandra会返回applied、所有主键列、以及其他列，所以我们需要按这个顺序绑定变量。
• 原子性保障：这个操作是完全原子的，和你在cqlsh里执行的效果一致，不需要提前执行SELECT查询，从根本上避免了竞态条件。
• 错误处理：ScanCAS()返回的错误是查询执行过程中的异常（比如连接问题、语法错误等），而不是“插入重复条目”这种业务场景——业务状态由applied变量来判断。

额外提示 #

如果你只关心操作是否生效，不需要获取已存在的数据，也必须为Cassandra返回的列提供对应变量（哪怕你之后不用它们）。如果不想处理这些数据，也可以用Iter()来迭代结果，但ScanCAS()是最直接的方式。

确保你使用的gocql版本是较新的，旧版本对CAS操作的支持可能存在兼容性问题。

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