298
}
299
300
>
func (s *historyNodeSuite) TestInsertDeleteSelect_Multiple() {
history_node.go
301
>
numNodeIDs := 50
302
>
nodePerNodeID := 2
303
>
pageSize := 100
304
>
305
>
shardID := rand.Int31()
306
>
treeID := primitives.NewUUID()
307
>
branchID := primitives.NewUUID()
308
>
309
>
nodeID := int64(1)
310
>
minNodeID := nodeID
311
>
312
>
for range numNodeIDs {
313
>
for range nodePerNodeID {
314
>
node := s.newRandomNodeRow(shardID, treeID, branchID, nodeID, rand.Int63(), rand.Int63())
315
>
result, err := s.store.InsertIntoHistoryNode(newExecutionContext(), &node)
316
>
s.NoError(err)
317
>
rowsAffected, err := result.RowsAffected()
318
>
s.NoError(err)
319
>
s.Equal(1, int(rowsAffected))
320
>
}
321
>
nodeID++
322
}
323
325
>
ShardID: shardID,
326
>
TreeID: treeID,
327
>
BranchID: branchID,
328
>
MinNodeID: minNodeID,
329
>
}
330
>
result, err := s.store.RangeDeleteFromHistoryNode(newExecutionContext(), deleteFilter)
331
>
s.NoError(err)
332
>
rowsAffected, err := result.RowsAffected()
333
>
s.NoError(err)
334
>
s.Equal(numNodeIDs*nodePerNodeID, int(rowsAffected))
335
>
336
>
selectFilter := sqlplugin.HistoryNodeSelectFilter{
337
>
ShardID: shardID,
338
>
TreeID: treeID,
339
>
BranchID: branchID,
340
>
MinNodeID: nodeID,
341
>
MinTxnID: sql.MinTxnID,
342
>
MaxNodeID: math.MaxInt64,
343
>
PageSize: pageSize,
344
>
}
345
>
rows, err := s.store.RangeSelectFromHistoryNode(newExecutionContext(), selectFilter)
346
>
s.NoError(err)
347
>
for index := range rows {
348
rows[index].ShardID = shardID
349
rows[index].TreeID = treeID
350
rows[index].BranchID = branchID
351
}
353
}
354