155
}
156
158
>
shardID := rand.Int31()
159
>
namespaceID := primitives.NewUUID()
160
>
workflowID := shuffle.String(testHistoryExecutionWorkflowID)
161
>
runID := primitives.NewUUID()
162
>
timerID := shuffle.String(testHistoryExecutionTimerID)
163
>
164
>
deletFilter := sqlplugin.TimerInfoMapsFilter{
165
>
ShardID: shardID,
166
>
NamespaceID: namespaceID,
167
>
WorkflowID: workflowID,
168
>
RunID: runID,
169
>
TimerIDs: []string{timerID},
170
>
}
171
>
result, err := s.store.DeleteFromTimerInfoMaps(newExecutionContext(), deletFilter)
172
>
s.NoError(err)
173
>
rowsAffected, err := result.RowsAffected()
174
>
s.NoError(err)
175
>
s.Equal(0, int(rowsAffected))
176
>
177
>
selectFilter := sqlplugin.TimerInfoMapsAllFilter{
178
>
ShardID: shardID,
179
>
NamespaceID: namespaceID,
180
>
WorkflowID: workflowID,
181
>
RunID: runID,
182
>
}
183
>
rows, err := s.store.SelectAllFromTimerInfoMaps(newExecutionContext(), selectFilter)
184
>
s.NoError(err)
185
>
s.Equal([]sqlplugin.TimerInfoMapsRow(nil), rows)
186
>
}
187
188
func (s *historyExecutionTimerSuite) TestDeleteSelect_Multiple() {