From c1190eb7b572e9e993cbfc175c22209b53a4a1b4 Mon Sep 17 00:00:00 2001 From: Robin Tang Date: Mon, 17 Jun 2024 12:53:04 -0700 Subject: [PATCH] Clean up. --- lib/debezium/decimal.go | 4 ++-- lib/debezium/decimal_test.go | 9 +++++++-- 2 files changed, 9 insertions(+), 4 deletions(-) diff --git a/lib/debezium/decimal.go b/lib/debezium/decimal.go index 81595cc65..183b9bcb8 100644 --- a/lib/debezium/decimal.go +++ b/lib/debezium/decimal.go @@ -12,7 +12,7 @@ import ( func EncodeDecimal(value string, scale int) ([]byte, error) { bigFloatValue := new(big.Float) if _, success := bigFloatValue.SetString(value); !success { - return nil, fmt.Errorf("unable to use '%s' as a floating-point number", value) + return nil, fmt.Errorf("unable to use %q as a floating-point number", value) } scaledValue := big.NewFloat(math.Pow(10, float64(scale))) @@ -21,7 +21,7 @@ func EncodeDecimal(value string, scale int) ([]byte, error) { // Extract the scaled integer value. bigIntValue := new(big.Int) if _, success := bigIntValue.SetString(bigFloatValue.String(), 10); !success { - return nil, fmt.Errorf("unable to use '%s' as a floating-point number", value) + return nil, fmt.Errorf("unable to use %q as a floating-point number", value) } data := bigIntValue.Bytes() diff --git a/lib/debezium/decimal_test.go b/lib/debezium/decimal_test.go index 395415281..4f8b6e7e1 100644 --- a/lib/debezium/decimal_test.go +++ b/lib/debezium/decimal_test.go @@ -66,15 +66,20 @@ func TestEncodeDecimal(t *testing.T) { value: "6408.355", scale: 3, }, + { + name: "total", + value: "1.05", + scale: 2, + }, { name: "malformed - empty string", value: "", - expectedErr: "unable to use '' as a floating-point number", + expectedErr: `unable to use "" as a floating-point number`, }, { name: "malformed - not a floating-point", value: "abcdefg", - expectedErr: "unable to use 'abcdefg' as a floating-point number", + expectedErr: `unable to use "abcdefg" as a floating-point number`, }, }