215
}
216
218
>
shardID := rand.Int31()
219
>
namespaceID := primitives.NewUUID()
220
>
workflowID := shuffle.String(testHistoryExecutionWorkflowID)
221
>
runID := primitives.NewUUID()
222
>
nextEventID := rand.Int63()
223
>
lastWriteVersion := rand.Int63()
224
>
225
>
execution := s.newRandomExecutionRow(shardID, namespaceID, workflowID, runID, nextEventID, lastWriteVersion)
226
>
result, err := s.store.InsertIntoExecutions(newExecutionContext(), &execution)
227
>
s.NoError(err)
228
>
rowsAffected, err := result.RowsAffected()
229
>
s.NoError(err)
230
>
s.Equal(1, int(rowsAffected))
231
>
232
>
filter := sqlplugin.ExecutionsFilter{
233
>
ShardID: shardID,
234
>
NamespaceID: namespaceID,
235
>
WorkflowID: workflowID,
236
>
RunID: runID,
237
>
}
238
>
result, err = s.store.DeleteFromExecutions(newExecutionContext(), filter)
239
>
s.NoError(err)
240
>
rowsAffected, err = result.RowsAffected()
241
>
s.NoError(err)
242
>
s.Equal(1, int(rowsAffected))
243
>
244
>
_, err = s.store.SelectFromExecutions(newExecutionContext(), filter)
245
>
s.Error(err) // TODO persistence layer should do proper error translation
246
>
}
247
248
func (s *historyExecutionSuite) TestReadLock() {