215
}
216
218
>
pageSize := 100
219
>
220
>
shardID := rand.Int31()
221
>
treeID := primitives.NewUUID()
222
>
branchID := primitives.NewUUID()
223
>
nodeID := int64(1)
224
>
225
>
deleteFilter := sqlplugin.HistoryNodeDeleteFilter{
226
>
ShardID: shardID,
227
>
TreeID: treeID,
228
>
BranchID: branchID,
229
>
MinNodeID: nodeID,
230
>
}
231
>
result, err := s.store.RangeDeleteFromHistoryNode(newExecutionContext(), deleteFilter)
232
>
s.NoError(err)
233
>
rowsAffected, err := result.RowsAffected()
234
>
s.NoError(err)
235
>
s.Equal(0, int(rowsAffected))
236
>
237
>
selectFilter := sqlplugin.HistoryNodeSelectFilter{
238
>
ShardID: shardID,
239
>
TreeID: treeID,
240
>
BranchID: branchID,
241
>
MinNodeID: nodeID,
242
>
MinTxnID: sql.MinTxnID,
243
>
MaxNodeID: math.MaxInt64,
244
>
PageSize: pageSize,
245
>
}
246
>
rows, err := s.store.RangeSelectFromHistoryNode(newExecutionContext(), selectFilter)
247
>
s.NoError(err)
248
>
for index := range rows {
249
rows[index].ShardID = shardID
250
rows[index].TreeID = treeID
251
rows[index].BranchID = branchID
252
}
254
}
255