66
}
67
68
>
func (s *matchingTaskSuite) TestInsert_Multiple_Success() {
matching_task.go
69
>
queueID := shuffle.Bytes(testMatchingTaskTaskQueueID)
70
>
taskID := int64(1)
71
>
72
>
task1 := s.newRandomTasksRow(queueID, taskID)
73
>
taskID++
74
>
task2 := s.newRandomTasksRow(queueID, taskID)
75
>
taskID++
76
>
result, err := s.store.InsertIntoTasks(newExecutionContext(), []sqlplugin.TasksRow{task1, task2})
77
>
s.NoError(err)
78
>
rowsAffected, err := result.RowsAffected()
79
>
s.NoError(err)
80
>
s.Equal(2, int(rowsAffected))
81
>
}
82
83
func (s *matchingTaskSuite) TestInsert_Single_Fail_Duplicate() {