66
}
67
69
>
queueType := persistence.QueueType(rand.Int31())
70
>
71
>
queueMetadata := s.newRandomQueueMetadataRow(queueType)
72
>
result, err := s.store.InsertIntoQueueMetadata(newExecutionContext(), &queueMetadata)
73
>
s.NoError(err)
74
>
rowsAffected, err := result.RowsAffected()
75
>
s.NoError(err)
76
>
s.Equal(1, int(rowsAffected))
77
>
78
>
queueMetadata = s.newRandomQueueMetadataRow(queueType)
79
>
_, err = s.store.InsertIntoQueueMetadata(newExecutionContext(), &queueMetadata)
80
>
s.Error(err) // TODO persistence layer should do proper error translation
81
>
}
82
83
func (s *queueMetadataSuite) TestInsertSelect() {