Set nan inf numeric to nil (#1224)

PeerDB-io · Feb 9, 2024 · dc8a444 · dc8a444
1 parent 0dd48b0
commit dc8a444
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/flow/connectors/postgres/qvalue_convert.go b/flow/connectors/postgres/qvalue_convert.go
@@ -517,12 +517,13 @@ func parseFieldFromPostgresOID(oid uint32, value interface{}) (qvalue.QValue, er
 func numericToRat(numVal *pgtype.Numeric) (*big.Rat, error) {
 	if numVal.Valid {
 		if numVal.NaN {
-			return nil, errors.New("numeric value is NaN")
+			// set to nil if NaN
+			return nil, nil
 		}
 
 		switch numVal.InfinityModifier {
 		case pgtype.NegativeInfinity, pgtype.Infinity:
-			return nil, errors.New("numeric value is infinity")
+			return nil, nil
 		}
 
 		rat := new(big.Rat).SetInt(numVal.Int)