Support prepared statement

Author: AShiou

graphmdl-base/src/main/java/io/graphmdl/base/type/IntervalType.java

@@ -60,6 +60,21 @@ public class IntervalType
             .appendSecondsWithOptionalMillis()
             .toFormatter();
 
+    private static final PeriodFormatter PG_INTERVAL_FORMATTER = new PeriodFormatterBuilder()
+            .appendYears()
+            .appendSuffix(" years ")
+            .appendMonths()
+            .appendSuffix(" mons ")
+            .appendDays()
+            .appendSuffix(" days ")
+            .appendHours()
+            .appendSuffix(" hours ")
+            .appendMinutes()
+            .appendSuffix(" mins ")
+            .appendSecondsWithOptionalMillis()
+            .appendSuffix(" secs")
+            .toFormatter();
+
     private IntervalType()
     {
         super(OID, TYPE_LEN, TYPE_MOD, "interval");
@@ -154,7 +169,6 @@ public byte[] encodeAsUTF8Text(@Nonnull Period value)
     @Override
     public Period decodeUTF8Text(byte[] bytes)
     {
-        // return IntervalType.PERIOD_FORMATTER.parsePeriod(new String(bytes, StandardCharsets.UTF_8));
-        return new Period(new String(bytes, StandardCharsets.UTF_8));
+        return PG_INTERVAL_FORMATTER.parsePeriod(new String(bytes, StandardCharsets.UTF_8));
     }
 }

graphmdl-connector-client/pom.xml

@@ -90,5 +90,9 @@
             <groupId>javax.ws.rs</groupId>
             <artifactId>javax.ws.rs-api</artifactId>
         </dependency>
+        <dependency>
+            <groupId>joda-time</groupId>
+            <artifactId>joda-time</artifactId>
+        </dependency>
     </dependencies>
 </project>

graphmdl-connector-client/src/main/java/io/graphmdl/connector/bigquery/BigQueryType.java

@@ -22,6 +22,7 @@
 import io.graphmdl.base.type.NumericType;
 import io.graphmdl.base.type.PGType;
 import io.graphmdl.base.type.TimestampType;
+import org.joda.time.Period;
 
 import java.util.Map;
 import java.util.Optional;
@@ -106,6 +107,9 @@ public static Object toBqValue(PGType<?> pgType, Object value)
         if (pgType.equals(SMALLINT) && value instanceof Short) {
             return ((Short) value).intValue();
         }
+        if (pgType.equals(IntervalType.INTERVAL) && value instanceof Period) {
+            return value.toString();
+        }
         return value;
     }
 }

graphmdl-tests/src/test/java/io/graphmdl/testing/bigquery/TestWireProtocolWithBigquery.java

@@ -22,6 +22,7 @@
 import io.graphmdl.testing.TestingWireProtocolClient;
 import org.assertj.core.api.AssertionsForClassTypes;
 import org.intellij.lang.annotations.Language;
+import org.postgresql.util.PGInterval;
 import org.testng.annotations.DataProvider;
 import org.testng.annotations.Test;
 
@@ -887,7 +888,8 @@ public Object[][] paramTypes()
                 // TODO support timestamptz
                 // {"timestamptz", ZonedDateTime.of(LocalDateTime.of(1900, 1, 3, 12, 10, 16, 123000000), ZoneId.of("America/Los_Angeles"))},
                 {"json", "{\"test\":3, \"test2\":4}"},
-                {"bytea", "test1".getBytes(UTF_8)}
+                {"bytea", "test1".getBytes(UTF_8)},
+                {"interval", new PGInterval(1, 5, -3, 7, 55, 20)}
 
                 // TODO: type support
                 // {"any", new Object[] {1, "test", new BigDecimal(10)}}