186
}
187
189
>
shardID := rand.Int31()
190
>
namespaceID := primitives.NewUUID()
191
>
workflowID := shuffle.String(testHistoryExecutionWorkflowID)
192
>
runID := primitives.NewUUID()
193
>
194
>
deleteFilter := sqlplugin.TimerInfoMapsFilter{
195
>
ShardID: shardID,
196
>
NamespaceID: namespaceID,
197
>
WorkflowID: workflowID,
198
>
RunID: runID,
199
>
TimerIDs: []string{shuffle.String(testHistoryExecutionTimerID), shuffle.String(testHistoryExecutionTimerID)},
200
>
}
201
>
result, err := s.store.DeleteFromTimerInfoMaps(newExecutionContext(), deleteFilter)
202
>
s.NoError(err)
203
>
rowsAffected, err := result.RowsAffected()
204
>
s.NoError(err)
205
>
s.Equal(0, int(rowsAffected))
206
>
207
>
selectFilter := sqlplugin.TimerInfoMapsAllFilter{
208
>
ShardID: shardID,
209
>
NamespaceID: namespaceID,
210
>
WorkflowID: workflowID,
211
>
RunID: runID,
212
>
}
213
>
rows, err := s.store.SelectAllFromTimerInfoMaps(newExecutionContext(), selectFilter)
214
>
s.NoError(err)
215
>
s.Equal([]sqlplugin.TimerInfoMapsRow(nil), rows)
216
>
}
217
218
func (s *historyExecutionTimerSuite) TestDeleteSelect_All() {