if continue on error, continue on ANY error

JumpMind · Jul 13, 2014 · 070fee0 · 070fee0
1 parent aacc7f4
commit 070fee0
Showing 1 changed file with 11 additions and 6 deletions.
diff --git a/symmetric-io/src/main/java/org/jumpmind/symmetric/io/data/DbFill.java b/symmetric-io/src/main/java/org/jumpmind/symmetric/io/data/DbFill.java
@@ -369,15 +369,20 @@ private void insertRandomRecord(Table table) {
                 if (verbose) {
                     System.out.println("Successful insert into " + tbl.getName());
                 }
-            } catch (SqlException ex) {
-                log.error("Failed to process {} with values of {}", statement.getSql(),
-                        ArrayUtils.toString(statementValues));
+            } catch (Exception ex) {
+                log.error("Failed to process {} with values of {} because: {}", new Object[] {statement.getSql(),
+                        ArrayUtils.toString(statementValues), ex.getMessage() });
                 if (continueOnError) {
-                    if (debug) {
-                        ex.printStackTrace();
+                    if (debug || !(ex instanceof SqlException)) {
+                        log.debug(ex.getMessage(), ex);
                     }
                 } else {
-                    throw ex;
+                    if (ex instanceof RuntimeException) {
+                        throw (RuntimeException)ex;
+                    } else {
+                        throw new RuntimeException(ex);
+                    }
+
                 }
             }
         }