75
}
76
78
>
shardID := rand.Int31()
79
>
namespaceID := primitives.NewUUID()
80
>
workflowID := shuffle.String(testHistoryExecutionWorkflowID)
81
>
runID := primitives.NewUUID()
82
>
nextEventID := rand.Int63()
83
>
lastWriteVersion := rand.Int63()
84
>
85
>
execution := s.newRandomExecutionRow(shardID, namespaceID, workflowID, runID, nextEventID, lastWriteVersion)
86
>
result, err := s.store.InsertIntoExecutions(newExecutionContext(), &execution)
87
>
s.NoError(err)
88
>
rowsAffected, err := result.RowsAffected()
89
>
s.NoError(err)
90
>
s.Equal(1, int(rowsAffected))
91
>
92
>
execution = s.newRandomExecutionRow(shardID, namespaceID, workflowID, runID, nextEventID, lastWriteVersion)
93
>
_, err = s.store.InsertIntoExecutions(newExecutionContext(), &execution)
94
>
s.Error(err) // TODO persistence layer should do proper error translation
95
>
}
96
97
func (s *historyExecutionSuite) TestInsertSelect() {