324
}
325
327
>
numSignalRequests := 20
328
>
329
>
shardID := rand.Int31()
330
>
namespaceID := primitives.NewUUID()
331
>
workflowID := shuffle.String(testHistoryExecutionWorkflowID)
332
>
runID := primitives.NewUUID()
333
>
334
>
var signalRequests []sqlplugin.SignalsRequestedSetsRow
335
>
for range numSignalRequests {
336
>
signalRequest := s.newRandomExecutionSignalRequestRow(shardID, namespaceID, workflowID, runID, shuffle.String(testHistoryExecutionSignalID))
337
>
signalRequests = append(signalRequests, signalRequest)
338
>
}
339
>
result, err := s.store.ReplaceIntoSignalsRequestedSets(newExecutionContext(), signalRequests)
340
>
s.NoError(err)
341
>
rowsAffected, err := result.RowsAffected()
342
>
s.NoError(err)
343
>
s.Equal(numSignalRequests, int(rowsAffected))
344
>
345
>
deleteFilter := sqlplugin.SignalsRequestedSetsAllFilter{
346
>
ShardID: shardID,
347
>
NamespaceID: namespaceID,
348
>
WorkflowID: workflowID,
349
>
RunID: runID,
350
>
}
351
>
result, err = s.store.DeleteAllFromSignalsRequestedSets(newExecutionContext(), deleteFilter)
352
>
s.NoError(err)
353
>
rowsAffected, err = result.RowsAffected()
354
>
s.NoError(err)
355
>
s.Equal(numSignalRequests, int(rowsAffected))
356
>
357
>
selectFilter := sqlplugin.SignalsRequestedSetsAllFilter{
358
>
ShardID: shardID,
359
>
NamespaceID: namespaceID,
360
>
WorkflowID: workflowID,
361
>
RunID: runID,
362
>
}
363
>
rows, err := s.store.SelectAllFromSignalsRequestedSets(newExecutionContext(), selectFilter)
364
>
s.NoError(err)
365
>
s.Equal([]sqlplugin.SignalsRequestedSetsRow(nil), rows)
366
}
367