66
}
67
69
>
shardID := rand.Int31()
70
>
taskID := int64(1)
71
>
72
>
task1 := s.newRandomTransferTaskRow(shardID, taskID)
73
>
taskID++
74
>
task2 := s.newRandomTransferTaskRow(shardID, taskID)
75
>
result, err := s.store.InsertIntoTransferTasks(newExecutionContext(), []sqlplugin.TransferTasksRow{task1, task2})
76
>
s.NoError(err)
77
>
rowsAffected, err := result.RowsAffected()
78
>
s.NoError(err)
79
>
s.Equal(2, int(rowsAffected))
80
>
}
81
82
func (s *historyHistoryTransferTaskSuite) TestInsert_Single_Fail_Duplicate() {