這段代碼并沒有刪除數據，不知道為什么。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
1 回答
海綿寶寶撒
TA貢獻1809條經驗 獲得超8個贊
Gocql 查詢是異步執行DELETE的，因此不能保證您的查詢在INSERT.
在任何情況下，您的測試用例都是無效的，因為在剛剛插入分區后立即刪除它不是一個有效的用例。
作為旁注，您的代碼對我來說似乎是錯誤的。您在插入數據時調用Query.ScanCAS()，但查詢不是輕量級事務——它缺少條件IF EXISTS/ IF NOT EXISTS。干杯!
- 1 回答
- 0 關注
- 127 瀏覽
添加回答
舉報
0/150
提交
取消