244
}
245
247
>
shardID := rand.Int31()
248
>
namespaceID := primitives.NewUUID()
249
>
workflowID := shuffle.String(testHistoryExecutionWorkflowID)
250
>
runID := primitives.NewUUID()
251
>
initiatedID := rand.Int63()
252
>
253
>
childWorkflow := s.newRandomExecutionChildWorkflowRow(shardID, namespaceID, workflowID, runID, initiatedID)
254
>
result, err := s.store.ReplaceIntoChildExecutionInfoMaps(newExecutionContext(), []sqlplugin.ChildExecutionInfoMapsRow{childWorkflow})
255
>
s.NoError(err)
256
>
rowsAffected, err := result.RowsAffected()
257
>
s.NoError(err)
258
>
s.Equal(1, int(rowsAffected))
259
>
260
>
deleteFilter := sqlplugin.ChildExecutionInfoMapsFilter{
261
>
ShardID: shardID,
262
>
NamespaceID: namespaceID,
263
>
WorkflowID: workflowID,
264
>
RunID: runID,
265
>
InitiatedIDs: []int64{initiatedID},
266
>
}
267
>
result, err = s.store.DeleteFromChildExecutionInfoMaps(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.ChildExecutionInfoMapsAllFilter{
274
>
ShardID: shardID,
275
>
NamespaceID: namespaceID,
276
>
WorkflowID: workflowID,
277
>
RunID: runID,
278
>
}
279
>
rows, err := s.store.SelectAllFromChildExecutionInfoMaps(newExecutionContext(), selectFilter)
280
>
s.NoError(err)
281
>
s.Equal([]sqlplugin.ChildExecutionInfoMapsRow(nil), rows)
282
>
}
283
284
func (s *historyExecutionChildWorkflowSuite) TestReplaceDeleteSelect_Multiple() {