188
}
189
190
>
func (s *namespaceSuite) TestInsertDeleteSelect_ID() {
namespace.go
191
>
id := primitives.NewUUID()
192
>
name := shuffle.String(testNamespaceName)
193
>
notificationVersion := int64(1)
194
>
195
>
namespace := s.newRandomNamespaceRow(id, name, notificationVersion)
196
>
result, err := s.store.InsertIntoNamespace(newExecutionContext(), &namespace)
197
>
s.NoError(err)
198
>
rowsAffected, err := result.RowsAffected()
199
>
s.NoError(err)
200
>
s.Equal(1, int(rowsAffected))
201
>
202
>
filter := sqlplugin.NamespaceFilter{
203
>
ID: &id,
204
>
}
205
>
result, err = s.store.DeleteFromNamespace(newExecutionContext(), filter)
206
>
s.NoError(err)
207
>
rowsAffected, err = result.RowsAffected()
208
>
s.NoError(err)
209
>
s.Equal(1, int(rowsAffected))
210
>
211
>
filter = sqlplugin.NamespaceFilter{
212
>
ID: &id,
213
>
}
214
>
_, err = s.store.SelectFromNamespace(newExecutionContext(), filter)
215
>
s.Error(err) // TODO persistence layer should do proper error translation
216
>
217
>
filter = sqlplugin.NamespaceFilter{
218
>
Name: &name,
219
>
}
220
>
_, err = s.store.SelectFromNamespace(newExecutionContext(), filter)
221
>
s.Error(err) // TODO persistence layer should do proper error translation
222
>
}
223
224
func (s *namespaceSuite) TestInsertDeleteSelect_Name() {