Alternative Consructor

Author: Philipp Wagner

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

@@ -3,7 +3,6 @@
 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;
@@ -14,7 +13,7 @@ public class IntervalValueHandler extends BaseValueHandler<Interval> {
     protected void internalHandle(DataOutputStream buffer, final Interval value) throws Exception {
         buffer.writeInt(16);
 
-        buffer.writeLong(value.getTime());
+        buffer.writeLong(value.getTimeOfDay());
         buffer.writeInt(value.getDays());
         buffer.writeInt(value.getMonths());
     }

PgBulkInsert/src/main/java/de/bytefish/pgbulkinsert/pgsql/model/interval/Interval.java

@@ -1,15 +1,23 @@
 package de.bytefish.pgbulkinsert.pgsql.model.interval;
 
+import java.util.concurrent.TimeUnit;
+
 public class Interval {
 
     private final int months;
     private final int days;
-    private final long time;
+    private final long timeOfDay;
 
-    public Interval(int months, int days, long time) {
+    public Interval(int months, int days, long timeOfDay) {
         this.months = months;
         this.days = days;
-        this.time = time;
+        this.timeOfDay = timeOfDay;
+    }
+
+    public Interval(int months, int days, int hours, int minutes, int wholeSeconds, long microSeconds) {
+        this.months = months;
+        this.days = days;
+        this.timeOfDay = calcTimeOfDay(hours, minutes, wholeSeconds, microSeconds);
     }
 
     public int getMonths() {
@@ -20,7 +28,14 @@ public int getDays() {
         return days;
     }
 
-    public long getTime() {
-        return time;
+    public long getTimeOfDay() {
+        return timeOfDay;
+    }
+
+    private long calcTimeOfDay(int hours, int minutes, int wholeSeconds, long microSeconds) {
+        return TimeUnit.HOURS.toMicros(hours)
+                + TimeUnit.MINUTES.toMicros(minutes)
+                + TimeUnit.SECONDS.toMicros(wholeSeconds)
+                + microSeconds;
     }
 }

PgBulkInsert/src/test/java/de/bytefish/pgbulkinsert/test/pgsql/handlers/PgBulkInsertTest.java

@@ -192,6 +192,39 @@ public void saveAll_interval_Test() throws SQLException {
         }
     }
 
+    @Test
+    public void saveAll_interval_AlternateConstructor_Test() throws SQLException {
+
+        // This list will be inserted.
+        List<SampleEntity> entities = new ArrayList<>();
+
+        // Create the Entity to insert:
+        SampleEntity entity = new SampleEntity();
+
+        // 2 mons 15 days 02:03:04.005
+        entity.col_interval = new Interval(2, 15, 2, 3, 4, 5000);
+
+        entities.add(entity);
+
+        PgBulkInsert<SampleEntity> pgBulkInsert = new PgBulkInsert<>(new SampleEntityMapping());
+
+        pgBulkInsert.saveAll(PostgreSqlUtils.getPGConnection(connection), entities.stream());
+
+        ResultSet rs = getAll();
+
+        while (rs.next()) {
+            PGInterval v = (PGInterval) rs.getObject("col_interval");
+
+            Assert.assertEquals(entity.col_interval.getDays(), v.getDays());
+            Assert.assertEquals(entity.col_interval.getMonths(), v.getMonths());
+            Assert.assertEquals(2, v.getHours());
+            Assert.assertEquals(3, v.getMinutes());
+            Assert.assertEquals(4, v.getWholeSeconds());
+            Assert.assertEquals(5000, v.getMicroSeconds());
+        }
+    }
+
+
     @Test
     public void saveAll_numeric_Test() throws SQLException {