143
}
144
145
>
func (s *historyTreeSuite) TestInsertDeleteSelect() {
history_tree.go
146
>
shardID := rand.Int31()
147
>
treeID := primitives.NewUUID()
148
>
branchID := primitives.NewUUID()
149
>
150
>
tree := s.newRandomTreeRow(shardID, treeID, branchID)
151
>
result, err := s.store.InsertIntoHistoryTree(newExecutionContext(), &tree)
152
>
s.NoError(err)
153
>
rowsAffected, err := result.RowsAffected()
154
>
s.NoError(err)
155
>
s.Equal(1, int(rowsAffected))
156
>
157
>
deleteFilter := sqlplugin.HistoryTreeDeleteFilter{
158
>
ShardID: shardID,
159
>
TreeID: treeID,
160
>
BranchID: branchID,
161
>
}
162
>
result, err = s.store.DeleteFromHistoryTree(newExecutionContext(), deleteFilter)
163
>
s.NoError(err)
164
>
rowsAffected, err = result.RowsAffected()
165
>
s.NoError(err)
166
>
s.Equal(1, int(rowsAffected))
167
>
168
>
selectFilter := sqlplugin.HistoryTreeSelectFilter{
169
>
ShardID: shardID,
170
>
TreeID: treeID,
171
>
}
172
>
rows, err := s.store.SelectFromHistoryTree(newExecutionContext(), selectFilter)
173
>
s.NoError(err)
174
>
for index := range rows {
175
rows[index].ShardID = shardID
176
rows[index].TreeID = treeID
177
}
179
}
180