276
}
277
279
>
shardID := rand.Int31()
280
>
namespaceID := primitives.NewUUID()
281
>
workflowID := shuffle.String(testHistoryExecutionWorkflowID)
282
>
runID := primitives.NewUUID()
283
>
nextEventID := rand.Int63()
284
>
lastWriteVersion := rand.Int63()
285
>
286
>
execution := s.newRandomExecutionRow(shardID, namespaceID, workflowID, runID, nextEventID, lastWriteVersion)
287
>
result, err := s.store.InsertIntoExecutions(newExecutionContext(), &execution)
288
>
s.NoError(err)
289
>
rowsAffected, err := result.RowsAffected()
290
>
s.NoError(err)
291
>
s.Equal(1, int(rowsAffected))
292
>
293
>
tx, err := s.store.BeginTx(newExecutionContext())
294
>
s.NoError(err)
295
>
filter := sqlplugin.ExecutionsFilter{
296
>
ShardID: shardID,
297
>
NamespaceID: namespaceID,
298
>
WorkflowID: workflowID,
299
>
RunID: runID,
300
>
}
301
>
rowDBVersion, rowNextEventID, err := tx.WriteLockExecutions(newExecutionContext(), filter)
302
>
s.NoError(err)
303
>
s.Equal(execution.DBRecordVersion, rowDBVersion)
304
>
s.Equal(execution.NextEventID, rowNextEventID)
305
>
s.NoError(tx.Commit())
306
>
}
307
308
func (s *historyExecutionSuite) newRandomExecutionRow(