Debugging the skipped connection

babelfish-for-postgresql · Jan 23, 2025 · 3228283 · 3228283
1 parent b1b31ca
commit 3228283
Showing 1 changed file with 16 additions and 21 deletions.
diff --git a/test/JDBC/src/main/java/com/sqlsamples/JDBCCrossDialect.java b/test/JDBC/src/main/java/com/sqlsamples/JDBCCrossDialect.java
@@ -164,36 +164,31 @@ Connection getPsqlConnection (String strLine, BufferedWriter bw, Logger logger)
 
     void closeConnectionsUtil (HashMap<String, Connection> connectionMap, BufferedWriter bw, Logger logger) 
     {
-        //boolean needSkipFirst = (majorVersion > 16) || (majorVersion == 16 && minorVersion >= 6) ? true : false;
+        boolean needSkipFirst = (majorVersion > 16) || (majorVersion == 16 && minorVersion >= 6) ? true : false;
         Iterator<Map.Entry<String, Connection>> iterator = connectionMap.entrySet().iterator();
 
         while (iterator.hasNext()) 
         {
             Map.Entry<String, Connection> entry = iterator.next();
             Connection connection = entry.getValue();
-
-            try 
+            if (!needSkipFirst) 
             {
-                connection.close();
-            } 
-            catch (SQLException e) 
+                try 
+                {
+                    connection.close();
+                } catch (SQLException e) {
+                    handleSQLExceptionWithFile(e, bw, logger);
+                }
+            }
+            else
             {
-                handleSQLExceptionWithFile(e, bw, logger);
+                System.out.println();
+                System.out.println("---------------------------------------------");
+                System.out.println(entry);
+                System.out.println("---------------------------------------------");
+                System.out.println();
+                needSkipFirst = false;
             }
-
-            // if (!needSkipFirst) 
-            // {
-            //     try 
-            //     {
-            //         connection.close();
-            //     } catch (SQLException e) {
-            //         handleSQLExceptionWithFile(e, bw, logger);
-            //     }
-            // }
-            // else
-            // {
-            //     needSkipFirst = false;
-            // }
         }
     }