Merge pull request alaisi#27 from thoughtmanifest/numeric-conversion-support

alaisi · web-flow · commit 4423c9d1ce2b · 2016-09-13T13:04:18.000+03:00
Support Numeric Conversion from Object to BigDecimal.
diff --git a/src/main/java/com/github/pgasync/impl/conversion/DataConverter.java b/src/main/java/com/github/pgasync/impl/conversion/DataConverter.java
@@ -84,6 +84,7 @@ public <TArray> TArray toArray(Class<TArray> arrayType, Oid oid, byte[] value) {
             case VARCHAR_ARRAY:
                 return ArrayConversions.toArray(arrayType, oid, value, StringConversions::toString);
 
+            case NUMERIC_ARRAY:
             case FLOAT4_ARRAY:
             case FLOAT8_ARRAY:
                 return ArrayConversions.toArray(arrayType, oid, value, NumericConversions::toBigDecimal);
@@ -176,6 +177,7 @@ public Object toObject(Oid oid, byte[] value) {
             case INT2: return toShort(oid, value);
             case INT4: return toInteger(oid, value);
             case INT8: return toLong(oid, value);
+	    case NUMERIC: // fallthrough
             case FLOAT4: // fallthrough
             case FLOAT8: return toBigDecimal(oid, value);
             case BYTEA: return toBytes(oid, value);
@@ -190,6 +192,7 @@ public Object toObject(Oid oid, byte[] value) {
             case INT2_ARRAY:
             case INT4_ARRAY:
             case INT8_ARRAY:
+	    case NUMERIC_ARRAY:
             case FLOAT4_ARRAY:
             case FLOAT8_ARRAY:
             case TEXT_ARRAY:
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`