93
return err
94
}
95
>
result, err := tx.UpdateShards(ctx, &sqlplugin.ShardsRow{
shard.go
96
>
ShardID: request.ShardID,
97
>
RangeID: request.RangeID,
98
>
Data: request.ShardInfo.Data,
99
>
DataEncoding: request.ShardInfo.EncodingType.String(),
100
>
})
101
>
if err != nil {
102
return err
103
}
104
>
rowsAffected, err := result.RowsAffected()
shard.go
105
>
if err != nil {
106
return fmt.Errorf("rowsAffected returned error for shardID %v: %v", request.ShardID, err)
107
}
109
return fmt.Errorf("rowsAffected returned %v shards instead of one", rowsAffected)
110
}
112
})
113
}