Start Refactoring the API

Author: bytefish

JSqlServerBulkInsert/src/main/java/de/bytefish/jsqlserverbulkinsert/converters/BaseConverter.java

@@ -0,0 +1,16 @@
+package de.bytefish.jsqlserverbulkinsert.converters;
+
+import java.sql.Types;
+
+public abstract class BaseConverter<TSourceType> implements IConverter<TSourceType> {
+
+    public Object convert(TSourceType value) {
+        if(value == null) {
+            return null;
+        }
+
+        return internalConvert(value);
+    }
+
+    public abstract Object internalConvert(TSourceType value);
+}

JSqlServerBulkInsert/src/main/java/de/bytefish/jsqlserverbulkinsert/converters/BigDecimalConverter.java

@@ -0,0 +1,18 @@
+package de.bytefish.jsqlserverbulkinsert.converters;
+
+import java.math.BigDecimal;
+import java.time.LocalDate;
+
+public class BigDecimalConverter extends BaseConverter<BigDecimal> {
+
+    private final int scale;
+
+    public BigDecimalConverter(int scale) {
+        this.scale = scale;
+    }
+
+    @Override
+    public Object internalConvert(BigDecimal value) {
+        return value.setScale(scale, BigDecimal.ROUND_HALF_UP);
+    }
+}

JSqlServerBulkInsert/src/main/java/de/bytefish/jsqlserverbulkinsert/converters/BigIntegerConverter.java

@@ -0,0 +1,10 @@
+package de.bytefish.jsqlserverbulkinsert.converters;
+
+import java.math.BigInteger;
+
+public class BigIntegerConverter extends BaseConverter<BigInteger> {
+    @Override
+    public Object internalConvert(BigInteger value) {
+        return value.longValueExact();
+    }
+}

JSqlServerBulkInsert/src/main/java/de/bytefish/jsqlserverbulkinsert/converters/BooleanConverter.java

@@ -0,0 +1,8 @@
+package de.bytefish.jsqlserverbulkinsert.converters;
+
+public class BooleanConverter extends BaseConverter<Boolean> {
+    @Override
+    public Object internalConvert(Boolean value) {
+        return value;
+    }
+}

JSqlServerBulkInsert/src/main/java/de/bytefish/jsqlserverbulkinsert/converters/CharacterConverter.java

@@ -0,0 +1,8 @@
+package de.bytefish.jsqlserverbulkinsert.converters;
+
+public class CharacterConverter extends BaseConverter<Character> {
+    @Override
+    public Object internalConvert(Character value) {
+        return value;
+    }
+}

JSqlServerBulkInsert/src/main/java/de/bytefish/jsqlserverbulkinsert/converters/DoubleConverter.java

@@ -0,0 +1,8 @@
+package de.bytefish.jsqlserverbulkinsert.converters;
+
+public class DoubleConverter extends BaseConverter<Double> {
+    @Override
+    public Object internalConvert(Double value) {
+        return value;
+    }
+}

JSqlServerBulkInsert/src/main/java/de/bytefish/jsqlserverbulkinsert/converters/FloatConverter.java

@@ -0,0 +1,8 @@
+package de.bytefish.jsqlserverbulkinsert.converters;
+
+public class FloatConverter extends BaseConverter<Float> {
+    @Override
+    public Object internalConvert(Float value) {
+        return value;
+    }
+}

JSqlServerBulkInsert/src/main/java/de/bytefish/jsqlserverbulkinsert/converters/IConverter.java

@@ -0,0 +1,6 @@
+package de.bytefish.jsqlserverbulkinsert.converters;
+
+public interface IConverter<TSourceType> {
+
+    Object convert(TSourceType value);
+}

JSqlServerBulkInsert/src/main/java/de/bytefish/jsqlserverbulkinsert/converters/InstantConverter.java

@@ -0,0 +1,23 @@
+package de.bytefish.jsqlserverbulkinsert.converters;
+
+import java.sql.Timestamp;
+import java.time.Instant;
+
+public class InstantConverter extends BaseConverter<Instant> {
+
+    @Override
+    public Object internalConvert(Instant value) {
+
+        if (value == null) {
+            return null;
+        }
+
+        Timestamp castedResult = new Timestamp(value.toEpochMilli());
+
+        // Round to the nearest 100 nanoseconds, the precision that SQL server can handle:
+        castedResult.setNanos((value.getNano()/100)*100);
+
+        return castedResult;
+    };
+
+}

JSqlServerBulkInsert/src/main/java/de/bytefish/jsqlserverbulkinsert/converters/IntegerConverter.java

@@ -0,0 +1,8 @@
+package de.bytefish.jsqlserverbulkinsert.converters;
+
+public class IntegerConverter extends BaseConverter<Integer> {
+    @Override
+    public Object internalConvert(Integer value) {
+        return value;
+    }
+}