94
}
95
97
>
id := primitives.NewUUID()
98
>
name := shuffle.String(testNamespaceName)
99
>
notificationVersion := int64(1)
100
>
101
>
namespace := s.newRandomNamespaceRow(id, name, notificationVersion)
102
>
result, err := s.store.InsertIntoNamespace(newExecutionContext(), &namespace)
103
>
s.NoError(err)
104
>
rowsAffected, err := result.RowsAffected()
105
>
s.NoError(err)
106
>
s.Equal(1, int(rowsAffected))
107
>
108
>
filter := sqlplugin.NamespaceFilter{
109
>
ID: &id,
110
>
}
111
>
rows, err := s.store.SelectFromNamespace(newExecutionContext(), filter)
112
>
s.NoError(err)
113
>
s.Equal([]sqlplugin.NamespaceRow{namespace}, rows)
114
>
115
>
filter = sqlplugin.NamespaceFilter{
116
>
Name: &name,
117
>
}
118
>
rows, err = s.store.SelectFromNamespace(newExecutionContext(), filter)
119
>
s.NoError(err)
120
>
s.Equal([]sqlplugin.NamespaceRow{namespace}, rows)
121
>
}
122
123
func (s *namespaceSuite) TestInsertUpdate_Success() {