246
}
247
249
>
shardID := rand.Int31()
250
>
namespaceID := primitives.NewUUID()
251
>
workflowID := shuffle.String(testHistoryExecutionWorkflowID)
252
>
runID := primitives.NewUUID()
253
>
nextEventID := rand.Int63()
254
>
lastWriteVersion := rand.Int63()
255
>
256
>
execution := s.newRandomExecutionRow(shardID, namespaceID, workflowID, runID, nextEventID, lastWriteVersion)
257
>
result, err := s.store.InsertIntoExecutions(newExecutionContext(), &execution)
258
>
s.NoError(err)
259
>
rowsAffected, err := result.RowsAffected()
260
>
s.NoError(err)
261
>
s.Equal(1, int(rowsAffected))
262
>
263
>
tx, err := s.store.BeginTx(newExecutionContext())
264
>
s.NoError(err)
265
>
filter := sqlplugin.ExecutionsFilter{
266
>
ShardID: shardID,
267
>
NamespaceID: namespaceID,
268
>
WorkflowID: workflowID,
269
>
RunID: runID,
270
>
}
271
>
rowDBVersion, rowNextEventID, err := tx.ReadLockExecutions(newExecutionContext(), filter)
272
>
s.NoError(err)
273
>
s.Equal(execution.DBRecordVersion, rowDBVersion)
274
>
s.Equal(execution.NextEventID, rowNextEventID)
275
>
s.NoError(tx.Commit())
276
>
}
277
278
func (s *historyExecutionSuite) TestWriteLock() {