95
}
96
98
>
shardID := rand.Int31()
99
>
namespaceID := primitives.NewUUID()
100
>
workflowID := shuffle.String(testHistoryExecutionWorkflowID)
101
>
runID := primitives.NewUUID()
102
>
nextEventID := rand.Int63()
103
>
lastWriteVersion := rand.Int63()
104
>
105
>
execution := s.newRandomExecutionRow(shardID, namespaceID, workflowID, runID, nextEventID, lastWriteVersion)
106
>
result, err := s.store.InsertIntoExecutions(newExecutionContext(), &execution)
107
>
s.NoError(err)
108
>
rowsAffected, err := result.RowsAffected()
109
>
s.NoError(err)
110
>
s.Equal(1, int(rowsAffected))
111
>
112
>
filter := sqlplugin.ExecutionsFilter{
113
>
ShardID: shardID,
114
>
NamespaceID: namespaceID,
115
>
WorkflowID: workflowID,
116
>
RunID: runID,
117
>
}
118
>
row, err := s.store.SelectFromExecutions(newExecutionContext(), filter)
119
>
s.NoError(err)
120
>
s.Equal(&execution, row)
121
>
}
122
123
func (s *historyExecutionSuite) TestInsertUpdate_Success() {