156
}
157
159
>
queueType := persistence.QueueType(rand.Int31())
160
>
161
>
queueMetadata := s.newRandomQueueMetadataRow(queueType)
162
>
result, err := s.store.InsertIntoQueueMetadata(newExecutionContext(), &queueMetadata)
163
>
s.NoError(err)
164
>
rowsAffected, err := result.RowsAffected()
165
>
s.NoError(err)
166
>
s.Equal(1, int(rowsAffected))
167
>
168
>
// NOTE: lock without transaction is equivalent to select
169
>
// this test only test the select functionality
170
>
filter := sqlplugin.QueueMetadataFilter{
171
>
QueueType: queueType,
172
>
}
173
>
row, err := s.store.LockQueueMetadata(newExecutionContext(), filter)
174
>
s.NoError(err)
175
>
row.QueueType = queueType
176
>
s.Equal(&queueMetadata, row)
177
>
}
178
179
func (s *queueMetadataSuite) newRandomQueueMetadataRow(