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