ARCHIVE/clio
1
0
Fork 0
mirror of https://github.com/XRPLF/clio.git synced 2025-11-20 11:45:53 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fix deletion script (#1357)

Browse Source 
Because the slice has not done deep clone. All the _Data_ in
_deleteInfo_ will eventually refer to the last item in partition.

Please refer to "reuse slice session" from:
https://pkg.go.dev/github.com/gocql/gocql#hdr-Reusing_slices
This commit is contained in:
cyan317
2024-04-12 15:06:51 +01:00
committed by GitHub
parent 6b9c8a12d0
commit 1fe42c88c3
1 changed files with 3 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
tools/cassandra_delete_range/main.go
View File

@@ -484,8 +484,6 @@ func prepareDeleteQueries(cluster *gocql.ClusterConfig, fromLedgerIdx uint64, qu
var pageState []byte var pageState []byte
var rowsRetrieved uint64 var rowsRetrieved uint64
var key []byte
var seq uint64
for { for {
iter := preparedQuery.PageSize(*clusterPageSize).PageState(pageState).Iter() iter := preparedQuery.PageSize(*clusterPageSize).PageState(pageState).Iter()
@@ -493,6 +491,9 @@ func prepareDeleteQueries(cluster *gocql.ClusterConfig, fromLedgerIdx uint64, qu
scanner := iter.Scanner() scanner := iter.Scanner()
for scanner.Next() { for scanner.Next() {
var key []byte
var seq uint64
err = scanner.Scan(&key, &seq) err = scanner.Scan(&key, &seq)
if err == nil { if err == nil {
rowsRetrieved++ rowsRetrieved++