222
}
223
224
>
func (s *namespaceSuite) TestInsertDeleteSelect_Name() {
namespace.go
225
>
id := primitives.NewUUID()
226
>
name := shuffle.String(testNamespaceName)
227
>
notificationVersion := int64(1)
228
>
229
>
namespace := s.newRandomNamespaceRow(id, name, notificationVersion)
230
>
result, err := s.store.InsertIntoNamespace(newExecutionContext(), &namespace)
231
>
s.NoError(err)
232
>
rowsAffected, err := result.RowsAffected()
233
>
s.NoError(err)
234
>
s.Equal(1, int(rowsAffected))
235
>
236
>
filter := sqlplugin.NamespaceFilter{
237
>
Name: &name,
238
>
}
239
>
result, err = s.store.DeleteFromNamespace(newExecutionContext(), filter)
240
>
s.NoError(err)
241
>
rowsAffected, err = result.RowsAffected()
242
>
s.NoError(err)
243
>
s.Equal(1, int(rowsAffected))
244
>
245
>
filter = sqlplugin.NamespaceFilter{
246
>
ID: &id,
247
>
}
248
>
_, err = s.store.SelectFromNamespace(newExecutionContext(), filter)
249
>
s.Error(err) // TODO persistence layer should do proper error translation
250
>
251
>
filter = sqlplugin.NamespaceFilter{
252
>
Name: &name,
253
>
}
254
>
_, err = s.store.SelectFromNamespace(newExecutionContext(), filter)
255
>
s.Error(err) // TODO persistence layer should do proper error translation
256
>
}
257
258
func (s *namespaceSuite) TestInsertSelect_Pagination() {