89
}
90
92
>
shardID := rand.Int31()
93
>
treeID := primitives.NewUUID()
94
>
branchID := primitives.NewUUID()
95
>
96
>
tree := s.newRandomTreeRow(shardID, treeID, branchID)
97
>
result, err := s.store.InsertIntoHistoryTree(newExecutionContext(), &tree)
98
>
s.NoError(err)
99
>
rowsAffected, err := result.RowsAffected()
100
>
s.NoError(err)
101
>
s.Equal(1, int(rowsAffected))
102
>
103
>
selectFilter := sqlplugin.HistoryTreeSelectFilter{
104
>
ShardID: shardID,
105
>
TreeID: treeID,
106
>
}
107
>
rows, err := s.store.SelectFromHistoryTree(newExecutionContext(), selectFilter)
108
>
s.NoError(err)
109
>
for index := range rows {
110
>
rows[index].ShardID = shardID
111
>
rows[index].TreeID = treeID
112
>
}
113
>
s.Equal([]sqlplugin.HistoryTreeRow{tree}, rows)
114
}
115