160
}
161
163
>
shardID := rand.Int31()
164
>
namespaceID := primitives.NewUUID()
165
>
workflowID := shuffle.String(testHistoryExecutionWorkflowID)
166
>
runID := primitives.NewUUID()
167
>
nextEventID := rand.Int63()
168
>
lastWriteVersion := rand.Int63()
169
>
170
>
execution := s.newRandomExecutionRow(shardID, namespaceID, workflowID, runID, nextEventID, lastWriteVersion)
171
>
result, err := s.store.InsertIntoExecutions(newExecutionContext(), &execution)
172
>
s.NoError(err)
173
>
rowsAffected, err := result.RowsAffected()
174
>
s.NoError(err)
175
>
s.Equal(1, int(rowsAffected))
176
>
177
>
execution = s.newRandomExecutionRow(shardID, namespaceID, workflowID, runID, rand.Int63(), rand.Int63())
178
>
result, err = s.store.UpdateExecutions(newExecutionContext(), &execution)
179
>
s.NoError(err)
180
>
rowsAffected, err = result.RowsAffected()
181
>
s.NoError(err)
182
>
s.Equal(1, int(rowsAffected))
183
>
184
>
filter := sqlplugin.ExecutionsFilter{
185
>
ShardID: shardID,
186
>
NamespaceID: namespaceID,
187
>
WorkflowID: workflowID,
188
>
RunID: runID,
189
>
}
190
>
row, err := s.store.SelectFromExecutions(newExecutionContext(), filter)
191
>
s.NoError(err)
192
>
s.Equal(&execution, row)
193
>
}
194
195
func (s *historyExecutionSuite) TestDeleteSelect() {