182
}
183
185
>
shardID := rand.Int31()
186
>
rangeID := int64(rand.Int31())
187
>
188
>
shard := s.newRandomShardRow(shardID, rangeID)
189
>
result, err := s.store.InsertIntoShards(newExecutionContext(), &shard)
190
>
s.NoError(err)
191
>
rowsAffected, err := result.RowsAffected()
192
>
s.NoError(err)
193
>
s.Equal(1, int(rowsAffected))
194
>
195
>
tx, err := s.store.BeginTx(newExecutionContext())
196
>
s.NoError(err)
197
>
filter := sqlplugin.ShardsFilter{
198
>
ShardID: shardID,
199
>
}
200
>
shardRange, err := tx.WriteLockShards(newExecutionContext(), filter)
201
>
s.NoError(err)
202
>
s.Equal(rangeID, shardRange)
203
>
s.NoError(tx.Commit())
204
>
}
205
206
func (s *historyShardSuite) newRandomShardRow(