215
}
216
218
>
shardID := rand.Int31()
219
>
namespaceID := primitives.NewUUID()
220
>
workflowID := shuffle.String(testHistoryExecutionWorkflowID)
221
>
runID := primitives.NewUUID()
222
>
223
>
deleteFilter := sqlplugin.RequestCancelInfoMapsAllFilter{
224
>
ShardID: shardID,
225
>
NamespaceID: namespaceID,
226
>
WorkflowID: workflowID,
227
>
RunID: runID,
228
>
}
229
>
result, err := s.store.DeleteAllFromRequestCancelInfoMaps(newExecutionContext(), deleteFilter)
230
>
s.NoError(err)
231
>
rowsAffected, err := result.RowsAffected()
232
>
s.NoError(err)
233
>
s.Equal(0, int(rowsAffected))
234
>
235
>
selectFilter := sqlplugin.RequestCancelInfoMapsAllFilter{
236
>
ShardID: shardID,
237
>
NamespaceID: namespaceID,
238
>
WorkflowID: workflowID,
239
>
RunID: runID,
240
>
}
241
>
rows, err := s.store.SelectAllFromRequestCancelInfoMaps(newExecutionContext(), selectFilter)
242
>
s.NoError(err)
243
>
s.Equal([]sqlplugin.RequestCancelInfoMapsRow(nil), rows)
244
>
}
245
246
func (s *historyExecutionRequestCancelSuite) TestReplaceDeleteSelect_Single() {