fix(deps): Update github.com/cloudquery/plugin-sdk/v4 to v4.5.5 (#13297)

candiduslynx · web-flow · commit 38d4d59e37ff · 2023-08-23T13:06:42.000Z
Extracted from #13262 Part of #13153 BEGIN_COMMIT_OVERRIDE fix(deps): Update `github.com/cloudquery/plugin-sdk/v4` to v4.5.5 (#13297) fix: Properly handle trailing zeroes in uint64 values when reading END_COMMIT_OVERRIDE
diff --git a/plugins/destination/postgresql/client/read.go b/plugins/destination/postgresql/client/read.go
@@ -4,6 +4,7 @@ import (
 	"context"
 	"database/sql/driver"
 	"fmt"
+	"math/big"
 	"strings"
 
 	"github.com/apache/arrow/go/v13/arrow"
@@ -134,14 +135,35 @@ func prepareValueForResourceSet(dataType arrow.DataType, v any) (any, error) {
 			if !vt.Valid {
 				v = nil
 			} else {
-				v = vt.Int.Uint64()
+				v = numericToUint64(vt)
 			}
 		}
 		return v, nil
 	}
 	return v, nil
 }
 
+var (
+	big10 = big.NewInt(10)
+)
+
+func numericToUint64(n pgtype.Numeric) uint64 {
+	if n.Exp < 0 {
+		panic("unsupported negative exponent")
+	}
+
+	val := n.Int.Uint64()
+	if n.Exp == 0 {
+		return val
+	}
+
+	// exp can only be positive for our use-case
+	return new(big.Int).Mul(
+		new(big.Int).SetUint64(val),
+		new(big.Int).Exp(big10, big.NewInt(int64(n.Exp)), nil),
+	).Uint64()
+}
+
 func stringForTime(t pgtype.Time, unit arrow.TimeUnit) string {
 	extra := ""
 	hour := t.Microseconds / 1e6 / 60 / 60
diff --git a/plugins/destination/postgresql/go.mod b/plugins/destination/postgresql/go.mod
@@ -4,7 +4,7 @@ go 1.20
 
 require (
 	github.com/apache/arrow/go/v13 v13.0.0-20230731205701-112f94971882
-	github.com/cloudquery/plugin-sdk/v4 v4.5.1
+	github.com/cloudquery/plugin-sdk/v4 v4.5.5
 	github.com/jackc/pgx-zerolog v0.0.0-20230315001418-f978528409eb
 	github.com/jackc/pgx/v5 v5.3.1
 	github.com/rs/zerolog v1.29.1
diff --git a/plugins/destination/postgresql/go.sum b/plugins/destination/postgresql/go.sum
@@ -51,8 +51,8 @@ github.com/cloudquery/plugin-pb-go v1.9.3 h1:A+TwhOHB68ZnjqrQYnVtWAzmUKEDnKleVG6
 github.com/cloudquery/plugin-pb-go v1.9.3/go.mod h1:f00zd6V5mWD+8Qw9U0eb4HD8RnAobwV9byBexE7Qa+0=
 github.com/cloudquery/plugin-sdk/v2 v2.7.0 h1:hRXsdEiaOxJtsn/wZMFQC9/jPfU1MeMK3KF+gPGqm7U=
 github.com/cloudquery/plugin-sdk/v2 v2.7.0/go.mod h1:pAX6ojIW99b/Vg4CkhnsGkRIzNaVEceYMR+Bdit73ug=
-github.com/cloudquery/plugin-sdk/v4 v4.5.1 h1:V6EfHkW6kyYVMSX2S/Fn1b+62bU1jegIuv16Koo2f98=
-github.com/cloudquery/plugin-sdk/v4 v4.5.1/go.mod h1:WNTjNp8CPDDSpJHOSaho+MUzntKO6czG6E+yvVe++aA=
+github.com/cloudquery/plugin-sdk/v4 v4.5.5 h1:/8yr2zcuIUIK2VF1OoR1iHTL4U0SXBekIpcK8OZfJhY=
+github.com/cloudquery/plugin-sdk/v4 v4.5.5/go.mod h1:/2/9y6iODo8jOT0mrAp8K1eogr7+228cy53jK8aUCjY=
 github.com/cncf/udpa/go v0.0.0-20191209042840-269d4d468f6f/go.mod h1:M8M6+tZqaGXZJjfX53e64911xZQV5JYwmTeXPW+k8Sc=
 github.com/cncf/udpa/go v0.0.0-20201120205902-5459f2c99403/go.mod h1:WmhPx2Nbnhtbo57+VJT5O0JRkEi1Wbu0z5j0R8u5Hbk=
 github.com/cncf/udpa/go v0.0.0-20210930031921-04548b0d99d4/go.mod h1:6pvJx4me5XPnfI9Z40ddWsdw2W/uZgQLFXToKeRcDiI=
