Add logging to avoid loss of information when exception changes durin…

…g retries
embulk · Sep 7, 2023 · 32e152d · 32e152d
1 parent ecec67b
commit 32e152d
Showing 1 changed file with 12 additions and 1 deletion.
diff --git a/embulk-output-jdbc/src/main/java/org/embulk/output/jdbc/AbstractJdbcOutputPlugin.java b/embulk-output-jdbc/src/main/java/org/embulk/output/jdbc/AbstractJdbcOutputPlugin.java
@@ -1369,7 +1369,18 @@ public void onGiveup(Exception firstException, Exception lastException)
                 SQLException ex = (SQLException) firstException;
                 String sqlState = ex.getSQLState();
                 int errorCode = ex.getErrorCode();
-                logger.error("{} ({}:{})", errorMessage, errorCode, sqlState);
+                logger.error("{} (first exception:{SQLState={}, ErrorCode={}})", errorMessage, errorCode, sqlState, ex);
+            } else {
+                logger.error("{} (first exception)", errorMessage, firstException);
+            }
+
+            if (lastException instanceof SQLException) {
+                SQLException ex = (SQLException) lastException;
+                String sqlState = ex.getSQLState();
+                int errorCode = ex.getErrorCode();
+                logger.error("{} (last exception:{SQLState={}, ErrorCode={}})", errorMessage, errorCode, sqlState, ex);
+            } else {
+                logger.error("{} (last exception)", errorMessage, lastException);
             }
         }