276
}
277
278
>
namespaces := map[string]*sqlplugin.NamespaceRow{}
namespace.go
279
>
numNamespace := 2
280
>
numNamespacePerPage := 1
281
>
282
>
for range numNamespace {
283
>
id := primitives.NewUUID()
284
>
name := shuffle.String(testNamespaceName)
285
>
notificationVersion := int64(1)
286
>
287
>
namespace := s.newRandomNamespaceRow(id, name, notificationVersion)
288
>
result, err := s.store.InsertIntoNamespace(newExecutionContext(), &namespace)
289
>
s.NoError(err)
290
>
rowsAffected, err := result.RowsAffected()
291
>
s.NoError(err)
292
>
s.Equal(1, int(rowsAffected))
293
>
294
>
namespaces[namespace.ID.String()] = &namespace
295
>
}
296
297
>
rows := map[string]*sqlplugin.NamespaceRow{}
namespace.go
298
>
filter := sqlplugin.NamespaceFilter{
299
>
GreaterThanID: nil,
300
>
PageSize: new(numNamespacePerPage),
301
>
}
302
>
for doContinue := true; doContinue; doContinue = filter.GreaterThanID != nil {
303
>
rowsPerPage, err := s.store.SelectFromNamespace(newExecutionContext(), filter)
304
>
switch err {
305
>
case nil:
306
>
for _, row := range rowsPerPage {
307
>
rows[row.ID.String()] = &row
308
>
}
309
>
length := len(rowsPerPage)
310
>
if length == 0 {
311
>
filter.GreaterThanID = nil
312
>
} else {
313
>
filter.GreaterThanID = &rowsPerPage[len(rowsPerPage)-1].ID
314
>
}
315
316
case sql.ErrNoRows: