133
}
134
136
>
shardID := rand.Int31()
137
>
rangeID := int64(1)
138
>
139
>
shard := s.newRandomShardRow(shardID, rangeID)
140
>
rangeID += 100
141
>
result, err := s.store.InsertIntoShards(newExecutionContext(), &shard)
142
>
s.NoError(err)
143
>
rowsAffected, err := result.RowsAffected()
144
>
s.NoError(err)
145
>
s.Equal(1, int(rowsAffected))
146
>
147
>
shard = s.newRandomShardRow(shardID, rangeID)
148
>
result, err = s.store.UpdateShards(newExecutionContext(), &shard)
149
>
s.NoError(err)
150
>
rowsAffected, err = result.RowsAffected()
151
>
s.NoError(err)
152
>
s.Equal(1, int(rowsAffected))
153
>
154
>
filter := sqlplugin.ShardsFilter{
155
>
ShardID: shardID,
156
>
}
157
>
row, err := s.store.SelectFromShards(newExecutionContext(), filter)
158
>
s.NoError(err)
159
>
s.Equal(&shard, row)
160
>
}
161
162
func (s *historyShardSuite) TestInsertReadLock() {