185
}
186
188
>
shardID := rand.Int31()
189
>
namespaceID := primitives.NewUUID()
190
>
workflowID := shuffle.String(testHistoryExecutionWorkflowID)
191
>
runID := primitives.NewUUID()
192
>
193
>
deleteFilter := sqlplugin.ActivityInfoMapsFilter{
194
>
ShardID: shardID,
195
>
NamespaceID: namespaceID,
196
>
WorkflowID: workflowID,
197
>
RunID: runID,
198
>
ScheduleIDs: []int64{rand.Int63(), rand.Int63()},
199
>
}
200
>
result, err := s.store.DeleteFromActivityInfoMaps(newExecutionContext(), deleteFilter)
201
>
s.NoError(err)
202
>
rowsAffected, err := result.RowsAffected()
203
>
s.NoError(err)
204
>
s.Equal(0, int(rowsAffected))
205
>
206
>
selectFilter := sqlplugin.ActivityInfoMapsAllFilter{
207
>
ShardID: shardID,
208
>
NamespaceID: namespaceID,
209
>
WorkflowID: workflowID,
210
>
RunID: runID,
211
>
}
212
>
rows, err := s.store.SelectAllFromActivityInfoMaps(newExecutionContext(), selectFilter)
213
>
s.NoError(err)
214
>
s.Equal([]sqlplugin.ActivityInfoMapsRow(nil), rows)
215
>
}
216
217
func (s *historyExecutionActivitySuite) TestDeleteSelect_All() {