}
func (s *historyHistoryReplicationTaskSuite) TestInsert_Single_Success() {
history_replication_task.go
shardID := rand.Int31()
taskID := int64(1)
task := s.newRandomReplicationTaskRow(shardID, taskID)
result, err := s.store.InsertIntoReplicationTasks(newExecutionContext(), []sqlplugin.ReplicationTasksRow{task})
s.NoError(err)
rowsAffected, err := result.RowsAffected()
s.NoError(err)
s.Equal(1, int(rowsAffected))
}
func (s *historyHistoryReplicationTaskSuite) TestInsert_Multiple_Success() {