Add a String and Double Mapping Test

Author: Philipp Wagner

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

@@ -73,7 +73,7 @@ protected void mapBoolean(String columnName, Func2<TEntity, Boolean> propertyGet
         addColumn(columnName, Types.BIT, propertyGetter);
     }
 
-    protected void mapNumeric(String columnName, int scale, int precision, Func2<TEntity, BigDecimal> propertyGetter) {
+    protected void mapNumeric(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

JSqlServerBulkInsert/src/test/java/de/bytefish/jsqlserverbulkinsert/test/mapping/DoubleMappingTest.java

@@ -0,0 +1,82 @@
+// 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.sql.ResultSet;
+import java.sql.SQLException;
+import java.sql.Statement;
+import java.util.Arrays;
+import java.util.List;
+
+public class DoubleMappingTest extends TransactionalTestBase {
+
+    private class DoubleEntity extends SampleEntity<Double> {
+
+        public DoubleEntity(Double value) {
+            super(value);
+        }
+    }
+
+    private class BigDecimalInsert extends SqlServerBulkInsert<DoubleEntity> {
+
+        public BigDecimalInsert() {
+            super("dbo", "UnitTest");
+
+            mapDouble("DoubleValue", DoubleEntity::getValue);
+        }
+
+    }
+
+    @Override
+    protected void onSetUpInTransaction() throws Exception {
+        createTestTable();
+    }
+
+    @Test
+    public void bulkInsertPersonDataTest() throws SQLException {
+        Double doubleValue = 123.123d;
+        // Create the Value:
+        List<DoubleEntity> entities = Arrays.asList(new DoubleEntity(doubleValue));
+        // 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:
+        Double resultDoubleValue = rs.getDouble("DoubleValue");
+        // Assert both are equal:
+        Assert.assertEquals(doubleValue, resultDoubleValue, 1e-10);
+        // 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" +
+                "                DoubleValue FLOAT\n" +
+                "            );";
+
+        Statement statement = connection.createStatement();
+
+        statement.execute(sqlStatement);
+    }
+
+}

JSqlServerBulkInsert/src/test/java/de/bytefish/jsqlserverbulkinsert/test/mapping/StringMappingTest.java

@@ -0,0 +1,88 @@
+// 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.sql.ResultSet;
+import java.sql.SQLException;
+import java.sql.Statement;
+import java.util.Arrays;
+import java.util.List;
+
+public class StringMappingTest extends TransactionalTestBase {
+
+    private class StringEntity {
+
+        private final String value;
+
+        public StringEntity(String value) {
+            this.value = value;
+        }
+
+        public String getValue() {
+            return value;
+        }
+    }
+
+    private class StringInsert extends SqlServerBulkInsert<StringEntity> {
+
+        public StringInsert() {
+            super("dbo", "UnitTest");
+
+            mapString("StringValue", StringEntity::getValue);
+        }
+
+    }
+
+    @Override
+    protected void onSetUpInTransaction() throws Exception {
+        createTestTable();
+    }
+
+    @Test
+    public void bulkInsertPersonDataTest() throws SQLException {
+        String stringData = "Halli Hallo Hallöchen";
+        // Create te
+        List<StringEntity> entities = Arrays.asList(new StringEntity(stringData));
+        // Create the BulkInserter:
+        StringInsert localDateInsert = new StringInsert();
+        // 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:
+        String resultString = rs.getString("StringValue");
+        // Assert both are equal:
+        Assert.assertEquals(stringData, resultString);
+        // 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" +
+                "                StringValue NVARCHAR(255)\n" +
+                "            );";
+
+        Statement statement = connection.createStatement();
+
+        statement.execute(sqlStatement);
+    }
+
+}