jrunner/src/main/java/jrunner/jrunner.java

@@ -208,15 +208,6 @@ public class jrunner {
         }
         try {
             scon = DriverManager.getConnection(scu, scn, scp);
-            // Migration mode only: PostgreSQL ignores setFetchSize unless autoCommit
-            // is false — without this it buffers the ENTIRE result set into memory
-            // (OOM on big tables). The migration source is read-only, so never
-            // committing is harmless. Do NOT do this in query mode: callers run
-            // committed DDL/DML through query mode, and autoCommit=false would roll
-            // those statements back on connection close.
-            if (!queryMode) {
-                scon.setAutoCommit(false);
-            }
         } catch (SQLException e) {
             System.out.println("issue connecting to source:");
             e.printStackTrace();
@@ -311,16 +302,7 @@ public class jrunner {
                 nr = "";
                 for (int i = 1; i <= cols; i++){
                     switch (dtn[i].toUpperCase()){
-                        // PG string-ish types that otherwise fall to the default
-                        // case and get emitted UNQUOTED (breaking the INSERT):
-                        // jsonb/json carry embedded quotes, bpchar is PG's char(n),
-                        // uuid is a quoted literal. Quote them like varchar.
-                        case "JSON":
-                        case "JSONB":
-                        case "BPCHAR":
-                        case "UUID":
                         case "VARCHAR":
-                        case "NVARCHAR":
                             nc = rs.getString(i);
                             if (rs.wasNull() || nc == null) {
                                 nc = "NULL";
@@ -331,7 +313,6 @@ public class jrunner {
                             nc = "'" + nc + "'";
                             break;
                         case "TEXT":
-                        case "NTEXT":
                             nc = rs.getString(i);
                             if (rs.wasNull() || nc == null) {
                                 nc = "NULL";
@@ -342,7 +323,6 @@ public class jrunner {
                             nc = "'" + nc + "'";
                             break;
                         case "CHAR":
-                        case "NCHAR":
                             nc = rs.getString(i);
                             if (rs.wasNull() || nc == null) {
                                 nc = "NULL";
@@ -353,7 +333,6 @@ public class jrunner {
                             nc = "'" + nc + "'";
                             break;
                         case "CLOB":
-                        case "NCLOB":
                             nc = rs.getString(i);
                             if (rs.wasNull() || nc == null) {
                                 nc = "NULL";