85
}
86
87
>
func (s *historyExecutionChildWorkflowSuite) TestReplaceSelect_Single() {
history_execution_child_workflow.go
88
>
shardID := rand.Int31()
89
>
namespaceID := primitives.NewUUID()
90
>
workflowID := shuffle.String(testHistoryExecutionWorkflowID)
91
>
runID := primitives.NewUUID()
92
>
initiatedID := rand.Int63()
93
>
94
>
childWorkflow := s.newRandomExecutionChildWorkflowRow(shardID, namespaceID, workflowID, runID, initiatedID)
95
>
result, err := s.store.ReplaceIntoChildExecutionInfoMaps(newExecutionContext(), []sqlplugin.ChildExecutionInfoMapsRow{childWorkflow})
96
>
s.NoError(err)
97
>
rowsAffected, err := result.RowsAffected()
98
>
s.NoError(err)
99
>
s.Equal(1, int(rowsAffected))
100
>
101
>
selectFilter := sqlplugin.ChildExecutionInfoMapsAllFilter{
102
>
ShardID: shardID,
103
>
NamespaceID: namespaceID,
104
>
WorkflowID: workflowID,
105
>
RunID: runID,
106
>
}
107
>
rows, err := s.store.SelectAllFromChildExecutionInfoMaps(newExecutionContext(), selectFilter)
108
>
s.NoError(err)
109
>
rowMap := map[int64]sqlplugin.ChildExecutionInfoMapsRow{}
110
>
for _, childWorkflow := range rows {
111
>
rowMap[childWorkflow.InitiatedID] = childWorkflow
112
>
}
113
>
s.Equal(map[int64]sqlplugin.ChildExecutionInfoMapsRow{
114
>
childWorkflow.InitiatedID: childWorkflow,
115
>
}, rowMap)
116
}
117