97
}
98
99
>
func (s *matchingTaskSuite) TestInsert_Multiple_Fail_Duplicate() {
matching_task.go
100
>
queueID := shuffle.Bytes(testMatchingTaskTaskQueueID)
101
>
taskID := int64(1)
102
>
103
>
task1 := s.newRandomTasksRow(queueID, taskID)
104
>
taskID++
105
>
task2 := s.newRandomTasksRow(queueID, taskID)
106
>
result, err := s.store.InsertIntoTasks(newExecutionContext(), []sqlplugin.TasksRow{task1, task2})
107
>
s.NoError(err)
108
>
rowsAffected, err := result.RowsAffected()
109
>
s.NoError(err)
110
>
s.Equal(2, int(rowsAffected))
111
>
112
>
task2 = s.newRandomTasksRow(queueID, taskID)
113
>
taskID++
114
>
task3 := s.newRandomTasksRow(queueID, taskID)
115
>
_, err = s.store.InsertIntoTasks(newExecutionContext(), []sqlplugin.TasksRow{task2, task3})
116
>
s.Error(err) // TODO persistence layer should do proper error translation
117
>
}
118
119
func (s *matchingTaskSuite) TestInsertSelect_Single() {