114
}
115
117
>
shardID := rand.Int31()
118
>
treeID := primitives.NewUUID()
119
>
branchID := primitives.NewUUID()
120
>
121
>
deleteFilter := sqlplugin.HistoryTreeDeleteFilter{
122
>
ShardID: shardID,
123
>
TreeID: treeID,
124
>
BranchID: branchID,
125
>
}
126
>
result, err := s.store.DeleteFromHistoryTree(newExecutionContext(), deleteFilter)
127
>
s.NoError(err)
128
>
rowsAffected, err := result.RowsAffected()
129
>
s.NoError(err)
130
>
s.Equal(0, int(rowsAffected))
131
>
132
>
selectFilter := sqlplugin.HistoryTreeSelectFilter{
133
>
ShardID: shardID,
134
>
TreeID: treeID,
135
>
}
136
>
rows, err := s.store.SelectFromHistoryTree(newExecutionContext(), selectFilter)
137
>
s.NoError(err)
138
>
for index := range rows {
139
rows[index].ShardID = shardID
140
rows[index].TreeID = treeID
141
}
143
}
144