96
}
97
99
>
shardID := rand.Int31()
100
>
taskID := int64(1)
101
>
102
>
task1 := s.newRandomVisibilityTaskRow(shardID, taskID)
103
>
taskID++
104
>
task2 := s.newRandomVisibilityTaskRow(shardID, taskID)
105
>
result, err := s.store.InsertIntoVisibilityTasks(newExecutionContext(), []sqlplugin.VisibilityTasksRow{task1, task2})
106
>
s.NoError(err)
107
>
rowsAffected, err := result.RowsAffected()
108
>
s.NoError(err)
109
>
s.Equal(2, int(rowsAffected))
110
>
111
>
task2 = s.newRandomVisibilityTaskRow(shardID, taskID)
112
>
taskID++
113
>
task3 := s.newRandomVisibilityTaskRow(shardID, taskID)
114
>
_, err = s.store.InsertIntoVisibilityTasks(newExecutionContext(), []sqlplugin.VisibilityTasksRow{task2, task3})
115
>
s.Error(err) // TODO persistence layer should do proper error translation
116
>
}
117
118
func (s *historyHistoryVisibilityTaskSuite) TestInsertSelect_Single() {