192
}
193
194
>
func (s *matchingTaskSuite) TestInsertDeleteSingle_Fail() {
matching_task.go
195
>
queueID := shuffle.Bytes(testMatchingTaskTaskQueueID)
196
>
taskID := int64(100)
197
>
198
>
task := s.newRandomTasksRow(queueID, taskID)
199
>
result, err := s.store.InsertIntoTasks(newExecutionContext(), []sqlplugin.TasksRow{task})
200
>
s.NoError(err)
201
>
rowsAffected, err := result.RowsAffected()
202
>
s.NoError(err)
203
>
s.Equal(1, int(rowsAffected))
204
>
205
>
filter := sqlplugin.TasksFilter{
206
>
RangeHash: testMatchingTaskRangeHash,
207
>
TaskQueueID: queueID,
208
>
}
209
>
result, err = s.store.DeleteFromTasks(newExecutionContext(), filter)
210
>
s.Error(err)
211
>
}
212
213
func (s *matchingTaskSuite) TestInsertDeleteSelect_Multiple() {