diff --git a/src/main/java/io/ebeaninternal/server/query/CQueryEngine.java b/src/main/java/io/ebeaninternal/server/query/CQueryEngine.java
index 46f3fb0fc..9315964de 100644
--- a/src/main/java/io/ebeaninternal/server/query/CQueryEngine.java
+++ b/src/main/java/io/ebeaninternal/server/query/CQueryEngine.java
@@ -232,7 +232,11 @@ public class CQueryEngine {
       return readIterate;
 
     } catch (SQLException e) {
-      throw cquery.createPersistenceException(e);
+      try {
+        throw cquery.createPersistenceException(e);
+      } finally {
+        request.rollbackTransIfRequired();
+      }
     }
   }