154
}
155
157
>
shardID := rand.Int31()
158
>
namespaceID := primitives.NewUUID()
159
>
workflowID := shuffle.String(testHistoryExecutionWorkflowID)
160
>
runID := primitives.NewUUID()
161
>
initiatedID := rand.Int63()
162
>
163
>
deleteFilter := sqlplugin.SignalInfoMapsFilter{
164
>
ShardID: shardID,
165
>
NamespaceID: namespaceID,
166
>
WorkflowID: workflowID,
167
>
RunID: runID,
168
>
InitiatedIDs: []int64{initiatedID},
169
>
}
170
>
result, err := s.store.DeleteFromSignalInfoMaps(newExecutionContext(), deleteFilter)
171
>
s.NoError(err)
172
>
rowsAffected, err := result.RowsAffected()
173
>
s.NoError(err)
174
>
s.Equal(0, int(rowsAffected))
175
>
176
>
selectFilter := sqlplugin.SignalInfoMapsAllFilter{
177
>
ShardID: shardID,
178
>
NamespaceID: namespaceID,
179
>
WorkflowID: workflowID,
180
>
RunID: runID,
181
>
}
182
>
rows, err := s.store.SelectAllFromSignalInfoMaps(newExecutionContext(), selectFilter)
183
>
s.NoError(err)
184
>
s.Equal([]sqlplugin.SignalInfoMapsRow(nil), rows)
185
>
}
186
187
func (s *historyExecutionSignalSuite) TestDeleteSelect_Multiple() {