81
}
82
84
>
queueType := persistence.QueueType(rand.Int31())
85
>
86
>
queueMetadata := s.newRandomQueueMetadataRow(queueType)
87
>
result, err := s.store.InsertIntoQueueMetadata(newExecutionContext(), &queueMetadata)
88
>
s.NoError(err)
89
>
rowsAffected, err := result.RowsAffected()
90
>
s.NoError(err)
91
>
s.Equal(1, int(rowsAffected))
92
>
93
>
filter := sqlplugin.QueueMetadataFilter{
94
>
QueueType: queueType,
95
>
}
96
>
row, err := s.store.SelectFromQueueMetadata(newExecutionContext(), filter)
97
>
s.NoError(err)
98
>
row.QueueType = queueType
99
>
s.Equal(&queueMetadata, row)
100
>
}
101
102
func (s *queueMetadataSuite) TestInsertUpdate_Success() {