245
}
246
248
>
shardID := rand.Int31()
249
>
namespaceID := primitives.NewUUID()
250
>
workflowID := shuffle.String(testHistoryExecutionWorkflowID)
251
>
runID := primitives.NewUUID()
252
>
timerID := shuffle.String(testHistoryExecutionTimerID)
253
>
254
>
timer := s.newRandomExecutionTimerRow(shardID, namespaceID, workflowID, runID, timerID)
255
>
result, err := s.store.ReplaceIntoTimerInfoMaps(newExecutionContext(), []sqlplugin.TimerInfoMapsRow{timer})
256
>
s.NoError(err)
257
>
rowsAffected, err := result.RowsAffected()
258
>
s.NoError(err)
259
>
s.Equal(1, int(rowsAffected))
260
>
261
>
deleteFilter := sqlplugin.TimerInfoMapsFilter{
262
>
ShardID: shardID,
263
>
NamespaceID: namespaceID,
264
>
WorkflowID: workflowID,
265
>
RunID: runID,
266
>
TimerIDs: []string{timerID},
267
>
}
268
>
result, err = s.store.DeleteFromTimerInfoMaps(newExecutionContext(), deleteFilter)
269
>
s.NoError(err)
270
>
rowsAffected, err = result.RowsAffected()
271
>
s.NoError(err)
272
>
s.Equal(1, int(rowsAffected))
273
>
274
>
selectFilter := sqlplugin.TimerInfoMapsAllFilter{
275
>
ShardID: shardID,
276
>
NamespaceID: namespaceID,
277
>
WorkflowID: workflowID,
278
>
RunID: runID,
279
>
}
280
>
rows, err := s.store.SelectAllFromTimerInfoMaps(newExecutionContext(), selectFilter)
281
>
s.NoError(err)
282
>
s.Equal([]sqlplugin.TimerInfoMapsRow(nil), rows)
283
>
}
284
285
func (s *historyExecutionTimerSuite) TestReplaceDeleteSelect_Multiple() {