182
}
183
185
>
shardID := rand.Int31()
186
>
namespaceID := primitives.NewUUID()
187
>
workflowID := shuffle.String(testHistoryExecutionWorkflowID)
188
>
runID := primitives.NewUUID()
189
>
requestID := primitives.NewUUID().String()
190
>
lastWriteVersion := rand.Int63()
191
>
192
>
currentExecution := s.newRandomCurrentExecutionRow(shardID, namespaceID, workflowID, runID, requestID, lastWriteVersion)
193
>
result, err := s.store.InsertIntoCurrentExecutions(newExecutionContext(), ¤tExecution)
194
>
s.NoError(err)
195
>
rowsAffected, err := result.RowsAffected()
196
>
s.NoError(err)
197
>
s.Equal(1, int(rowsAffected))
198
>
199
>
currentExecution = s.newRandomCurrentExecutionRow(shardID, namespaceID, workflowID, runID, primitives.NewUUID().String(), rand.Int63())
200
>
result, err = s.store.UpdateCurrentExecutions(newExecutionContext(), ¤tExecution)
201
>
s.NoError(err)
202
>
rowsAffected, err = result.RowsAffected()
203
>
s.NoError(err)
204
>
s.Equal(1, int(rowsAffected))
205
>
206
>
filter := sqlplugin.CurrentExecutionsFilter{
207
>
ShardID: shardID,
208
>
NamespaceID: namespaceID,
209
>
WorkflowID: workflowID,
210
>
RunID: nil,
211
>
ArchetypeID: s.archetypeID,
212
>
}
213
>
row, err := s.store.SelectFromCurrentExecutions(newExecutionContext(), filter)
214
>
s.NoError(err)
215
>
s.Equal(¤tExecution, row)
216
>
}
217
218
func (s *historyCurrentExecutionSuite) TestInsertDeleteSelect_Success() {