66
}
67
69
>
shardID := rand.Int31()
70
>
taskID := int64(1)
71
>
72
>
task1 := s.newRandomVisibilityTaskRow(shardID, taskID)
73
>
taskID++
74
>
task2 := s.newRandomVisibilityTaskRow(shardID, taskID)
75
>
result, err := s.store.InsertIntoVisibilityTasks(newExecutionContext(), []sqlplugin.VisibilityTasksRow{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 *historyHistoryVisibilityTaskSuite) TestInsert_Single_Fail_Duplicate() {