82
}
83
85
>
shardID := rand.Int31()
86
>
rangeID := int64(1)
87
>
88
>
shard := s.newRandomShardRow(shardID, rangeID)
89
>
result, err := s.store.InsertIntoShards(newExecutionContext(), &shard)
90
>
s.NoError(err)
91
>
rowsAffected, err := result.RowsAffected()
92
>
s.NoError(err)
93
>
s.Equal(1, int(rowsAffected))
94
>
95
>
filter := sqlplugin.ShardsFilter{
96
>
ShardID: shardID,
97
>
}
98
>
row, err := s.store.SelectFromShards(newExecutionContext(), filter)
99
>
s.NoError(err)
100
>
s.Equal(&shard, row)
101
>
}
102
103
func (s *historyShardSuite) TestInsertUpdate_Success() {