}
func (s *historyHistoryTransferTaskSuite) TestInsert_Single_Success() {
history_transfer_task.go
shardID := rand.Int31()
taskID := int64(1)
task := s.newRandomTransferTaskRow(shardID, taskID)
result, err := s.store.InsertIntoTransferTasks(newExecutionContext(), []sqlplugin.TransferTasksRow{task})
s.NoError(err)
rowsAffected, err := result.RowsAffected()
s.NoError(err)
s.Equal(1, int(rowsAffected))
}
func (s *historyHistoryTransferTaskSuite) TestInsert_Multiple_Success() {