Skip to content

Commit 0b00130

Browse files
author
Henrik Johansson
authored
Merge pull request #94 from scylladb/ensure_range_tombstones
schema: Ensure we create range tombstones
2 parents 1f0a1ec + fe523ae commit 0b00130

File tree

1 file changed

+5
-6
lines changed

1 file changed

+5
-6
lines changed

schema.go

+5-6
Original file line numberDiff line numberDiff line change
@@ -352,12 +352,11 @@ func (s *Schema) GenDeleteRows(t Table, p *PartitionRange) (*Stmt, error) {
352352
values = appendValue(pk.Type, p, values)
353353
typs = append(typs, pk.Type)
354354
}
355-
if len(t.ClusteringKeys) == 1 {
356-
for _, ck := range t.ClusteringKeys {
357-
relations = append(relations, fmt.Sprintf("%s >= ? AND %s <= ?", ck.Name, ck.Name))
358-
values = appendValueRange(ck.Type, p, values)
359-
typs = append(typs, ck.Type, ck.Type)
360-
}
355+
if len(t.ClusteringKeys) > 0 {
356+
ck := t.ClusteringKeys[0]
357+
relations = append(relations, fmt.Sprintf("%s >= ? AND %s <= ?", ck.Name, ck.Name))
358+
values = appendValueRange(ck.Type, p, values)
359+
typs = append(typs, ck.Type, ck.Type)
361360
}
362361
query := fmt.Sprintf("DELETE FROM %s.%s WHERE %s", s.Keyspace.Name, t.Name, strings.Join(relations, " AND "))
363362
return &Stmt{

0 commit comments

Comments
 (0)