160
}
161
163
>
shardID := rand.Int31()
164
>
rangeID := int64(rand.Int31())
165
>
166
>
shard := s.newRandomShardRow(shardID, rangeID)
167
>
result, err := s.store.InsertIntoShards(newExecutionContext(), &shard)
168
>
s.NoError(err)
169
>
rowsAffected, err := result.RowsAffected()
170
>
s.NoError(err)
171
>
s.Equal(1, int(rowsAffected))
172
>
173
>
tx, err := s.store.BeginTx(newExecutionContext())
174
>
s.NoError(err)
175
>
filter := sqlplugin.ShardsFilter{
176
>
ShardID: shardID,
177
>
}
178
>
shardRange, err := tx.ReadLockShards(newExecutionContext(), filter)
179
>
s.NoError(err)
180
>
s.Equal(rangeID, shardRange)
181
>
s.NoError(tx.Commit())
182
>
}
183
184
func (s *historyShardSuite) TestInsertWriteLock() {