193
}
194
196
>
shardID := rand.Int31()
197
>
namespaceID := primitives.NewUUID()
198
>
workflowID := shuffle.String(testHistoryExecutionWorkflowID)
199
>
runID := primitives.NewUUID()
200
>
201
>
filter := sqlplugin.ExecutionsFilter{
202
>
ShardID: shardID,
203
>
NamespaceID: namespaceID,
204
>
WorkflowID: workflowID,
205
>
RunID: runID,
206
>
}
207
>
result, err := s.store.DeleteFromExecutions(newExecutionContext(), filter)
208
>
s.NoError(err)
209
>
rowsAffected, err := result.RowsAffected()
210
>
s.NoError(err)
211
>
s.Equal(0, int(rowsAffected))
212
>
213
>
_, err = s.store.SelectFromExecutions(newExecutionContext(), filter)
214
>
s.Error(err) // TODO persistence layer should do proper error translation
215
>
}
216
217
func (s *historyExecutionSuite) TestInsertDeleteSelect() {