Add support for JSONB quals. Closes #185

Author: kaidaguerre

fdw/common.h

@@ -98,6 +98,7 @@ inet *datumInet(Datum datum, ConversionInfo *cinfo);
 inet *datumCIDR(Datum datum, ConversionInfo *cinfo);
 double  datumDouble(Datum datum, ConversionInfo *cinfo);
 bool  datumBool(Datum datum, ConversionInfo *cinfo);
+Jsonb *datumJsonb(Datum datum, ConversionInfo *cinfo);
 Timestamp datumDate(Datum datum, ConversionInfo *cinfo);
 Timestamp datumTimestamp(Datum datum, ConversionInfo *cinfo);
 

fdw/datum.c

@@ -30,6 +30,10 @@ bool datumBool(Datum datum, ConversionInfo *cinfo) {
     return DatumGetBool(datum);
 }
 
+Jsonb * datumJsonb(Datum datum, ConversionInfo *cinfo) {
+    return DatumGetJsonbP(datum);
+}
+
 Timestamp datumDate(Datum datum, ConversionInfo *cinfo) {
 	datum = DirectFunctionCall1(date_timestamp, datum);
     return DatumGetInt64(datum);

quals.go

@@ -405,7 +405,12 @@ func datumToQualValue(datum C.Datum, typeOid C.Oid, cinfo *C.ConversionInfo) (re
 		result.Value = &proto.QualValue_DoubleValue{DoubleValue: float64(C.datumDouble(datum, cinfo))}
 	case C.BOOLOID:
 		result.Value = &proto.QualValue_BoolValue{BoolValue: bool(C.datumBool(datum, cinfo))}
+	case C.JSONBOID:
+		jsonbQual := C.datumJsonb(datum, cinfo)
+		jsonbQualStr := C.JsonbToCStringIndent(nil, &(jsonbQual.root), -1)
+		result.Value = &proto.QualValue_JsonbValue{JsonbValue: C.GoString(jsonbQualStr)}
 	default:
+		log.Printf("[INFO] datumToQualValue unknown typeoid %v ", typeOid)
 		result, err = convertUnknown(datum, typeOid, cinfo)
 	}
 	return