168
}
169
170
>
func (s *visibilitySuite) TestReplaceSelect_NonExists() {
visibility.go
171
>
namespaceID := primitives.NewUUID()
172
>
runID := primitives.NewUUID()
173
>
workflowTypeName := shuffle.String(testVisibilityWorkflowTypeName)
174
>
workflowID := shuffle.String(testVisibilityWorkflowID)
175
>
startTime := s.now()
176
>
executionTime := startTime.Add(time.Second)
177
>
status := int32(0)
178
>
closeTime := executionTime.Add(time.Second)
179
>
historyLength := rand.Int63()
180
>
181
>
visibility := s.newRandomVisibilityRow(
182
>
namespaceID,
183
>
runID,
184
>
workflowTypeName,
185
>
workflowID,
186
>
startTime,
187
>
executionTime,
188
>
status,
189
>
new(closeTime),
190
>
new(historyLength),
191
>
)
192
>
result, err := s.store.ReplaceIntoVisibility(newVisibilityContext(), &visibility)
193
>
s.NoError(err)
194
>
rowsAffected, err := result.RowsAffected()
195
>
s.NoError(err)
196
>
s.Equal(1, int(rowsAffected))
197
>
198
>
selectFilter := sqlplugin.VisibilitySelectFilter{
199
>
NamespaceID: namespaceID.String(),
200
>
RunID: new(runID.String()),
201
>
}
202
>
rows, err := s.store.SelectFromVisibility(newVisibilityContext(), selectFilter)
203
>
s.NoError(err)
204
>
for index := range rows {
205
>
rows[index].NamespaceID = namespaceID.String()
206
>
}
207
>
s.Equal([]sqlplugin.VisibilityRow{visibility}, rows)
208
}
209