Refactor Method Signature

Throwing out all checked exceptions.

Author: bytefish

JSqlServerBulkInsert/pom.xml

@@ -7,7 +7,7 @@
 
     <groupId>de.bytefish</groupId>
     <artifactId>jsqlserverbulkinsert</artifactId>
-    <version>1.0</version>
+    <version>1.1</version>
     <name>jsqlserverbulkinsert</name>
     <description>JSqlServerBulkInsert is a Java library for Bulk Inserts to the SQL Server.</description>
     <url>http://www.github.com/bytefish/JSqlServerBulkInsert</url>

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

@@ -6,6 +6,7 @@
 import com.microsoft.sqlserver.jdbc.ISQLServerBulkRecord;
 import com.microsoft.sqlserver.jdbc.SQLServerBulkCopy;
 import com.microsoft.sqlserver.jdbc.SQLServerBulkCopyOptions;
+import com.microsoft.sqlserver.jdbc.SQLServerException;
 import de.bytefish.jsqlserverbulkinsert.mapping.AbstractMapping;
 import de.bytefish.jsqlserverbulkinsert.records.SqlServerRecord;
 
@@ -22,11 +23,11 @@ public SqlServerBulkInsert(AbstractMapping<TEntity> mapping)
         this.mapping = mapping;
     }
 
-    public void saveAll(Connection connection, Stream<TEntity> entities) throws SQLException {
+    public void saveAll(Connection connection, Stream<TEntity> entities) {
         saveAll(connection, new SQLServerBulkCopyOptions(), entities);
     }
 
-    public void saveAll(Connection connection, SQLServerBulkCopyOptions options, Stream<TEntity> entities) throws SQLException {
+    public void saveAll(Connection connection, SQLServerBulkCopyOptions options, Stream<TEntity> entities) {
         // Create a new SQLServerBulkCopy Instance on the given Connection:
         try (SQLServerBulkCopy sqlServerBulkCopy = new SQLServerBulkCopy(connection)) {
             // Set the Options:
@@ -36,14 +37,10 @@ public void saveAll(Connection connection, SQLServerBulkCopyOptions options, Str
             // The SQL Records to insert:
             ISQLServerBulkRecord record = new SqlServerRecord<TEntity>(mapping.getColumns(), entities.iterator());
             // Finally start the Bulk Copy Process:
-            internalWriteToServer(sqlServerBulkCopy, record);
-        }
-    }
-
-    public void internalWriteToServer(SQLServerBulkCopy sqlServerBulkCopy, ISQLServerBulkRecord record) {
-        try {
             sqlServerBulkCopy.writeToServer(record);
-        } catch(Exception e) {
+            // Handle Exceptions:
+        } catch (SQLServerException e) {
+            // Wrap it in a RunTimeException to provide a nice API:
             throw new RuntimeException(e);
         }
     }

JSqlServerBulkInsert/src/main/java/de/bytefish/jsqlserverbulkinsert/functional/Action0.java

@@ -5,5 +5,5 @@
 
 @FunctionalInterface
 public interface Action0 {
-    void invoke() throws Exception;
+    void invoke();
 }

JSqlServerBulkInsert/src/main/java/de/bytefish/jsqlserverbulkinsert/functional/Action1.java

@@ -5,5 +5,5 @@
 
 @FunctionalInterface
 public interface Action1<S> {
-    void invoke(S s) throws Exception;
+    void invoke(S s);
 }

JSqlServerBulkInsert/src/main/java/de/bytefish/jsqlserverbulkinsert/functional/Action2.java

@@ -5,5 +5,5 @@
 
 @FunctionalInterface
 public interface Action2<S, T> {
-    void invoke(S s, T t) throws Exception;
+    void invoke(S s, T t);
 }

JSqlServerBulkInsert/src/main/java/de/bytefish/jsqlserverbulkinsert/functional/Func1.java

@@ -5,5 +5,5 @@
 
 @FunctionalInterface
 public interface Func1<S> {
-    S invoke() throws Exception;
+    S invoke();
 }

JSqlServerBulkInsert/src/test/java/de/bytefish/jsqlserverbulkinsert/test/integration/IntegrationTest.java

@@ -7,6 +7,7 @@
 import de.bytefish.jsqlserverbulkinsert.test.model.Person;
 import de.bytefish.jsqlserverbulkinsert.SqlServerBulkInsert;
 import de.bytefish.jsqlserverbulkinsert.test.base.TransactionalTestBase;
+import de.bytefish.jsqlserverbulkinsert.test.utils.MeasurementUtils;
 import org.junit.Assert;
 import org.junit.Test;
 
@@ -34,8 +35,11 @@ public void bulkInsertPersonDataTest() throws SQLException {
         PersonMapping mapping = new PersonMapping();
         // Create the Bulk Inserter:
         SqlServerBulkInsert<Person> bulkInsert = new SqlServerBulkInsert<>(mapping);
-        // Now save all entities of a given stream:
-        bulkInsert.saveAll(connection, persons.stream());
+        // Measure the Bulk Insert time:
+        MeasurementUtils.MeasureElapsedTime("Bulk Insert 1000000 Entities", () -> {
+            // Now save all entities of a given stream:
+            bulkInsert.saveAll(connection, persons.stream());
+        });
         // And assert all have been written to the database:
         Assert.assertEquals(numEntities, getRowCount());
     }

JSqlServerBulkInsert/src/test/java/de/bytefish/jsqlserverbulkinsert/test/utils/MeasurementUtils.java

@@ -0,0 +1,25 @@
+package de.bytefish.jsqlserverbulkinsert.test.utils;
+
+import de.bytefish.jsqlserverbulkinsert.functional.Action0;
+
+import java.time.Duration;
+import java.time.Instant;
+
+public class MeasurementUtils {
+
+    public static void MeasureElapsedTime(String description, Action0 action) {
+        Duration duration = MeasureElapsedTime(action);
+
+        System.out.println(String.format("[%s] %s", description, duration));
+    }
+
+    private static Duration MeasureElapsedTime(Action0 action) {
+        Instant start = Instant.now();
+
+        action.invoke();
+
+        Instant end = Instant.now();
+
+        return Duration.between(start, end);
+    }
+}

README.md

@@ -1,5 +1,6 @@
 # JSqlServerBulkInsert #
 
+[JSqlServerBulkInsert]: https://github.com/bytefish/JSqlServerBulkInsert
 [MIT License]: https://opensource.org/licenses/MIT
 
 [JSqlServerBulkInsert] is a library to simplify Bulk Inserts to the SQL Server. It wraps the ``SQLServerBulkCopy`` behind a nice API.
@@ -12,14 +13,22 @@ You can obtain [JSqlServerBulkInsert] from Maven by adding the following:
 <dependency>
 	<groupId>de.bytefish</groupId>
 	<artifactId>jsqlserverbulkinsert</artifactId>
-	<version>1.0</version>
+	<version>1.1</version>
 </dependency>
 ```
 
 ## Getting Started ##
 
 Imagine ``1,000,000`` Persons should be inserted into an SQL Server database.
 
+### Results ###
+
+Bulk Inserting ``1,000,000``entities to a SQL Server 2016 database took ``5`` Seconds:
+
+```
+[Bulk Insert 1000000 Entities] PT4.559S
+```
+
 ### Domain Model ###
 
 The domain model could be the ``Person`` class with a First Name, Last Name and a birth date. 
@@ -118,6 +127,7 @@ import de.bytefish.jsqlserverbulkinsert.mapping.AbstractMapping;
 import de.bytefish.jsqlserverbulkinsert.test.model.Person;
 import de.bytefish.jsqlserverbulkinsert.SqlServerBulkInsert;
 import de.bytefish.jsqlserverbulkinsert.test.base.TransactionalTestBase;
+import de.bytefish.jsqlserverbulkinsert.test.utils.MeasurementUtils;
 import org.junit.Assert;
 import org.junit.Test;
 
@@ -145,8 +155,11 @@ public class IntegrationTest extends TransactionalTestBase {
         PersonMapping mapping = new PersonMapping();
         // Create the Bulk Inserter:
         SqlServerBulkInsert<Person> bulkInsert = new SqlServerBulkInsert<>(mapping);
-        // Now save all entities of a given stream:
-        bulkInsert.saveAll(connection, persons.stream());
+        // Measure the Bulk Insert time:
+        MeasurementUtils.MeasureElapsedTime("Bulk Insert 1000000 Entities", () -> {
+            // Now save all entities of a given stream:
+            bulkInsert.saveAll(connection, persons.stream());
+        });
         // And assert all have been written to the database:
         Assert.assertEquals(numEntities, getRowCount());
     }