80
}
81
83
>
shardID := rand.Int31()
84
>
taskID := int64(1)
85
>
86
>
task := s.newRandomReplicationTaskRow(shardID, taskID)
87
>
result, err := s.store.InsertIntoReplicationTasks(newExecutionContext(), []sqlplugin.ReplicationTasksRow{task})
88
>
s.NoError(err)
89
>
rowsAffected, err := result.RowsAffected()
90
>
s.NoError(err)
91
>
s.Equal(1, int(rowsAffected))
92
>
93
>
task = s.newRandomReplicationTaskRow(shardID, taskID)
94
>
_, err = s.store.InsertIntoReplicationTasks(newExecutionContext(), []sqlplugin.ReplicationTasksRow{task})
95
>
s.Error(err) // TODO persistence layer should do proper error translation
96
>
}
97
98
func (s *historyHistoryReplicationTaskSuite) TestInsert_Multiple_Fail_Duplicate() {