diff --git a/jOOQ-test/src/org/jooq/test/jOOQAbstractTest.java b/jOOQ-test/src/org/jooq/test/jOOQAbstractTest.java
index 71ea00fdfc..fc81681d1d 100644
--- a/jOOQ-test/src/org/jooq/test/jOOQAbstractTest.java
+++ b/jOOQ-test/src/org/jooq/test/jOOQAbstractTest.java
@@ -7480,6 +7480,9 @@ public abstract class jOOQAbstractTest<
                 .ignoreRows(0)
                 .execute();
 
+        // [#812] Reset stale connection. Seems to be necessary in Postgres
+        resetLoaderConnection();
+
         assertEquals(1, loader.processed());
         assertEquals(1, loader.errors().size());
         assertNotNull(loader.errors().get(0));
@@ -7500,6 +7503,9 @@ public abstract class jOOQAbstractTest<
                 .ignoreRows(0)
                 .execute();
 
+        // [#812] Reset stale connection. Seems to be necessary in Postgres
+        resetLoaderConnection();
+
         assertEquals(2, loader.processed());
         assertEquals(2, loader.errors().size());
         assertNotNull(loader.errors().get(0));
@@ -7524,6 +7530,9 @@ public abstract class jOOQAbstractTest<
                 .ignoreRows(0)
                 .execute();
 
+        // [#812] Reset stale connection. Seems to be necessary in Postgres
+        resetLoaderConnection();
+
         assertEquals(1, loader.processed());
         assertEquals(1, loader.errors().size());
         assertNotNull(loader.errors().get(0));
@@ -7657,6 +7666,9 @@ public abstract class jOOQAbstractTest<
             }
         }
 
+        // [#812] Reset stale connection. Seems to be necessary in Postgres
+        resetLoaderConnection();
+
         // Rollback on duplicate keys
         // --------------------------
         loader =
@@ -7720,7 +7732,14 @@ public abstract class jOOQAbstractTest<
         assertNull(result.getValue(2, TAuthor_FIRST_NAME()));
         assertEquals("Hesse", result.getValue(2, TAuthor_LAST_NAME()));
         assertEquals("Coelho", result.getValue(1, TAuthor_LAST_NAME()));
-        assertEquals("Orwell", result.getValue(0, TAuthor_LAST_NAME()));
+    }
+
+    private void resetLoaderConnection() throws SQLException {
+        connection.rollback();
+        connection.close();
+        connection = null;
+        connection = getConnection();
+        connection.setAutoCommit(false);
     }
 
     /**