265
}
266
268
>
namespaceID := primitives.NewUUID()
269
>
runID := primitives.NewUUID()
270
>
workflowTypeName := shuffle.String(testVisibilityWorkflowTypeName)
271
>
workflowID := shuffle.String(testVisibilityWorkflowID)
272
>
startTime := s.now()
273
>
executionTime := startTime.Add(time.Second)
274
>
status := int32(0)
275
>
closeTime := (*time.Time)(nil)
276
>
historyLength := (*int64)(nil)
277
>
278
>
visibility1 := s.newRandomVisibilityRow(
279
>
namespaceID,
280
>
runID,
281
>
workflowTypeName,
282
>
workflowID,
283
>
startTime,
284
>
executionTime,
285
>
status,
286
>
closeTime,
287
>
historyLength,
288
>
)
289
>
result, err := s.store.InsertIntoVisibility(newVisibilityContext(), &visibility1)
290
>
s.NoError(err)
291
>
rowsAffected, err := result.RowsAffected()
292
>
s.NoError(err)
293
>
s.Equal(1, int(rowsAffected))
294
>
295
>
visibility2 := s.newRandomVisibilityRow(
296
>
namespaceID,
297
>
runID,
298
>
workflowTypeName,
299
>
workflowID,
300
>
startTime,
301
>
executionTime,
302
>
status,
303
>
closeTime,
304
>
historyLength,
305
>
)
306
>
_, err = s.store.InsertIntoVisibility(newVisibilityContext(), &visibility2)
307
>
s.NoError(err)
308
>
// NOTE: cannot do assertion on affected rows
309
>
// PostgreSQL will return 0
310
>
// MySQL will return 1: ref https://dev.mysql.com/doc/c-api/5.7/en/mysql-affected-rows.html
311
>
312
>
getFilter := sqlplugin.VisibilityGetFilter{
313
>
NamespaceID: namespaceID.String(),
314
>
RunID: runID.String(),
315
>
}
316
>
row, err := s.store.GetFromVisibility(newVisibilityContext(), getFilter)
317
>
s.NoError(err)
318
>
row.NamespaceID = namespaceID.String()
319
>
s.Equal(&visibility1, row)
320
>
}
321
322
func (s *visibilitySuite) TestDeleteGet() {