240
}
241
243
>
shardID := rand.Int31()
244
>
namespaceID := primitives.NewUUID()
245
>
workflowID := shuffle.String(testHistoryExecutionWorkflowID)
246
>
runID := primitives.NewUUID()
247
>
signalID := shuffle.String(testHistoryExecutionSignalID)
248
>
249
>
signalRequest := s.newRandomExecutionSignalRequestRow(shardID, namespaceID, workflowID, runID, signalID)
250
>
result, err := s.store.ReplaceIntoSignalsRequestedSets(newExecutionContext(), []sqlplugin.SignalsRequestedSetsRow{signalRequest})
251
>
s.NoError(err)
252
>
rowsAffected, err := result.RowsAffected()
253
>
s.NoError(err)
254
>
s.Equal(1, int(rowsAffected))
255
>
256
>
deleteFilter := sqlplugin.SignalsRequestedSetsFilter{
257
>
ShardID: shardID,
258
>
NamespaceID: namespaceID,
259
>
WorkflowID: workflowID,
260
>
RunID: runID,
261
>
SignalIDs: []string{signalID},
262
>
}
263
>
result, err = s.store.DeleteFromSignalsRequestedSets(newExecutionContext(), deleteFilter)
264
>
s.NoError(err)
265
>
rowsAffected, err = result.RowsAffected()
266
>
s.NoError(err)
267
>
s.Equal(1, int(rowsAffected))
268
>
269
>
selectFilter := sqlplugin.SignalsRequestedSetsAllFilter{
270
>
ShardID: shardID,
271
>
NamespaceID: namespaceID,
272
>
WorkflowID: workflowID,
273
>
RunID: runID,
274
>
}
275
>
rows, err := s.store.SelectAllFromSignalsRequestedSets(newExecutionContext(), selectFilter)
276
>
s.NoError(err)
277
>
s.Equal([]sqlplugin.SignalsRequestedSetsRow(nil), rows)
278
>
}
279
280
func (s *historyExecutionSignalRequestSuite) TestReplaceDeleteSelect_Multiple() {