Golang cassandra gocql事务需要延迟时间才能执行

Question

这段代码并没有删除数据，不知道为什么。

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()

但是如果我像这样添加一些延迟：

s.Query(

        "INSERT INTO smth (id, name) VALUES (?,?)",

        data.ID

        data.Name

    ).ScanCAS(nil, nil, nil)

time.Sleep(time.Second)

s.Query(

    "DELETE FROM smth WHERE id = ? AND name = ?",

    data.ID

    data.Name

).Exec()

数据将被删除。

有谁知道如何在不增加延迟的情况下修复它？我在用着github.com/gocql/gocql

Answer 1

Gocql 查询是异步执行DELETE的，因此不能保证您的查询在INSERT.在任何情况下，您的测试用例都是无效的，因为在刚刚插入分区后立即删除它不是一个有效的用例。作为旁注，您的代码对我来说似乎是错误的。您在插入数据时调用Query.ScanCAS()，但查询不是轻量级事务——它缺少条件IF EXISTS/ IF NOT EXISTS。干杯!