src/main/java/org/embulk/output/jdbc/JdbcOutputConnection.java in embulk-output-jdbc-0.8.2 vs src/main/java/org/embulk/output/jdbc/JdbcOutputConnection.java in embulk-output-jdbc-0.8.3

@@ -36,9 +36,26 @@
         if (schemaName != null) {
             setSearchPath(schemaName);
         }
     }
 
+    public void initialize(boolean autoCommit, Optional<TransactionIsolation> transactionIsolation)
+            throws SQLException
+    {
+        connection.setAutoCommit(autoCommit);
+
+        if (transactionIsolation.isPresent()) {
+            connection.setTransactionIsolation(transactionIsolation.get().toInt());
+        }
+
+        try {
+            TransactionIsolation currentTransactionIsolation = TransactionIsolation.fromInt(connection.getTransactionIsolation());
+            logger.info("TransactionIsolation={}", currentTransactionIsolation.toString());
+        } catch (IllegalArgumentException e) {
+            logger.info("TransactionIsolation=unknown");
+        }
+    }
+
     @Override
     public void close() throws SQLException
     {
         if (!connection.isClosed()) {
             connection.close();