102
}
103
104
>
func (s *historyHistoryTimerTaskSuite) TestInsert_Multiple_Fail_Duplicate() {
history_timer_task.go
105
>
shardID := rand.Int31()
106
>
timestamp := s.now()
107
>
taskID := int64(1)
108
>
109
>
task1 := s.newRandomTimerTaskRow(shardID, timestamp, taskID)
110
>
timestamp = timestamp.Add(time.Millisecond)
111
>
taskID++
112
>
task2 := s.newRandomTimerTaskRow(shardID, timestamp, taskID)
113
>
result, err := s.store.InsertIntoTimerTasks(newExecutionContext(), []sqlplugin.TimerTasksRow{task1, task2})
114
>
s.NoError(err)
115
>
rowsAffected, err := result.RowsAffected()
116
>
s.NoError(err)
117
>
s.Equal(2, int(rowsAffected))
118
>
119
>
task2 = s.newRandomTimerTaskRow(shardID, timestamp, taskID)
120
>
timestamp = timestamp.Add(time.Millisecond)
121
>
taskID++
122
>
task3 := s.newRandomTimerTaskRow(shardID, timestamp, taskID)
123
>
_, err = s.store.InsertIntoTimerTasks(newExecutionContext(), []sqlplugin.TimerTasksRow{task2, task3})
124
>
s.Error(err) // TODO persistence layer should do proper error translation
125
>
}
126
127
func (s *historyHistoryTimerTaskSuite) TestInsertSelect_Single() {