Start working on array serialization

Author: dsmyth

src/CMakeLists.txt

@@ -4,6 +4,7 @@ add_library(${OATPP_THIS_MODULE_NAME}
         oatpp-postgresql/mapping/type/Uuid.hpp
         oatpp-postgresql/mapping/Deserializer.cpp
         oatpp-postgresql/mapping/Deserializer.hpp
+        oatpp-postgresql/mapping/PgArray.hpp
         oatpp-postgresql/mapping/Oid.hpp
         oatpp-postgresql/mapping/ResultMapper.cpp
         oatpp-postgresql/mapping/ResultMapper.hpp

src/oatpp-postgresql/mapping/Deserializer.cpp

@@ -25,6 +25,7 @@
 #include "Deserializer.hpp"
 
 #include "Oid.hpp"
+#include "PgArray.hpp"
 #include "oatpp-postgresql/Types.hpp"
 
 #if defined(WIN32) || defined(_WIN32)
@@ -279,7 +280,7 @@ const oatpp::Type* Deserializer::guessAnyType(Oid oid) {
 
     case TIMESTAMPOID: return oatpp::UInt64::Class::getType();
 
-    case FLOAT4ARRAYOID: return oatpp::Vector<Float32>::Class::getType();
+    case FLOAT8ARRAYOID: return oatpp::Vector<Float64>::Class::getType();
 
     case UUIDOID: return oatpp::postgresql::Uuid::Class::getType();
 
@@ -316,18 +317,6 @@ oatpp::Void Deserializer::deserializeUuid(const Deserializer* _this, const InDat
 
 }
 
-// after https://stackoverflow.com/questions/4016412/postgresqls-libpq-encoding-for-binary-transport-of-array-data
-struct PgArray {
-    int32_t ndim;   // Number of dimensions
-    int32_t _ign;   // offset for data, removed by libpq
-    Oid oid;        // type of element in the array
-
-    // Start of array (1st dimension)
-    int32_t size;   // Number of elements
-    int32_t index;  // Index of first element
-    int32_t elem;   // Beginning of (size, value) elements
-};
-
 oatpp::Void Deserializer::deserializeArray(const Deserializer* _this, const InData& data, const Type* type) {
 
     (void) _this;

src/oatpp-postgresql/mapping/PgArray.hpp

@@ -0,0 +1,20 @@
+//
+// Created by dsmyth on 1/1/21.
+//
+
+#ifndef oatpp_postgresql_mapping_PgArray_hpp
+#define oatpp_postgresql_mapping_PgArray_hpp
+
+// after https://stackoverflow.com/questions/4016412/postgresqls-libpq-encoding-for-binary-transport-of-array-data
+struct PgArray {
+    int32_t ndim;   // Number of dimensions
+    int32_t _ign;   // offset for data, removed by libpq
+    Oid oid;        // type of element in the array
+
+    // Start of array (1st dimension)
+    int32_t size;   // Number of elements
+    int32_t index;  // Index of first element
+    int32_t elem;   // Beginning of (size, value) elements
+};
+
+#endif // oatpp_postgresql_mapping_PgArray_hpp

src/oatpp-postgresql/mapping/Serializer.cpp

@@ -67,6 +67,7 @@ void Serializer::setSerializerMethods() {
   ////
 
   setSerializerMethod(postgresql::mapping::type::__class::Uuid::CLASS_ID, &Serializer::serializeUuid);
+  setSerializerMethod(data::mapping::type::__class::AbstractVector::CLASS_ID, &Serializer::serializeArray);
 
 }
 
@@ -91,11 +92,12 @@ void Serializer::setTypeOidMethods() {
   setTypeOidMethod(data::mapping::type::__class::Float64::CLASS_ID, &Serializer::getTypeOid<FLOAT8OID>);
   setTypeOidMethod(data::mapping::type::__class::Boolean::CLASS_ID, &Serializer::getTypeOid<BOOLOID>);
 
-  setTypeOidMethod(data::mapping::type::__class::AbstractEnum::CLASS_ID, &Serializer::getEnumTypeOid);
+  setTypeOidMethod(data::mapping::type::__class::AbstractVector::CLASS_ID, &Serializer::getTypeOid<FLOAT8ARRAYOID>);
 
   ////
 
   setTypeOidMethod(postgresql::mapping::type::__class::Uuid::CLASS_ID, &Serializer::getTypeOid<UUIDOID>);
+  setTypeOidMethod(data::mapping::type::__class::AbstractEnum::CLASS_ID, &Serializer::getEnumTypeOid);
 
 }
 
@@ -389,4 +391,19 @@ void Serializer::serializeUuid(const Serializer* _this, OutputData& outData, con
   }
 }
 
+void Serializer::serializeArray(const Serializer* _this, OutputData& outData, const oatpp::Void& polymorph) {
+
+    (void) _this;
+
+    if(polymorph) {
+        auto v = polymorph.staticCast<oatpp::Vector<Float64>>();
+        outData.data = nullptr;
+        outData.dataSize = 0;
+        outData.dataFormat = 1;
+        outData.oid = FLOAT8ARRAYOID;
+    } else{
+        serNull(outData);
+    }
+}
+
 }}}

src/oatpp-postgresql/mapping/Serializer.hpp

@@ -99,6 +99,7 @@ class Serializer {
 
   static void serializeUuid(const Serializer* _this, OutputData& outData, const oatpp::Void& polymorph);
 
+  static void serializeArray(const Serializer* _this, OutputData& outData, const oatpp::Void& polymorph);
 private:
 
   template<Oid OID>