244
}
245
247
>
shardID := rand.Int31()
248
>
namespaceID := primitives.NewUUID()
249
>
workflowID := shuffle.String(testHistoryExecutionWorkflowID)
250
>
runID := primitives.NewUUID()
251
>
scheduledEventID := rand.Int63()
252
>
253
>
activity := s.newRandomExecutionActivityRow(shardID, namespaceID, workflowID, runID, scheduledEventID)
254
>
result, err := s.store.ReplaceIntoActivityInfoMaps(newExecutionContext(), []sqlplugin.ActivityInfoMapsRow{activity})
255
>
s.NoError(err)
256
>
rowsAffected, err := result.RowsAffected()
257
>
s.NoError(err)
258
>
s.Equal(1, int(rowsAffected))
259
>
260
>
deleteFilter := sqlplugin.ActivityInfoMapsFilter{
261
>
ShardID: shardID,
262
>
NamespaceID: namespaceID,
263
>
WorkflowID: workflowID,
264
>
RunID: runID,
265
>
ScheduleIDs: []int64{scheduledEventID},
266
>
}
267
>
result, err = s.store.DeleteFromActivityInfoMaps(newExecutionContext(), deleteFilter)
268
>
s.NoError(err)
269
>
rowsAffected, err = result.RowsAffected()
270
>
s.NoError(err)
271
>
s.Equal(1, int(rowsAffected))
272
>
273
>
selectFilter := sqlplugin.ActivityInfoMapsAllFilter{
274
>
ShardID: shardID,
275
>
NamespaceID: namespaceID,
276
>
WorkflowID: workflowID,
277
>
RunID: runID,
278
>
}
279
>
rows, err := s.store.SelectAllFromActivityInfoMaps(newExecutionContext(), selectFilter)
280
>
s.NoError(err)
281
>
s.Equal([]sqlplugin.ActivityInfoMapsRow(nil), rows)
282
>
}
283
284
func (s *historyExecutionActivitySuite) TestReplaceDeleteSelect_Multiple() {