282
}
283
285
>
numActivities := 20
286
>
287
>
shardID := rand.Int31()
288
>
namespaceID := primitives.NewUUID()
289
>
workflowID := shuffle.String(testHistoryExecutionWorkflowID)
290
>
runID := primitives.NewUUID()
291
>
292
>
var activities []sqlplugin.ActivityInfoMapsRow
293
>
var activityScheduledEventIDs []int64
294
>
for range numActivities {
295
>
activityScheduledEventID := rand.Int63()
296
>
activity := s.newRandomExecutionActivityRow(shardID, namespaceID, workflowID, runID, activityScheduledEventID)
297
>
activityScheduledEventIDs = append(activityScheduledEventIDs, activityScheduledEventID)
298
>
activities = append(activities, activity)
299
>
}
300
>
result, err := s.store.ReplaceIntoActivityInfoMaps(newExecutionContext(), activities)
301
>
s.NoError(err)
302
>
rowsAffected, err := result.RowsAffected()
303
>
s.NoError(err)
304
>
s.Equal(numActivities, int(rowsAffected))
305
>
306
>
deleteFilter := sqlplugin.ActivityInfoMapsFilter{
307
>
ShardID: shardID,
308
>
NamespaceID: namespaceID,
309
>
WorkflowID: workflowID,
310
>
RunID: runID,
311
>
ScheduleIDs: activityScheduledEventIDs,
312
>
}
313
>
result, err = s.store.DeleteFromActivityInfoMaps(newExecutionContext(), deleteFilter)
314
>
s.NoError(err)
315
>
rowsAffected, err = result.RowsAffected()
316
>
s.NoError(err)
317
>
s.Equal(numActivities, int(rowsAffected))
318
>
319
>
selectFilter := sqlplugin.ActivityInfoMapsAllFilter{
320
>
ShardID: shardID,
321
>
NamespaceID: namespaceID,
322
>
WorkflowID: workflowID,
323
>
RunID: runID,
324
>
}
325
>
rows, err := s.store.SelectAllFromActivityInfoMaps(newExecutionContext(), selectFilter)
326
>
s.NoError(err)
327
>
s.Equal([]sqlplugin.ActivityInfoMapsRow(nil), rows)
328
}
329