wip

1 files changed, 4 insertions, 14 deletions

diff --git a/src/main/java/io/trygvis/async/SqlEffectExecutor.java b/src/main/java/io/trygvis/async/SqlEffectExecutor.java
index 51ad31d..3da2cd3 100644
--- a/src/main/java/io/trygvis/async/SqlEffectExecutor.java
+++ b/src/main/java/io/trygvis/async/SqlEffectExecutor.java
@@ -15,11 +15,11 @@ public class SqlEffectExecutor {
     }
 
     public <A> A transaction(SqlEffect<A> effect) throws SQLException {
-        int pid;
+//        int pid;
 
         try (Connection c = dataSource.getConnection()) {
-            pid = getPid(c);
-            System.out.println("pid = " + pid);
+//            pid = getPid(c);
+//            System.out.println("pid = " + pid);
 
             boolean ok = false;
             try {
@@ -28,7 +28,7 @@ public class SqlEffectExecutor {
                 ok = true;
                 return a;
             } finally {
-                System.out.println("Closing, pid = " + pid);
+//                System.out.println("Closing, pid = " + pid);
                 if (!ok) {
                     try {
                         c.rollback();
@@ -49,14 +49,4 @@ public class SqlEffectExecutor {
             }
         });
     }
-
-    private int getPid(Connection c) throws SQLException {
-        int pid;
-        try (Statement statement = c.createStatement()) {
-            ResultSet rs = statement.executeQuery("SELECT pg_backend_pid()");
-            rs.next();
-            pid = rs.getInt(1);
-        }
-        return pid;
-    }
 }