66
}
67
69
>
shardID := rand.Int31()
70
>
rangeID := int64(1)
71
>
72
>
shard := s.newRandomShardRow(shardID, rangeID)
73
>
result, err := s.store.InsertIntoShards(newExecutionContext(), &shard)
74
>
s.NoError(err)
75
>
rowsAffected, err := result.RowsAffected()
76
>
s.NoError(err)
77
>
s.Equal(1, int(rowsAffected))
78
>
79
>
shard = s.newRandomShardRow(shardID, rangeID)
80
>
_, err = s.store.InsertIntoShards(newExecutionContext(), &shard)
81
>
s.Error(err) // TODO persistence layer should do proper error translation
82
>
}
83
84
func (s *historyShardSuite) TestInsertSelect() {