Support Numeric Conversion from Object to Double

thoughtmanifest · thoughtmanifest · commit b47f0a097b8a · 2016-09-02T13:58:45.000-04:00
diff --git a/src/main/java/com/github/pgasync/impl/conversion/DataConverter.java b/src/main/java/com/github/pgasync/impl/conversion/DataConverter.java
@@ -88,6 +88,9 @@ public <TArray> TArray toArray(Class<TArray> arrayType, Oid oid, byte[] value) {
             case FLOAT8_ARRAY:
                 return ArrayConversions.toArray(arrayType, oid, value, NumericConversions::toBigDecimal);
 
+            case NUMERIC_ARRAY:
+		return ArrayConversions.toArray(arrayType, oid, value, NumericConversions::toDouble);
+
             case TIMESTAMP_ARRAY:
             case TIMESTAMPTZ_ARRAY:
                 return ArrayConversions.toArray(arrayType, oid, value, TemporalConversions::toTimestamp);
@@ -178,6 +181,7 @@ public Object toObject(Oid oid, byte[] value) {
             case INT8: return toLong(oid, value);
             case FLOAT4: // fallthrough
             case FLOAT8: return toBigDecimal(oid, value);
+            case NUMERIC: return toDouble(oid, value);
             case BYTEA: return toBytes(oid, value);
             case DATE: return toDate(oid, value);
             case TIMETZ: // fallthrough
diff --git a/src/main/java/com/github/pgasync/impl/conversion/NumericConversions.java b/src/main/java/com/github/pgasync/impl/conversion/NumericConversions.java
@@ -95,7 +95,7 @@ static Double toDouble(Oid oid, byte[] value) {
             case FLOAT8:
                 return Double.valueOf(new String(value, UTF_8));
             default:
-                throw new SqlException("Unsupported conversion " + oid.name() + " -> BigDecimal");
+                throw new SqlException("Unsupported conversion " + oid.name() + " -> Double");
         }
     }
 

Original file line number	Diff line number	Diff line change
`@@ -95,7 +95,7 @@ static Double toDouble(Oid oid, byte[] value) {`
`95`	`95`	`case FLOAT8:`
`96`	`96`	`return Double.valueOf(new String(value, UTF_8));`
`97`	`97`	`default:`
`98`		`- throw new SqlException("Unsupported conversion " + oid.name() + " -> BigDecimal");`
	`98`	`+ throw new SqlException("Unsupported conversion " + oid.name() + " -> Double");`
`99`	`99`	`}`
`100`	`100`	`}`
`101`	`101`