101
}
102
104
>
shardID := rand.Int31()
105
>
rangeID := int64(1)
106
>
107
>
shard := s.newRandomShardRow(shardID, rangeID)
108
>
rangeID += 100
109
>
result, err := s.store.InsertIntoShards(newExecutionContext(), &shard)
110
>
s.NoError(err)
111
>
rowsAffected, err := result.RowsAffected()
112
>
s.NoError(err)
113
>
s.Equal(1, int(rowsAffected))
114
>
115
>
shard = s.newRandomShardRow(shardID, rangeID)
116
>
result, err = s.store.UpdateShards(newExecutionContext(), &shard)
117
>
s.NoError(err)
118
>
rowsAffected, err = result.RowsAffected()
119
>
s.NoError(err)
120
>
s.Equal(1, int(rowsAffected))
121
>
}
122
123
func (s *historyShardSuite) TestUpdate_Fail() {