Add Unit Tests

Author: Philipp Wagner

JSqlServerBulkInsert/src/main/java/de/bytefish/jsqlserverbulkinsert/SqlServerBulkInsert.java

@@ -78,13 +78,15 @@ protected void mapNumeric(String columnName, int scale, int precision, Func2<TEn
         addColumn(columnName, Types.NUMERIC, precision, scale, false, propertyGetter);
     }
 
-    protected void mapDecimal(String columnName, int scale, int precision, Func2<TEntity, BigDecimal> propertyGetter)
+    protected void mapDecimal(String columnName, int precision, int scale, Func2<TEntity, BigDecimal> propertyGetter)
     {
         // We need to scale the incoming decimal, before writing it to SQL Server:
         final Func2<TEntity, BigDecimal> wrapper = entity -> {
-            BigDecimal result = propertyGetter.invoke(entity);
+            BigDecimal result = propertyGetter
+                    .invoke(entity)
+                    .setScale(10, BigDecimal.ROUND_HALF_UP);
 
-            return result.setScale(scale, RoundingMode.HALF_UP);
+            return result;
         };
 
         addColumn(columnName, Types.DECIMAL, precision, scale, false, wrapper);

JSqlServerBulkInsert/src/main/java/de/bytefish/jsqlserverbulkinsert/exceptions/BinaryWriteFailedException.java

@@ -1,7 +1,7 @@
 // Copyright (c) Philipp Wagner. All rights reserved.
 // Licensed under the MIT license. See LICENSE file in the project root for full license information.
 
-package de.bytefish.jsqlserverbulkinsert;
+package de.bytefish.jsqlserverbulkinsert.test.base;
 
 
 import org.junit.After;

JSqlServerBulkInsert/src/main/java/de/bytefish/jsqlserverbulkinsert/exceptions/PgConnectionException.java

@@ -1,8 +1,11 @@
 // Copyright (c) Philipp Wagner. All rights reserved.
 // Licensed under the MIT license. See LICENSE file in the project root for full license information.
 
-package de.bytefish.jsqlserverbulkinsert;
+package de.bytefish.jsqlserverbulkinsert.test.integration;
 
+import de.bytefish.jsqlserverbulkinsert.test.model.Person;
+import de.bytefish.jsqlserverbulkinsert.SqlServerBulkInsert;
+import de.bytefish.jsqlserverbulkinsert.test.base.TransactionalTestBase;
 import org.junit.Assert;
 import org.junit.Test;
 

JSqlServerBulkInsert/src/main/java/de/bytefish/jsqlserverbulkinsert/exceptions/SaveEntityFailedException.java

@@ -0,0 +1,92 @@
+// Copyright (c) Philipp Wagner. All rights reserved.
+// Licensed under the MIT license. See LICENSE file in the project root for full license information.
+
+package de.bytefish.jsqlserverbulkinsert.test.mapping;
+
+import de.bytefish.jsqlserverbulkinsert.SqlServerBulkInsert;
+import de.bytefish.jsqlserverbulkinsert.test.base.TransactionalTestBase;
+import org.junit.Assert;
+import org.junit.Test;
+
+import java.math.BigDecimal;
+import java.sql.Date;
+import java.sql.ResultSet;
+import java.sql.SQLException;
+import java.sql.Statement;
+import java.time.LocalDate;
+import java.util.Arrays;
+import java.util.List;
+
+public class DecimalMappingTest extends TransactionalTestBase {
+
+    private class BigDecimalEntity {
+
+        private final BigDecimal value;
+
+        public BigDecimalEntity(BigDecimal value) {
+            this.value = value;
+        }
+
+        public BigDecimal getValue() {
+            return value;
+        }
+    }
+
+    private class BigDecimalInsert extends SqlServerBulkInsert<BigDecimalEntity> {
+
+        public BigDecimalInsert() {
+            super("dbo", "UnitTest");
+
+            mapDecimal("DecimalValue", 20, 10, BigDecimalEntity::getValue);
+        }
+
+    }
+
+    @Override
+    protected void onSetUpInTransaction() throws Exception {
+        createTestTable();
+    }
+
+    @Test
+    public void bulkInsertPersonDataTest() throws SQLException {
+        // Expected LocalDate 2013/01/01:
+        BigDecimal bigDecimal = new BigDecimal("100.123");
+        // Create te
+        List<BigDecimalEntity> entities = Arrays.asList(new BigDecimalEntity(bigDecimal));
+        // Create the BulkInserter:
+        BigDecimalInsert localDateInsert = new BigDecimalInsert();
+        // Now save all entities of a given stream:
+        localDateInsert.saveAll(connection, entities.stream());
+        // And assert all have been written to the database:
+        ResultSet rs = getAll();
+        // We have a Value:
+        Assert.assertEquals(true, rs.next());
+        // Get the Date we have written:
+        BigDecimal resultBigDecimal = rs.getBigDecimal("DecimalValue");
+        // Assert both are equal:
+        Assert.assertEquals(bigDecimal.stripTrailingZeros(), resultBigDecimal.stripTrailingZeros());
+        // Assert only one record was read:
+        Assert.assertEquals(false, rs.next());
+    }
+
+    private ResultSet getAll() throws SQLException {
+
+        String sqlStatement = "SELECT * FROM dbo.UnitTest";
+
+        Statement statement = connection.createStatement();
+
+        return statement.executeQuery(sqlStatement);
+    }
+
+    private void createTestTable() throws SQLException {
+        String sqlStatement = "CREATE TABLE [dbo].[UnitTest]\n" +
+                "            (\n" +
+                "                DecimalValue NUMERIC(20, 10)\n" +
+                "            );";
+
+        Statement statement = connection.createStatement();
+
+        statement.execute(sqlStatement);
+    }
+
+}

JSqlServerBulkInsert/src/main/java/de/bytefish/jsqlserverbulkinsert/exceptions/ValueHandlerAlreadyRegisteredException.java

@@ -0,0 +1,101 @@
+// Copyright (c) Philipp Wagner. All rights reserved.
+// Licensed under the MIT license. See LICENSE file in the project root for full license information.
+
+package de.bytefish.jsqlserverbulkinsert.test.mapping;
+
+import de.bytefish.jsqlserverbulkinsert.SqlServerBulkInsert;
+import de.bytefish.jsqlserverbulkinsert.test.base.TransactionalTestBase;
+import de.bytefish.jsqlserverbulkinsert.test.integration.IntegrationTest;
+import de.bytefish.jsqlserverbulkinsert.test.model.Person;
+import org.junit.Assert;
+import org.junit.Test;
+
+import java.sql.Date;
+import java.sql.ResultSet;
+import java.sql.SQLException;
+import java.sql.Statement;
+import java.time.LocalDate;
+import java.util.Arrays;
+import java.util.List;
+
+public class LocalDateMappingTest extends TransactionalTestBase {
+
+    private class LocalDateEntity {
+
+        private LocalDate localDate;
+
+        private LocalDateEntity(LocalDate localDate) {
+            this.localDate = localDate;
+        }
+
+        public LocalDate getLocalDate() {
+            return localDate;
+        }
+    }
+
+    private class LocalDateInsert extends SqlServerBulkInsert<LocalDateEntity> {
+
+        public LocalDateInsert() {
+            super("dbo", "UnitTest");
+
+            mapDate("LocalDate", LocalDateEntity::getLocalDate);
+        }
+
+    }
+
+    @Override
+    protected void onSetUpInTransaction() throws Exception {
+        createTestTable();
+    }
+
+    @Test
+    public void bulkInsertPersonDataTest() throws SQLException {
+        // Expected LocalDate 2013/01/01:
+        LocalDate localDate = LocalDate.of(2013, 1, 1);
+        // Create te
+        List<LocalDateEntity> persons = Arrays.asList(new LocalDateEntity(localDate));
+        // Create the BulkInserter:
+        LocalDateInsert localDateInsert = new LocalDateInsert();
+        // Now save all entities of a given stream:
+        localDateInsert.saveAll(connection, persons.stream());
+        // And assert all have been written to the database:
+        ResultSet rs = getAll();
+
+        while (rs.next()) {
+
+            // Get the Date we have written:
+            Date date = rs.getDate("LocalDate");
+
+            // We should have a date:
+            Assert.assertNotNull(date);
+
+            // Get the LocalDate:
+            LocalDate resultDate = date.toLocalDate();
+
+            Assert.assertEquals(localDate.getYear(), resultDate.getYear());
+            Assert.assertEquals(localDate.getMonthValue(), resultDate.getMonthValue());
+            Assert.assertEquals(localDate.getDayOfMonth(), resultDate.getDayOfMonth());
+        }
+    }
+
+    private ResultSet getAll() throws SQLException {
+
+        String sqlStatement = "SELECT * FROM dbo.UnitTest";
+
+        Statement statement = connection.createStatement();
+
+        return statement.executeQuery(sqlStatement);
+    }
+
+    private void createTestTable() throws SQLException {
+        String sqlStatement = "CREATE TABLE [dbo].[UnitTest]\n" +
+                "            (\n" +
+                "                LocalDate DATE\n" +
+                "            );";
+
+        Statement statement = connection.createStatement();
+
+        statement.execute(sqlStatement);
+    }
+
+}