Fix double qual values failing to convert. Closes #243

Author: kaidaguerre

fdw/common.h

@@ -93,10 +93,13 @@ typedef struct FdwDeparsedSortGroup
 
 // datum.c
 char *datumString(Datum datum, ConversionInfo *cinfo);
+int64   datumInt16(Datum datum, ConversionInfo *cinfo);
+int64   datumInt32(Datum datum, ConversionInfo *cinfo);
 int64   datumInt64(Datum datum, ConversionInfo *cinfo);
 inet *datumInet(Datum datum, ConversionInfo *cinfo);
 inet *datumCIDR(Datum datum, ConversionInfo *cinfo);
-double  datumDouble(Datum datum, ConversionInfo *cinfo);
+double  datumFloat4(Datum datum, ConversionInfo *cinfo);
+double  datumFloat8(Datum datum, ConversionInfo *cinfo);
 bool  datumBool(Datum datum, ConversionInfo *cinfo);
 Jsonb *datumJsonb(Datum datum, ConversionInfo *cinfo);
 Timestamp datumDate(Datum datum, ConversionInfo *cinfo);

fdw/datum.c

@@ -18,14 +18,27 @@ inet *datumInet(Datum datum, ConversionInfo *cinfo) {
     return DatumGetInetPP(datum);
 }
 
+
+int64 datumInt16(Datum datum, ConversionInfo *cinfo) {
+    return DatumGetInt16(datum);
+}
+
+int64 datumInt32(Datum datum, ConversionInfo *cinfo) {
+    return DatumGetInt32(datum);
+}
+
 int64 datumInt64(Datum datum, ConversionInfo *cinfo) {
     return DatumGetInt64(datum);
 }
 
-double datumDouble(Datum datum, ConversionInfo *cinfo) {
+double datumFloat4(Datum datum, ConversionInfo *cinfo) {
     return DatumGetFloat4(datum);
 }
 
+double datumFloat8(Datum datum, ConversionInfo *cinfo) {
+    return DatumGetFloat8(datum);
+}
+
 bool datumBool(Datum datum, ConversionInfo *cinfo) {
     return DatumGetBool(datum);
 }

quals.go

@@ -427,10 +427,16 @@ func datumToQualValue(datum C.Datum, typeOid C.Oid, cinfo *C.ConversionInfo) (re
 			break
 		}
 		result.Value = &proto.QualValue_TimestampValue{TimestampValue: timestamp}
-	case C.INT2OID, C.INT4OID, C.INT8OID:
+	case C.INT2OID:
+		result.Value = &proto.QualValue_Int64Value{Int64Value: int64(C.datumInt16(datum, cinfo))}
+	case C.INT4OID:
+		result.Value = &proto.QualValue_Int64Value{Int64Value: int64(C.datumInt32(datum, cinfo))}
+	case C.INT8OID:
 		result.Value = &proto.QualValue_Int64Value{Int64Value: int64(C.datumInt64(datum, cinfo))}
 	case C.FLOAT4OID:
-		result.Value = &proto.QualValue_DoubleValue{DoubleValue: float64(C.datumDouble(datum, cinfo))}
+		result.Value = &proto.QualValue_DoubleValue{DoubleValue: float64(C.datumFloat4(datum, cinfo))}
+	case C.FLOAT8OID:
+		result.Value = &proto.QualValue_DoubleValue{DoubleValue: float64(C.datumFloat8(datum, cinfo))}
 	case C.BOOLOID:
 		result.Value = &proto.QualValue_BoolValue{BoolValue: bool(C.datumBool(datum, cinfo))}
 	case C.JSONBOID: