Compare commits

...

4 commits

Author SHA1 Message Date
Egor Seredin
5bc41f90eb
Merge dd34943dc4 into 547861c49b 2024-04-03 22:13:40 +02:00
Philip Dubé
547861c49b
Avoid reallocation of initial slice in MarshalBinary (GobEncode) (#355) 2024-04-03 22:12:19 +02:00
Egor Seredin
dd34943dc4 Test: NewFromInt: add MinInt case 2024-02-13 06:59:58 +00:00
Egor Seredin
19b27aafdc Add NewFromUint64 2024-02-13 06:59:34 +00:00
2 changed files with 50 additions and 18 deletions

View file

@ -130,6 +130,18 @@ func NewFromInt32(value int32) Decimal {
} }
} }
// NewFromUint64 converts an uint64 to Decimal.
//
// Example:
//
// NewFromUint64(123).String() // output: "123"
func NewFromUint64(value uint64) Decimal {
return Decimal{
value: new(big.Int).SetUint64(value),
exp: 0,
}
}
// NewFromBigInt returns a new Decimal from a big.Int, value * 10 ^ exp // NewFromBigInt returns a new Decimal from a big.Int, value * 10 ^ exp
func NewFromBigInt(value *big.Int, exp int32) Decimal { func NewFromBigInt(value *big.Int, exp int32) Decimal {
return Decimal{ return Decimal{
@ -1784,19 +1796,18 @@ func (d *Decimal) UnmarshalBinary(data []byte) error {
// MarshalBinary implements the encoding.BinaryMarshaler interface. // MarshalBinary implements the encoding.BinaryMarshaler interface.
func (d Decimal) MarshalBinary() (data []byte, err error) { func (d Decimal) MarshalBinary() (data []byte, err error) {
// Write the exponent first since it's a fixed size // exp is written first, but encode value first to know output size
v1 := make([]byte, 4) var valueData []byte
binary.BigEndian.PutUint32(v1, uint32(d.exp)) if valueData, err = d.value.GobEncode(); err != nil {
return nil, err
// Add the value
var v2 []byte
if v2, err = d.value.GobEncode(); err != nil {
return
} }
// Write the exponent in front, since it's a fixed size
expData := make([]byte, 4, len(valueData)+4)
binary.BigEndian.PutUint32(expData, uint32(d.exp))
// Return the byte array // Return the byte array
data = append(v1, v2...) return append(expData, valueData...), nil
return
} }
// Scan implements the sql.Scanner interface for database deserialization. // Scan implements the sql.Scanner interface for database deserialization.

View file

@ -476,10 +476,11 @@ func TestNewFromFloatWithExponent(t *testing.T) {
func TestNewFromInt(t *testing.T) { func TestNewFromInt(t *testing.T) {
tests := map[int64]string{ tests := map[int64]string{
0: "0", 0: "0",
1: "1", 1: "1",
323412345: "323412345", 323412345: "323412345",
9223372036854775807: "9223372036854775807", 9223372036854775807: "9223372036854775807",
-9223372036854775808: "-9223372036854775808",
} }
// add negatives // add negatives
@ -501,10 +502,11 @@ func TestNewFromInt(t *testing.T) {
func TestNewFromInt32(t *testing.T) { func TestNewFromInt32(t *testing.T) {
tests := map[int32]string{ tests := map[int32]string{
0: "0", 0: "0",
1: "1", 1: "1",
323412345: "323412345", 323412345: "323412345",
2147483647: "2147483647", 2147483647: "2147483647",
-2147483648: "-2147483648",
} }
// add negatives // add negatives
@ -524,6 +526,25 @@ func TestNewFromInt32(t *testing.T) {
} }
} }
func TestNewFromUint64(t *testing.T) {
tests := map[uint64]string{
0: "0",
1: "1",
323412345: "323412345",
9223372036854775807: "9223372036854775807",
18446744073709551615: "18446744073709551615",
}
for input, s := range tests {
d := NewFromUint64(input)
if d.String() != s {
t.Errorf("expected %s, got %s (%s, %d)",
s, d.String(),
d.value.String(), d.exp)
}
}
}
func TestNewFromBigIntWithExponent(t *testing.T) { func TestNewFromBigIntWithExponent(t *testing.T) {
type Inp struct { type Inp struct {
val *big.Int val *big.Int