Add IntervalValueHandler

Author: Philipp Wagner

PgBulkInsert/src/main/java/de/bytefish/pgbulkinsert/pgsql/handlers/ValueHandlerProvider.java

@@ -5,6 +5,7 @@
 import de.bytefish.pgbulkinsert.exceptions.ValueHandlerAlreadyRegisteredException;
 import de.bytefish.pgbulkinsert.exceptions.ValueHandlerNotRegisteredException;
 import de.bytefish.pgbulkinsert.pgsql.constants.DataType;
+import de.bytefish.pgbulkinsert.pgsql.handlers.utils.IntervalValueHandler;
 
 import java.util.EnumMap;
 import java.util.Map;
@@ -51,6 +52,7 @@ public ValueHandlerProvider() {
         add(DataType.Int8Range, new RangeValueHandler<>(new LongValueHandler<>()));
         add(DataType.NumRange, new RangeValueHandler<>(new BigDecimalValueHandler<>()));
         add(DataType.DateRange, new RangeValueHandler<>(new LocalDateValueHandler()));
+        add(DataType.Interval, new IntervalValueHandler());
     }
 
     public <TTargetType> ValueHandlerProvider add(DataType targetType, IValueHandler<TTargetType> valueHandler) {

PgBulkInsert/src/main/java/de/bytefish/pgbulkinsert/pgsql/handlers/utils/IntervalValueHandler.java

@@ -0,0 +1,26 @@
+// Licensed under the MIT license. See LICENSE file in the project root for full license information.
+
+package de.bytefish.pgbulkinsert.pgsql.handlers.utils;
+
+import de.bytefish.pgbulkinsert.pgsql.handlers.BaseValueHandler;
+import de.bytefish.pgbulkinsert.pgsql.model.geometric.Box;
+import de.bytefish.pgbulkinsert.pgsql.model.interval.Interval;
+
+import java.io.DataOutputStream;
+
+public class IntervalValueHandler extends BaseValueHandler<Interval> {
+
+    @Override
+    protected void internalHandle(DataOutputStream buffer, final Interval value) throws Exception {
+        buffer.writeInt(16);
+
+        buffer.writeLong(value.getTime());
+        buffer.writeInt(value.getDays());
+        buffer.writeInt(value.getMonths());
+    }
+
+    @Override
+    public int getLength(Interval value) {
+        return 16;
+    }
+}