154
}
155
156
>
func (s *namespaceSuite) TestInsertUpdateSelect() {
namespace.go
157
>
id := primitives.NewUUID()
158
>
name := shuffle.String(testNamespaceName)
159
>
notificationVersion := int64(1)
160
>
161
>
namespace := s.newRandomNamespaceRow(id, name, notificationVersion)
162
>
result, err := s.store.InsertIntoNamespace(newExecutionContext(), &namespace)
163
>
s.NoError(err)
164
>
rowsAffected, err := result.RowsAffected()
165
>
s.NoError(err)
166
>
s.Equal(1, int(rowsAffected))
167
>
168
>
namespace = s.newRandomNamespaceRow(id, name, notificationVersion)
169
>
result, err = s.store.UpdateNamespace(newExecutionContext(), &namespace)
170
>
s.NoError(err)
171
>
rowsAffected, err = result.RowsAffected()
172
>
s.NoError(err)
173
>
s.Equal(1, int(rowsAffected))
174
>
175
>
filter := sqlplugin.NamespaceFilter{
176
>
ID: &id,
177
>
}
178
>
rows, err := s.store.SelectFromNamespace(newExecutionContext(), filter)
179
>
s.NoError(err)
180
>
s.Equal([]sqlplugin.NamespaceRow{namespace}, rows)
181
>
182
>
filter = sqlplugin.NamespaceFilter{
183
>
Name: &name,
184
>
}
185
>
rows, err = s.store.SelectFromNamespace(newExecutionContext(), filter)
186
>
s.NoError(err)
187
>
s.Equal([]sqlplugin.NamespaceRow{namespace}, rows)
188
>
}
189
190
func (s *namespaceSuite) TestInsertDeleteSelect_ID() {