69
}
70
72
>
sourceCluster := shuffle.String(testHistoryReplicationTaskDLQSourceCluster)
73
>
shardID := rand.Int31()
74
>
taskID := int64(1)
75
>
76
>
task1 := s.newRandomReplicationTasksDLQRow(sourceCluster, shardID, taskID)
77
>
taskID++
78
>
task2 := s.newRandomReplicationTasksDLQRow(sourceCluster, shardID, taskID)
79
>
result, err := s.store.InsertIntoReplicationDLQTasks(newExecutionContext(), []sqlplugin.ReplicationDLQTasksRow{task1, task2})
80
>
s.NoError(err)
81
>
rowsAffected, err := result.RowsAffected()
82
>
s.NoError(err)
83
>
s.Equal(2, int(rowsAffected))
84
>
}
85
86
func (s *historyHistoryReplicationDLQTaskSuite) TestInsert_Single_Fail_Duplicate() {